Axon.ThreadedComponent.threadedadaptivecommscomponent.send

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