}
/* Normal case */
if (request_context->peer_cb != NULL)
- request_context->peer_cb (request_context->cb_cls,
- &connect_message->peer, &connect_message->ats);
- GNUNET_CLIENT_receive (request_context->client,
- &receive_info,
+ request_context->peer_cb (request_context->cb_cls, &connect_message->peer,
+ &connect_message->ats);
+ GNUNET_CLIENT_receive (request_context->client, &receive_info,
request_context, GNUNET_TIME_UNIT_FOREVER_REL);
}
request_context->cb_cls = cb_cls;
request_context->peer = peer;
- request_context->th = GNUNET_CLIENT_notify_transmit_ready (client,
- sizeof (struct
- GNUNET_MessageHeader)
- +
- sizeof (struct
- GNUNET_PeerIdentity),
- GNUNET_TIME_relative_get_forever
- (), GNUNET_YES,
- &transmit_request,
- peer);
+ request_context->th =
+ GNUNET_CLIENT_notify_transmit_ready (client,
+ sizeof (struct GNUNET_MessageHeader)
+ +
+ sizeof (struct GNUNET_PeerIdentity),
+ GNUNET_TIME_relative_get_forever (),
+ GNUNET_YES, &transmit_request, peer);
GNUNET_assert (request_context->th != NULL);
GNUNET_CLIENT_receive (client, &receive_info, request_context,
GNUNET_TIME_relative_get_forever ());
request_context->peer_cb = peer_cb;
request_context->cb_cls = cb_cls;
- request_context->th = GNUNET_CLIENT_notify_transmit_ready (client,
- sizeof (struct
- GNUNET_MessageHeader),
- GNUNET_TIME_relative_get_forever
- (), GNUNET_YES,
- &transmit_request,
- NULL);
+ request_context->th =
+ GNUNET_CLIENT_notify_transmit_ready (client,
+ sizeof (struct GNUNET_MessageHeader),
+ GNUNET_TIME_relative_get_forever (),
+ GNUNET_YES, &transmit_request, NULL);
GNUNET_CLIENT_receive (client, &receive_info, request_context,
GNUNET_TIME_relative_get_forever ());