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

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

src/k/a/kamaelia-HEAD/Sketches/MH/Timer/Timer.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():
 
            # handle new registration/deregistration requests
            while self.dataReady("register"):
 
            # get new event requests
            while self.dataReady("inbox"):
                event = self.recv("inbox")
                heappush(self.events, event)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
        arrive at the "notify" inbox.
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
        timewithNone = 0
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Selector.py   kamaelia(Download)
        arrive at the "notify" inbox.
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
        shuttingDown = False
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
                message = self.recv("control")
                if isinstance(message,shutdown):

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/Selector.py   Kamaelia(Download)
        arrive at the "notify" inbox.
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
        timewithNone = 0
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
        arrive at the "notify" inbox.
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
        timewithNone = 0
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")

src/k/a/kamaelia-HEAD/Tests/Python/Axon/test_ThreadedComponent.py   kamaelia(Download)
                    self.toTestCase.put( (False,boxname) )
                    self.fromTestCase.get()
                    if not self.dataReady(boxname):
                        self.toTestCase.put( (True,"Data should have been ready at the new inbox") )
                        return