Add buffer size setting to the Telnet component, closes #1114

Author: zdimension

src/main/java/de/neemann/digital/core/element/Keys.java

@@ -9,6 +9,7 @@
 import de.neemann.digital.core.IntFormat;
 import de.neemann.digital.core.arithmetic.BarrelShifterMode;
 import de.neemann.digital.core.arithmetic.LeftRightFormat;
+import de.neemann.digital.core.element.Key.KeyInteger;
 import de.neemann.digital.core.extern.Application;
 import de.neemann.digital.core.io.CommonConnectionType;
 import de.neemann.digital.core.io.InValue;
@@ -1016,4 +1017,13 @@ private static File getATMISPPath() {
      */
     public static final Key<Boolean> SKIP_HDL =
             new Key<>("skipHDL", false).setSecondary();
+
+    /**
+     * Telnet buffer size
+     */
+    public static final Key<Integer> TELNET_BUFFER_SIZE =
+            new KeyInteger("telnetBufferSize", 1024)
+                    .setMin(1)
+                    .setMax(1 << 20)
+                    .allowGroupEdit();
 }

src/main/java/de/neemann/digital/core/io/telnet/Server.java

@@ -18,15 +18,14 @@
  */
 public class Server {
     private final ServerSocket serverSocket;
-    private final ByteBuffer buffer;
+    private ByteBuffer buffer;
     private final ServerThread serverThread;
     private boolean telnetEscape;
     private ClientThread client;
     private Telnet telnet;
     private SyncAccess syncAccess;
 
     Server(int port) throws IOException {
-        buffer = new ByteBuffer(1024);
         serverSocket = new ServerSocket(port);
         serverThread = new ServerThread();
         serverThread.start();
@@ -72,6 +71,10 @@ void setTelnetEscape(boolean telnetEscape) {
         this.telnetEscape = telnetEscape;
     }
 
+    void setBufferSize(int bufferSize) {
+        buffer = new ByteBuffer(bufferSize);
+    }
+
     private void dataReceived(int data) {
         if (syncAccess != null)
             syncAccess.modify(() -> {

src/main/java/de/neemann/digital/core/io/telnet/Telnet.java

@@ -30,12 +30,14 @@ public class Telnet extends Node implements Element {
             .addAttribute(Keys.ROTATE)
             .addAttribute(Keys.LABEL)
             .addAttribute(Keys.TELNET_ESCAPE)
-            .addAttribute(Keys.PORT);
+            .addAttribute(Keys.PORT)
+            .addAttribute(Keys.TELNET_BUFFER_SIZE);
 
     private final ObservableValue dataOut;
     private final ObservableValue dataAvail;
     private final int port;
     private final boolean telnetEscape;
+    private final int bufferSize;
     private ObservableValue dataIn;
     private ObservableValue clockValue;
     private ObservableValue writeEnable;
@@ -57,6 +59,7 @@ public Telnet(ElementAttributes attributes) {
                 .setPinDescription(DESCRIPTION);
         port = attributes.get(Keys.PORT);
         telnetEscape = attributes.get(Keys.TELNET_ESCAPE);
+        bufferSize = attributes.get(Keys.TELNET_BUFFER_SIZE);
     }
 
     @Override
@@ -103,6 +106,7 @@ public void init(Model model) throws NodeException {
             throw new NodeException(Lang.get("err_couldNotCreateServer"), e);
         }
         server.setTelnetEscape(telnetEscape);
+        server.setBufferSize(bufferSize);
         server.setTelnetNode(this, model);
     }
 

src/main/resources/lang/lang_en.xml

@@ -1673,6 +1673,10 @@
         the server is a simple TCP server.</string>
     <string name="key_port">Port</string>
     <string name="key_port_tt">The port to be opened by the server.</string>
+    <string name="key_telnetBufferSize">Buffer size</string>
+    <string name="key_telnetBufferSize_tt">The size (in bytes) of the buffer for the received data.
+        If data is received faster than it can be processed, the buffer can become full.
+        If the buffer is full, incoming data can be lost.</string>
 
     <string name="key_openRemotePort">Allow remote connection</string>
     <string name="key_openRemotePort_tt">If set, a TCP/IP port is opened, through which the control of the

src/main/resources/lang/lang_fr.xml

@@ -2689,7 +2689,11 @@ ligne d'en-tête utilisée pour spécifier les signaux testés.</p>
         De plus, le serveur envoie les commandes SGA et ECHO. Si cette option est désactivée,
         le serveur est un simple serveur TCP.</string>
     <string name="key_port">Port</string>
-    <string name="key_port_tt">Le port ouvert par le serveur.</string>
+    <string name="key_port_tt">Le port d'écoute du serveur.</string>
+    <string name="key_telnetBufferSize">Taille du tampon</string>
+    <string name="key_telnetBufferSize_tt">La taille (en octets) du tampon pour les données reçues.
+        Si les données sont reçues plus rapidement qu'elles ne sont traitées, le tampon se remplira.
+        Si le tampon est plein, les données reçues peuvent être perdues.</string>
     <string name="key_skipHDL">Ignorer lors de l'exportation en Verilog/VHDL</string>
     <string name="key_skipHDL_tt">Ignore la génération des composants internes au circuit lors de l'exportation en
         Verilog ou VHDL. Les références au circuit sont gardées, permettant de fournir une