Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(397)  |  Call(397)  |  Derive(0)  |  Import(0)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Device/DVB/Parse/ReassemblePSITables.py   kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg,(producerFinished,shutdownMicroprocess)):
    def main(self):
        while not self.shutdown():
 
            while self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
 
            # route incoming transport stream packets according to PID to the
            # appropriate reconstructor
            while self.dataReady("inbox"):
            for pid in self.activePids:
                inbox = self.activePids[pid][2]
                while self.dataReady(inbox):
                    psi_packet = self.recv(inbox)
                    for outbox in self.destinations[pid]:

src/k/a/kamaelia-HEAD/Sketches/Contrib/jsonrpc/bdjsonrpc.py   kamaelia(Download)
    def main(self):
        while not self.shutdown():
            if self.dataReady('inbox'):
                data = self.recv('inbox')
                if self.debug >= 3: print 'Task Manager got data: %s' % repr(data)
                for worker_num in range(len(self.workers)):
                    boxname = self.worker_box_names[worker_num]['from']
                    if self.dataReady(boxname):
                        data = self.recv(boxname)
                        if self.debug >= 3: print 'TaskManager got data %r on boxname %s' % (data, boxname)
    def shutdown(self):
        if self.dataReady('control'):
            msg = self.recv('control')
            if isinstance(msg, shutdownMicroprocess) or isinstance(msg, producerFinished):
                if self.debug >= 3: print '%s got shutdown msg: %r' % (self.__class__.__name__, msg)

src/k/a/kamaelia-HEAD/Sketches/MPS/VideoConf/DemuxRemuxTuple.py   kamaelia(Download)
              for boxkey in box_values:
                  if  box_values[boxkey] is undef:
                      if self.dataReady(subcomponent_inboxes[boxkey]):
                          message = self.recv(subcomponent_inboxes[boxkey])
                          box_values[boxkey] = message
 
              for component_name in subcomponent_controlboxes:
                  if self.dataReady(subcomponent_controlboxes[component_name]):
                      message = self.recv(subcomponent_controlboxes[component_name])
                      self.send(message, "signal")
      for boxkey in box_values:
          if  box_values[boxkey] is undef:
              if self.dataReady(subcomponent_inboxes[boxkey]):
                  message = self.recv(subcomponent_inboxes[boxkey])
                  box_values[boxkey] = message

src/k/a/kamaelia-HEAD/Sketches/JT/Jam/library/trunk/Kamaelia/Apps/Jam/Internet/UDPDispatcher.py   kamaelia(Download)
    def main(self):
        while 1:
            if self.dataReady("addPeer"):
                address, port = self.recv("addPeer")
                if not (address, port) in self.connectedPeers:
                        self.peers.add((address, port))
                        self.connectedPeers.add((address, port))
            if self.dataReady("peerSet"):
                self.peers.update(self.recv("peerSet"))
            if self.dataReady("inbox"):

src/k/a/kamaelia-HEAD/Sketches/MPS/DemuxRemuxTuple.py   kamaelia(Download)
              for boxkey in box_values:
                  if  box_values[boxkey] is undef:
                      if self.dataReady(subcomponent_inboxes[boxkey]):
                          message = self.recv(subcomponent_inboxes[boxkey])
                          box_values[boxkey] = message
 
              for component_name in subcomponent_controlboxes:
                  if self.dataReady(subcomponent_controlboxes[component_name]):
                      message = self.recv(subcomponent_controlboxes[component_name])
                      self.send(message, "signal")
      for boxkey in box_values:
          if  box_values[boxkey] is undef:
              if self.dataReady(subcomponent_inboxes[boxkey]):
                  message = self.recv(subcomponent_inboxes[boxkey])
                  box_values[boxkey] = message

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Chassis/ConnectedServer.py   kamaelia(Download)
            # Check and handle Out Of Bounds info
            # notifications of new and closed sockets
            while self.dataReady("_socketactivity"):
                data = self.recv("_socketactivity")
#                print ("DATA RECEIVED", data, repr(data))
                    self.handleClosedCSA(data)
                data = None
            if self.dataReady("control"):
                data = self.recv("control")
#                if isinstance(data, serverShutdown):

src/k/a/kamaelia-HEAD/Sketches/JMB/Descartes/DescartesCore.py   kamaelia(Download)
            # Check and handle Out Of Bounds info
            # notifications of new and closed sockets
            while self.dataReady("_socketactivity"):
                data = self.recv("_socketactivity")
                if isinstance(data, newCSA):
                    self.handleNewConnection(data)
                if isinstance(data, shutdownCSA):
                    self.handleClosedCSA(data)
            if self.dataReady("control"):

src/k/a/Kamaelia-0.6.0/Kamaelia/Device/DVB/Parse/ReassemblePSITables.py   Kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg,(producerFinished,shutdownMicroprocess)):
    def main(self):
        while not self.shutdown():
 
            while self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
 
            # route incoming transport stream packets according to PID to the
            # appropriate reconstructor
            while self.dataReady("inbox"):
            for pid in self.activePids:
                inbox = self.activePids[pid][2]
                while self.dataReady(inbox):
                    psi_packet = self.recv(inbox)
                    for outbox in self.destinations[pid]:

src/k/a/kamaelia-HEAD/Sketches/RJL/Packages/Kamaelia/Community/RJL/Kamaelia/Protocol/Torrent/TorrentService.py   kamaelia(Download)
            #print "TorrentService main loop"
            yield 1
            while self.dataReady("notify"):
                message = self.recv("notify")
                self.debug("NOTIFY")
                        self.send(message, "outbox")
 
            while self.dataReady("inbox"):
                message = self.recv("inbox")
                self.debug("INBOX")
                    self.debug(message)
 
            while self.dataReady("control"):
                message = self.recv("control")
                self.debug("CONTROL")
                while not torrentclientfinished:
                    yield 1            
                    while self.dataReady("_torrentcontrol"):
                        msg = self.recv("_torrentcontrol")
                        if isinstance(msg, producerFinished):
                    self.pause()
 
                if not self.dataReady("notify"):
                    TorrentService.endTorrentServices()
                else:

src/k/a/kamaelia-HEAD/Sketches/MPS/ConnectedServer.py   kamaelia(Download)
            # Check and handle Out Of Bounds info
            # notifications of new and closed sockets
            while self.dataReady("_socketactivity"):
                data = self.recv("_socketactivity")
                if isinstance(data, newCSA):
                    self.handleNewConnection(data)
                if isinstance(data, shutdownCSA):
                    self.handleClosedCSA(data)
            if self.dataReady("control"):

Previous  1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9  Next