[Pykafe-commits] SF.net SVN: pykafe: [74] trunk/pykafe/server/server.py

[<jn...@us...>]

Revision: 74
          http://pykafe.svn.sourceforge.net/pykafe/?rev=74&view=rev
Author:   jnmbk
Date:     2007-06-02 12:22:36 -0700 (Sat, 02 Jun 2007)

Log Message:
-----------
this is the reason of hanging

Modified Paths:
--------------
    trunk/pykafe/server/server.py

Modified: trunk/pykafe/server/server.py
===================================================================
--- trunk/pykafe/server/server.py	2007-06-02 17:13:16 UTC (rev 73)
+++ trunk/pykafe/server/server.py	2007-06-02 19:22:36 UTC (rev 74)
@@ -28,8 +28,8 @@
 _ = gettext.translation("pyKafe_server", fallback=True).ugettext
 
 class MessageSender(QtCore.QThread):
-    def __init__(self, parent, ip, port, message):
-        QtCore.QThread.__init__(self, parent)
+    def __init__(self, ip, port, message):
+        QtCore.QThread.__init__(self)
         self.ip, self.port, self.message = ip, port, message
         print "sending %s to %s:%d" % (message, ip, port)
     def run(self):
@@ -39,7 +39,6 @@
         tcpSocket.write(base64.encodestring(self.message))
         tcpSocket.waitForBytesWritten()
         tcpSocket.disconnectFromHost()
-        self.terminate()
 
 class ListenerThread(QtCore.QThread):
     def __init__(self, parent, socketDescriptor, clients, config):
@@ -91,7 +90,6 @@
                 #TODO: send current session information after taking 004
                 #message = "013"
                 #client.sendSession()
-                pass
         elif data[:3] == "000":
             #User wants to open
             if client.session.state == ClientSession.working:
@@ -114,7 +112,6 @@
         elif data[:3] == "008":
             client.setState(ClientSession.waitingMoney)
         self.tcpSocket.disconnectFromHost()
-        self.terminate()
 
 class ClientThread(QtCore.QThread):
     def __init__(self, parent, config):
@@ -159,7 +156,7 @@
             self.setBackground(i, QtGui.QBrush(QtGui.QColor(colorName)))
 
     def sendMessage(self, message):
-        thread = MessageSender(self.parent(), self.ip, int(self.config.network_port), message)
+        thread = MessageSender(self.ip, int(self.config.network_port), message)
         thread.start()
         self.threads.append(thread)
         print "This client has %d threads" % len(self.threads)


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.