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/Examples/Checkers/Checkers.py   kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
                    self.send("ACK", self.interactor_comms[objectid])
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/OpenGL/Checkers/Checkers.py   kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
                    self.send("ACK", self.interactor_comms[objectid])
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):

src/k/a/kamaelia-HEAD/Sketches/THF/Packages/Examples/Checkers/Checkers.py   kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
                    self.send("ACK", self.interactor_comms[objectid])
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/PersonalVideoRecorder.py   Kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg,(producerFinished,shutdownMicroprocess)):
        while not self.shutdown():
 
            while self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
            while self.dataReady("inbox"):

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/Checkers/Checkers.py   kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
                    self.send("ACK", self.interactor_comms[objectid])
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/likefile.py   kamaelia(Download)
            yield 1
            self.sendPendingOutput()
            if self.dataReady(self.deathbox):
                return
 
        for childSource, parentSink in self.childOutboxMapping.iteritems():
            queue = self.outQueues[childSource]
            while self.dataReady(parentSink):
                if not queue.full():
                    msg = self.recv(parentSink)

src/k/a/Kamaelia-0.6.0/Examples/SoC2006/THF/Checkers/Checkers.py   Kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
                    self.send("ACK", self.interactor_comms[objectid])
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/RecordNamedChannel.py   Kamaelia(Download)
        service_id = None
        while service_id == None:
            while not self.dataReady(fromSDT):
                self.pause()
                yield 1
        PMT_PID = None
        while PMT_PID == None:
            while not self.dataReady(fromPAT):
                self.pause()
                yield 1
        video_pid = None
        while audio_pid == None and video_pid == None:
            while not self.dataReady(fromPMT):
                self.pause()
                yield 1
 
        while 1:
            while self.dataReady(fromDemuxer):
                packet = self.recv(fromDemuxer)
                self.send(packet,"outbox")

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/AIM/MultiAIMBot.py   kamaelia(Download)
        print "INITIALISING DEMUXER"
        print self.ignore_first
        while not self.dataReady("control"):
            yield 1
            for message in self.Inbox():
 
 
        if self.dataReady("control"):
            self.send(self.recv("control"), "signal")
        else:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/JsonRPC/BDJsonRPC.py   kamaelia(Download)
    def main(self):
        while not self.shutdown():
            if self.dataReady('inbox'):
                data = self.recv('inbox')
                if self.debug >= 3: print ('Task Manager got data: %s' % repr(data))
                for worker_num in range(len(self.workers)):
                    boxname = self.worker_box_names[worker_num]['from']
                    if self.dataReady(boxname):
                        data = self.recv(boxname)
                        if self.debug >= 3: print ('TaskManager got data %r on boxname %s' % (data, boxname))
    def shutdown(self):
        if self.dataReady('control'):
            msg = self.recv('control')
            if isinstance(msg, shutdownMicroprocess) or isinstance(msg, producerFinished):
                if self.debug >= 3: print ('%s got shutdown msg: %r' % (self.__class__.__name__, msg))

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