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/CL/Topology3D/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/Code/Python/Kamaelia/Kamaelia/Device/DVB/Core.py   kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (shutdownMicroprocess, producerFinished)):
    def main(self):
        buffer = ""
        buffers = []
        self.shuttingdown=False
        while (not self.shutdown()) or self.dataReady("inbox"):
            if not self.dataReady("inbox"):
               continue
            else:
                while self.dataReady("inbox"):
                    buffers.append(self.recv("inbox"))
            while len(buffers)>0:

src/k/a/Kamaelia-0.6.0/Kamaelia/Chassis/ConnectedServer.py   Kamaelia(Download)
            # Check and handle Out Of Bounds info
            # notifications of new and closed sockets
            while self.dataReady("_socketactivity"):
                data = self.recv("_socketactivity")
                if isinstance(data, newCSA):
                    self.handleNewConnection(data)
                if isinstance(data, shutdownCSA):
                    self.handleClosedCSA(data)
            if self.dataReady("control"):

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/THF/Sketches/playground/Object3D.py   kamaelia(Download)
    def handleMovement(self):
        while self.dataReady("position"):
            pos = self.recv("position")
            self.pos = Vector(*pos)
 
        while self.dataReady("rotation"):
            rot = self.recv("rotation")
            self.rot = Vector(*rot)
 
        while self.dataReady("scaling"):
            self.scaling = Vector(*scaling)
 
        while self.dataReady("rel_position"):
            self.pos += Vector(*self.recv("rel_position"))
 
        while self.dataReady("rel_rotation"):

src/k/a/kamaelia-HEAD/Sketches/MH/new_splitter/Splitter.py   kamaelia(Download)
 
            # 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/THF/Packages/Kamaelia/Community/THF/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/RJL/Torrent/TorrentService.py   kamaelia(Download)
            #print "TorrentService main loop"
            yield 1
            while self.dataReady("notify"):
                message = self.recv("notify")
                print "NOTIFY"
                        self.send(message, "outbox")
 
            while self.dataReady("inbox"):
                message = self.recv("inbox")
                #print "INBOX"
                    print message
 
            while self.dataReady("control"):
                message = self.recv("control")
                print "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/THF/3D/playground/Object3D.py   kamaelia(Download)
    def handleMovement(self):
        while self.dataReady("position"):
            pos = self.recv("position")
            self.pos = Vector(*pos)
 
        while self.dataReady("rotation"):
            rot = self.recv("rotation")
            self.rot = Vector(*rot)
 
        while self.dataReady("scaling"):
            self.scaling = Vector(*scaling)
 
        while self.dataReady("rel_position"):
            self.pos += Vector(*self.recv("rel_position"))
 
        while self.dataReady("rel_rotation"):

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/THF/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/Code/Python/Kamaelia/Kamaelia/Device/DVB/SoftDemux.py   kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (shutdownMicroprocess, producerFinished)):
        self.shuttingdown = False
 
        while (not self.shutdown()) or self.dataReady("inbox"):
 
            while self.dataReady("inbox"):

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