jtag_uart/openocd: switch to raw tcp socket and get litex_server --jtag-uart working.

litex/build/openocd.py

@@ -42,7 +42,7 @@ class OpenOCD(GenericProgrammer):
 
     def stream(self, port=20000):
         """
-        Create a Telnet server to stream data to/from the internal JTAG TAP of the FPGA
+        Create a TCP server to stream data to/from the internal JTAG TAP of the FPGA
 
         Wire format: 10 bits LSB first
         Host to Target:
@@ -64,6 +64,7 @@ proc jtagstream_poll {tap tx n} {
     foreach txj [split $tx ""] {
         lset txi $i 1 [format 0x%4.4X [expr 0x201 | ([scan $txj %c] << 1)]]
         incr i
+        #echo tx[scan $txj %c]
     }
     set txi [concat {*}$txi]
     set rxi [split [drscan $tap {*}$txi -endstate DRPAUSE] " "]
@@ -95,12 +96,13 @@ proc jtagstream_drain {tap tx chunk_rx max_rx} {
 proc jtagstream_rxtx {tap client is_poll} {
     if {![$client eof]} {
         if {!$is_poll} {
-            set tx [$client gets]
+            set tx [$client read -nonewline 1]
         } else {
             set tx ""
         }
         set rx [jtagstream_drain $tap $tx 64 4096]
         if {[string length $rx]} {
+            #echo [string length $rx]
             $client puts -nonewline $rx
         }
         if {$is_poll} {

litex/tools/litex_term.py

@@ -17,7 +17,7 @@ import threading
 import multiprocessing
 import argparse
 import json
-import telnetlib
+import socket
 
 # Console ------------------------------------------------------------------------------------------
 
@@ -132,35 +132,36 @@ class JTAGUART:
 
     def open(self):
         self.file, self.name = pty.openpty()
-        self.jtag2telnet_thread = multiprocessing.Process(target=self.jtag2telnet)
-        self.jtag2telnet_thread.start()
+        self.jtag2tcp_thread = multiprocessing.Process(target=self.jtag2tcp)
+        self.jtag2tcp_thread.start()
         time.sleep(0.5)
-        self.pty2telnet_thread  = multiprocessing.Process(target=self.pty2telnet)
-        self.telnet2pty_thread  = multiprocessing.Process(target=self.telnet2pty)
-        self.telnet = telnetlib.Telnet("localhost", self.port)
-        self.pty2telnet_thread.start()
-        self.telnet2pty_thread.start()
+        self.pty2tcp_thread  = multiprocessing.Process(target=self.pty2tcp)
+        self.tcp2pty_thread  = multiprocessing.Process(target=self.tcp2pty)
+        self.tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        self.tcp.connect(("localhost", self.port))
+        self.pty2tcp_thread.start()
+        self.tcp2pty_thread.start()
 
     def close(self):
-        self.jtag2telnet_thread.terminate()
-        self.pty2telnet_thread.terminate()
-        self.telnet2pty_thread.terminate()
+        self.jtag2tcp_thread.terminate()
+        self.pty2tcp_thread.terminate()
+        self.tcp2pty_thread.terminate()
 
-    def jtag2telnet(self):
+    def jtag2tcp(self):
         prog = OpenOCD(self.config)
         prog.stream(self.port)
 
-    def pty2telnet(self):
+    def pty2tcp(self):
         while True:
             r = os.read(self.file, 1)
-            self.telnet.write(r)
+            self.tcp.send(r)
             if r == bytes("\n".encode("utf-8")):
-                self.telnet.write("\r".encode("utf-8"))
-            self.telnet.write("\n".encode("utf-8"))
+                self.tcp.send("\r".encode("utf-8"))
+            self.tcp.send("\n".encode("utf-8"))
 
-    def telnet2pty(self):
+    def tcp2pty(self):
         while True:
-            r = self.telnet.read_some()
+            r = self.tcp.recv(1)
             os.write(self.file, bytes(r))
 
 # SFL ----------------------------------------------------------------------------------------------