241a242
> has_peer = False
244a246,247
> if "network" in var and "physical_network" in var:
> has_peer = True
333a337,338
> if has_peer:
> code('void getQueuesFromPeer(AbstractController *);')
390a396
> has_peer = False
517a524,532
> else:
> if "network" in var and "physical_network" in var and \
> var["network"] == "To":
> has_peer = True
> code('''
> m_${{var.c_ident}}_ptr = new ${{var.type.c_ident}}();
> peerQueueMap[${{var["physical_network"]}}] = m_${{var.c_ident}}_ptr;
> m_${{var.c_ident}}_ptr->setSender(this);
> ''')
518a534,537
> code('''
> if (p->peer != NULL)
> connectWithPeer(p->peer);
> ''')
552,555c571
< # added by SS
< if "factory" in var:
< code('$vid = ${{var["factory"]}};')
< elif var.ident.find("mandatoryQueue") < 0:
---
> if var.ident.find("mandatoryQueue") < 0:
596,597d611
< vnet = var["virtual_network"]
< vnet_type = var["vnet_type"]
599,600c613,618
< assert var.machine is not None
< code('''
---
> if "virtual_network" in var:
> vnet = var["virtual_network"]
> vnet_type = var["vnet_type"]
>
> assert var.machine is not None
> code('''
601a620
> assert($vid != NULL);
604c623,627
< code('assert($vid != NULL);')
---
> # Set the end
> if network == "To":
> code('$vid->setSender(this);')
> else:
> code('$vid->setReceiver(this);')
606,611d628
< # Set the end
< if network == "To":
< code('$vid->setSender(this);')
< else:
< code('$vid->setReceiver(this);')
<
1009a1027,1046
> # Check if this controller has a peer, if yes then write the
> # function for connecting to the peer.
> if has_peer:
> code('''
>
> void
> $c_ident::getQueuesFromPeer(AbstractController *peer)
> {
> ''')
> for var in self.objects:
> if "network" in var and "physical_network" in var and \
> var["network"] == "From":
> code('''
> m_${{var.c_ident}}_ptr = peer->getPeerQueue(${{var["physical_network"]}});
> assert(m_${{var.c_ident}}_ptr != NULL);
> m_${{var.c_ident}}_ptr->setReceiver(this);
>
> ''')
> code('}')
>