static void
try_transmission_to_peer (struct NeighbourList *neighbour)
{
- struct GNUNET_TIME_Relative min_latency;
struct ReadyList *rl;
struct MessageQueue *mq;
struct GNUNET_TIME_Relative timeout;
if (neighbour->messages_head == NULL)
return; /* nothing to do */
- min_latency = GNUNET_TIME_UNIT_FOREVER_REL;
rl = NULL;
mq = neighbour->messages_head;
/* FIXME: support bi-directional use of TCP */
struct Plugin *plugin = cls;
char *buf;
struct UDPMessage *msg;
- const struct GNUNET_MessageHeader *hdr;
struct GNUNET_PeerIdentity *sender;
unsigned int buflen;
socklen_t fromlen;
GNUNET_NETWORK_fdset_set (plugin->rs, udp_sock);
return;
}
- hdr = (const struct GNUNET_MessageHeader *) &msg[1];
msgbuf = (char *)&msg[1];
sender = GNUNET_malloc (sizeof (struct GNUNET_PeerIdentity));
memcpy (sender, &msg->sender, sizeof (struct GNUNET_PeerIdentity));