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/UI/OpenGL/OpenGLDisplay.py   kamaelia(Download)
    def handleRequests(self):
        """ Handles service requests. """
        while self.dataReady("notify"):
            message = self.recv("notify")
 
    def handleEvents(self):
        """ Handles pygame input events. """
 
        # pre-fetch all waiting events in one go
        if self.dataReady("events"):

src/k/a/Kamaelia-0.6.0/Kamaelia/Util/Splitter.py   Kamaelia(Download)
         self.delayedboxlist = []
         dontpause = False # Assumption is that we should be able to pause after finishing
         if self.dataReady("configuration"):
            mes = self.recv("configuration")
            dontpause = True
                    postponedmesage = mes
                    self.delayedboxlist.append(box)
         if self.dataReady() and not postponedmesage:
            mes = self.recv()
            dontpause = True
 
            # check for requests to add/remove destinations
            while self.dataReady("configuration"):
                config = self.recv("configuration")
                if isinstance(config, addsink):
 
            # pass anything received on 'inbox' inbox
            while self.dataReady(self.inboxname):
                data = self.recv(self.inboxname)
                self.send(data, "outbox")
                for (boxname, linkage) in self.outboxsinks.values():
                    self.send(data, boxname)
 
            # pass anything received on 'control' inbox
            while self.dataReady(self.controlname):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/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/JT/Jam/library/trunk/Kamaelia/Apps/Jam/Audio/Polyphony.py   kamaelia(Download)
    def main(self):
        """ Main loop """
        while 1:
            if self.dataReady("inbox"):
                address, arguments = self.recv("inbox")
    def main(self):
        """ Main loop """
        while 1:
            if self.dataReady("inbox"):
                address, arguments = self.recv("inbox")

src/k/a/kamaelia-HEAD/Sketches/MPS/List/TaggingPluggableProcessor.py   kamaelia(Download)
    def main(self):
        self.lookup = {}
        while not self.dataReady("control"):
            for processor_request in self.Inbox("processor"):
                self.add_processor(processor_request)

src/k/a/Kamaelia-0.6.0/Kamaelia/UI/OpenGL/OpenGLComponent.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"):
    def handleMovement(self):
        """ Handle movement commands received by corresponding inboxes. """
        while self.dataReady("position"):
            pos = self.recv("position")
            self.position = Vector(*pos)
 
        while self.dataReady("rotation"):
            self.rotation = Vector(*rot)
 
        while self.dataReady("scaling"):
            scaling = self.recv("scaling")
            self.scaling = Vector(*scaling)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/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/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/MH/Services/auto_startup_and_shutdown.py   kamaelia(Download)
 
        print "Service started"
        while not self.dataReady("control"):
            while self.dataReady("request"):
                cmd = self.recv("request")

src/k/a/Kamaelia-0.6.0/Kamaelia/UI/OpenGL/Container.py   Kamaelia(Download)
    def main(self):
        while 1:
 
            while self.dataReady("control"):
                cmsg = self.recv("control")
    def handleMovement(self):
        """ Handle movement commands received by corresponding inboxes. """
        while self.dataReady("position"):
            pos = self.recv("position")
            self.position = Vector(*pos)
 
        while self.dataReady("rotation"):
            self.rotation = Vector(*rot)
 
        while self.dataReady("scaling"):
            scaling = self.recv("scaling")
            self.scaling = Vector(*scaling)
 
        while self.dataReady("rel_position"):

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