diff options
Diffstat (limited to 'src')
94 files changed, 156 insertions, 156 deletions
diff --git a/src/arm/arm_api.c b/src/arm/arm_api.c index 2967e62b75..a613438334 100644 --- a/src/arm/arm_api.c +++ b/src/arm/arm_api.c @@ -474,7 +474,7 @@ reconnect_arm (struct GNUNET_ARM_Handle *h) 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, diff --git a/src/arm/arm_monitor_api.c b/src/arm/arm_monitor_api.c index 471393c7e1..b4dc6cb6a7 100644 --- a/src/arm/arm_monitor_api.c +++ b/src/arm/arm_monitor_api.c @@ -209,7 +209,7 @@ reconnect_arm_monitor (struct GNUNET_ARM_MonitorHandle *h) 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, diff --git a/src/arm/test_exponential_backoff.c b/src/arm/test_exponential_backoff.c index ab47ff6350..0905f145d5 100644 --- a/src/arm/test_exponential_backoff.c +++ b/src/arm/test_exponential_backoff.c @@ -151,7 +151,7 @@ kill_task (void *cbData) GNUNET_free (shutdown_ctx); return; } - shutdown_ctx->mq = GNUNET_CLIENT_connecT (cfg, + shutdown_ctx->mq = GNUNET_CLIENT_connect (cfg, SERVICE, handlers, &mq_error_handler, diff --git a/src/ats-tests/ats-testing.c b/src/ats-tests/ats-testing.c index 1bcef58065..326d3bdd41 100644 --- a/src/ats-tests/ats-testing.c +++ b/src/ats-tests/ats-testing.c @@ -384,7 +384,7 @@ core_connect_adapter (void *cls, GNUNET_MQ_handler_end () }; - me->ch = GNUNET_CORE_connecT (cfg, + me->ch = GNUNET_CORE_connect (cfg, me, NULL, &comm_connect_cb, @@ -403,7 +403,7 @@ core_disconnect_adapter (void *cls, { struct BenchmarkPeer *me = cls; - GNUNET_CORE_disconnecT (me->ch); + GNUNET_CORE_disconnect (me->ch); me->ch = NULL; } diff --git a/src/ats/ats_api_connectivity.c b/src/ats/ats_api_connectivity.c index 241e5f93c2..d551aacd4a 100644 --- a/src/ats/ats_api_connectivity.c +++ b/src/ats/ats_api_connectivity.c @@ -195,7 +195,7 @@ reconnect (struct GNUNET_ATS_ConnectivityHandle *ch) 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, diff --git a/src/ats/ats_api_performance.c b/src/ats/ats_api_performance.c index dd8666d4cc..cd67583d15 100644 --- a/src/ats/ats_api_performance.c +++ b/src/ats/ats_api_performance.c @@ -585,7 +585,7 @@ reconnect (struct GNUNET_ATS_PerformanceHandle *ph) 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, diff --git a/src/ats/ats_api_scheduling.c b/src/ats/ats_api_scheduling.c index 4a872b90a5..faeeb60817 100644 --- a/src/ats/ats_api_scheduling.c +++ b/src/ats/ats_api_scheduling.c @@ -532,7 +532,7 @@ reconnect (struct GNUNET_ATS_SchedulingHandle *sh) 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, diff --git a/src/cadet/cadet_api.c b/src/cadet/cadet_api.c index d758155886..23305d8a97 100644 --- a/src/cadet/cadet_api.c +++ b/src/cadet/cadet_api.c @@ -1282,7 +1282,7 @@ do_reconnect (struct GNUNET_CADET_Handle *h) 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, diff --git a/src/cadet/gnunet-service-cadet_peer.c b/src/cadet/gnunet-service-cadet_peer.c index 918bf4e0ce..c1e2d32243 100644 --- a/src/cadet/gnunet-service-cadet_peer.c +++ b/src/cadet/gnunet-service-cadet_peer.c @@ -655,7 +655,7 @@ connect_to_core (const struct GNUNET_CONFIGURATION_Handle *c) 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, @@ -686,7 +686,7 @@ core_init_notify (void *cls, 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; } @@ -1325,12 +1325,12 @@ GCP_shutdown (void) 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, diff --git a/src/consensus/consensus_api.c b/src/consensus/consensus_api.c index 18898bebd3..d5ed8db80f 100644 --- a/src/consensus/consensus_api.c +++ b/src/consensus/consensus_api.c @@ -222,7 +222,7 @@ GNUNET_CONSENSUS_create (const struct GNUNET_CONFIGURATION_Handle *cfg, 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, diff --git a/src/conversation/conversation_api.c b/src/conversation/conversation_api.c index 8a74f0ca69..0b39206334 100644 --- a/src/conversation/conversation_api.c +++ b/src/conversation/conversation_api.c @@ -584,7 +584,7 @@ reconnect_phone (struct GNUNET_CONVERSATION_Phone *phone) 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, diff --git a/src/conversation/conversation_api_call.c b/src/conversation/conversation_api_call.c index 17e26465e1..a6bc506bc6 100644 --- a/src/conversation/conversation_api_call.c +++ b/src/conversation/conversation_api_call.c @@ -570,7 +570,7 @@ GNUNET_CONVERSATION_call_start (const struct GNUNET_CONFIGURATION_Handle *cfg, }; struct GNUNET_CRYPTO_EcdsaPublicKey my_zone; - call->mq = GNUNET_CLIENT_connecT (cfg, + call->mq = GNUNET_CLIENT_connect (cfg, "conversation", handlers, &call_error_handler, diff --git a/src/core/core_api.c b/src/core/core_api.c index cf7924a0d9..ace80b952b 100644 --- a/src/core/core_api.c +++ b/src/core/core_api.c @@ -97,12 +97,12 @@ struct GNUNET_CORE_Handle /** * 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. @@ -734,7 +734,7 @@ reconnect (struct GNUNET_CORE_Handle *h) 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, @@ -773,11 +773,11 @@ reconnect (struct GNUNET_CORE_Handle *h) * 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; @@ -810,7 +810,7 @@ GNUNET_CORE_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg, reconnect (h); if (NULL == h->mq) { - GNUNET_CORE_disconnecT (h); + GNUNET_CORE_disconnect (h); return NULL; } return h; @@ -823,7 +823,7 @@ GNUNET_CORE_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg, * @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"); diff --git a/src/core/core_api_monitor_peers.c b/src/core/core_api_monitor_peers.c index 1455eb2b01..796fdb9d5b 100644 --- a/src/core/core_api_monitor_peers.c +++ b/src/core/core_api_monitor_peers.c @@ -127,7 +127,7 @@ reconnect (struct GNUNET_CORE_MonitorHandle *mh) 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, diff --git a/src/core/test_core_api.c b/src/core/test_core_api.c index e6a113b528..847ba6e757 100644 --- a/src/core/test_core_api.c +++ b/src/core/test_core_api.c @@ -92,7 +92,7 @@ terminate_peer (struct PeerContext *p) { if (NULL != p->ch) { - GNUNET_CORE_disconnecT (p->ch); + GNUNET_CORE_disconnect (p->ch); p->ch = NULL; } if (NULL != p->ghh) @@ -243,7 +243,7 @@ init_notify (void *cls, GNUNET_assert (ok == 2); |