diff options
Diffstat (limited to 'src/service/peerstore/gnunet-service-peerstore.c')
| -rw-r--r-- | src/service/peerstore/gnunet-service-peerstore.c | 23 |
1 files changed, 7 insertions, 16 deletions
diff --git a/src/service/peerstore/gnunet-service-peerstore.c b/src/service/peerstore/gnunet-service-peerstore.c index 77523aa2e..90b4e8d88 100644 --- a/src/service/peerstore/gnunet-service-peerstore.c +++ b/src/service/peerstore/gnunet-service-peerstore.c | |||
| @@ -494,22 +494,13 @@ store_record_continuation (void *cls, int success) | |||
| 494 | struct PeerstoreResultMessage *msg; | 494 | struct PeerstoreResultMessage *msg; |
| 495 | struct GNUNET_MQ_Envelope *env; | 495 | struct GNUNET_MQ_Envelope *env; |
| 496 | 496 | ||
| 497 | if (GNUNET_OK == success) | 497 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Found a watcher to update.\n"); |
| 498 | { | 498 | env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE_RESULT); |
| 499 | 499 | msg->rid = src->rid; | |
| 500 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Found a watcher to update.\n"); | 500 | msg->result = htonl (success); |
| 501 | env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE_RESULT); | 501 | GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (src->client), env); |
| 502 | msg->rid = src->rid; | 502 | watch_notifier (src->record); |
| 503 | msg->result = htonl (success); | 503 | GNUNET_SERVICE_client_continue (src->client); |
| 504 | GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (src->client), env); | ||
| 505 | watch_notifier (src->record); | ||
| 506 | GNUNET_SERVICE_client_continue (src->client); | ||
| 507 | } | ||
| 508 | else | ||
| 509 | { | ||
| 510 | GNUNET_break (0); | ||
| 511 | GNUNET_SERVICE_client_drop (src->record->client); | ||
| 512 | } | ||
| 513 | PEERSTORE_destroy_record (src->record); | 504 | PEERSTORE_destroy_record (src->record); |
| 514 | GNUNET_free (src); | 505 | GNUNET_free (src); |
| 515 | } | 506 | } |