-class Sender:
- def __init__(self, *args):
- if len(args) != 3:
- raise AssertionError(
- "Actor sender requires 3 parameters, but got {:d}".format(len(args)))
- self.messages_count = int(args[0]) # number of tasks
- self.msg_size = int(args[1]) # communication cost (in bytes)
- self.receivers_count = int(args[2]) # number of receivers
-
- def __call__(self):
- # List in which we store all ongoing communications
- pending_comms = []
+import sys
+from simgrid import Actor, Engine, Host, Mailbox, this_actor