Ignore:
Timestamp:
07/01/10 06:17:37 (11 years ago)
Author:
sc
Message:

thinkgear_emulator/puzzlebox_thinkgear_client.py:

  • whitespace cleanup

thinkgear_emulator/puzzlebox_thinkgear_server.py:

  • whitespace cleanup
  • added minor exception handling

remote_control/puzzlebox_brainstorms_client_interface.py

  • connect/disconnect from ThinkGear? socket server support added

remote_control/interface/qt4_form.py:

  • minor tweaks to layout

configuration:

  • THINKGEAR_SERVER_INTERFACE variable added

remote_control/puzzlebox_brainstorms_network_server_thinkgear.py

  • initial checkin
  • conversion from Python Twisted to QtNetwork? model

remote_control/puzzlebox_brainstorms_network_server.py:

  • QtCore?.QCoreApplication support added
File:
1 edited

Legend:

Unmodified
Added
Removed
  • remote_control/puzzlebox_brainstorms_network_client_thinkgear.py

    r76 r78  
    9595                        if packet != '': 
    9696                                 
    97                                 data = json.loads(packet.data()) 
    98                                  
    99                                 if self.DEBUG: 
    100                                         print "<-- [%s] Received:" % self.socket.name, 
    101                                         print data 
    102                                  
    103                                 self.processPacketThinkGear(data) 
     97                                try: 
     98                                         
     99                                        data = json.loads(packet.data()) 
     100                                 
     101                                 
     102                                except Exception, e: 
     103                                         
     104                                        if self.DEBUG: 
     105                                                print "ERROR [%s]: Exception parsing packet:" % self.socket.name, 
     106                                                print packet.data() 
     107                                                print "ERROR [%s]: Data packet" % self.socket.name, 
     108                                                print e 
     109                                         
     110                                        continue 
     111                                 
     112                                 
     113                                else: 
     114                                         
     115                                        if self.DEBUG: 
     116                                                print "<-- [%s] Received:" % self.socket.name, 
     117                                                print data 
     118                                         
     119                                        self.processPacketThinkGear(data) 
    104120         
    105121         
     
    109125                 
    110126                if self.DEBUG: 
    111                         if (socketError != QtNetwork.QAbstractSocket.RemoteHostClosedError): 
     127                        if ((socketError != QtNetwork.QAbstractSocket.RemoteHostClosedError) and \ 
     128                                 (socketError != QtNetwork.QAbstractSocket.SocketTimeoutError)): 
    112129                                print "ERROR [%s]:" % self.socket.name, 
    113130                                print self.socket.errorString() 
     
    116133                if (self.parent != None): 
    117134                 
    118                         if socketError == QtNetwork.QAbstractSocket.RemoteHostClosedError: 
     135                        if ((socketError == QtNetwork.QAbstractSocket.RemoteHostClosedError) or \ 
     136                                 (socketError != QtNetwork.QAbstractSocket.SocketTimeoutError)): 
    119137                                pass 
    120138                         
     
    152170                data = json.dumps(command) 
    153171                 
    154                 if self.socket.waitForConnected(CLIENT_NO_REPLY_WAIT): 
    155                         self.socket.write(data) 
     172                self.socket.waitForConnected(CLIENT_NO_REPLY_WAIT) 
     173                 
     174                self.socket.write(data) 
     175                 
     176                try: 
     177                        self.socket.waitForBytesWritten(CLIENT_NO_REPLY_WAIT) 
     178                except Exception, e: 
     179                        print "ERROR [%s]: Exception:" % self.socket.name, 
     180                        print e 
    156181         
    157182         
     
    174199                                if (self.parent != None): 
    175200                                        self.parent.progressBarRelaxation.setValue(packet['eSense']['meditation']) 
     201         
     202         
     203        ################################################################## 
     204         
     205        def disconnectFromHost(self): 
     206                 
     207                self.socket.disconnectFromHost() 
    176208 
    177209 
     
    250282                    DEBUG=DEBUG) 
    251283         
    252         while client.socket.waitForReadyRead(CLIENT_NO_REPLY_WAIT): 
    253                 pass 
    254  
     284        while True: 
     285                while client.socket.waitForReadyRead(CLIENT_NO_REPLY_WAIT): 
     286                        pass 
     287 
Note: See TracChangeset for help on using the changeset viewer.