Ignore:
Timestamp:
07/01/10 11:55:18 (11 years ago)
Author:
sc
Message:

remote_control/puzzlebox_brainstorms_network_client_thinkgear.py:

  • converted to use QCoreApplication format

remote_control/puzzlebox_brainstorms_client_interface.py:

  • corrected handling of ThinkGear? connecting/disconnecting

remote_control/puzzlebox_brainstorms_network_server_thinkgear.py:

  • DEFAULT_SAMPLE_WAVELENGTH updated to 20 seconds
  • connection handling reorganized
  • comment cleanup
File:
1 edited

Legend:

Unmodified
Added
Removed
  • remote_control/puzzlebox_brainstorms_network_server_thinkgear.py

    r80 r81  
    99# For more information please refer to http://www.gnu.org/copyleft/gpl.html 
    1010# 
    11 # Last Update: 2010.06.30 
     11# Last Update: 2010.07.01 
    1212# 
    1313##################################################################### 
     
    4949                          # an adult blinks in a laboratory setting) 
    5050 
    51 DEFAULT_SAMPLE_WAVELENGTH = 10 # number of seconds from 0 to max to 0 for 
     51DEFAULT_SAMPLE_WAVELENGTH = 20 # number of seconds from 0 to max to 0 for 
    5252                               # any given detection value below 
    5353 
     
    126126                self.blink_frequency_timer = BLINK_FREQUENCY_TIMER 
    127127                 
    128                 #self.client_connected = False 
    129128                self.connection_timestamp = time.time() 
    130129                self.blink_timestamp = time.time() 
     
    135134                self.configureNetwork() 
    136135                 
    137                 self.timer = QtCore.QTimer() 
    138                 QtCore.QObject.connect(self.timer, QtCore.SIGNAL("timeout()"), self.timerEvent) 
    139                 self.timer.start(MESSAGE_FREQUENCY_TIMER) 
    140                  
    141                 #self.timer = QtCore.QTimer.singleShot(MESSAGE_FREQUENCY_TIMER, self.timerEvent) 
     136                self.updateTimer = QtCore.QTimer() 
     137                QtCore.QObject.connect(self.updateTimer, QtCore.SIGNAL("timeout()"), self.timerEvent) 
     138                self.updateTimer.start(MESSAGE_FREQUENCY_TIMER) 
    142139         
    143140         
     
    185182        ################################################################## 
    186183         
    187         #def getNextConnectionIndex(self): 
    188                  
    189                 #index = len(self.connections.keys()) 
    190                  
    191                 #while index in self.connection.keys(): 
    192                         #index += 1 
    193                  
    194                  
    195                 #return(index) 
    196          
    197          
    198         ################################################################## 
    199          
    200184        def deleteDisconnected(self): 
    201185                 
     
    204188                for connection in self.connections: 
    205189                         
    206                         if self.DEBUG: 
    207                                 print "Connection state:", 
    208                                 print connection.state() 
     190                        #if self.DEBUG: 
     191                                #print "Connection state:", 
     192                                #print connection.state() 
    209193                         
    210194                        if ((connection.state() != QtNetwork.QAbstractSocket.ConnectingState) and \ 
     
    212196                                 
    213197                                if self.DEBUG: 
    214                                         print "x-- [%s] Deleting disconnected socket:" % self.socket.name, 
     198                                        print "- - [%s] Deleting disconnected socket" % self.socket.name 
    215199                                 
    216200                                connection.deleteLater() 
     
    227211                 
    228212                clientConnection = self.socket.nextPendingConnection() 
    229                 #index = self.getNextConnectionIndex() 
    230                 #clientConnection.index = index 
    231                 #clientConnection.disconnected.connect(clientConnection.deleteLater) 
    232213                clientConnection.disconnected.connect(self.deleteDisconnected) 
    233                 #self.connections[index] = clientConnection 
     214                 
     215                self.connections.append(clientConnection) 
     216                 
    234217                 
    235218                # Wait until client sends authorization request or configuration packet 
     
    284267                                                 
    285268                                                self.sendResponse(clientConnection, response) 
    286                  
    287                  
    288                 self.connections.append(clientConnection) 
    289269         
    290270         
     
    479459                                packet = DEFAULT_BLINK_MESSAGE 
    480460                                self.packet_queue.append(packet) 
    481          
    482          
    483 ##################################################################### 
    484 ##################################################################### 
    485  
    486 #class networkServerThinkGearThread(QtCore.QThread): 
    487          
    488         #error = QtCore.pyqtSignal(QtNetwork.QTcpSocket.SocketError) 
    489  
    490         #def __init__(self, socketDescriptor, parent): 
    491                 ##super(networkServerThinkGearThread, self).__init__(parent) 
    492                  
    493                 #self.socketDescriptor = socketDescriptor 
    494          
    495          
    496         ################################################################### 
    497          
    498         #def run(self): 
    499                  
    500                 #tcpSocket = QtNetwork.QTcpSocket() 
    501                  
    502                 #if not tcpSocket.setSocketDescriptor(self.socketDescriptor): 
    503                         #self.error.emit(tcpSocket.error()) 
    504                          
    505                         #return 
    506  
    507                 ##block = QtCore.QByteArray() 
    508                 ##outstr = QtCore.QDataStream(block, QtCore.QIODevice.WriteOnly) 
    509                 ##outstr.setVersion(QtCore.QDataStream.Qt_4_0) 
    510                 ##outstr.writeUInt16(0) 
    511                 ##outstr.writeString(self.text) 
    512                 ##outstr.device().seek(0) 
    513                 ##outstr.writeUInt16(block.count() - 2) 
    514  
    515                 ##tcpSocket.write(block) 
    516                 ##tcpSocket.disconnectFromHost() 
    517                 ##tcpSocket.waitForDisconnected() 
    518461 
    519462 
Note: See TracChangeset for help on using the changeset viewer.