signal(SIGALRM, timeout);
+ memset(port, 0, sizeof(port));
+
for (i=0; i<NUM_PORTS; i++) {
addr[i].addr.s_addr = htonl(0x7f000001+i);
if (forb_inet_port_init(&port[i].desc, addr[i].addr, 0) != 0)
/* Send from zeroth node to all others (starting from 1) */
for (i=1; i<NUM_PORTS; i++) {
- forb_peer_t peer;
+ forb_peer_t *peer;
char buf[100];
char tmsg[100];
- memset(&peer, 0, sizeof(peer));
- peer.addr = port[i].desc.addr;
- peer.port = &port[0];
+ peer = forb_peer_new();
+ peer->addr = port[i].desc.addr;
+ peer->port = &port[0];
len = strlen(msg)+1;
- ret = inet_send(&peer, msg, len);
+ ret = inet_send(peer, msg, len);
+
+ peer->addr = NULL;
+ forb_peer_put(peer);
if (ret != len)
error(1, errno, "send(to %d) = %d", i, ret);