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

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

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")
        eitF = None
 
        while not self.dataReady("control"):      # wait until shutdown
            self.pause()
            yield 1
 
        print uid,"shutdown received"
        while self.dataReady("control"):
 
        print uid,"waiting for transcoder to finish"
        while not self.dataReady("_transcodingcomplete"):
            self.pause()
            yield 1
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
        while not self.dataReady("_fromChannelLookup"):
            self.pause()
            yield 1
            recording=False
            while not recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
 
            while recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
        while not self.dataReady("_fromChannelLookup"):
            self.pause()
            yield 1
        PMT_PID = None
        while PMT_PID == None:
            while not self.dataReady("_fromPAT"):
                self.pause()
                yield 1

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")
        eitF = None
 
        while not self.dataReady("control"):      # wait until shutdown
            self.pause()
            yield 1
 
        print uid,"shutdown received"
        while self.dataReady("control"):
 
        print uid,"waiting for transcoder to finish"
        while not self.dataReady("_transcodingcomplete"):
            self.pause()
            yield 1
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
        while not self.dataReady("_fromChannelLookup"):
            self.pause()
            yield 1
            recording=False
            while not recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
 
            while recording:
                if self.dataReady("inbox"):
                    newNowEvent = self.recv("inbox")
                    if newNowEvent['service'] == service_id:
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
        while not self.dataReady("_fromChannelLookup"):
            self.pause()
            yield 1
        PMT_PID = None
        while PMT_PID == None:
            while not self.dataReady("_fromPAT"):
                self.pause()
                yield 1

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")
        eitF = None
 
        while not self.dataReady("control"):      # wait until shutdown
            self.pause()
            yield 1
 
        print uid,"shutdown received"
        while self.dataReady("control"):
 
        print uid,"waiting for transcoder to finish"
        while not self.dataReady("_transcodingcomplete"):
            self.pause()
            yield 1
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):

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'):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Audio/PyMedia/Resample.py   kamaelia(Download)
    def main(self):
        shutdown=False
        data=""
        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"):

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:
                childComponent.activate()
 
            while self.dataReady('_inbox'):
                data = self.recv('_inbox')
                self.send(data, 'outbox')
 
            while self.dataReady('_inbox2'):
                self.send(data, 'outbox')
 
            while self.dataReady('control'):
                data = self.recv('control')
                self.send(data, 'signal')

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/Macro.py   Kamaelia(Download)
    def main(self):
        while 1:
            yield 1
            while self.dataReady("inbox"):
                packet = self.recv("inbox")
        eitF = None
 
        while not self.dataReady("control"):      # wait until shutdown
            self.pause()
            yield 1
 
        print uid,"shutdown received"
        while self.dataReady("control"):
 
        print uid,"waiting for transcoder to finish"
        while not self.dataReady("_transcodingcomplete"):
            self.pause()
            yield 1
        print uid,"transcoder has finished"
        while self.dataReady("_transcodingcomplete"):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/TorrentBasedStreaming_GSOC/TorrentSeeder/torrentseeder.py   kamaelia(Download)
    def main(self):
        while 1:
            yield 1
 
            while self.dataReady("a") and self.dataReady("b"):
                self.send([self.recv("a"), self.recv("b")], "outbox")
 
            while self.dataReady("control"):

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