aboutsummaryrefslogtreecommitdiff
path: root/src/peerinfo/peerinfo_api_notify.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/peerinfo/peerinfo_api_notify.c')
-rw-r--r--src/peerinfo/peerinfo_api_notify.c21
1 files changed, 10 insertions, 11 deletions
diff --git a/src/peerinfo/peerinfo_api_notify.c b/src/peerinfo/peerinfo_api_notify.c
index 0c7474f4a..4ec7b2192 100644
--- a/src/peerinfo/peerinfo_api_notify.c
+++ b/src/peerinfo/peerinfo_api_notify.c
@@ -104,8 +104,8 @@ reconnect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
104 if (NULL == nc->client) 104 if (NULL == nc->client)
105 { 105 {
106 /* ugh */ 106 /* ugh */
107 nc->task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, 107 nc->task =
108 &reconnect, nc); 108 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &reconnect, nc);
109 return; 109 return;
110 } 110 }
111 request_notifications (nc); 111 request_notifications (nc);
@@ -176,9 +176,8 @@ process_notification (void *cls, const struct GNUNET_MessageHeader *msg)
176static void 176static void
177receive_notifications (struct GNUNET_PEERINFO_NotifyContext *nc) 177receive_notifications (struct GNUNET_PEERINFO_NotifyContext *nc)
178{ 178{
179 GNUNET_CLIENT_receive (nc->client, 179 GNUNET_CLIENT_receive (nc->client, &process_notification, nc,
180 &process_notification, 180 GNUNET_TIME_UNIT_FOREVER_REL);
181 nc, GNUNET_TIME_UNIT_FOREVER_REL);
182} 181}
183 182
184 183
@@ -223,12 +222,12 @@ static void
223request_notifications (struct GNUNET_PEERINFO_NotifyContext *nc) 222request_notifications (struct GNUNET_PEERINFO_NotifyContext *nc)
224{ 223{
225 GNUNET_assert (NULL == nc->init); 224 GNUNET_assert (NULL == nc->init);
226 nc->init = GNUNET_CLIENT_notify_transmit_ready (nc->client, 225 nc->init =
227 sizeof (struct 226 GNUNET_CLIENT_notify_transmit_ready (nc->client,
228 GNUNET_MessageHeader), 227 sizeof (struct GNUNET_MessageHeader),
229 GNUNET_TIME_UNIT_FOREVER_REL, 228 GNUNET_TIME_UNIT_FOREVER_REL,
230 GNUNET_YES, 229 GNUNET_YES, &transmit_notify_request,
231 &transmit_notify_request, nc); 230 nc);
232} 231}
233 232
234 233