aboutsummaryrefslogtreecommitdiff
path: root/src/set
diff options
context:
space:
mode:
Diffstat (limited to 'src/set')
-rw-r--r--src/set/set_api.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c
index 0b99c7bf6..af4907dea 100644
--- a/src/set/set_api.c
+++ b/src/set/set_api.c
@@ -903,21 +903,21 @@ listen_connect (void *cls)
903 }; 903 };
904 struct GNUNET_MQ_Envelope *mqm; 904 struct GNUNET_MQ_Envelope *mqm;
905 struct GNUNET_SET_ListenMessage *msg; 905 struct GNUNET_SET_ListenMessage *msg;
906 struct GNUNET_CLIENT_Connection *client;
907 906
908 lh->reconnect_task = NULL; 907 lh->reconnect_task = NULL;
909 GNUNET_assert (NULL == lh->mq); 908 GNUNET_assert (NULL == lh->mq);
910 client = GNUNET_CLIENT_connect ("set", lh->cfg); 909 lh->mq = GNUNET_CLIENT_connecT (lh->cfg,
911 if (NULL == client) 910 "set",
911 mq_handlers,
912 &handle_client_listener_error,
913 lh);
914 if (NULL == lh->mq)
912 return; 915 return;
913 lh->mq = GNUNET_MQ_queue_for_connection_client (client,
914 mq_handlers,
915 &handle_client_listener_error,
916 lh);
917 mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_LISTEN); 916 mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_LISTEN);
918 msg->operation = htonl (lh->operation); 917 msg->operation = htonl (lh->operation);
919 msg->app_id = lh->app_id; 918 msg->app_id = lh->app_id;
920 GNUNET_MQ_send (lh->mq, mqm); 919 GNUNET_MQ_send (lh->mq,
920 mqm);
921} 921}
922 922
923 923