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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/RecordNamedChannel.py   kamaelia(Download)
                             ).activate()
 
        fromSDT = self.addInbox("fromSDT")
        fromSDT_linkage = self.link( (sdt_parser,"outbox"),(self,fromSDT) )
 
                             ).activate()
 
        fromPAT = self.addInbox("fromPAT")
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,fromPAT) )
 
                             ).activate()
 
        fromPMT = self.addInbox("fromPMT")
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,fromPMT) )
 
        # now set up to receive those pids and forward them on for all eternity
 
        fromDemuxer = self.addInbox("fromDemuxer")
        self.send( ("ADD",[audio_pid,video_pid], (self,fromDemuxer)), toDemuxer)
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/RecordNamedChannel.py   kamaelia(Download)
                             ).activate()
 
        fromSDT = self.addInbox("fromSDT")
        fromSDT_linkage = self.link( (sdt_parser,"outbox"),(self,fromSDT) )
 
                             ).activate()
 
        fromPAT = self.addInbox("fromPAT")
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,fromPAT) )
 
                             ).activate()
 
        fromPMT = self.addInbox("fromPMT")
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,fromPMT) )
 
        # now set up to receive those pids and forward them on for all eternity
 
        fromDemuxer = self.addInbox("fromDemuxer")
        self.send( ("ADD",[audio_pid,video_pid], (self,fromDemuxer)), toDemuxer)
 

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/RecordNamedChannel.py   Kamaelia(Download)
                             ).activate()
 
        fromSDT = self.addInbox("fromSDT")
        fromSDT_linkage = self.link( (sdt_parser,"outbox"),(self,fromSDT) )
 
                             ).activate()
 
        fromPAT = self.addInbox("fromPAT")
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,fromPAT) )
 
                             ).activate()
 
        fromPMT = self.addInbox("fromPMT")
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,fromPMT) )
 
        # now set up to receive those pids and forward them on for all eternity
 
        fromDemuxer = self.addInbox("fromDemuxer")
        self.send( ("ADD",[audio_pid,video_pid], (self,fromDemuxer)), toDemuxer)
 

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/likefile.py   kamaelia(Download)
        # we cannot rely on shutdown messages being propogated through the child.
        self.isDead = inputHandler.isDead
        self.deathbox = self.addInbox(str(id(self)))
        self.link((inputHandler, inputHandler.deathbox), (self, self.deathbox))
 

src/k/a/kamaelia-HEAD/Sketches/MPS/List/TaggingPluggableProcessor.py   kamaelia(Download)
 
        # Link from component so we can recieve results
        from_component = self.addInbox("_from_component")
        self.link( (filter_component, "outbox"), (self, from_component))
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Device/DVB/Parse/ReassemblePSITables.py   kamaelia(Download)
                    # set up a new PSI packet reconstructor
                    outboxname = self.addOutbox("_toReassembler_"+str(pid))
                    inboxname  = self.addInbox("_fromReassembler_"+str(pid))
                    ctrlboxname = self.addOutbox("_signalReassembler_"+str(pid))
                    PSIcomponent = ReassemblePSITables().activate()

src/k/a/kamaelia-HEAD/Sketches/JMB/protocol_manager.py   kamaelia(Download)
        sig_boxname = self.addOutbox("sig_%s" % (protocol_component.name))
        #print 'added ' + sig_boxname
        in_boxname = self.addInbox("in_%s" % (protocol_component.name))
        #print 'added ' + in_boxname
        ctl_boxname = self.addInbox("ctl_%s" % (protocol_component.name))

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/JsonRPC/BDJsonRPC.py   kamaelia(Download)
        for worker_num in range(len(self.workers)):
            outbox_name = self.addOutbox('to_worker_%s' % worker_num)
            inbox_name = self.addInbox('from_worker_%s' % worker_num)
            signal_name = self.addOutbox('signal_worker_%s' % worker_num)
            boxnames = {'to': outbox_name, 'from': inbox_name, 'signal': signal_name}

src/k/a/kamaelia-HEAD/Sketches/Contrib/jsonrpc/bdjsonrpc.py   kamaelia(Download)
        for worker_num in range(len(self.workers)):
            outbox_name = self.addOutbox('to_worker_%s' % worker_num)
            inbox_name = self.addInbox('from_worker_%s' % worker_num)
            signal_name = self.addOutbox('signal_worker_%s' % worker_num)
            boxnames = {'to': outbox_name, 'from': inbox_name, 'signal': signal_name}

src/k/a/Kamaelia-0.6.0/Kamaelia/Device/DVB/Parse/ReassemblePSITables.py   Kamaelia(Download)
                    # set up a new PSI packet reconstructor
                    outboxname = self.addOutbox("_toReassembler_"+str(pid))
                    inboxname  = self.addInbox("_fromReassembler_"+str(pid))
                    ctrlboxname = self.addOutbox("_signalReassembler_"+str(pid))
                    PSIcomponent = ReassemblePSITables().activate()

  1 | 2 | 3  Next