Improve serial console interaction and network driver fixes

- Serial agent script: stream output as it arrives with 10s idle timeout
  (replaces fixed CMD_TIMEOUT, handles both fast and slow commands)
- PingCommand: fix timeout handling, synchronized cancelRequest(),
  bounded cleanup loop to prevent infinite iterations
- LanceCore: increase RX/TX descriptor rings from 4 to 16
- ResolverImpl: filter DNS answers to only A records with null check
- Update jnode-interact skill docs for streaming behavior

Author: LSantha

.opencode/skills/jnode-interact/SKILL.md

@@ -245,8 +245,8 @@ python3 .opencode/skills/jnode-interact/scripts/jnode_agent_cmd.py \
 1. Connects to the Unix socket (`/tmp/jnode_com2` → `/tmp/jnode.serial2`)
 2. Clears any pending data from the buffer
 3. Sends each command followed by `\r\n`
-4. Reads response until timeout (1 second of silence)
-5. Prints output, strips trailing whitespace
+4. Streams output as it arrives — prints complete lines immediately
+5. Waits for either the prompt or 10 seconds of silence since last output
 
 ### Important: Single client only
 

.opencode/skills/jnode-interact/scripts/jnode_agent_cmd.py

@@ -11,18 +11,18 @@
 import sys
 
 
-PROMPT = b'[JNODE_AGENT_READY]'
-PROMPT_TIMEOUT = 3.0
-CMD_TIMEOUT = 2.0
-
-
 def connect_serial():
     sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
     sock.settimeout(5)
     sock.connect('/tmp/jnode_com2')
     return sock
 
 
+PROMPT = b'[JNODE_AGENT_READY]'
+PROMPT_TIMEOUT = 3.0
+OUTPUT_TIMEOUT = 10.0
+
+
 def clear_buffer(sock):
     """Clear any pending data in socket buffer."""
     sock.settimeout(0.1)
@@ -33,7 +33,6 @@ def clear_buffer(sock):
                 break
         except socket.timeout:
             break
-    sock.settimeout(CMD_TIMEOUT)
 
 
 def wait_for_prompt(sock, timeout):
@@ -58,30 +57,49 @@ def wait_for_prompt(sock, timeout):
 
 
 def send_cmd(sock, cmd):
-    """Send command and read response."""
+    """Send command and stream response until prompt or output timeout."""
     clear_buffer(sock)
 
     sock.send(f"{cmd}\r\n".encode())
 
     buf = b""
+    last_output_time = time.time()
+    printed_up_to = 0
+
     while True:
         try:
-            sock.settimeout(CMD_TIMEOUT)
+            remaining = last_output_time + OUTPUT_TIMEOUT - time.time()
+            if remaining <= 0:
+                break
+            sock.settimeout(min(1.0, remaining))
             r = sock.recv(4096)
             if r:
                 buf += r
-                if b'Packet statistics' in buf:
-                    time.sleep(0.3)
+                last_output_time = time.time()
+
+                # Print new complete lines immediately
+                decoded = buf[printed_up_to:].decode(errors='replace')
+                lines = decoded.split('\n')
+                for line in lines[:-1]:
+                    stripped = line.strip()
+                    if stripped and PROMPT.decode() not in stripped:
+                        print(line)
+                printed_up_to = len(buf) - len(lines[-1].encode(errors='replace'))
+
+                if PROMPT in buf:
                     break
             else:
                 break
         except socket.timeout:
-            break
+            if time.time() - last_output_time >= OUTPUT_TIMEOUT:
+                break
 
-    output = buf.decode(errors='replace').rstrip()
-    if output:
-        for line in output.split('\n'):
-            if line.strip():
+    # Print any remaining buffer
+    if printed_up_to < len(buf):
+        remaining = buf[printed_up_to:].decode(errors='replace')
+        for line in remaining.split('\n'):
+            stripped = line.strip()
+            if stripped and PROMPT.decode() not in stripped:
                 print(line)
 
 

cli/src/commands/org/jnode/command/net/PingCommand.java

@@ -8,16 +8,16 @@
  * by the Free Software Foundation; either version 2.1 of the License, or
  * (at your option) any later version.
  *
- * This library is distributed in the hope that it will be useful, but 
+ * This library is distributed in the hope that it will be useful, but
  * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
- * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public 
+ * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
  * License for more details.
  *
  * You should have received a copy of the GNU Lesser General Public License
- * along with this library; If not, write to the Free Software Foundation, Inc., 
+ * along with this library; If not, write to the Free Software Foundation, Inc.,
  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  */
- 
+
 package org.jnode.command.net;
 
 import java.io.PrintWriter;
