diff options
Diffstat (limited to 'src/rps/rps_api.c')
-rw-r--r-- | src/rps/rps_api.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c index 42cec9761..e06f73b9c 100644 --- a/src/rps/rps_api.c +++ b/src/rps/rps_api.c | |||
@@ -165,7 +165,7 @@ mq_error_handler (void *cls, enum GNUNET_MQ_Error error) | |||
165 | { | 165 | { |
166 | struct GNUNET_RPS_Handle *h = cls; | 166 | struct GNUNET_RPS_Handle *h = cls; |
167 | //TODO LOG | 167 | //TODO LOG |
168 | LOG (GNUNET_ERROR_TYPE_WARNING, "Some problem with the message queue. error: %i\n\ | 168 | LOG (GNUNET_ERROR_TYPE_WARNING, "Problem with message queue. error: %i\n\ |
169 | 1: READ,\n\ | 169 | 1: READ,\n\ |
170 | 2: WRITE,\n\ | 170 | 2: WRITE,\n\ |
171 | 4: TIMEOUT\n", | 171 | 4: TIMEOUT\n", |
@@ -426,7 +426,6 @@ GNUNET_RPS_request_cancel (struct GNUNET_RPS_Request_Handle *rh) | |||
426 | "Cancelling request with id %" PRIu32 "\n", | 426 | "Cancelling request with id %" PRIu32 "\n", |
427 | rh->id); | 427 | rh->id); |
428 | 428 | ||
429 | GNUNET_array_append (req_handlers, req_handlers_size, *rh); | ||
430 | ev = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_RPS_CS_REQUEST_CANCEL); | 429 | ev = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_RPS_CS_REQUEST_CANCEL); |
431 | msg->id = htonl (rh->id); | 430 | msg->id = htonl (rh->id); |
432 | GNUNET_MQ_send (rh->rps_handle->mq, ev); | 431 | GNUNET_MQ_send (rh->rps_handle->mq, ev); |