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)):
            # handle new registration/deregistration requests
            while self.dataReady("register"):
                msg = self.recv("register")
                cmd = msg[0]
                if cmd == "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)
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
#print type(message)
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")
                if isinstance(message,shutdown):
#                   print "recieved shutdown message"

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Selector.py   kamaelia(Download)
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
#print type(message)
        while 1: # SmokeTests_Selector.test_RunsForever
            if self.dataReady("control"):
                message = self.recv("control")
                if isinstance(message,shutdown):
#                   print "recieved shutdown message"

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/Selector.py   Kamaelia(Download)
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
#print type(message)
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")
                if isinstance(message,shutdown):
#                   print "recieved shutdown message"

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
        """
        while self.dataReady("notify"):
            message = self.recv("notify")
#            \
#print type(message)
            if self.dataReady("control"):
#                print "recieved control message"
                message = self.recv("control")
                if isinstance(message,shutdown):
#                   print "recieved shutdown message"

src/k/a/kamaelia-HEAD/Tests/Python/Axon/test_ThreadedComponent.py   kamaelia(Download)
                        self.toTestCase.put( (True,"Data should have been ready at the new inbox") )
                        return
                    self.toTestCase.put( (False,self.recv(boxname)) )
#                except Exception, e:
                except Exception: