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/MPS/BugReports/FixTests/Kamaelia/Examples/OpenGL/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
            yield 1
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
                    self.send(msg.statsdictionary.get("fractionDone","0"), self.torrent_progress_comms[ self.torrent_from_id[msg.torrentid]] )
 
            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"):
                self.addTorrent(filename, torrentfile)                
 
            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"):

src/k/a/kamaelia-HEAD/Sketches/CL/Topology3D/THF/Examples/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
            yield 1
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
                    self.send(msg.statsdictionary.get("fractionDone","0"), self.torrent_progress_comms[ self.torrent_from_id[msg.torrentid]] )
 
            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"):
                self.addTorrent(filename, torrentfile)                
 
            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"):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/OpenGL/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
            yield 1
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
                    self.send(msg.statsdictionary.get("fractionDone","0"), self.torrent_progress_comms[ self.torrent_from_id[msg.torrentid]] )
 
            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"):
                self.addTorrent(filename, torrentfile)                
 
            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"):

src/k/a/kamaelia-HEAD/Sketches/THF/Packages/Examples/TorrentOpenGLGUI/TorrentOpenGLGUI.py   kamaelia(Download)
            yield 1
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
                    self.send(msg.statsdictionary.get("fractionDone","0"), self.torrent_progress_comms[ self.torrent_from_id[msg.torrentid]] )
 
            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"):
                self.addTorrent(filename, torrentfile)                
 
            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"):

src/k/a/Kamaelia-0.6.0/Examples/SoC2006/THF/TorrentOpenGLGUI/TorrentOpenGLGUI.py   Kamaelia(Download)
            yield 1
 
            while self.dataReady("inbox"):
                msg = self.recv("inbox")
#                print msg
                    self.send(msg.statsdictionary.get("fractionDone","0"), self.torrent_progress_comms[ self.torrent_from_id[msg.torrentid]] )
 
            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"):
                self.addTorrent(filename, torrentfile)                
 
            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"):

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 not self.shutdown():
 
            while self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
            while self.dataReady("inbox"):

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 not self.shutdown():
 
            while self.dataReady("request"):
                self.handleSubscribeUnsubscribe(self.recv("request"))
 
            while self.dataReady("inbox"):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/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/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):
                    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/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")

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