if (NULL != h->mq)
return GNUNET_OK;
GNUNET_assert (GNUNET_NO == h->currently_up);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"arm",
handlers,
&mq_error_handler,
struct GNUNET_MQ_Envelope *env;
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"arm",
handlers,
&mq_error_handler,
GNUNET_free (shutdown_ctx);
return;
}
- shutdown_ctx->mq = GNUNET_CLIENT_connecT (cfg,
+ shutdown_ctx->mq = GNUNET_CLIENT_connect (cfg,
SERVICE,
handlers,
&mq_error_handler,
GNUNET_MQ_handler_end ()
};
- me->ch = GNUNET_CORE_connecT (cfg,
+ me->ch = GNUNET_CORE_connect (cfg,
me,
NULL,
&comm_connect_cb,
{
struct BenchmarkPeer *me = cls;
- GNUNET_CORE_disconnecT (me->ch);
+ GNUNET_CORE_disconnect (me->ch);
me->ch = NULL;
}
struct ClientStartMessage *init;
GNUNET_assert (NULL == ch->mq);
- ch->mq = GNUNET_CLIENT_connecT (ch->cfg,
+ ch->mq = GNUNET_CLIENT_connect (ch->cfg,
"ats",
handlers,
&error_handler,
struct ClientStartMessage *init;
GNUNET_assert (NULL == ph->mq);
- ph->mq = GNUNET_CLIENT_connecT (ph->cfg,
+ ph->mq = GNUNET_CLIENT_connect (ph->cfg,
"ats",
handlers,
&mq_error_handler,
struct GNUNET_ATS_AddressRecord *ar;
GNUNET_assert (NULL == sh->mq);
- sh->mq = GNUNET_CLIENT_connecT (sh->cfg,
+ sh->mq = GNUNET_CLIENT_connect (sh->cfg,
"ats",
handlers,
&error_handler,
LOG (GNUNET_ERROR_TYPE_DEBUG, "Connecting to CADET\n");
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"cadet",
handlers,
&handle_mq_error,
NULL),
GNUNET_MQ_handler_end ()
};
- core_handle = GNUNET_CORE_connecT (c, NULL,
+ core_handle = GNUNET_CORE_connect (c, NULL,
&core_init_notify,
&core_connect_handler,
&core_disconnect_handler,
LOG (GNUNET_ERROR_TYPE_ERROR, _("Wrong CORE service\n"));
LOG (GNUNET_ERROR_TYPE_ERROR, " core id %s\n", GNUNET_i2s (core_identity));
LOG (GNUNET_ERROR_TYPE_ERROR, " my id %s\n", GNUNET_i2s (&my_full_id));
- GNUNET_CORE_disconnecT (core_handle);
+ GNUNET_CORE_disconnect (core_handle);
connect_to_core (c);
return;
}
in_shutdown = GNUNET_YES;
if (NULL != core_handle)
{
- GNUNET_CORE_disconnecT (core_handle);
+ GNUNET_CORE_disconnect (core_handle);
core_handle = NULL;
}
GNUNET_PEER_change_rc (myid, -1);
/* With MQ API, CORE calls the disconnect handler for every peer
- * after calling GNUNET_CORE_disconnecT, shutdown must occur *after* that.
+ * after calling GNUNET_CORE_disconnect, shutdown must occur *after* that.
*/
GNUNET_CONTAINER_multipeermap_iterate (peers,
&shutdown_peer,
consensus->new_element_cb = new_element_cb;
consensus->new_element_cls = new_element_cls;
consensus->session_id = *session_id;
- consensus->mq = GNUNET_CLIENT_connecT (cfg,
+ consensus->mq = GNUNET_CLIENT_connect (cfg,
"consensus",
mq_handlers,
&mq_error_handler,
phone->mq = NULL;
}
phone->state = PS_REGISTER;
- phone->mq = GNUNET_CLIENT_connecT (phone->cfg,
+ phone->mq = GNUNET_CLIENT_connect (phone->cfg,
"conversation",
handlers,
&phone_error_handler,
};
struct GNUNET_CRYPTO_EcdsaPublicKey my_zone;
- call->mq = GNUNET_CLIENT_connecT (cfg,
+ call->mq = GNUNET_CLIENT_connect (cfg,
"conversation",
handlers,
&call_error_handler,
/**
* Function to call whenever we're notified about a peer connecting.
*/
- GNUNET_CORE_ConnecTEventHandler connects;
+ GNUNET_CORE_ConnectEventHandler connects;
/**
* Function to call whenever we're notified about a peer disconnecting.
*/
- GNUNET_CORE_DisconnecTEventHandler disconnects;
+ GNUNET_CORE_DisconnectEventHandler disconnects;
/**
* Function handlers for messages of particular type.
uint16_t *ts;
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"core",
handlers,
&handle_mq_error,
* NULL on error (in this case, init is never called)
*/
struct GNUNET_CORE_Handle *
-GNUNET_CORE_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg,
+GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
void *cls,
GNUNET_CORE_StartupCallback init,
- GNUNET_CORE_ConnecTEventHandler connects,
- GNUNET_CORE_DisconnecTEventHandler disconnects,
+ GNUNET_CORE_ConnectEventHandler connects,
+ GNUNET_CORE_DisconnectEventHandler disconnects,
const struct GNUNET_MQ_MessageHandler *handlers)
{
struct GNUNET_CORE_Handle *h;
reconnect (h);
if (NULL == h->mq)
{
- GNUNET_CORE_disconnecT (h);
+ GNUNET_CORE_disconnect (h);
return NULL;
}
return h;
* @param handle connection to core to disconnect
*/
void
-GNUNET_CORE_disconnecT (struct GNUNET_CORE_Handle *handle)
+GNUNET_CORE_disconnect (struct GNUNET_CORE_Handle *handle)
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Disconnecting from CORE service\n");
if (NULL != mh->mq)
GNUNET_MQ_destroy (mh->mq);
/* FIXME: use backoff? */
- mh->mq = GNUNET_CLIENT_connecT (mh->cfg,
+ mh->mq = GNUNET_CLIENT_connect (mh->cfg,
"core",
handlers,
&handle_mq_error,
{
if (NULL != p->ch)
{
- GNUNET_CORE_disconnecT (p->ch);
+ GNUNET_CORE_disconnect (p->ch);
p->ch = NULL;
}
if (NULL != p->ghh)
GNUNET_assert (ok == 2);
OKPP;
/* connect p2 */
- p2.ch = GNUNET_CORE_connecT (p2.cfg,
+ p2.ch = GNUNET_CORE_connect (p2.cfg,
&p2,
&init_notify,
&connect_notify,
(GNUNET_TIME_UNIT_SECONDS, 300),
&terminate_task_error, NULL);
p1.ch =
- GNUNET_CORE_connecT (p1.cfg,
+ GNUNET_CORE_connect (p1.cfg,
&p1,
&init_notify,
&connect_notify,
{
if (NULL != p->ch)
{
- GNUNET_CORE_disconnecT (p->ch);
+ GNUNET_CORE_disconnect (p->ch);
p->ch = NULL;
}
if (NULL != p->ghh)
OKPP;
/* connect p2 */
GNUNET_assert (NULL !=
- (p2.ch = GNUNET_CORE_connecT (p2.cfg,
+ (p2.ch = GNUNET_CORE_connect (p2.cfg,
&p2,
&init_notify,
&connect_notify,
NULL);
GNUNET_assert (NULL !=
- (p1.ch = GNUNET_CORE_connecT (p1.cfg,
+ (p1.ch = GNUNET_CORE_connect (p1.cfg,
&p1,
&init_notify,
&connect_notify,
}
if (NULL != core)
{
- GNUNET_CORE_disconnecT (core);
+ GNUNET_CORE_disconnect (core);
core = NULL;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
};
core =
- GNUNET_CORE_connecT (cfg,
+ GNUNET_CORE_connect (cfg,
NULL,
&init,
&connect_cb,
static void
shutdown_task (void *cls)
{
- GNUNET_CORE_disconnecT (p1.ch);
+ GNUNET_CORE_disconnect (p1.ch);
p1.ch = NULL;
- GNUNET_CORE_disconnecT (p2.ch);
+ GNUNET_CORE_disconnect (p2.ch);
p2.ch = NULL;
ok = 0;
}
if (p == &p1)
{
/* connect p2 */
- p2.ch = GNUNET_CORE_connecT (p2.cfg,
+ p2.ch = GNUNET_CORE_connect (p2.cfg,
&p2,
&init_notify,
&connect_notify,
"Timeout.\n");
if (NULL != p1.ch)
{
- GNUNET_CORE_disconnecT (p1.ch);
+ GNUNET_CORE_disconnect (p1.ch);
p1.ch = NULL;
}
if (NULL != p2.ch)
{
- GNUNET_CORE_disconnecT (p2.ch);
+ GNUNET_CORE_disconnect (p2.ch);
p2.ch = NULL;
}
ok = 42;
TIMEOUT),
&timeout_task,
NULL);
- p1.ch = GNUNET_CORE_connecT (p1.cfg,
+ p1.ch = GNUNET_CORE_connect (p1.cfg,
&p1,
&init_notify,
&connect_notify,
{
if (NULL != p->ch)
{
- GNUNET_CORE_disconnecT (p->ch);
+ GNUNET_CORE_disconnect (p->ch);
p->ch = NULL;
}
if (NULL != p->ghh)
GNUNET_assert (ok == 2);
OKPP;
/* connect p2 */
- p2.ch = GNUNET_CORE_connecT (p2.cfg,
+ p2.ch = GNUNET_CORE_connect (p2.cfg,
&p2,
&init_notify,
&connect_notify,
"WAN_QUOTA_OUT",
¤t_quota_p2_out));
- p1.ch = GNUNET_CORE_connecT (p1.cfg,
+ p1.ch = GNUNET_CORE_connect (p1.cfg,
&p1,
&init_notify,
&connect_notify,
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Re-connecting to issue DROP!\n");
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"datastore",
NULL,
&disconnect_on_mq_error,
h->retry_time = GNUNET_TIME_STD_BACKOFF (h->retry_time);
h->reconnect_task = NULL;
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"datastore",
handlers,
&mq_error_handler,
};
if (NULL != h->mq)
return GNUNET_OK;
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"dht",
handlers,
&mq_error_handler,
log_route_details_stderr =
(NULL != getenv("GNUNET_DHT_ROUTE_DEBUG")) ? GNUNET_YES : GNUNET_NO;
ats_ch = GNUNET_ATS_connectivity_init (GDS_cfg);
- core_api = GNUNET_CORE_connecT (GDS_cfg,
+ core_api = GNUNET_CORE_connect (GDS_cfg,
NULL,
&core_init,
&handle_core_connect,
{
if (NULL == core_api)
return;
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
GNUNET_assert (0 ==
GNUNET_CONTAINER_multipeermap_size (all_connected_peers));
GNUNET_MQ_handler_end ()
};
- core_api = GNUNET_CORE_connecT (GDS_cfg, NULL,
+ core_api = GNUNET_CORE_connect (GDS_cfg, NULL,
&core_init,
&handle_core_connect,
&handle_core_disconnect,
{
if (NULL == core_api)
return;
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
GNUNET_assert (0 == GNUNET_CONTAINER_multipeermap_size (friends_peermap));
GNUNET_CONTAINER_multipeermap_destroy (friends_peermap);
GNUNET_MQ_handler_end ()
};
- core_api = GNUNET_CORE_connecT (GDS_cfg,
+ core_api = GNUNET_CORE_connect (GDS_cfg,
NULL,
&core_init,
&handle_core_connect,
if (NULL == core_api)
return;
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
delete_finger_table_entries();
struct GNUNET_DNS_Register *msg;
dh->reconnect_task = NULL;
- dh->mq = GNUNET_CLIENT_connecT (dh->cfg,
+ dh->mq = GNUNET_CLIENT_connect (dh->cfg,
"dns",
handlers,
&mq_error_handler,
sh);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to DV service\n");
- sh->mq = GNUNET_CLIENT_connecT (sh->cfg,
+ sh->mq = GNUNET_CLIENT_connect (sh->cfg,
"dv",
handlers,
&mq_error_handler,
in_shutdown = GNUNET_YES;
GNUNET_assert (NULL != core_api);
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
GNUNET_ATS_performance_done (ats);
ats = NULL;
GNUNET_NO);
all_routes = GNUNET_CONTAINER_multipeermap_create (65536,
GNUNET_NO);
- core_api = GNUNET_CORE_connecT (cfg,
+ core_api = GNUNET_CORE_connect (cfg,
NULL,
&core_init,
&handle_core_connect,
NULL);
if (NULL == ats)
{
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
return;
}
};
dc->task = NULL;
- dc->mq = GNUNET_CLIENT_connecT (dc->h->cfg,
+ dc->mq = GNUNET_CLIENT_connect (dc->h->cfg,
"fs",
handlers,
&download_mq_error_handler,
struct GNUNET_MQ_Envelope *env;
struct GNUNET_MessageHeader *msg;
- gic->mq = GNUNET_CLIENT_connecT (h->cfg,
+ gic->mq = GNUNET_CLIENT_connect (h->cfg,
"fs",
handlers,
&mq_error_handler,
GNUNET_free (fn);
return;
}
- pc->mq = GNUNET_CLIENT_connecT (pc->h->cfg,
+ pc->mq = GNUNET_CLIENT_connect (pc->h->cfg,
"fs",
handlers,
&index_mq_error_handler,
if (NULL != pc->mq)
GNUNET_MQ_destroy (pc->mq);
- pc->mq = GNUNET_CLIENT_connecT (pc->h->cfg,
+ pc->mq = GNUNET_CLIENT_connect (pc->h->cfg,
"fs",
handlers,
&loc_mq_error_handler,
};
sc->task = NULL;
- sc->mq = GNUNET_CLIENT_connecT (sc->h->cfg,
+ sc->mq = GNUNET_CLIENT_connect (sc->h->cfg,
"fs",
handlers,
&search_mq_error_handler,
uc->seen_dh = NULL;
uc->state = UNINDEX_STATE_FS_NOTIFY;
GNUNET_FS_unindex_sync_ (uc);
- uc->mq = GNUNET_CLIENT_connecT (uc->h->cfg,
+ uc->mq = GNUNET_CLIENT_connect (uc->h->cfg,
"fs",
handlers,
&unindex_mq_error_handler,
GSF_cadet_stop_server ();
if (NULL != GSF_core)
{
- GNUNET_CORE_disconnecT (GSF_core);
+ GNUNET_CORE_disconnect (GSF_core);
GSF_core = NULL;
}
if (NULL != GSF_ats)
/**
- * Function called after GNUNET_CORE_connecT has succeeded
+ * Function called after GNUNET_CORE_connect has succeeded
* (or failed for good). Note that the private key of the
* peer is intentionally not exposed here; if you need it,
* your process should try to read the private key file
"I am peer %s\n",
GNUNET_i2s (&GSF_my_id));
GSF_core
- = GNUNET_CORE_connecT (GSF_cfg,
+ = GNUNET_CORE_connect (GSF_cfg,
NULL,
&peer_init_handler,
&GSF_peer_connect_handler,
GNUNET_assert (NULL == handle->mq);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Trying to connect to GNS\n");
- handle->mq = GNUNET_CLIENT_connecT (handle->cfg,
+ handle->mq = GNUNET_CLIENT_connect (handle->cfg,
"gns",
handlers,
&mq_error_handler,
/**
* Handle to hostlist server's connect handler
*/
-static GNUNET_CORE_ConnecTEventHandler server_ch;
+static GNUNET_CORE_ConnectEventHandler server_ch;
#endif
/**
* Handle to hostlist client's connect handler
*/
-static GNUNET_CORE_ConnecTEventHandler client_ch;
+static GNUNET_CORE_ConnectEventHandler client_ch;
/**
* Handle to hostlist client's disconnect handler
*/
-static GNUNET_CORE_DisconnecTEventHandler client_dh;
+static GNUNET_CORE_DisconnectEventHandler client_dh;
GNUNET_NETWORK_STRUCT_BEGIN
"Hostlist daemon is shutting down\n");
if (NULL != core)
{
- GNUNET_CORE_disconnecT (core);
+ GNUNET_CORE_disconnect (core);
core = NULL;
}
if (bootstrapping)
&client_adv_handler,
learning);
core =
- GNUNET_CORE_connecT (cfg,
+ GNUNET_CORE_connect (cfg,
NULL,
&core_init,
&connect_handler,
int
GNUNET_HOSTLIST_client_start (const struct GNUNET_CONFIGURATION_Handle *c,
struct GNUNET_STATISTICS_Handle *st,
- GNUNET_CORE_ConnecTEventHandler *ch,
- GNUNET_CORE_DisconnecTEventHandler *dh,
+ GNUNET_CORE_ConnectEventHandler *ch,
+ GNUNET_CORE_DisconnectEventHandler *dh,
GNUNET_HOSTLIST_UriHandler *msgh,
int learn)
{
int
GNUNET_HOSTLIST_client_start (const struct GNUNET_CONFIGURATION_Handle *c,
struct GNUNET_STATISTICS_Handle *st,
- GNUNET_CORE_ConnecTEventHandler *ch,
- GNUNET_CORE_DisconnecTEventHandler *dh,
+ GNUNET_CORE_ConnectEventHandler *ch,
+ GNUNET_CORE_DisconnectEventHandler *dh,
GNUNET_HOSTLIST_UriHandler *msgh,
int learn);
GNUNET_HOSTLIST_server_start (const struct GNUNET_CONFIGURATION_Handle *c,
struct GNUNET_STATISTICS_Handle *st,
struct GNUNET_CORE_Handle *co,
- GNUNET_CORE_ConnecTEventHandler *server_ch,
+ GNUNET_CORE_ConnectEventHandler *server_ch,
int advertise)
{
unsigned long long port;
GNUNET_HOSTLIST_server_start (const struct GNUNET_CONFIGURATION_Handle *c,
struct GNUNET_STATISTICS_Handle *st,
struct GNUNET_CORE_Handle *core,
- GNUNET_CORE_ConnecTEventHandler *server_ch,
+ GNUNET_CORE_ConnectEventHandler *server_ch,
int advertise);
}
if (NULL != adv_peer.core)
{
- GNUNET_CORE_disconnecT (adv_peer.core);
+ GNUNET_CORE_disconnect (adv_peer.core);
adv_peer.core = NULL;
}
if (NULL != learn_peer.core)
{
- GNUNET_CORE_disconnecT (learn_peer.core);
+ GNUNET_CORE_disconnect (learn_peer.core);
learn_peer.core = NULL;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
}
GNUNET_free (filename);
}
- p->core = GNUNET_CORE_connecT (p->cfg,
+ p->core = GNUNET_CORE_connect (p->cfg,
NULL,
NULL,
NULL,
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to identity provider service.\n");
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"identity-provider",
handlers,
&mq_error_handler,
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to identity service.\n");
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"identity",
handlers,
&mq_error_handler,
* @return the message queue, NULL on error
*/
struct GNUNET_MQ_Handle *
-GNUNET_CLIENT_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg,
+GNUNET_CLIENT_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
const char *service_name,
const struct GNUNET_MQ_MessageHandler *handlers,
GNUNET_MQ_ErrorHandler error_handler,
* @param peer peer identity this notification is about
*/
typedef void *
-(*GNUNET_CORE_ConnecTEventHandler) (void *cls,
+(*GNUNET_CORE_ConnectEventHandler) (void *cls,
const struct GNUNET_PeerIdentity *peer,
struct GNUNET_MQ_Handle *mq);
* @param peer peer identity this notification is about
*/
typedef void
-(*GNUNET_CORE_DisconnecTEventHandler) (void *cls,
+(*GNUNET_CORE_DisconnectEventHandler) (void *cls,
const struct GNUNET_PeerIdentity *peer,
void *peer_cls);
* NULL on error (in this case, init is never called)
*/
struct GNUNET_CORE_Handle *
-GNUNET_CORE_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg,
+GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
void *cls,
GNUNET_CORE_StartupCallback init,
- GNUNET_CORE_ConnecTEventHandler connects,
- GNUNET_CORE_DisconnecTEventHandler disconnects,
+ GNUNET_CORE_ConnectEventHandler connects,
+ GNUNET_CORE_DisconnectEventHandler disconnects,
const struct GNUNET_MQ_MessageHandler *handlers);
* @param handle connection to core to disconnect
*/
void
-GNUNET_CORE_disconnecT (struct GNUNET_CORE_Handle *handle);
+GNUNET_CORE_disconnect (struct GNUNET_CORE_Handle *handle);
/**
GNUNET_MQ_handler_end ()
};
- grp->mq = GNUNET_CLIENT_connecT (grp->cfg, "multicast",
+ grp->mq = GNUNET_CLIENT_connect (grp->cfg, "multicast",
handlers, origin_disconnected, orig);
GNUNET_assert (NULL != grp->mq);
GNUNET_MQ_send_copy (grp->mq, grp->connect_env);
GNUNET_MQ_handler_end ()
};
- grp->mq = GNUNET_CLIENT_connecT (grp->cfg, "multicast",
+ grp->mq = GNUNET_CLIENT_connect (grp->cfg, "multicast",
handlers, member_disconnected, mem);
GNUNET_assert (NULL != grp->mq);
GNUNET_MQ_send_copy (grp->mq, grp->connect_env);
GNUNET_MQ_handler_end ()
};
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"namecache",
handlers,
&mq_error_handler,
struct GNUNET_NAMESTORE_QueueEntry *qe;
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"namestore",
handlers,
&mq_error_handler,
GNUNET_MQ_destroy (zm->mq);
zm->error_cb (zm->error_cb_cls);
}
- zm->mq = GNUNET_CLIENT_connecT (zm->cfg,
+ zm->mq = GNUNET_CLIENT_connect (zm->cfg,
"namestore",
handlers,
&mq_error_handler,
ca = GNUNET_new (struct ClientActivity);
ca->h = h;
- ca->mq = GNUNET_CLIENT_connecT (h->cfg,
+ ca->mq = GNUNET_CLIENT_connect (h->cfg,
"gnunet-nat-server",
NULL,
&mq_error_handler,
LOG (GNUNET_ERROR_TYPE_INFO,
"Asking gnunet-nat-server to connect to `%s'\n",
ah->stun_ip);
- ah->mq = GNUNET_CLIENT_connecT (ah->cfg,
+ ah->mq = GNUNET_CLIENT_connect (ah->cfg,
"gnunet-nat-server",
NULL,
&mq_error_handler,
}
ah->arc = cb;
ah->arc_cls = cb_cls;
- ah->mq = GNUNET_CLIENT_connecT (cfg,
+ ah->mq = GNUNET_CLIENT_connect (cfg,
"nat",
handlers,
&ah_error_handler,
ca = GNUNET_new (struct ClientActivity);
ca->h = h;
- ca->mq = GNUNET_CLIENT_connecT (h->cfg,
+ ca->mq = GNUNET_CLIENT_connect (h->cfg,
"gnunet-nat-server",
NULL,
&mq_error_handler,
struct GNUNET_MQ_Envelope *env;
nh->reconnect_task = NULL;
- nh->mq = GNUNET_CLIENT_connecT (nh->cfg,
+ nh->mq = GNUNET_CLIENT_connect (nh->cfg,
"nat",
handlers,
&mq_error_handler,
}
if (NULL != core_api)
{
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
}
if (NULL != stats)
GNUNET_YES);
nc = GNUNET_notification_context_create (1);
/* Connect to core service and register core handlers */
- core_api = GNUNET_CORE_connecT (cfg, /* Main configuration */
+ core_api = GNUNET_CORE_connect (cfg, /* Main configuration */
NULL, /* Closure passed to functions */
&core_init, /* Call core_init once connected */
&handle_core_connect, /* Handle connects */
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to network size estimation service.\n");
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"nse",
handlers,
&mq_error_handler,
GNUNET_MQ_destroy (h->mq);
h->mq = NULL;
}
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"peerinfo",
handlers,
&mq_error_handler,
struct NotifyMessage *nm;
nc->task = NULL;
- nc->mq = GNUNET_CLIENT_connecT (nc->cfg,
+ nc->mq = GNUNET_CLIENT_connect (nc->cfg,
"peerinfo",
handlers,
&mq_error_handler,
GNUNET_MQ_destroy (h->mq);
h->mq = NULL;
}
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"peerstore",
mq_handlers,
&handle_client_error,
GNUNET_MQ_handler_end ()
};
- chn->mq = GNUNET_CLIENT_connecT (chn->cfg, "psyc",
+ chn->mq = GNUNET_CLIENT_connect (chn->cfg, "psyc",
handlers, master_disconnected, mst);
GNUNET_assert (NULL != chn->mq);
chn->tmit = GNUNET_PSYC_transmit_create (chn->mq);
GNUNET_MQ_handler_end ()
};
- chn->mq = GNUNET_CLIENT_connecT (chn->cfg, "psyc",
+ chn->mq = GNUNET_CLIENT_connect (chn->cfg, "psyc",
handlers, slave_disconnected, slv);
GNUNET_assert (NULL != chn->mq);
chn->tmit = GNUNET_PSYC_transmit_create (chn->mq);
h->op = GNUNET_OP_create ();
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg, "psycstore",
+ h->mq = GNUNET_CLIENT_connect (h->cfg, "psycstore",
handlers, disconnected, h);
GNUNET_assert (NULL != h->mq);
}
struct AnnounceMessage *am;
size_t slen;
- a->mq = GNUNET_CLIENT_connecT (a->cfg,
+ a->mq = GNUNET_CLIENT_connect (a->cfg,
"regex",
NULL,
&announce_mq_error_handler,
struct RegexSearchMessage *rsm;
GNUNET_assert (NULL == s->mq);
- s->mq = GNUNET_CLIENT_connecT (s->cfg,
+ s->mq = GNUNET_CLIENT_connect (s->cfg,
"regex",
handlers,
&mq_error_handler,
}
if (NULL != core_api)
{
- GNUNET_CORE_disconnecT (core_api);
+ GNUNET_CORE_disconnect (core_api);
core_api = NULL;
}
if (NULL != stats)
peers = GNUNET_CONTAINER_multipeermap_create (128,
GNUNET_YES);
/* Connect to core service and register core handlers */
- core_api = GNUNET_CORE_connecT (cfg, /* Main configuration */
+ core_api = GNUNET_CORE_connect (cfg, /* Main configuration */
NULL, /* Closure passed to functions */
&core_init, /* Call core_init once connected */
&handle_core_connect, /* Handle connects */
struct QueryMessage *qm;
struct GNUNET_MQ_Envelope *env;
- q->mq = GNUNET_CLIENT_connecT (cfg,
+ q->mq = GNUNET_CLIENT_connect (cfg,
"revocation",
handlers,
&query_mq_error_handler,
return NULL;
}
- h->mq = GNUNET_CLIENT_connecT (cfg,
+ h->mq = GNUNET_CLIENT_connect (cfg,
"revocation",
handlers,
&revocation_mq_error_handler,
struct TestPeer *me = cls;
me->cfg = cfg;
- me->ch = GNUNET_CORE_connecT (cfg,
+ me->ch = GNUNET_CORE_connect (cfg,
me,
NULL,
&connect_cb,
{
struct TestPeer *me = cls;
- GNUNET_CORE_disconnecT (me->ch);
+ GNUNET_CORE_disconnect (me->ch);
me->ch = NULL;
}
if (NULL != h->mq)
GNUNET_MQ_destroy (h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"rps",
mq_handlers,
&mq_error_handler,
h->response_proc = &process_status_message;
h->cfg = cfg;
h->key = *session_key;
- h->mq = GNUNET_CLIENT_connecT (cfg,
+ h->mq = GNUNET_CLIENT_connect (cfg,
"scalarproduct-bob",
handlers,
&mq_error_handler,
if (GNUNET_SYSERR == check_unique (elements,
element_count))
return NULL;
- h->mq = GNUNET_CLIENT_connecT (cfg,
+ h->mq = GNUNET_CLIENT_connect (cfg,
"scalarproduct-alice",
handlers,
&mq_error_handler,
struct GNUNET_MQ_Envelope *ev;
struct GNUNET_SECRETSHARING_CreateMessage *msg;
- s->mq = GNUNET_CLIENT_connecT (cfg,
+ s->mq = GNUNET_CLIENT_connect (cfg,
"secretsharing",
mq_handlers,
&handle_session_client_error,
s->decrypt_cb = decrypt_cb;
s->decrypt_cls = decrypt_cb_cls;
- s->mq = GNUNET_CLIENT_connecT (cfg,
+ s->mq = GNUNET_CLIENT_connect (cfg,
"secretsharing",
mq_handlers,
&handle_decrypt_client_error,
struct GNUNET_SET_CopyLazyConnectMessage *copy_msg;
set->cfg = cfg;
- set->mq = GNUNET_CLIENT_connecT (cfg,
+ set->mq = GNUNET_CLIENT_connect (cfg,
"set",
mq_handlers,
&handle_client_set_error,
lh->reconnect_task = NULL;
GNUNET_assert (NULL == lh->mq);
- lh->mq = GNUNET_CLIENT_connecT (lh->cfg,
+ lh->mq = GNUNET_CLIENT_connect (lh->cfg,
"set",
mq_handlers,
&handle_client_listener_error,
GNUNET_MQ_handler_end ()
};
- plc->mq = GNUNET_CLIENT_connecT (plc->cfg, "social",
+ plc->mq = GNUNET_CLIENT_connect (plc->cfg, "social",
handlers, host_disconnected, hst);
GNUNET_assert (NULL != plc->mq);
plc->tmit = GNUNET_PSYC_transmit_create (plc->mq);
GNUNET_MQ_handler_end ()
};
- plc->mq = GNUNET_CLIENT_connecT (plc->cfg, "social",
+ plc->mq = GNUNET_CLIENT_connect (plc->cfg, "social",
handlers, guest_disconnected, gst);
GNUNET_assert (NULL != plc->mq);
plc->tmit = GNUNET_PSYC_transmit_create (plc->mq);
GNUNET_MQ_handler_end ()
};
- app->mq = GNUNET_CLIENT_connecT (app->cfg, "social",
+ app->mq = GNUNET_CLIENT_connect (app->cfg, "social",
handlers, app_disconnected, app);
GNUNET_assert (NULL != app->mq);
GNUNET_MQ_send_copy (app->mq, app->connect_env);
return GNUNET_NO;
if (NULL != h->mq)
return GNUNET_YES;
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"statistics",
handlers,
&mq_error_handler,
struct GNUNET_TESTBED_LOGGER_Handle *h;
h = GNUNET_new (struct GNUNET_TESTBED_LOGGER_Handle);
- h->mq = GNUNET_CLIENT_connecT (cfg,
+ h->mq = GNUNET_CLIENT_connect (cfg,
"testbed-logger",
NULL,
&mq_error_handler,
/**
- * Function called after #GNUNET_CORE_connecT() has succeeded (or failed
+ * Function called after #GNUNET_CORE_connect() has succeeded (or failed
* for good). Note that the private key of the peer is intentionally
* not exposed here; if you need it, your process should try to read
* the private key file directly (which should work if you are
* authorized...). Implementations of this function must not call
- * #GNUNET_CORE_disconnecT() (other than by scheduling a new task to
+ * #GNUNET_CORE_disconnect() (other than by scheduling a new task to
* do this later).
*
* @param cls the #PooledConnection object
LOG_DEBUG ("Opening a CORE connection to peer %u\n",
entry->index);
entry->handle_core
- = GNUNET_CORE_connecT (entry->cfg,
+ = GNUNET_CORE_connect (entry->cfg,
entry, /* closure */
&core_startup_cb, /* core startup notify */
&core_peer_connect_cb, /* peer connect notify */
if (NULL == entry->handle_core)
return;
- GNUNET_CORE_disconnecT (entry->handle_core);
+ GNUNET_CORE_disconnect (entry->handle_core);
entry->handle_core = NULL;
GNUNET_free_non_null (entry->peer_identity);
entry->peer_identity = NULL;
controller->cc_cls = cc_cls;
controller->event_mask = event_mask;
controller->cfg = GNUNET_CONFIGURATION_dup (cfg);
- controller->mq = GNUNET_CLIENT_connecT (controller->cfg,
+ controller->mq = GNUNET_CLIENT_connect (controller->cfg,
"testbed",
handlers,
&mq_error_handler,
h->name = GNUNET_strdup (name);
h->cb = cb;
h->cb_cls = cb_cls;
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"testbed-barrier",
handlers,
&mq_error_handler,
/**
- * Function called after #GNUNET_CORE_connecT has succeeded
+ * Function called after #GNUNET_CORE_connect has succeeded
* (or failed for good).
*
* @param cls closure
}
if (NULL != handle)
{
- GNUNET_CORE_disconnecT (handle);
+ GNUNET_CORE_disconnect (handle);
handle = NULL;
}
whitelist_peers ();
&blacklist_check,
NULL);
ats = GNUNET_ATS_connectivity_init (cfg);
- handle = GNUNET_CORE_connecT (cfg,
+ handle = GNUNET_CORE_connect (cfg,
NULL,
&core_init,
&connect_notify,
}
alc->cb = aluc;
alc->cb_cls = aluc_cls;
- alc->mq = GNUNET_CLIENT_connecT (cfg,
+ alc->mq = GNUNET_CLIENT_connect (cfg,
"transport",
handlers,
&mq_error_handler,
if (NULL != br->mq)
GNUNET_MQ_destroy (br->mq);
- br->mq = GNUNET_CLIENT_connecT (br->cfg,
+ br->mq = GNUNET_CLIENT_connect (br->cfg,
"transport",
handlers,
&mq_error_handler,
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to transport service.\n");
GNUNET_assert (NULL == h->mq);
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"transport",
handlers,
&mq_error_handler,
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Connecting to transport service.\n");
GNUNET_assert (NULL == ghh->mq);
- ghh->mq = GNUNET_CLIENT_connecT (ghh->cfg,
+ ghh->mq = GNUNET_CLIENT_connect (ghh->cfg,
"transport",
handlers,
&mq_error_handler,
"Connecting to transport service.\n");
GNUNET_assert (NULL == h->mq);
h->reconnecting = GNUNET_NO;
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"transport",
handlers,
&mq_error_handler,
struct GNUNET_MQ_Envelope *env;
pal_ctx->reconnect_task = NULL;
- pal_ctx->mq = GNUNET_CLIENT_connecT (pal_ctx->cfg,
+ pal_ctx->mq = GNUNET_CLIENT_connect (pal_ctx->cfg,
"transport",
handlers,
&mq_error_handler,
struct GNUNET_MQ_Envelope *env;
pm->reconnect_task = NULL;
- pm->mq = GNUNET_CLIENT_connecT (pm->cfg,
+ pm->mq = GNUNET_CLIENT_connect (pm->cfg,
"transport",
handlers,
&mq_error_handler,
GNUNET_free (ohh);
return NULL;
}
- ohh->mq = GNUNET_CLIENT_connecT (cfg,
+ ohh->mq = GNUNET_CLIENT_connect (cfg,
"transport",
NULL,
NULL,
* @return the message queue, NULL on error
*/
struct GNUNET_MQ_Handle *
-GNUNET_CLIENT_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg,
+GNUNET_CLIENT_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
const char *service_name,
const struct GNUNET_MQ_MessageHandler *handlers,
GNUNET_MQ_ErrorHandler error_handler,
return; /* no work pending */
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Trying to connect to DNS service\n");
- mq = GNUNET_CLIENT_connecT (resolver_cfg,
+ mq = GNUNET_CLIENT_connect (resolver_cfg,
"resolver",
handlers,
&mq_error_handler,
/* test that ill-configured client fails instantly */
GNUNET_assert (NULL ==
- GNUNET_CLIENT_connecT (cfg,
+ GNUNET_CLIENT_connect (cfg,
"invalid-service",
NULL,
&mq_error_handler,
NULL));
- client_mq = GNUNET_CLIENT_connecT (cfg,
+ client_mq = GNUNET_CLIENT_connect (cfg,
"test_client",
chandlers,
&mq_error_handler,
"resolver",
"HOSTNAME",
"localhost");
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
"test-server",
chandlers,
&mq_error_handler,
"localhost");
GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME",
"localhost");
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
"test-server",
NULL,
NULL,
GNUNET_CONFIGURATION_set_value_string (cfg, "test", "HOSTNAME", "localhost");
GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME",
"localhost");
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
"test",
NULL,
NULL,
GNUNET_CONFIGURATION_set_value_string (cfg, "test", "UNIXPATH", unixpath);
GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME",
"localhost");
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
"test",
NULL,
NULL,
struct GNUNET_MQ_Envelope *env;
struct GNUNET_MessageHeader *msg;
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
service_name,
NULL,
NULL,
handlers[0].callback_cls = cls;
handlers[1].callback_cls = cls;
GNUNET_SERVER_add_handlers (server, handlers);
- mq = GNUNET_CLIENT_connecT (cfg,
+ mq = GNUNET_CLIENT_connect (cfg,
MYNAME,
chandlers,
&mq_error_handler,
struct GNUNET_VPN_RedirectionRequest *rr;
vh->rt = NULL;
- vh->mq = GNUNET_CLIENT_connecT (vh->cfg,
+ vh->mq = GNUNET_CLIENT_connect (vh->cfg,
"vpn",
handlers,
&mq_error_handler,