diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-06-29 20:08:15 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-06-29 20:08:15 +0000 |
commit | 2adb94f3b45872a26b81755398372e97fdc1a852 (patch) | |
tree | 64a651e9ea15f2fc36f97ae86ae41fdb4f3808e8 /src | |
parent | 43933dab999a5714dc86ccfd2e8ba6cae60fed1b (diff) | |
download | gnunet-2adb94f3b45872a26b81755398372e97fdc1a852.tar.gz gnunet-2adb94f3b45872a26b81755398372e97fdc1a852.zip |
-disconnects DO happen
Diffstat (limited to 'src')
-rw-r--r-- | src/util/mq.c | 3 | ||||
-rw-r--r-- | src/util/resolver_api.c | 1 |
2 files changed, 1 insertions, 3 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index d4c5b1644..185fe5170 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -162,7 +162,7 @@ struct ServerClientSocketState | |||
162 | /** | 162 | /** |
163 | * Active transmission request to the client. | 163 | * Active transmission request to the client. |
164 | */ | 164 | */ |
165 | struct GNUNET_SERVER_TransmitHandle* th; | 165 | struct GNUNET_SERVER_TransmitHandle *th; |
166 | }; | 166 | }; |
167 | 167 | ||
168 | 168 | ||
@@ -644,7 +644,6 @@ server_client_send_impl (struct GNUNET_MQ_Handle *mq, | |||
644 | struct ServerClientSocketState *state = impl_state; | 644 | struct ServerClientSocketState *state = impl_state; |
645 | 645 | ||
646 | GNUNET_assert (NULL != mq); | 646 | GNUNET_assert (NULL != mq); |
647 | GNUNET_assert (NULL != state); | ||
648 | state->th = GNUNET_SERVER_notify_transmit_ready (state->client, | 647 | state->th = GNUNET_SERVER_notify_transmit_ready (state->client, |
649 | ntohs (msg->size), | 648 | ntohs (msg->size), |
650 | GNUNET_TIME_UNIT_FOREVER_REL, | 649 | GNUNET_TIME_UNIT_FOREVER_REL, |
diff --git a/src/util/resolver_api.c b/src/util/resolver_api.c index 9be7014c2..b41382683 100644 --- a/src/util/resolver_api.c +++ b/src/util/resolver_api.c | |||
@@ -337,7 +337,6 @@ static void | |||
337 | mq_error_handler (void *cls, | 337 | mq_error_handler (void *cls, |
338 | enum GNUNET_MQ_Error error) | 338 | enum GNUNET_MQ_Error error) |
339 | { | 339 | { |
340 | GNUNET_break (0); | ||
341 | GNUNET_MQ_destroy (mq); | 340 | GNUNET_MQ_destroy (mq); |
342 | mq = NULL; | 341 | mq = NULL; |
343 | reconnect (); | 342 | reconnect (); |