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.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/peerinfo/peerinfo_api_notify.c b/src/peerinfo/peerinfo_api_notify.c
index 2557cdfde..b9e83c9e7 100644
--- a/src/peerinfo/peerinfo_api_notify.c
+++ b/src/peerinfo/peerinfo_api_notify.c
@@ -133,7 +133,7 @@ process_notification (void *cls, const struct GNUNET_MessageHeader *msg)
133 133
134 if (msg == NULL) 134 if (msg == NULL)
135 { 135 {
136 GNUNET_CLIENT_disconnect (nc->client, GNUNET_NO); 136 GNUNET_CLIENT_disconnect (nc->client);
137 reconnect (nc, NULL); 137 reconnect (nc, NULL);
138 return; 138 return;
139 } 139 }
@@ -142,7 +142,7 @@ process_notification (void *cls, const struct GNUNET_MessageHeader *msg)
142 (ntohs (msg->type) != GNUNET_MESSAGE_TYPE_PEERINFO_INFO)) 142 (ntohs (msg->type) != GNUNET_MESSAGE_TYPE_PEERINFO_INFO))
143 { 143 {
144 GNUNET_break (0); 144 GNUNET_break (0);
145 GNUNET_CLIENT_disconnect (nc->client, GNUNET_NO); 145 GNUNET_CLIENT_disconnect (nc->client);
146 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg); 146 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg);
147 request_notifications (nc); 147 request_notifications (nc);
148 return; 148 return;
@@ -155,7 +155,7 @@ process_notification (void *cls, const struct GNUNET_MessageHeader *msg)
155 if (ms != sizeof (struct InfoMessage) + GNUNET_HELLO_size (hello)) 155 if (ms != sizeof (struct InfoMessage) + GNUNET_HELLO_size (hello))
156 { 156 {
157 GNUNET_break (0); 157 GNUNET_break (0);
158 GNUNET_CLIENT_disconnect (nc->client, GNUNET_NO); 158 GNUNET_CLIENT_disconnect (nc->client);
159 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg); 159 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg);
160 request_notifications (nc); 160 request_notifications (nc);
161 return; 161 return;
@@ -200,7 +200,7 @@ transmit_notify_request (void *cls, size_t size, void *buf)
200 nc->init = NULL; 200 nc->init = NULL;
201 if (buf == NULL) 201 if (buf == NULL)
202 { 202 {
203 GNUNET_CLIENT_disconnect (nc->client, GNUNET_NO); 203 GNUNET_CLIENT_disconnect (nc->client);
204 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg); 204 nc->client = GNUNET_CLIENT_connect ("peerinfo", nc->cfg);
205 request_notifications (nc); 205 request_notifications (nc);
206 return 0; 206 return 0;
@@ -281,7 +281,7 @@ GNUNET_PEERINFO_notify_cancel (struct GNUNET_PEERINFO_NotifyContext *nc)
281 nc->init = NULL; 281 nc->init = NULL;
282 } 282 }
283 if (NULL != nc->client) 283 if (NULL != nc->client)
284 GNUNET_CLIENT_disconnect (nc->client, GNUNET_NO); 284 GNUNET_CLIENT_disconnect (nc->client);
285 if (GNUNET_SCHEDULER_NO_TASK != nc->task) 285 if (GNUNET_SCHEDULER_NO_TASK != nc->task)
286 GNUNET_SCHEDULER_cancel (nc->task); 286 GNUNET_SCHEDULER_cancel (nc->task);
287 GNUNET_free (nc); 287 GNUNET_free (nc);