Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(2757)  |  Call(2757)  |  Derive(0)  |  Import(0)

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name)
        assert(service_id)
            while not recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            while recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name, service_id)
 
                yield 1
 
            pat_table = self.recv("_fromPAT")
            # see if we can find our service's PMT
            for transport_stream_id in pat_table['transport_streams']:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name)
        assert(service_id)
            while not recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            while recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name, service_id)
 
                yield 1
 
            pat_table = self.recv("_fromPAT")
            # see if we can find our service's PMT
            for transport_stream_id in pat_table['transport_streams']:

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/Macro.py   kamaelia(Download)
    def main(self):
        while 1:
            yield 1
            while self.dataReady("inbox"):
                packet = self.recv("inbox")
        print uid,"shutdown received"
        while self.dataReady("control"):
            self.recv("control")                 # flush out shutdown messages
 
        # tell transcoder to stop
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):
            self.recv("_transcodingcomplete")
 
        # move the transcoded file and eit data to final destination

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/Macro.py   kamaelia(Download)
    def main(self):
        while 1:
            yield 1
            while self.dataReady("inbox"):
                packet = self.recv("inbox")
        print uid,"shutdown received"
        while self.dataReady("control"):
            self.recv("control")                 # flush out shutdown messages
 
        # tell transcoder to stop
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):
            self.recv("_transcodingcomplete")
 
        # move the transcoded file and eit data to final destination

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/Macro.py   kamaelia(Download)
    def main(self):
        while 1:
            yield 1
            while self.dataReady("inbox"):
                packet = self.recv("inbox")
        print uid,"shutdown received"
        while self.dataReady("control"):
            self.recv("control")                 # flush out shutdown messages
 
        # tell transcoder to stop
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):
            self.recv("_transcodingcomplete")
 
        # move the transcoded file and eit data to final destination

src/k/a/kamaelia-HEAD/Sketches/PO/KamPlanet/SimpleSample.py   kamaelia(Download)
    def main(self):
        while True:
            while self.dataReady('inbox'):
                data = self.recv('inbox')
                self.send(data, 'outbox')
            while self.dataReady('numbers'):
                data = self.recv('numbers')
                self.send(str(data), 'outbox')
            while self.dataReady('control'):
                data = self.recv('control')

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Audio/PyMedia/Resample.py   kamaelia(Download)
        while self.anyReady() or not shutdown:
            while self.dataReady("inbox"):
                data = self.recv("inbox")
                resampled = str(self.resampler.resample(data))
                self.send(resampled, "outbox")
 
            while self.dataReady("control"):
                msg=self.recv("control")

src/k/a/kamaelia-HEAD/Sketches/PO/test_examples/example4.py   kamaelia(Download)
    def main(self):
        while True:
            while self.dataReady('inbox'):
                hostname, port = self.recv('inbox')
                # Normally someone would write:
 
            while self.dataReady('_inbox'):
                data = self.recv('_inbox')
                self.send(data, 'outbox')
 
            while self.dataReady('_inbox2'):
                data = self.recv('_inbox2')
 
            while self.dataReady('control'):
                data = self.recv('control')
                self.send(data, 'signal')
                return

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/PersonalVideoRecorder.py   Kamaelia(Download)
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name)
        assert(service_id)
            while not recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            while recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
                        recording = newNowEvent['name'].lower().strip() == self.programme_name
            yield 1
 
        channel_name, service_id, ts_id = self.recv("_fromChannelLookup")
        assert(channel_name == self.channel_name, service_id)
 
                yield 1
 
            pat_table = self.recv("_fromPAT")
            # see if we can find our service's PMT
            for transport_stream_id in pat_table['transport_streams']:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Audio/PyMedia/Resample.py   kamaelia(Download)
        while self.anyReady() or not shutdown:
            while self.dataReady("inbox"):
                data = self.recv("inbox")
                resampled = str(self.resampler.resample(data))
                self.send(resampled, "outbox")
 
            while self.dataReady("control"):
                msg=self.recv("control")

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