aboutsummaryrefslogtreecommitdiff
path: root/src/peerinfo
diff options
context:
space:
mode:
Diffstat (limited to 'src/peerinfo')
-rw-r--r--src/peerinfo/peerinfo_api.c4
-rw-r--r--src/peerinfo/peerinfo_api_notify.c10
2 files changed, 7 insertions, 7 deletions
diff --git a/src/peerinfo/peerinfo_api.c b/src/peerinfo/peerinfo_api.c
index 593ee8b3c..5eb58af44 100644
--- a/src/peerinfo/peerinfo_api.c
+++ b/src/peerinfo/peerinfo_api.c
@@ -172,7 +172,7 @@ GNUNET_PEERINFO_disconnect (struct GNUNET_PEERINFO_Handle *h)
172 } 172 }
173 if (NULL != h->client) 173 if (NULL != h->client)
174 { 174 {
175 GNUNET_CLIENT_disconnect (h->client, GNUNET_NO); 175 GNUNET_CLIENT_disconnect (h->client);
176 h->client = NULL; 176 h->client = NULL;
177 } 177 }
178 if (GNUNET_SCHEDULER_NO_TASK != h->r_task) 178 if (GNUNET_SCHEDULER_NO_TASK != h->r_task)
@@ -238,7 +238,7 @@ reconnect (struct GNUNET_PEERINFO_Handle *h)
238 } 238 }
239 if (NULL != h->client) 239 if (NULL != h->client)
240 { 240 {
241 GNUNET_CLIENT_disconnect (h->client, GNUNET_SYSERR); 241 GNUNET_CLIENT_disconnect (h->client);
242 h->client = NULL; 242 h->client = NULL;
243 } 243 }
244 h->client = GNUNET_CLIENT_connect ("peerinfo", h->cfg); 244 h->client = GNUNET_CLIENT_connect ("peerinfo", h->cfg);
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);