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/Sketches/THF/Packages/Kamaelia/Community/THF/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"):

src/k/a/kamaelia-HEAD/Sketches/MPS/Axon.DSL/Axon/DSL/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/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/Sketches/RJL/Kamaelia/Community/RJL/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/Code/Python/Kamaelia/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/Sketches/THF/Packages/Kamaelia/Community/THF/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/Sketches/CL/Topology3D/THF/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"):

src/k/a/kamaelia-HEAD/Sketches/MH/OnDemandBackplane/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/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/Code/Python/Kamaelia/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  1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9  Next