diff -r 2b5355061b66 -r dfa28b22a36c gmyth-stream/server/plugins/comm/tcp.py
--- a/gmyth-stream/server/plugins/comm/tcp.py	Wed Apr 04 23:30:44 2007 +0100
+++ b/gmyth-stream/server/plugins/comm/tcp.py	Thu Apr 12 13:22:53 2007 +0100
@@ -1,36 +1,79 @@
 import lib
 import time
 import socket
+import logging as log
 
 class Server(object):
 
     def __init__(self, config):
-        self.host = ''
+        self.host = '0.0.0.0'
         self.port = int(config.get("Comm", "port"))
         self.finish = 0
 
+        addr = (self.host, self.port)
+        log.debug("Setup TCP server at %s:%s" % addr)
         self.tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         self.tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-        self.tcp.bind( (self.host, self.port) )
+        self.tcp.bind(addr)
         self.tcp.listen(1)
+        log.info("TCP server listening at %s:%s (sock=%d)" %
+                 (self.host, self.port, self.tcp.fileno()))
 
-    def getMsg(self, size):
-        return self.con.recv(size)
+    def getMsg(self):
+        bytes = []
+        try:
+            while 1:
+                c = self.con.recv(1)
+                bytes.append(c)
+                if not c or c == "\n":
+                    break
+        except Exception, e:
+            log.error("Error reading message from client: %s" % e)
+            return None
+
+        if not bytes or bytes[-1] != "\n":
+            msg = "".join(bytes)
+            log.error("Invalid message from client: %r" % msg)
+            return None
+
+        # remove \n and \r
+        bytes.pop()
+        if bytes[-1] == "\r":
+            bytes.pop()
+
+        msg = "".join(bytes)
+        log.debug("RECV: %r" % msg)
+        return msg
 
     def sendMsg(self, msg):
+        log.debug("SEND: %r" % msg)
         self.con.send(msg + "\n")
 
-    def Ack(self, command):
-        msg = "[%s] Command %s received" % (lib.now(), command)
-        self.sendMsg(msg)
+    def sendOk(self, payload=None):
+        self.sendMsg("OK %d" % bool(payload is not None))
+        if payload is not None:
+            if not isinstance(payload, (tuple, list)):
+                payload = (payload,)
+            for e in payload:
+                self.sendMsg("+%s" % e)
+            self.sendMsg(".")
+
+    def sendNotOk(self, reason=""):
+        self.sendMsg("NOTOK %r" % reason)
 
     def getRequest(self):
+        log.debug("Wait for client request at %s:%s (sock=%d)" %
+                  (self.host, self.port, self.tcp.fileno()))
         self.con, self.client = self.tcp.accept()
-        print "[%s] Received request from ip=%s" % (lib.now(), self.client )
+        log.info("Incoming request from %s (con=%s)" %
+                 (self.client, self.con.fileno()))
         return (self.con, self.client, self.port)
 
     def disconnect_client(self, connection):
+        log.info("Closed request from %s (con=%s)" %
+                 (self.client, self.con.fileno()))
         connection.close()
 
     def stop(self):
+        log.debug("Stop")
         self.tcp.close()