usawa

commit a92686dcda65ba4f56a46eec4530e8a3371602e9
parent 0c7e0ebfc3c2b176fcaad8dbf0039feb43a03169
Author: lash <dev@holbrook.no>
Date:   Wed, 11 Mar 2026 07:02:32 -0600

Reinstitute threading for unix server

Diffstat:
M
dummy/usawa/service.py
 | 
12
++++--------

1 file changed, 4 insertions(+), 8 deletions(-)
diff --git a/dummy/usawa/service.py b/dummy/usawa/service.py
@@ -1,6 +1,7 @@
 import logging
 import socket
 import os
+import threading
 
 from whee import Interface
 from usawa.store import LedgerStore
@@ -241,14 +242,8 @@ class SocketServer:
                 break
             if sckc != None:
                 logg.info('connect: {}'.format(address))
-                #th = threading.Thread(target=self.receive, args=(sckc, address))
-                #th.start()
-                try:
-                    self.receive(sckc, address)
-                except ConnectionResetError:
-                    logg.warning('connection reset')
-                sckc.close()
-                break
+                th = threading.Thread(target=self.receive, args=(sckc, address))
+                th.start()
 
 
     """Implements whee.Interface
@@ -316,6 +311,7 @@ class SocketServer:
                 v = b'\x01'
             logg.debug('harvest {}'.format(v.hex()))
             sckc.sendall(v)
+        sckc.close()
 
 
     def __str__(self):