aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-06-29 20:08:15 +0000
committerChristian Grothoff <christian@grothoff.org>2016-06-29 20:08:15 +0000
commit2adb94f3b45872a26b81755398372e97fdc1a852 (patch)
tree64a651e9ea15f2fc36f97ae86ae41fdb4f3808e8 /src
parent43933dab999a5714dc86ccfd2e8ba6cae60fed1b (diff)
downloadgnunet-2adb94f3b45872a26b81755398372e97fdc1a852.tar.gz
gnunet-2adb94f3b45872a26b81755398372e97fdc1a852.zip
-disconnects DO happen
Diffstat (limited to 'src')
-rw-r--r--src/util/mq.c3
-rw-r--r--src/util/resolver_api.c1
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
337mq_error_handler (void *cls, 337mq_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 ();