aboutsummaryrefslogtreecommitdiff
path: root/src/conversation/conversation_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/conversation/conversation_api.c')
-rw-r--r--src/conversation/conversation_api.c14
1 files changed, 6 insertions, 8 deletions
diff --git a/src/conversation/conversation_api.c b/src/conversation/conversation_api.c
index 3e0db67ea..730cf1c70 100644
--- a/src/conversation/conversation_api.c
+++ b/src/conversation/conversation_api.c
@@ -557,7 +557,6 @@ reconnect_phone (struct GNUNET_CONVERSATION_Phone *phone)
557 }; 557 };
558 struct GNUNET_MQ_Envelope *e; 558 struct GNUNET_MQ_Envelope *e;
559 struct ClientPhoneRegisterMessage *reg; 559 struct ClientPhoneRegisterMessage *reg;
560 struct GNUNET_CLIENT_Connection *client;
561 560
562 clean_up_callers (phone); 561 clean_up_callers (phone);
563 if (NULL != phone->mq) 562 if (NULL != phone->mq)
@@ -566,14 +565,13 @@ reconnect_phone (struct GNUNET_CONVERSATION_Phone *phone)
566 phone->mq = NULL; 565 phone->mq = NULL;
567 } 566 }
568 phone->state = PS_REGISTER; 567 phone->state = PS_REGISTER;
569 client = GNUNET_CLIENT_connect ("conversation", 568 phone->mq = GNUNET_CLIENT_connecT (phone->cfg,
570 phone->cfg); 569 "conversation",
571 if (NULL == client) 570 handlers,
571 &phone_error_handler,
572 phone);
573 if (NULL == phone->mq)
572 return; 574 return;
573 phone->mq = GNUNET_MQ_queue_for_connection_client (client,
574 handlers,
575 &phone_error_handler,
576 phone);
577 e = GNUNET_MQ_msg (reg, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_REGISTER); 575 e = GNUNET_MQ_msg (reg, GNUNET_MESSAGE_TYPE_CONVERSATION_CS_PHONE_REGISTER);
578 reg->line = phone->my_record.line; 576 reg->line = phone->my_record.line;
579 GNUNET_MQ_send (phone->mq, e); 577 GNUNET_MQ_send (phone->mq, e);