(self)
| 17 | self.n = args['n'] |
| 18 | |
| 19 | def exec(self): |
| 20 | for i in range(self.n): |
| 21 | msg = {} |
| 22 | msg['message'] = 'send to {}'.format(i) |
| 23 | envelope = Envelope.pack(msg) |
| 24 | envelope.to_addr = i |
| 25 | envelope.tag = "TransGraph{}".format(i % 2) |
| 26 | self.out.send(envelope) |
| 27 | |
| 28 | sleep(5) |
| 29 | |
| 30 | for i in range(self.n): |
| 31 | envelope = Envelope.pack(None) |
| 32 | envelope.to_addr = i |
| 33 | self.out.send(envelope) |