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-0.6.0/Kamaelia/UI/OpenGL/Movement.py   Kamaelia(Download)
 
        while 1:
            while self.dataReady("control"):
                cmsg = self.recv("control")
                if isinstance(cmsg, producerFinished) or isinstance(cmsg, shutdownMicroprocess):
                    self.send(cmsg, "signal")
                    return
 
            while self.dataReady("notify"):
                            self.target_position[0] -= self.distance
 
            while self.dataReady("switch"):
                msg = self.recv("switch")
                if msg == "NEXT" and self.currentobject < 0:

src/k/a/kamaelia-HEAD/Sketches/MPS/Old/Selector.py   kamaelia(Download)
    def handleNotify(self, meta, readers,writers, exceptionals):
        if self.dataReady("notify"):
            message = self.recv("notify")
            if isinstance(message, newReader):
                replyService, selectable = message.object
        self.pause()
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
                message = self.recv("control")
                if isinstance(message,shutdown):

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

src/k/a/Kamaelia-0.6.0/Kamaelia/UI/Pygame/Display.py   Kamaelia(Download)
         """
 
         while self.dataReady("notify"):
            message = self.recv("notify")
            if isinstance(message, Axon.Ipc.producerFinished): ### VOMIT : mixed data types
              self.needsRedrawing=True
              theinbox, _ = theoverlay['yuvservice']
              while self.dataReady(theinbox):
                  yuv = self.recv(theinbox)
 
              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/THF/Packages/Kamaelia/Community/THF/Kamaelia/UI/OpenGL/Interactor.py   kamaelia(Download)
 
        # wait for response on displayrequest
        while not self.dataReady("callback"): yield 1
        self.identifier = self.recv("callback")
 
        while 1:
            yield 1
 
            while self.dataReady("control"):

src/k/a/Kamaelia-0.6.0/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-0.6.0/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-HEAD/Sketches/MPS/Axon.DSL/Axon/DSL/MultiAIMBot.py   kamaelia(Download)
        print "INITIALISING DEMUXER"
        print self.ignore_first
        while not self.dataReady("control"):
            yield 1
            for message in self.Inbox():
 
 
        if self.dataReady("control"):
            self.send(self.recv("control"), "signal")
        else:

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/THF/Kamaelia/UI/OpenGL/Interactor.py   kamaelia(Download)
 
        # wait for response on displayrequest
        while not self.dataReady("callback"): yield 1
        self.identifier = self.recv("callback")
 
        while 1:
            yield 1
 
            while self.dataReady("control"):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Experimental/Services.py   kamaelia(Download)
 
            while 1:
                while self.dataReady("inbox"):
                    req = self.recv("inbox")
                    if req[0] == "ADD":

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