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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/OpenGL/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
 
 
            while self.dataReady("torrent_url"):
                url = self.recv("torrent_url")
                filename = os.path.basename(url)
                self.requested_files.append(filename)
                self.send(url, "fetcher")
 
            while self.dataReady("torrent_file"):
                torrentfile = self.recv("torrent_file")
 
            while self.dataReady("nav"):
                msg = self.recv("nav")
                if msg == "UP":
                    self.send("NEXT", "mover_switch")
                if msg == "DOWN":
                    self.send("PREVIOUS", "mover_switch")
 
            while self.dataReady("start"):
                torrent = self.recv("start")

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/THF/Examples/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
 
 
            while self.dataReady("torrent_url"):
                url = self.recv("torrent_url")
                filename = os.path.basename(url)
                self.requested_files.append(filename)
                self.send(url, "fetcher")
 
            while self.dataReady("torrent_file"):
                torrentfile = self.recv("torrent_file")
 
            while self.dataReady("nav"):
                msg = self.recv("nav")
                if msg == "UP":
                    self.send("NEXT", "mover_switch")
                if msg == "DOWN":
                    self.send("PREVIOUS", "mover_switch")
 
            while self.dataReady("start"):
                torrent = self.recv("start")

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/OpenGL/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
 
 
            while self.dataReady("torrent_url"):
                url = self.recv("torrent_url")
                filename = os.path.basename(url)
                self.requested_files.append(filename)
                self.send(url, "fetcher")
 
            while self.dataReady("torrent_file"):
                torrentfile = self.recv("torrent_file")
 
            while self.dataReady("nav"):
                msg = self.recv("nav")
                if msg == "UP":
                    self.send("NEXT", "mover_switch")
                if msg == "DOWN":
                    self.send("PREVIOUS", "mover_switch")
 
            while self.dataReady("start"):
                torrent = self.recv("start")

src/k/a/kamaelia-HEAD/Sketches/THF/Packages/Examples/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
 
 
            while self.dataReady("torrent_url"):
                url = self.recv("torrent_url")
                filename = os.path.basename(url)
                self.requested_files.append(filename)
                self.send(url, "fetcher")
 
            while self.dataReady("torrent_file"):
                torrentfile = self.recv("torrent_file")
 
            while self.dataReady("nav"):
                msg = self.recv("nav")
                if msg == "UP":
                    self.send("NEXT", "mover_switch")
                if msg == "DOWN":
                    self.send("PREVIOUS", "mover_switch")
 
            while self.dataReady("start"):
                torrent = self.recv("start")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/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 self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
            while self.dataReady("inbox"):
                self.sdt_table = self.recv("inbox")

src/k/a/Kamaelia-0.6.0/Examples/SoC2006/THF/TorrentOpenGLGUI/TorrentOpenGLGUI.py   Kamaelia(Download)
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
 
 
            while self.dataReady("torrent_url"):
                url = self.recv("torrent_url")
                filename = os.path.basename(url)
                self.requested_files.append(filename)
                self.send(url, "fetcher")
 
            while self.dataReady("torrent_file"):
                torrentfile = self.recv("torrent_file")
 
            while self.dataReady("nav"):
                msg = self.recv("nav")
                if msg == "UP":
                    self.send("NEXT", "mover_switch")
                if msg == "DOWN":
                    self.send("PREVIOUS", "mover_switch")
 
            while self.dataReady("start"):
                torrent = self.recv("start")

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/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 self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
            while self.dataReady("inbox"):
                self.sdt_table = self.recv("inbox")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/RecordNamedChannel.py   kamaelia(Download)
                yield 1
 
            sdt_table = self.recv(fromSDT)
 
            transport_stream_id = sdt_table['transport_stream_id']
                yield 1
 
            sdt_table = self.recv(fromPAT)
            # see if we can find our service's PMT
            ts_services = sdt_table['transport_streams'][transport_stream_id]
                yield 1
 
            pmt_table = self.recv(fromPMT)
            if service_id in pmt_table['services']:
                service = pmt_table['services'][service_id]
        while 1:
            while self.dataReady(fromDemuxer):
                packet = self.recv(fromDemuxer)
                self.send(packet,"outbox")
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/RecordNamedChannel.py   kamaelia(Download)
                yield 1
 
            sdt_table = self.recv(fromSDT)
 
            transport_stream_id = sdt_table['transport_stream_id']
                yield 1
 
            sdt_table = self.recv(fromPAT)
            # see if we can find our service's PMT
            ts_services = sdt_table['transport_streams'][transport_stream_id]
                yield 1
 
            pmt_table = self.recv(fromPMT)
            if service_id in pmt_table['services']:
                service = pmt_table['services'][service_id]
        while 1:
            while self.dataReady(fromDemuxer):
                packet = self.recv(fromDemuxer)
                self.send(packet,"outbox")
 

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/OpenGL/Checkers/Checkers.py   kamaelia(Download)
    def mainBody(self):
        while self.dataReady("inbox"):
            msg = self.recv("inbox")
 
            if msg.get("PLACEMENT", None):
 
        while self.dataReady("control"):
            cmsg = self.recv("control")
            if isinstance(cmsg, Axon.Ipc.shutdownMicroprocess):
                # dirty way to terminate program

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