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/DemuxerService.py   kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (shutdownMicroprocess, producerFinished)):
        while not self.shutdown():
 
            while self.dataReady("request"):
                cmd = self.recv("request")
                self.handleCommand(cmd)
 
            while self.dataReady("inbox"):

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/componentWrapperOutput.py   kamaelia(Download)
            yield 1
            self.sendPendingOutput()
            if self.dataReady(self.deathbox):
                return
 
        for childSource, parentSink in self.childOutboxMapping.iteritems():
            queue = self.outQueues[childSource]
            while self.dataReady(parentSink):
                if not queue.full():
                    msg = self.recv(parentSink)

src/k/a/kamaelia-HEAD/Sketches/AB/backup/AB-Whiteboard-V1/Kamaelia/UI/Pygame/Display.py   kamaelia(Download)
         """
 
         while self.dataReady("notify"):
            message = self.recv("notify")
#            print message
              self.needsRedrawing=True
              theinbox, _ = theoverlay['yuvservice']
              while self.dataReady(theinbox):
                  yuv = self.recv(theinbox)
                  if yuv is None:
              self.needsRedrawing=True
              theinbox, _ = theoverlay['posservice']
              while self.dataReady(theinbox):
                  theoverlay['position'] = self.recv(theinbox)
                  theoverlay['overlay'].set_location( (theoverlay['position'], 
   def handleEvents(self):
      # pre-fetch all waiting events in one go
      events = []
      if self.dataReady("events"):
          while 1:
                  events.append(event)
 
          while self.dataReady("events"):
                self.recv("events")
 

src/k/a/kamaelia-HEAD/Sketches/AB/backup/AB-Dev/Kamaelia/UI/Pygame/Display.py   kamaelia(Download)
         """
 
         while self.dataReady("notify"):
            message = self.recv("notify")
#            print message
              self.needsRedrawing=True
              theinbox, _ = theoverlay['yuvservice']
              while self.dataReady(theinbox):
                  yuv = self.recv(theinbox)
                  if yuv is None:
              self.needsRedrawing=True
              theinbox, _ = theoverlay['posservice']
              while self.dataReady(theinbox):
                  theoverlay['position'] = self.recv(theinbox)
                  theoverlay['overlay'].set_location( (theoverlay['position'], 
   def handleEvents(self):
      # pre-fetch all waiting events in one go
      events = []
      if self.dataReady("events"):
          while 1:
                  events.append(event)
 
          while self.dataReady("events"):
                self.recv("events")
 

src/k/a/kamaelia-HEAD/Sketches/MH/exceptions/Axon/experimental/_pprocess_support.py   kamaelia(Download)
            yield 1
            self.sendPendingOutput()
            if self.dataReady(self.deathbox):
                return
 
        for childSource, parentSink in self.childOutboxMapping.iteritems():
            queue = self.outQueues[childSource]
            while self.dataReady(parentSink):
                if not queue.full():
                    msg = self.recv(parentSink)

src/k/a/Kamaelia-0.6.0/Kamaelia/Device/DVB/Core.py   Kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (shutdownMicroprocess, producerFinished)):
    def main(self):
        buffer = ""
        buffers = []
        self.shuttingdown=False
        while (not self.shutdown()) or self.dataReady("inbox"):
            if not self.dataReady("inbox"):
               continue
            else:
                while self.dataReady("inbox"):
                    buffers.append(self.recv("inbox"))
            while len(buffers)>0:

src/k/a/kamaelia-HEAD/Sketches/JMB/protocol_manager.py   kamaelia(Download)
    def igetInbox(self, name='inbox'):
        while self.dataReady(name):
            yield self.recv(name)
 
    _CRLF_re = re.compile('(?<!\r)\n')

src/k/a/Kamaelia-0.6.0/Kamaelia/Device/DVB/SoftDemux.py   Kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (shutdownMicroprocess, producerFinished)):
        self.shuttingdown = False
 
        while (not self.shutdown()) or self.dataReady("inbox"):
 
            while self.dataReady("inbox"):

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/Utils/TopologyViewer3D.py   kamaelia(Download)
        self.send(disprequest, "display_signal")        
        # wait for response on displayrequest and get identifier of the viewer
        while not self.dataReady("callback"):  yield 1
        self.identifier = self.recv("callback")
 
        while True:
            # process incoming messages
            if self.dataReady("inbox"):
                message = self.recv("inbox")
                self.doCommand(message)
                #print message
 
                # wait for response on displayrequest and get identifier of the particle
                if self.isNewNode:
                    while not self.dataReady("callback"):  yield 1
            else:
                yield 1
            if self.dataReady("control"):
                msg = self.recv("control")
                if isinstance(msg, Axon.Ipc.shutdownMicroprocess):
    def handleEvents(self):
        """ Handle events. """
        while self.dataReady("events"):
            event = self.recv("events")
            if event.type == pygame.MOUSEBUTTONDOWN or pygame.MOUSEMOTION and self.grabbed:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/UI/Pygame/Display.py   kamaelia(Download)
         """
 
         while self.dataReady("notify"):
            message = self.recv("notify")
#            print (message)
              self.needsRedrawing=True
              theinbox, _ = theoverlay['yuvservice']
              while self.dataReady(theinbox):
                  yuv = self.recv(theinbox)
                  if yuv is None:
              self.needsRedrawing=True
              theinbox, _ = theoverlay['posservice']
              while self.dataReady(theinbox):
                  theoverlay['position'] = self.recv(theinbox)
                  theoverlay['overlay'].set_location( (theoverlay['position'], 
      topxratio, bottomxratio, leftyratio, rightyratio = self.calibration_ratios
 
      if self.dataReady("events"):
          while 1:
              event = pygame.event.poll()
                  events.append(event)
 
          while self.dataReady("events"):
                self.recv("events")
 

Previous  3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11  Next