camkes/templates/macros.py

305         for end in connection.from_ends:
306             if end.instance == instance:
308                     name = "%s_%s_%04d" % (instance_name, end.interface.name, x)
310                                                    end.interface.name, options.default_stack_size)
311                     ts.append(Thread(name, end.interface, x, stack_size))
312         for end in connection.to_ends:
313             if end.instance == instance:
315                     name = "%s_%s_%04d" % (instance_name, end.interface.name, x)
317                                                    end.interface.name, options.default_stack_size)
318                     ts.append(Thread(name, end.interface, x, stack_size))
523         groups = set(get_canonical_label(end.instance.name)
524                      for end in conn.from_ends + conn.to_ends)
537 def global_endpoint_badges(composition, end, configuration):
552             raise Exception("Couldn't allocate notification badge for %s" % end)
561     instance = end.instance
578                 if end is to_end:
583                     if end is i:
589                     if end is i:
593     raise Exception("Couldn't allocate notification badge for %s" % end)
599 def global_rpc_endpoint_badges(composition, end, configuration):
603     Return a list of badges, one for each end on the other side of the connection from the
604     supplied end. This means that for a connection with 1 server and 3 clients, if the server
617             raise Exception("Couldn't allocate endpoint badge for %s" % end)
625     instance = end.instance
638                     if end is i:
647                     if end is i:
651     raise Exception("Couldn't allocate notification badge for %s" % end)
657 def virtqueue_get_client_id(composition, end, configuration):
668     instance = end.instance
670     base = configuration[instance.name].get("%s_id" % end.interface.name)
689     return ids[connections.index(end)]