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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/likefile.py   kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
                except noSpaceInBox, e:
                    raise "Box delivery failed despite box (earlier) reporting being not full. Is more than one thread directly accessing boxes?"

src/k/a/kamaelia-HEAD/Sketches/MH/Timer/Timer.py   kamaelia(Download)
    def shutdown(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            self.send(msg,"signal")
            if isinstance(msg, (producerFinished,shutdownMicroprocess)):
                    try:
                        boxname = self.mappings[handle][0]
                        self.send(when,boxname)
                    except KeyError:
                        # in case the box has been deleted, just sink the event

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/componentWrapperInput.py   kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
                except noSpaceInBox, e:
                    raise "Box delivery failed despite box (earlier) reporting being not full. Is more than one thread directly accessing boxes?"

src/k/a/kamaelia-HEAD/Sketches/MH/exceptions/Axon/experimental/_pprocess_support.py   kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
                except noSpaceInBox, e:
                    raise RuntimeError("Box delivery failed despite box (earlier) reporting being not full. Is more than one thread directly accessing boxes?")

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/experimental/_pprocess_support.py   kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
#                except noSpaceInBox, e:     # python 2.6 & earlier
#                except noSpaceInBox as e:   # python 2.6 and later

src/k/a/Kamaelia-0.6.0/Axon/experimental/_pprocess_support.py   Kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
                except noSpaceInBox, e:
                    raise "Box delivery failed despite box (earlier) reporting being not full. Is more than one thread directly accessing boxes?"

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
#                            try:
                                replyService, outbox, linkage = meta[i][selectable]
                                self.send(selectable, outbox)
#                                print "sent",selectable,"to",outbox
                                replyService, outbox, linkage = None, None, None

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Selector.py   kamaelia(Download)
                            try:
                                replyService, outbox, linkage = meta[i][selectable]
                                self.send(selectable, outbox)
                                replyService, outbox, linkage = None, None, None
                                # Note we remove the selectable until we know the reason for it being here has cleared.

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/Selector.py   Kamaelia(Download)
#                            try:
                                replyService, outbox, linkage = meta[i][selectable]
                                self.send(selectable, outbox)
#                                print "sent",selectable,"to",outbox
                                replyService, outbox, linkage = None, None, None

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Axon/Axon/experimental/_pprocess_support.py   kamaelia(Download)
                # tells the foreground object that we've successfully processed a shutdown message.
                # unfortunately, whether the child honours it or not is a matter of debate.
                self.send(object, self.deathbox)
                return
 
                msg = queue.get_nowait() # won't fail, we're the only one reading from the queue.
                try:
                    self.send(msg, parentSource)
#                except noSpaceInBox, e:     # python 2.6 & earlier
#                except noSpaceInBox as e:   # python 2.6 and later

  1 | 2  Next