@@ -55,7 +55,7 @@ public class PingCommand extends AbstractCommand implements ICMPListener {
     private static final String fmt_stats = "-> Packet statistics%n%s%n";
     private static final String fmt_get_stats = "%d packets transmitted, %d packets received%nround-trip min/avg/max" +
                                                 " = %d/%.3f/%dms";
-    
+
     // FIXME Some of the following could be command parameters ...
     private final Statistics stat = new Statistics();
     private boolean wait = true;
@@ -79,7 +79,7 @@ public PingCommand() {
     public static void main(String[] args) throws Exception {
         new PingCommand().execute(args);
     }
-    
+
     public void execute() throws SocketException, InterruptedException {
         try {
             this.dst = new IPv4Address(argHost.getAsInetAddress());
@@ -88,7 +88,7 @@ public void execute() throws SocketException, InterruptedException {
             exit(1);
         }
         final PrintWriter out = getOutput().getPrintWriter();
-        
+
         final IPv4Header netHeader =
                 new IPv4Header(0, this.ttl, IPv4Constants.IPPROTO_ICMP, this.dst, 8);
         netHeader.setDontFragment(this.dontFragment);
@@ -122,14 +122,10 @@ public void execute() throws SocketException, InterruptedException {
                 r.arm();
 
                 while (this.wait) {
-                    long time = System.currentTimeMillis() - r.getTimestamp();
-                    if (time > this.interval) {
-                        this.wait = false;
-                    }
-                    Thread.sleep(500);
+                    Thread.sleep(Math.min(500, this.interval));
                     synchronized (this) {
                         if (response) {
-                            out.format(fmt_reply, 
+                            out.format(fmt_reply,
                                 dst.toString(), hdr1.getDataLength(), hdr1.getTtl(), hdr2.getSeqNumber(), roundt);
                             response = false;
                         }
@@ -139,16 +135,17 @@ public void execute() throws SocketException, InterruptedException {
                 seq_count++;
             }
 
-            while (!isEmpty()) {
-                Thread.sleep(100);
+            long cleanupDeadline = System.currentTimeMillis() + 100;
+            while (!isEmpty() && (System.currentTimeMillis() < cleanupDeadline)) {
+                Thread.sleep(10);
             }
         } finally {
             icmpProtocol.removeListener(this);
         }
-        
+
         out.format(fmt_stats, this.stat.getStatistics());
     }
-    
+
     private long match(int id, int seq, Request r) {
         if (r != null && id == r.getId()) {
             return r.getTimestamp();
@@ -231,24 +228,24 @@ void arm() {
         }
 
         public void run() {
-            if (!this.Obsolete()) {
-                stat.recordLost();
-                removeRequest(this.seq);
-            }
+            Obsolete();
         }
 
         synchronized boolean Obsolete() {
             if (!obsolete) {
                 this.obsolete = true;
                 this.cancelled = true;
                 this.timer.cancel();
+                this.stat.recordLost();
+                removeRequest(this.seq);
+                wait = false;
                 return false;
             } else {
                 return true;
             }
         }
 
-        void cancelRequest() {
+        synchronized void cancelRequest() {
             this.cancelled = true;
             this.timer.cancel();
         }

net/src/driver/org/jnode/driver/net/lance/LanceCore.java

@@ -66,8 +66,8 @@ public class LanceCore extends AbstractDeviceCore implements IRQHandler, LanceCo
 
     // This is the number of descriptors for the receive and transmit rings
     // Note: Valid numbers are 2^x where x is 0..8 (1, 2, 4, 8, 16, .., 512)
-    private static final int RX_DESCRIPTOR_LENGTH = 4;
-    private static final int TX_DESCRIPTOR_LENGTH = 4;
+    private static final int RX_DESCRIPTOR_LENGTH = 16;
+    private static final int TX_DESCRIPTOR_LENGTH = 16;
 
     /**
      * Device Driver

net/src/net/org/jnode/net/ipv4/util/ResolverImpl.java

@@ -244,7 +244,23 @@ private static Record[] resolveFromServer(String hostname, String server, int ti
             if ((answers == null) || (answers.length == 0)) {
                 throw new UnknownHostException("No DNS answer for " + hostname);
             }
-            return answers;
+            int answerCount = 0;
+            for (int i = 0; i < answers.length; i++) {
+                if (answers[i].getType() == Type.A) {
+                    answerCount++;
+                }
+            }
+            if (answerCount == 0) {
+                throw new UnknownHostException("No DNS A answer for " + hostname);
+            }
+            Record[] aAnswers = new Record[answerCount];
+            int index = 0;
+            for (int i = 0; i < answers.length; i++) {
+                if (answers[i].getType() == Type.A) {
+                    aAnswers[index++] = answers[i];
+                }
+            }
+            return aAnswers;
         } catch (TextParseException ex) {
             throw new UnknownHostException(hostname);
         } catch (IOException ex) {