Changeset 81 for remote_control


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
Location:
remote_control
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • remote_control/puzzlebox_brainstorms_client_interface.py

    r78 r81  
    150150        ################################################################## 
    151151         
    152         def configureNetworkThinkGear(self): 
     152        def connectToThinkGearHost(self): 
     153                 
     154                if self.DEBUG: 
     155                        print "Connecting to ThinkGear Host" 
    153156                 
    154157                self.thinkgearClient = \ 
    155158                   thinkgear_client.puzzlebox_brainstorms_network_client_thinkgear(self.log, parent=self) 
    156159                 
     160                self.disconnect(self.pushButtonThinkGearConnect, \ 
     161                             QtCore.SIGNAL("clicked()"), \ 
     162                             self.connectToThinkGearHost) 
     163                 
    157164                self.connect(self.pushButtonThinkGearConnect, \ 
    158165                                  QtCore.SIGNAL("clicked()"), \ 
    … …  
    160167                 
    161168                self.pushButtonThinkGearConnect.setText('Disconnect') 
    162                  
    163                 #self.pushButtonThinkGearConnect.setEnabled(False) 
    164169         
    165170         
    … …  
    168173        def diconnectFromThinkGearHost(self): 
    169174                 
     175                if self.DEBUG: 
     176                        print "Disconnecting from ThinkGear Host" 
     177                 
    170178                self.thinkgearClient.disconnectFromHost() 
    171179                 
     180                self.disconnect(self.pushButtonThinkGearConnect, \ 
     181                                  QtCore.SIGNAL("clicked()"), \ 
     182                                  self.diconnectFromThinkGearHost) 
     183                 
    172184                self.connect(self.pushButtonThinkGearConnect, \ 
    173185                                  QtCore.SIGNAL("clicked()"), \ 
    174                                   self.configureNetworkThinkGear) 
     186                                  self.connectToThinkGearHost) 
    175187                 
    176188                self.pushButtonThinkGearConnect.setText('Connect') 
    … …  
    214226                self.connect(self.pushButtonThinkGearConnect, \ 
    215227                                  QtCore.SIGNAL("clicked()"), \ 
    216                                   self.configureNetworkThinkGear) 
     228                                  self.connectToThinkGearHost) 
    217229         
    218230         

  • remote_control/puzzlebox_brainstorms_network_client_thinkgear.py

    r79 r81  
    99# For more information please refer to http://www.gnu.org/copyleft/gpl.html 
    1010# 
    11 # Last Update: 2010.06.28 
     11# Last Update: 2010.07.01 
    1212# 
    1313##################################################################### 
    … …  
    1616import signal 
    1717 
    18 from PyQt4 import QtCore, QtGui, QtNetwork 
     18from PyQt4 import QtCore, QtNetwork 
    1919 
    2020import simplejson as json 
    … …  
    276276        #log.info("Command parameters: %s" % command_parameters) 
    277277         
     278        app = QtCore.QCoreApplication(sys.argv) 
     279         
    278280        client = puzzlebox_brainstorms_network_client_thinkgear_command_line(log, \ 
    279281                    command_parameters, \ 
    … …  
    282284                    DEBUG=DEBUG) 
    283285         
    284         while True: 
    285                 while client.socket.waitForReadyRead(CLIENT_NO_REPLY_WAIT): 
    286                         pass 
    287  
     286        #while True: 
     287                #while client.socket.waitForReadyRead(CLIENT_NO_REPLY_WAIT): 
     288                        #pass 
     289         
     290        sys.exit(app.exec_()) 
     291 

  • 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.