/*
- This file is part of GNUnet.
- Copyright (C) 2008--2013, 2016 GNUnet e.V.
-
- GNUnet is free software: you can redistribute it and/or modify it
- under the terms of the GNU Affero General Public License as published
- by the Free Software Foundation, either version 3 of the License,
- or (at your option) any later version.
-
- GNUnet is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Affero General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>.
+ This file is part of GNUnet.
+ Copyright (C) 2008--2013, 2016 GNUnet e.V.
+
+ GNUnet is free software: you can redistribute it and/or modify it
+ under the terms of the GNU Affero General Public License as published
+ by the Free Software Foundation, either version 3 of the License,
+ or (at your option) any later version.
+
+ GNUnet is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ Affero General Public License for more details.
+
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
SPDX-License-Identifier: AGPL3.0-or-later
-*/
+ */
/**
/**
* Context information to manage peers' services
*/
-struct ManageServiceContext
-{
+struct ManageServiceContext {
/**
* DLL next ptr
*/
/**
* Context information for peer re-configure operations
*/
-struct PeerReconfigureContext
-{
+struct PeerReconfigureContext {
/**
* DLL next for inclusoin in peer reconfigure operations list
*/
* @param peer the peer to add
*/
static void
-peer_list_add (struct Peer *peer)
+peer_list_add(struct Peer *peer)
{
if (peer->id >= GST_peer_list_size)
- GST_array_grow_large_enough (GST_peer_list, GST_peer_list_size, peer->id);
- GNUNET_assert (NULL == GST_peer_list[peer->id]);
+ GST_array_grow_large_enough(GST_peer_list, GST_peer_list_size, peer->id);
+ GNUNET_assert(NULL == GST_peer_list[peer->id]);
GST_peer_list[peer->id] = peer;
if (GNUNET_NO == peer->is_remote)
GST_num_local_peers++;
* @param peer the peer to be removed
*/
static void
-peer_list_remove (struct Peer *peer)
+peer_list_remove(struct Peer *peer)
{
unsigned int orig_size;
uint32_t id;
GST_peer_list[peer->id] = NULL;
orig_size = GST_peer_list_size;
while (GST_peer_list_size >= LIST_GROW_STEP)
- {
- for (id = GST_peer_list_size - 1;
- (id >= GST_peer_list_size - LIST_GROW_STEP) && (id != UINT32_MAX);
- id--)
- if (NULL != GST_peer_list[id])
+ {
+ for (id = GST_peer_list_size - 1;
+ (id >= GST_peer_list_size - LIST_GROW_STEP) && (id != UINT32_MAX);
+ id--)
+ if (NULL != GST_peer_list[id])
+ break;
+ if (id != ((GST_peer_list_size - LIST_GROW_STEP) - 1))
break;
- if (id != ((GST_peer_list_size - LIST_GROW_STEP) - 1))
- break;
- GST_peer_list_size -= LIST_GROW_STEP;
- }
+ GST_peer_list_size -= LIST_GROW_STEP;
+ }
if (orig_size == GST_peer_list_size)
return;
GST_peer_list =
- GNUNET_realloc (GST_peer_list,
- sizeof (struct Peer *) * GST_peer_list_size);
+ GNUNET_realloc(GST_peer_list,
+ sizeof(struct Peer *) * GST_peer_list_size);
}
* @param cls the FowardedOperationContext
*/
static void
-peer_create_forward_timeout (void *cls)
+peer_create_forward_timeout(void *cls)
{
struct ForwardedOperationContext *fopc = cls;
- GNUNET_free (fopc->cls);
- GST_forwarded_operation_timeout (fopc);
+ GNUNET_free(fopc->cls);
+ GST_forwarded_operation_timeout(fopc);
}
* @param msg the peer create success message
*/
static void
-peer_create_success_cb (void *cls, const struct GNUNET_MessageHeader *msg)
+peer_create_success_cb(void *cls, const struct GNUNET_MessageHeader *msg)
{
struct ForwardedOperationContext *fopc = cls;
struct Peer *remote_peer;
- if (ntohs (msg->type) == GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS)
- {
- GNUNET_assert (NULL != fopc->cls);
- remote_peer = fopc->cls;
- peer_list_add (remote_peer);
- }
- GST_forwarded_operation_reply_relay (fopc,
- msg);
+ if (ntohs(msg->type) == GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS)
+ {
+ GNUNET_assert(NULL != fopc->cls);
+ remote_peer = fopc->cls;
+ peer_list_add(remote_peer);
+ }
+ GST_forwarded_operation_reply_relay(fopc,
+ msg);
}
* @param peer the peer structure to destroy
*/
void
-GST_destroy_peer (struct Peer *peer)
+GST_destroy_peer(struct Peer *peer)
{
- GNUNET_break (0 == peer->reference_cnt);
+ GNUNET_break(0 == peer->reference_cnt);
if (GNUNET_YES == peer->is_remote)
- {
- peer_list_remove (peer);
- GNUNET_free (peer);
- return;
- }
+ {
+ peer_list_remove(peer);
+ GNUNET_free(peer);
+ return;
+ }
if (GNUNET_YES == peer->details.local.is_running)
- {
- GNUNET_TESTING_peer_stop (peer->details.local.peer);
- peer->details.local.is_running = GNUNET_NO;
- }
- GNUNET_TESTING_peer_destroy (peer->details.local.peer);
- GNUNET_CONFIGURATION_destroy (peer->details.local.cfg);
- peer_list_remove (peer);
- GNUNET_free (peer);
+ {
+ GNUNET_TESTING_peer_stop(peer->details.local.peer);
+ peer->details.local.is_running = GNUNET_NO;
+ }
+ GNUNET_TESTING_peer_destroy(peer->details.local.peer);
+ GNUNET_CONFIGURATION_destroy(peer->details.local.cfg);
+ peer_list_remove(peer);
+ GNUNET_free(peer);
}
* @param mctx the ManageServiceContext
*/
static void
-cleanup_mctx (struct ManageServiceContext *mctx)
+cleanup_mctx(struct ManageServiceContext *mctx)
{
mctx->expired = GNUNET_YES;
- GNUNET_CONTAINER_DLL_remove (mctx_head,
- mctx_tail,
- mctx);
- GNUNET_ARM_disconnect (mctx->ah);
- GNUNET_assert (0 < mctx->peer->reference_cnt);
+ GNUNET_CONTAINER_DLL_remove(mctx_head,
+ mctx_tail,
+ mctx);
+ GNUNET_ARM_disconnect(mctx->ah);
+ GNUNET_assert(0 < mctx->peer->reference_cnt);
mctx->peer->reference_cnt--;
- if ( (GNUNET_YES == mctx->peer->destroy_flag) &&
- (0 == mctx->peer->reference_cnt) )
- GST_destroy_peer (mctx->peer);
- GNUNET_free (mctx->service);
- GNUNET_free (mctx);
+ if ((GNUNET_YES == mctx->peer->destroy_flag) &&
+ (0 == mctx->peer->reference_cnt))
+ GST_destroy_peer(mctx->peer);
+ GNUNET_free(mctx->service);
+ GNUNET_free(mctx);
}
* @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
*/
static int
-stop_peer (struct Peer *peer)
+stop_peer(struct Peer *peer)
{
- GNUNET_assert (GNUNET_NO == peer->is_remote);
- if (GNUNET_OK != GNUNET_TESTING_peer_kill (peer->details.local.peer))
+ GNUNET_assert(GNUNET_NO == peer->is_remote);
+ if (GNUNET_OK != GNUNET_TESTING_peer_kill(peer->details.local.peer))
return GNUNET_SYSERR;
peer->details.local.is_running = GNUNET_NO;
return GNUNET_OK;
* @param prc the PeerReconfigureContext
*/
static void
-cleanup_prc (struct PeerReconfigureContext *prc)
+cleanup_prc(struct PeerReconfigureContext *prc)
{
struct Peer *peer;
- if (VALID_PEER_ID (prc->peer_id))
- {
- peer = GST_peer_list [prc->peer_id];
- if (1 != prc->stopped)
+ if (VALID_PEER_ID(prc->peer_id))
{
- GNUNET_TESTING_peer_stop_async_cancel (peer->details.local.peer);
- stop_peer (peer); /* Stop the peer synchronously */
+ peer = GST_peer_list [prc->peer_id];
+ if (1 != prc->stopped)
+ {
+ GNUNET_TESTING_peer_stop_async_cancel(peer->details.local.peer);
+ stop_peer(peer); /* Stop the peer synchronously */
+ }
}
- }
if (NULL != prc->cfg)
- GNUNET_CONFIGURATION_destroy (prc->cfg);
- GNUNET_CONTAINER_DLL_remove (prc_head,
- prc_tail,
- prc);
- GNUNET_free (prc);
+ GNUNET_CONFIGURATION_destroy(prc->cfg);
+ GNUNET_CONTAINER_DLL_remove(prc_head,
+ prc_tail,
+ prc);
+ GNUNET_free(prc);
}
* @param client the client that disconnected
*/
void
-GST_notify_client_disconnect_peers (struct GNUNET_SERVICE_Client *client)
+GST_notify_client_disconnect_peers(struct GNUNET_SERVICE_Client *client)
{
struct ForwardedOperationContext *fopc;
struct ForwardedOperationContext *fopcn;
struct PeerReconfigureContext *prcn;
for (fopc = fopcq_head; NULL != fopc; fopc = fopcn)
- {
- fopcn = fopc->next;
- if (client == fopc->client)
{
- if (OP_PEER_CREATE == fopc->type)
- GNUNET_free (fopc->cls);
- GNUNET_SCHEDULER_cancel (fopc->timeout_task);
- GST_forwarded_operation_timeout (fopc);
+ fopcn = fopc->next;
+ if (client == fopc->client)
+ {
+ if (OP_PEER_CREATE == fopc->type)
+ GNUNET_free(fopc->cls);
+ GNUNET_SCHEDULER_cancel(fopc->timeout_task);
+ GST_forwarded_operation_timeout(fopc);
+ }
}
- }
for (mctx = mctx_head; NULL != mctx; mctx = mctxn)
- {
- mctxn = mctx->next;
- if (client == mctx->client)
- cleanup_mctx (mctx);
- }
+ {
+ mctxn = mctx->next;
+ if (client == mctx->client)
+ cleanup_mctx(mctx);
+ }
for (prc = prc_head; NULL != prc; prc = prcn)
- {
- prcn = prc->next;
- if (client == prc->client)
- cleanup_prc (prc);
- }
+ {
+ prcn = prc->next;
+ if (client == prc->client)
+ cleanup_prc(prc);
+ }
}
* @param msg the peer create success message
*/
static void
-peer_destroy_success_cb (void *cls, const struct GNUNET_MessageHeader *msg)
+peer_destroy_success_cb(void *cls, const struct GNUNET_MessageHeader *msg)
{
struct ForwardedOperationContext *fopc = cls;
struct Peer *remote_peer;
if (GNUNET_MESSAGE_TYPE_TESTBED_GENERIC_OPERATION_SUCCESS ==
- ntohs (msg->type))
- {
- remote_peer = fopc->cls;
- GNUNET_assert (NULL != remote_peer);
- remote_peer->destroy_flag = GNUNET_YES;
- if (0 == remote_peer->reference_cnt)
- GST_destroy_peer (remote_peer);
- }
- GST_forwarded_operation_reply_relay (fopc,
- msg);
+ ntohs(msg->type))
+ {
+ remote_peer = fopc->cls;
+ GNUNET_assert(NULL != remote_peer);
+ remote_peer->destroy_flag = GNUNET_YES;
+ if (0 == remote_peer->reference_cnt)
+ GST_destroy_peer(remote_peer);
+ }
+ GST_forwarded_operation_reply_relay(fopc,
+ msg);
}
* @return #GNUNET_OK if @a msg is well-formed
*/
int
-check_peer_create (void *cls,
- const struct GNUNET_TESTBED_PeerCreateMessage *msg)
+check_peer_create(void *cls,
+ const struct GNUNET_TESTBED_PeerCreateMessage *msg)
{
return GNUNET_OK; /* checked later */
}
* @param msg the actual message
*/
void
-handle_peer_create (void *cls,
- const struct GNUNET_TESTBED_PeerCreateMessage *msg)
+handle_peer_create(void *cls,
+ const struct GNUNET_TESTBED_PeerCreateMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct GNUNET_MQ_Envelope *env;
uint32_t host_id;
uint32_t peer_id;
- host_id = ntohl (msg->host_id);
- peer_id = ntohl (msg->peer_id);
- if (VALID_PEER_ID (peer_id))
- {
- (void) GNUNET_asprintf (&emsg,
+ host_id = ntohl(msg->host_id);
+ peer_id = ntohl(msg->peer_id);
+ if (VALID_PEER_ID(peer_id))
+ {
+ (void)GNUNET_asprintf(&emsg,
"Peer with ID %u already exists",
peer_id);
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- emsg);
- GNUNET_free (emsg);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ emsg);
+ GNUNET_free(emsg);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
if (UINT32_MAX == peer_id)
- {
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- "Cannot create peer with given ID");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- if (host_id == GST_context->host_id)
- {
- /* We are responsible for this peer */
- cfg = GNUNET_TESTBED_extract_config_ (&msg->header);
- if (NULL == cfg)
{
- GNUNET_break (0);
- GNUNET_SERVICE_client_drop (client);
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ "Cannot create peer with given ID");
+ GNUNET_SERVICE_client_continue(client);
return;
}
- GNUNET_CONFIGURATION_set_value_number (cfg,
- "TESTBED",
- "PEERID",
- (unsigned long long) peer_id);
-
- GNUNET_CONFIGURATION_set_value_number (cfg,
- "PATHS",
- "PEERID",
- (unsigned long long) peer_id);
- peer = GNUNET_new (struct Peer);
- peer->is_remote = GNUNET_NO;
- peer->details.local.cfg = cfg;
- peer->id = peer_id;
- LOG_DEBUG ("Creating peer with id: %u\n",
- (unsigned int) peer->id);
- peer->details.local.peer =
- GNUNET_TESTING_peer_configure (GST_context->system,
- peer->details.local.cfg, peer->id,
- NULL /* Peer id */ ,
- &emsg);
- if (NULL == peer->details.local.peer)
+ if (host_id == GST_context->host_id)
{
- LOG (GNUNET_ERROR_TYPE_WARNING,
- "Configuring peer failed: %s\n",
- emsg);
- GNUNET_free (emsg);
- GNUNET_free (peer);
- GNUNET_break (0);
- GNUNET_SERVICE_client_drop (client);
+ /* We are responsible for this peer */
+ cfg = GNUNET_TESTBED_extract_config_(&msg->header);
+ if (NULL == cfg)
+ {
+ GNUNET_break(0);
+ GNUNET_SERVICE_client_drop(client);
+ return;
+ }
+ GNUNET_CONFIGURATION_set_value_number(cfg,
+ "TESTBED",
+ "PEERID",
+ (unsigned long long)peer_id);
+
+ GNUNET_CONFIGURATION_set_value_number(cfg,
+ "PATHS",
+ "PEERID",
+ (unsigned long long)peer_id);
+ peer = GNUNET_new(struct Peer);
+ peer->is_remote = GNUNET_NO;
+ peer->details.local.cfg = cfg;
+ peer->id = peer_id;
+ LOG_DEBUG("Creating peer with id: %u\n",
+ (unsigned int)peer->id);
+ peer->details.local.peer =
+ GNUNET_TESTING_peer_configure(GST_context->system,
+ peer->details.local.cfg, peer->id,
+ NULL /* Peer id */,
+ &emsg);
+ if (NULL == peer->details.local.peer)
+ {
+ LOG(GNUNET_ERROR_TYPE_WARNING,
+ "Configuring peer failed: %s\n",
+ emsg);
+ GNUNET_free(emsg);
+ GNUNET_free(peer);
+ GNUNET_break(0);
+ GNUNET_SERVICE_client_drop(client);
+ return;
+ }
+ peer->details.local.is_running = GNUNET_NO;
+ peer_list_add(peer);
+ env = GNUNET_MQ_msg(reply,
+ GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS);
+ reply->peer_id = msg->peer_id;
+ reply->operation_id = msg->operation_id;
+ GNUNET_MQ_send(GNUNET_SERVICE_client_get_mq(client),
+ env);
+ GNUNET_SERVICE_client_continue(client);
return;
}
- peer->details.local.is_running = GNUNET_NO;
- peer_list_add (peer);
- env = GNUNET_MQ_msg (reply,
- GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS);
- reply->peer_id = msg->peer_id;
- reply->operation_id = msg->operation_id;
- GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client),
- env);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
/* Forward peer create request */
- route = GST_find_dest_route (host_id);
+ route = GST_find_dest_route(host_id);
if (NULL == route)
- {
- GNUNET_break (0);
- GNUNET_SERVICE_client_continue (client); // ?
- return;
- }
- peer = GNUNET_new (struct Peer);
+ {
+ GNUNET_break(0);
+ GNUNET_SERVICE_client_continue(client); // ?
+ return;
+ }
+ peer = GNUNET_new(struct Peer);
peer->is_remote = GNUNET_YES;
peer->id = peer_id;
peer->details.remote.slave = GST_slave_list[route->dest];
peer->details.remote.remote_host_id = host_id;
- fo_ctxt = GNUNET_new (struct ForwardedOperationContext);
+ fo_ctxt = GNUNET_new(struct ForwardedOperationContext);
fo_ctxt->client = client;
- fo_ctxt->operation_id = GNUNET_ntohll (msg->operation_id);
+ fo_ctxt->operation_id = GNUNET_ntohll(msg->operation_id);
fo_ctxt->cls = peer;
fo_ctxt->type = OP_PEER_CREATE;
fo_ctxt->opc =
- GNUNET_TESTBED_forward_operation_msg_ (GST_slave_list
- [route->dest]->controller,
- fo_ctxt->operation_id,
- &msg->header,
- &peer_create_success_cb,
- fo_ctxt);
+ GNUNET_TESTBED_forward_operation_msg_(GST_slave_list
+ [route->dest]->controller,
+ fo_ctxt->operation_id,
+ &msg->header,
+ &peer_create_success_cb,
+ fo_ctxt);
fo_ctxt->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &peer_create_forward_timeout,
- fo_ctxt);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fo_ctxt);
- GNUNET_SERVICE_client_continue (client);
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &peer_create_forward_timeout,
+ fo_ctxt);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fo_ctxt);
+ GNUNET_SERVICE_client_continue(client);
}
* @param msg the actual message
*/
void
-handle_peer_destroy (void *cls,
- const struct GNUNET_TESTBED_PeerDestroyMessage *msg)
+handle_peer_destroy(void *cls,
+ const struct GNUNET_TESTBED_PeerDestroyMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct ForwardedOperationContext *fopc;
struct Peer *peer;
uint32_t peer_id;
- peer_id = ntohl (msg->peer_id);
- LOG_DEBUG ("Received peer destory on peer: %u and operation id: %llu\n",
- (unsigned int) peer_id,
- (unsigned long long) GNUNET_ntohll (msg->operation_id));
- if (!VALID_PEER_ID (peer_id))
- {
- LOG (GNUNET_ERROR_TYPE_ERROR,
- "Asked to destroy a non existent peer with id: %u\n", peer_id);
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- "Peer doesn't exist");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ peer_id = ntohl(msg->peer_id);
+ LOG_DEBUG("Received peer destory on peer: %u and operation id: %llu\n",
+ (unsigned int)peer_id,
+ (unsigned long long)GNUNET_ntohll(msg->operation_id));
+ if (!VALID_PEER_ID(peer_id))
+ {
+ LOG(GNUNET_ERROR_TYPE_ERROR,
+ "Asked to destroy a non existent peer with id: %u\n", peer_id);
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ "Peer doesn't exist");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer = GST_peer_list[peer_id];
if (GNUNET_YES == peer->is_remote)
- {
- /* Forward the destory message to sub controller */
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->cls = peer;
- fopc->type = OP_PEER_DESTROY;
- fopc->operation_id = GNUNET_ntohll (msg->operation_id);
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id,
- &msg->header,
- &peer_destroy_success_cb,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ {
+ /* Forward the destory message to sub controller */
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->cls = peer;
+ fopc->type = OP_PEER_DESTROY;
+ fopc->operation_id = GNUNET_ntohll(msg->operation_id);
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id,
+ &msg->header,
+ &peer_destroy_success_cb,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer->destroy_flag = GNUNET_YES;
if (0 == peer->reference_cnt)
- GST_destroy_peer (peer);
+ GST_destroy_peer(peer);
else
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Delaying peer destroy as peer is currently in use\n");
- GST_send_operation_success_msg (client,
- GNUNET_ntohll (msg->operation_id));
- GNUNET_SERVICE_client_continue (client);
+ LOG(GNUNET_ERROR_TYPE_DEBUG,
+ "Delaying peer destroy as peer is currently in use\n");
+ GST_send_operation_success_msg(client,
+ GNUNET_ntohll(msg->operation_id));
+ GNUNET_SERVICE_client_continue(client);
}
* @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
*/
static int
-start_peer (struct Peer *peer)
+start_peer(struct Peer *peer)
{
- GNUNET_assert (GNUNET_NO == peer->is_remote);
- if (GNUNET_OK != GNUNET_TESTING_peer_start (peer->details.local.peer))
+ GNUNET_assert(GNUNET_NO == peer->is_remote);
+ if (GNUNET_OK != GNUNET_TESTING_peer_start(peer->details.local.peer))
return GNUNET_SYSERR;
peer->details.local.is_running = GNUNET_YES;
return GNUNET_OK;
* @param msg the actual message
*/
void
-handle_peer_start (void *cls,
- const struct GNUNET_TESTBED_PeerStartMessage *msg)
+handle_peer_start(void *cls,
+ const struct GNUNET_TESTBED_PeerStartMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct GNUNET_MQ_Envelope *env;
struct Peer *peer;
uint32_t peer_id;
- peer_id = ntohl (msg->peer_id);
- if (! VALID_PEER_ID (peer_id))
- {
- GNUNET_break (0);
- LOG (GNUNET_ERROR_TYPE_ERROR,
- "Asked to start a non existent peer with id: %u\n",
- peer_id);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ peer_id = ntohl(msg->peer_id);
+ if (!VALID_PEER_ID(peer_id))
+ {
+ GNUNET_break(0);
+ LOG(GNUNET_ERROR_TYPE_ERROR,
+ "Asked to start a non existent peer with id: %u\n",
+ peer_id);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer = GST_peer_list[peer_id];
if (GNUNET_YES == peer->is_remote)
- {
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->operation_id = GNUNET_ntohll (msg->operation_id);
- fopc->type = OP_PEER_START;
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id, &msg->header,
- &GST_forwarded_operation_reply_relay,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- if (GNUNET_OK != start_peer (peer))
- {
- GST_send_operation_fail_msg (client, GNUNET_ntohll (msg->operation_id),
- "Failed to start");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- env = GNUNET_MQ_msg (reply,
- GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT);
- reply->event_type = htonl (GNUNET_TESTBED_ET_PEER_START);
- reply->host_id = htonl (GST_context->host_id);
+ {
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->operation_id = GNUNET_ntohll(msg->operation_id);
+ fopc->type = OP_PEER_START;
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id, &msg->header,
+ &GST_forwarded_operation_reply_relay,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ if (GNUNET_OK != start_peer(peer))
+ {
+ GST_send_operation_fail_msg(client, GNUNET_ntohll(msg->operation_id),
+ "Failed to start");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ env = GNUNET_MQ_msg(reply,
+ GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT);
+ reply->event_type = htonl(GNUNET_TESTBED_ET_PEER_START);
+ reply->host_id = htonl(GST_context->host_id);
reply->peer_id = msg->peer_id;
reply->operation_id = msg->operation_id;
- GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client),
- env);
- GNUNET_SERVICE_client_continue (client);
+ GNUNET_MQ_send(GNUNET_SERVICE_client_get_mq(client),
+ env);
+ GNUNET_SERVICE_client_continue(client);
}
* @param msg the actual message
*/
void
-handle_peer_stop (void *cls,
- const struct GNUNET_TESTBED_PeerStopMessage *msg)
+handle_peer_stop(void *cls,
+ const struct GNUNET_TESTBED_PeerStopMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct GNUNET_MQ_Envelope *env;
struct Peer *peer;
uint32_t peer_id;
- peer_id = ntohl (msg->peer_id);
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Received PEER_STOP for peer %u\n",
- (unsigned int) peer_id);
- if (! VALID_PEER_ID (peer_id))
- {
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- "Peer not found");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ peer_id = ntohl(msg->peer_id);
+ LOG(GNUNET_ERROR_TYPE_DEBUG,
+ "Received PEER_STOP for peer %u\n",
+ (unsigned int)peer_id);
+ if (!VALID_PEER_ID(peer_id))
+ {
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ "Peer not found");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer = GST_peer_list[peer_id];
if (GNUNET_YES == peer->is_remote)
- {
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Forwarding PEER_STOP for peer %u\n",
- (unsigned int) peer_id);
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->operation_id = GNUNET_ntohll (msg->operation_id);
- fopc->type = OP_PEER_STOP;
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id,
- &msg->header,
- &GST_forwarded_operation_reply_relay,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- if (GNUNET_OK != stop_peer (peer))
- {
- LOG (GNUNET_ERROR_TYPE_WARNING,
- "Stopping peer %u failed\n",
- (unsigned int) peer_id);
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- "Peer not running");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Peer %u successfully stopped\n",
- (unsigned int) peer_id);
- env = GNUNET_MQ_msg (reply,
- GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT);
- reply->event_type = htonl (GNUNET_TESTBED_ET_PEER_STOP);
- reply->host_id = htonl (GST_context->host_id);
+ {
+ LOG(GNUNET_ERROR_TYPE_DEBUG,
+ "Forwarding PEER_STOP for peer %u\n",
+ (unsigned int)peer_id);
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->operation_id = GNUNET_ntohll(msg->operation_id);
+ fopc->type = OP_PEER_STOP;
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id,
+ &msg->header,
+ &GST_forwarded_operation_reply_relay,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ if (GNUNET_OK != stop_peer(peer))
+ {
+ LOG(GNUNET_ERROR_TYPE_WARNING,
+ "Stopping peer %u failed\n",
+ (unsigned int)peer_id);
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ "Peer not running");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ LOG(GNUNET_ERROR_TYPE_DEBUG,
+ "Peer %u successfully stopped\n",
+ (unsigned int)peer_id);
+ env = GNUNET_MQ_msg(reply,
+ GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT);
+ reply->event_type = htonl(GNUNET_TESTBED_ET_PEER_STOP);
+ reply->host_id = htonl(GST_context->host_id);
reply->peer_id = msg->peer_id;
reply->operation_id = msg->operation_id;
- GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client),
- env);
- GNUNET_SERVICE_client_continue (client);
- GNUNET_TESTING_peer_wait (peer->details.local.peer);
+ GNUNET_MQ_send(GNUNET_SERVICE_client_get_mq(client),
+ env);
+ GNUNET_SERVICE_client_continue(client);
+ GNUNET_TESTING_peer_wait(peer->details.local.peer);
}
* @param msg the actual message
*/
void
-handle_peer_get_config (void *cls,
- const struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg)
+handle_peer_get_config(void *cls,
+ const struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct GNUNET_MQ_Envelope *env;
size_t xc_size;
uint32_t peer_id;
- peer_id = ntohl (msg->peer_id);
- LOG_DEBUG ("Received GET_CONFIG for peer %u\n",
- (unsigned int) peer_id);
- if (!VALID_PEER_ID (peer_id))
- {
- GST_send_operation_fail_msg (client,
- GNUNET_ntohll (msg->operation_id),
- "Peer not found");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ peer_id = ntohl(msg->peer_id);
+ LOG_DEBUG("Received GET_CONFIG for peer %u\n",
+ (unsigned int)peer_id);
+ if (!VALID_PEER_ID(peer_id))
+ {
+ GST_send_operation_fail_msg(client,
+ GNUNET_ntohll(msg->operation_id),
+ "Peer not found");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer = GST_peer_list[peer_id];
if (GNUNET_YES == peer->is_remote)
- {
- LOG_DEBUG ("Forwarding PEER_GET_CONFIG for peer: %u\n",
- (unsigned int) peer_id);
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->operation_id = GNUNET_ntohll (msg->operation_id);
- fopc->type = OP_PEER_INFO;
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id,
- &msg->header,
- &GST_forwarded_operation_reply_relay,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- LOG_DEBUG ("Received PEER_GET_CONFIG for peer: %u\n",
- peer_id);
+ {
+ LOG_DEBUG("Forwarding PEER_GET_CONFIG for peer: %u\n",
+ (unsigned int)peer_id);
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->operation_id = GNUNET_ntohll(msg->operation_id);
+ fopc->type = OP_PEER_INFO;
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id,
+ &msg->header,
+ &GST_forwarded_operation_reply_relay,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ LOG_DEBUG("Received PEER_GET_CONFIG for peer: %u\n",
+ peer_id);
config =
- GNUNET_CONFIGURATION_serialize (GST_peer_list[peer_id]->details.local.cfg,
- &c_size);
- xc_size = GNUNET_TESTBED_compress_config_ (config,
- c_size,
- &xconfig);
- GNUNET_free (config);
- env = GNUNET_MQ_msg_extra (reply,
- xc_size,
- GNUNET_MESSAGE_TYPE_TESTBED_PEER_INFORMATION);
+ GNUNET_CONFIGURATION_serialize(GST_peer_list[peer_id]->details.local.cfg,
+ &c_size);
+ xc_size = GNUNET_TESTBED_compress_config_(config,
+ c_size,
+ &xconfig);
+ GNUNET_free(config);
+ env = GNUNET_MQ_msg_extra(reply,
+ xc_size,
+ GNUNET_MESSAGE_TYPE_TESTBED_PEER_INFORMATION);
reply->peer_id = msg->peer_id;
reply->operation_id = msg->operation_id;
- GNUNET_TESTING_peer_get_identity (GST_peer_list[peer_id]->details.local.peer,
- &reply->peer_identity);
- reply->config_size = htons ((uint16_t) c_size);
- GNUNET_memcpy (&reply[1],
- xconfig,
- xc_size);
- GNUNET_free (xconfig);
- GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client),
- env);
- GNUNET_SERVICE_client_continue (client);
+ GNUNET_TESTING_peer_get_identity(GST_peer_list[peer_id]->details.local.peer,
+ &reply->peer_identity);
+ reply->config_size = htons((uint16_t)c_size);
+ GNUNET_memcpy(&reply[1],
+ xconfig,
+ xc_size);
+ GNUNET_free(xconfig);
+ GNUNET_MQ_send(GNUNET_SERVICE_client_get_mq(client),
+ env);
+ GNUNET_SERVICE_client_continue(client);
}
* Cleans up the Peer reconfigure context list
*/
void
-GST_free_prcq ()
+GST_free_prcq()
{
while (NULL != prc_head)
- cleanup_prc (prc_head);
+ cleanup_prc(prc_head);
}
* @return error message (freshly allocated); NULL upon success
*/
static char *
-update_peer_config (struct Peer *peer,
- struct GNUNET_CONFIGURATION_Handle *cfg)
+update_peer_config(struct Peer *peer,
+ struct GNUNET_CONFIGURATION_Handle *cfg)
{
char *emsg;
- GNUNET_TESTING_peer_destroy (peer->details.local.peer);
- GNUNET_CONFIGURATION_destroy (peer->details.local.cfg);
+ GNUNET_TESTING_peer_destroy(peer->details.local.peer);
+ GNUNET_CONFIGURATION_destroy(peer->details.local.cfg);
peer->details.local.cfg = cfg;
emsg = NULL;
peer->details.local.peer
- = GNUNET_TESTING_peer_configure (GST_context->system,
- peer->details.local.cfg,
- peer->id,
- NULL /* Peer id */ ,
- &emsg);
+ = GNUNET_TESTING_peer_configure(GST_context->system,
+ peer->details.local.cfg,
+ peer->id,
+ NULL /* Peer id */,
+ &emsg);
return emsg;
}
* error
*/
static void
-prc_stop_cb (void *cls,
- struct GNUNET_TESTING_Peer *p,
- int success)
+prc_stop_cb(void *cls,
+ struct GNUNET_TESTING_Peer *p,
+ int success)
{
struct PeerReconfigureContext *prc = cls;
struct Peer *peer;
char *emsg;
- GNUNET_assert (VALID_PEER_ID (prc->peer_id));
+ GNUNET_assert(VALID_PEER_ID(prc->peer_id));
peer = GST_peer_list [prc->peer_id];
- GNUNET_assert (GNUNET_NO == peer->is_remote);
- emsg = update_peer_config (peer, prc->cfg);
+ GNUNET_assert(GNUNET_NO == peer->is_remote);
+ emsg = update_peer_config(peer, prc->cfg);
prc->cfg = NULL;
prc->stopped = 1;
if (NULL != emsg)
- {
- GST_send_operation_fail_msg (prc->client,
- prc->op_id,
- emsg);
- goto cleanup;
- }
- if (GNUNET_OK != start_peer (peer))
- {
- GST_send_operation_fail_msg (prc->client,
- prc->op_id,
- "Failed to start reconfigured peer");
- goto cleanup;
- }
- GST_send_operation_success_msg (prc->client,
- prc->op_id);
-
- cleanup:
- cleanup_prc (prc);
+ {
+ GST_send_operation_fail_msg(prc->client,
+ prc->op_id,
+ emsg);
+ goto cleanup;
+ }
+ if (GNUNET_OK != start_peer(peer))
+ {
+ GST_send_operation_fail_msg(prc->client,
+ prc->op_id,
+ "Failed to start reconfigured peer");
+ goto cleanup;
+ }
+ GST_send_operation_success_msg(prc->client,
+ prc->op_id);
+
+cleanup:
+ cleanup_prc(prc);
return;
}
* @return #GNUNET_OK if @a msg is well-formed
*/
int
-check_peer_reconfigure (void *cls,
- const struct GNUNET_TESTBED_PeerReconfigureMessage *msg)
+check_peer_reconfigure(void *cls,
+ const struct GNUNET_TESTBED_PeerReconfigureMessage *msg)
{
return GNUNET_OK; /* checked later */
}
* @param msg the actual message
*/
void
-handle_peer_reconfigure (void *cls,
- const struct GNUNET_TESTBED_PeerReconfigureMessage *msg)
+handle_peer_reconfigure(void *cls,
+ const struct GNUNET_TESTBED_PeerReconfigureMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct Peer *peer;
uint64_t op_id;
uint32_t peer_id;
- peer_id = ntohl (msg->peer_id);
- op_id = GNUNET_ntohll (msg->operation_id);
- if (! VALID_PEER_ID (peer_id))
- {
- GNUNET_break (0);
- GST_send_operation_fail_msg (client,
- op_id,
- "Peer not found");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ peer_id = ntohl(msg->peer_id);
+ op_id = GNUNET_ntohll(msg->operation_id);
+ if (!VALID_PEER_ID(peer_id))
+ {
+ GNUNET_break(0);
+ GST_send_operation_fail_msg(client,
+ op_id,
+ "Peer not found");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
peer = GST_peer_list[peer_id];
if (GNUNET_YES == peer->is_remote)
- {
- LOG_DEBUG ("Forwarding PEER_RECONFIGURE for peer: %u\n", peer_id);
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->operation_id = op_id;
- fopc->type = OP_PEER_RECONFIGURE;
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id,
- &msg->header,
- &GST_forwarded_operation_reply_relay,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- LOG_DEBUG ("Received PEER_RECONFIGURE for peer %u\n",
- (unsigned int) peer_id);
+ {
+ LOG_DEBUG("Forwarding PEER_RECONFIGURE for peer: %u\n", peer_id);
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->operation_id = op_id;
+ fopc->type = OP_PEER_RECONFIGURE;
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id,
+ &msg->header,
+ &GST_forwarded_operation_reply_relay,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ LOG_DEBUG("Received PEER_RECONFIGURE for peer %u\n",
+ (unsigned int)peer_id);
if (0 < peer->reference_cnt)
- {
- GNUNET_break (0);
- GST_send_operation_fail_msg (client,
- op_id,
- "Peer in use");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ {
+ GNUNET_break(0);
+ GST_send_operation_fail_msg(client,
+ op_id,
+ "Peer in use");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
if (GNUNET_YES == peer->destroy_flag)
- {
- GNUNET_break (0);
- GST_send_operation_fail_msg (client,
- op_id,
- "Peer is being destroyed");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
- cfg = GNUNET_TESTBED_extract_config_ (&msg->header);
+ {
+ GNUNET_break(0);
+ GST_send_operation_fail_msg(client,
+ op_id,
+ "Peer is being destroyed");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
+ cfg = GNUNET_TESTBED_extract_config_(&msg->header);
if (NULL == cfg)
- {
- GNUNET_break (0);
- GST_send_operation_fail_msg (client,
- op_id,
- "Compression error");
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ {
+ GNUNET_break(0);
+ GST_send_operation_fail_msg(client,
+ op_id,
+ "Compression error");
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
if (GNUNET_NO == peer->details.local.is_running)
- {
- emsg = update_peer_config (peer,
- cfg);
- if (NULL != emsg)
- GST_send_operation_fail_msg (client,
- op_id,
- emsg);
- GST_send_operation_success_msg (client,
- op_id);
- GNUNET_SERVICE_client_continue (client);
- GNUNET_free_non_null (emsg);
- return;
- }
- prc = GNUNET_new (struct PeerReconfigureContext);
+ {
+ emsg = update_peer_config(peer,
+ cfg);
+ if (NULL != emsg)
+ GST_send_operation_fail_msg(client,
+ op_id,
+ emsg);
+ GST_send_operation_success_msg(client,
+ op_id);
+ GNUNET_SERVICE_client_continue(client);
+ GNUNET_free_non_null(emsg);
+ return;
+ }
+ prc = GNUNET_new(struct PeerReconfigureContext);
if (GNUNET_OK !=
- GNUNET_TESTING_peer_stop_async (peer->details.local.peer,
- &prc_stop_cb,
- prc))
- {
- GNUNET_assert (0 < GNUNET_asprintf (&emsg,
+ GNUNET_TESTING_peer_stop_async(peer->details.local.peer,
+ &prc_stop_cb,
+ prc))
+ {
+ GNUNET_assert(0 < GNUNET_asprintf(&emsg,
"Error trying to stop peer %u asynchronously\n",
peer_id));
- LOG (GNUNET_ERROR_TYPE_ERROR,
- "%s\n",
- emsg);
- GST_send_operation_fail_msg (client,
- op_id,
- emsg);
- GNUNET_SERVICE_client_continue (client);
- GNUNET_free (prc);
- GNUNET_free (emsg);
- return;
- }
+ LOG(GNUNET_ERROR_TYPE_ERROR,
+ "%s\n",
+ emsg);
+ GST_send_operation_fail_msg(client,
+ op_id,
+ emsg);
+ GNUNET_SERVICE_client_continue(client);
+ GNUNET_free(prc);
+ GNUNET_free(emsg);
+ return;
+ }
prc->cfg = cfg;
prc->peer_id = peer_id;
prc->op_id = op_id;
prc->client = client;
- GNUNET_CONTAINER_DLL_insert_tail (prc_head,
- prc_tail,
- prc);
- GNUNET_SERVICE_client_continue (client);
+ GNUNET_CONTAINER_DLL_insert_tail(prc_head,
+ prc_tail,
+ prc);
+ GNUNET_SERVICE_client_continue(client);
}
* Frees the ManageServiceContext queue
*/
void
-GST_free_mctxq ()
+GST_free_mctxq()
{
while (NULL != mctx_head)
- cleanup_mctx (mctx_head);
+ cleanup_mctx(mctx_head);
}
* @return a string interpretation of the request status
*/
static const char *
-arm_req_string (enum GNUNET_ARM_RequestStatus rs)
+arm_req_string(enum GNUNET_ARM_RequestStatus rs)
{
switch (rs)
- {
- case GNUNET_ARM_REQUEST_SENT_OK:
- return _("Message was sent successfully");
- case GNUNET_ARM_REQUEST_DISCONNECTED:
- return _("We disconnected from ARM before we could send a request");
- }
+ {
+ case GNUNET_ARM_REQUEST_SENT_OK:
+ return _("Message was sent successfully");
+
+ case GNUNET_ARM_REQUEST_DISCONNECTED:
+ return _("We disconnected from ARM before we could send a request");
+ }
return _("Unknown request status");
}
* @return a string interpretation
*/
static const char *
-arm_ret_string (enum GNUNET_ARM_Result result)
+arm_ret_string(enum GNUNET_ARM_Result result)
{
switch (result)
- {
- case GNUNET_ARM_RESULT_STOPPED:
- return _("%s is stopped");
- case GNUNET_ARM_RESULT_STARTING:
- return _("%s is starting");
- case GNUNET_ARM_RESULT_STOPPING:
- return _("%s is stopping");
- case GNUNET_ARM_RESULT_IS_STARTING_ALREADY:
- return _("%s is starting already");
- case GNUNET_ARM_RESULT_IS_STOPPING_ALREADY:
- return _("%s is stopping already");
- case GNUNET_ARM_RESULT_IS_STARTED_ALREADY:
- return _("%s is started already");
- case GNUNET_ARM_RESULT_IS_STOPPED_ALREADY:
- return _("%s is stopped already");
- case GNUNET_ARM_RESULT_IS_NOT_KNOWN:
- return _("%s service is not known to ARM");
- case GNUNET_ARM_RESULT_START_FAILED:
- return _("%s service failed to start");
- case GNUNET_ARM_RESULT_IN_SHUTDOWN:
- return _("%s service can't be started because ARM is shutting down");
- }
+ {
+ case GNUNET_ARM_RESULT_STOPPED:
+ return _("%s is stopped");
+
+ case GNUNET_ARM_RESULT_STARTING:
+ return _("%s is starting");
+
+ case GNUNET_ARM_RESULT_STOPPING:
+ return _("%s is stopping");
+
+ case GNUNET_ARM_RESULT_IS_STARTING_ALREADY:
+ return _("%s is starting already");
+
+ case GNUNET_ARM_RESULT_IS_STOPPING_ALREADY:
+ return _("%s is stopping already");
+
+ case GNUNET_ARM_RESULT_IS_STARTED_ALREADY:
+ return _("%s is started already");
+
+ case GNUNET_ARM_RESULT_IS_STOPPED_ALREADY:
+ return _("%s is stopped already");
+
+ case GNUNET_ARM_RESULT_IS_NOT_KNOWN:
+ return _("%s service is not known to ARM");
+
+ case GNUNET_ARM_RESULT_START_FAILED:
+ return _("%s service failed to start");
+
+ case GNUNET_ARM_RESULT_IN_SHUTDOWN:
+ return _("%s service can't be started because ARM is shutting down");
+ }
return _("%.s Unknown result code.");
}
* @param result result of the operation
*/
static void
-service_manage_result_cb (void *cls,
- enum GNUNET_ARM_RequestStatus rs,
- enum GNUNET_ARM_Result result)
+service_manage_result_cb(void *cls,
+ enum GNUNET_ARM_RequestStatus rs,
+ enum GNUNET_ARM_Result result)
{
struct ManageServiceContext *mctx = cls;
char *emsg;
if (GNUNET_YES == mctx->expired)
return;
if (GNUNET_ARM_REQUEST_SENT_OK != rs)
- {
- GNUNET_asprintf (&emsg,
- "Error communicating with Peer %u's ARM: %s",
- mctx->peer->id,
- arm_req_string (rs));
- goto ret;
- }
+ {
+ GNUNET_asprintf(&emsg,
+ "Error communicating with Peer %u's ARM: %s",
+ mctx->peer->id,
+ arm_req_string(rs));
+ goto ret;
+ }
if (1 == mctx->start)
goto service_start_check;
- if (! ((GNUNET_ARM_RESULT_STOPPED == result)
- || (GNUNET_ARM_RESULT_STOPPING == result)
- || (GNUNET_ARM_RESULT_IS_STOPPING_ALREADY == result)
- || (GNUNET_ARM_RESULT_IS_STOPPED_ALREADY == result)) )
- {
- /* stopping a service failed */
- GNUNET_asprintf (&emsg,
- arm_ret_string (result),
- mctx->service);
- goto ret;
- }
+ if (!((GNUNET_ARM_RESULT_STOPPED == result)
+ || (GNUNET_ARM_RESULT_STOPPING == result)
+ || (GNUNET_ARM_RESULT_IS_STOPPING_ALREADY == result)
+ || (GNUNET_ARM_RESULT_IS_STOPPED_ALREADY == result)))
+ {
+ /* stopping a service failed */
+ GNUNET_asprintf(&emsg,
+ arm_ret_string(result),
+ mctx->service);
+ goto ret;
+ }
/* service stopped successfully */
goto ret;
- service_start_check:
- if (! ((GNUNET_ARM_RESULT_STARTING == result)
- || (GNUNET_ARM_RESULT_IS_STARTING_ALREADY == result)
- || (GNUNET_ARM_RESULT_IS_STARTED_ALREADY == result)) )
- {
- /* starting a service failed */
- GNUNET_asprintf (&emsg,
- arm_ret_string (result),
- mctx->service);
- goto ret;
- }
+service_start_check:
+ if (!((GNUNET_ARM_RESULT_STARTING == result)
+ || (GNUNET_ARM_RESULT_IS_STARTING_ALREADY == result)
+ || (GNUNET_ARM_RESULT_IS_STARTED_ALREADY == result)))
+ {
+ /* starting a service failed */
+ GNUNET_asprintf(&emsg,
+ arm_ret_string(result),
+ mctx->service);
+ goto ret;
+ }
/* service started successfully */
- ret:
+ret:
if (NULL != emsg)
- {
- LOG_DEBUG ("%s\n", emsg);
- GST_send_operation_fail_msg (mctx->client,
- mctx->op_id,
- emsg);
- }
+ {
+ LOG_DEBUG("%s\n", emsg);
+ GST_send_operation_fail_msg(mctx->client,
+ mctx->op_id,
+ emsg);
+ }
else
- GST_send_operation_success_msg (mctx->client,
- mctx->op_id);
- GNUNET_free_non_null (emsg);
- cleanup_mctx (mctx);
+ GST_send_operation_success_msg(mctx->client,
+ mctx->op_id);
+ GNUNET_free_non_null(emsg);
+ cleanup_mctx(mctx);
}
* @return #GNUNET_OK if @a msg is well-formed
*/
int
-check_manage_peer_service (void *cls,
- const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg)
+check_manage_peer_service(void *cls,
+ const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg)
{
uint16_t msize;
const char* service;
- msize = ntohs (msg->header.size);
- service = (const char *) &msg[1];
+ msize = ntohs(msg->header.size);
+ service = (const char *)&msg[1];
if ('\0' != service[msize - sizeof
(struct GNUNET_TESTBED_ManagePeerServiceMessage) - 1])
- {
- GNUNET_break_op (0);
- return GNUNET_SYSERR;
- }
+ {
+ GNUNET_break_op(0);
+ return GNUNET_SYSERR;
+ }
if (1 < msg->start)
- {
- GNUNET_break_op (0);
- return GNUNET_SYSERR;
- }
+ {
+ GNUNET_break_op(0);
+ return GNUNET_SYSERR;
+ }
return GNUNET_OK;
}
* @param msg the actual message
*/
void
-handle_manage_peer_service (void *cls,
- const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg)
+handle_manage_peer_service(void *cls,
+ const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
const char* service;
uint64_t op_id;
uint32_t peer_id;
- service = (const char *) &msg[1];
- peer_id = ntohl (msg->peer_id);
- op_id = GNUNET_ntohll (msg->operation_id);
- LOG_DEBUG ("Received request to manage service %s on peer %u\n",
- service, (unsigned int) peer_id);
+ service = (const char *)&msg[1];
+ peer_id = ntohl(msg->peer_id);
+ op_id = GNUNET_ntohll(msg->operation_id);
+ LOG_DEBUG("Received request to manage service %s on peer %u\n",
+ service, (unsigned int)peer_id);
if ((GST_peer_list_size <= peer_id)
|| (NULL == (peer = GST_peer_list[peer_id])))
- {
- GNUNET_asprintf (&emsg, "Asked to manage service of a non existent peer "
- "with id: %u", peer_id);
- goto err_ret;
- }
- if (0 == strcasecmp ("arm", service))
- {
- emsg = GNUNET_strdup ("Cannot start/stop peer's ARM service. "
- "Use peer start/stop for that");
- goto err_ret;
- }
+ {
+ GNUNET_asprintf(&emsg, "Asked to manage service of a non existent peer "
+ "with id: %u", peer_id);
+ goto err_ret;
+ }
+ if (0 == strcasecmp("arm", service))
+ {
+ emsg = GNUNET_strdup("Cannot start/stop peer's ARM service. "
+ "Use peer start/stop for that");
+ goto err_ret;
+ }
if (GNUNET_YES == peer->is_remote)
- {
- /* Forward the destory message to sub controller */
- fopc = GNUNET_new (struct ForwardedOperationContext);
- fopc->client = client;
- fopc->cls = peer;
- fopc->type = OP_MANAGE_SERVICE;
- fopc->operation_id = op_id;
- fopc->opc =
- GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.
- slave->controller,
- fopc->operation_id,
- &msg->header,
- &GST_forwarded_operation_reply_relay,
- fopc);
- fopc->timeout_task =
- GNUNET_SCHEDULER_add_delayed (GST_timeout,
- &GST_forwarded_operation_timeout,
- fopc);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fopc);
- GNUNET_SERVICE_client_continue (client);
- return;
- }
+ {
+ /* Forward the destory message to sub controller */
+ fopc = GNUNET_new(struct ForwardedOperationContext);
+ fopc->client = client;
+ fopc->cls = peer;
+ fopc->type = OP_MANAGE_SERVICE;
+ fopc->operation_id = op_id;
+ fopc->opc =
+ GNUNET_TESTBED_forward_operation_msg_(peer->details.remote.
+ slave->controller,
+ fopc->operation_id,
+ &msg->header,
+ &GST_forwarded_operation_reply_relay,
+ fopc);
+ fopc->timeout_task =
+ GNUNET_SCHEDULER_add_delayed(GST_timeout,
+ &GST_forwarded_operation_timeout,
+ fopc);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fopc);
+ GNUNET_SERVICE_client_continue(client);
+ return;
+ }
if (GNUNET_NO == peer->details.local.is_running)
- {
- emsg = GNUNET_strdup ("Peer not running\n");
- goto err_ret;
- }
+ {
+ emsg = GNUNET_strdup("Peer not running\n");
+ goto err_ret;
+ }
if ((0 != peer->reference_cnt)
- && ( (0 == strcasecmp ("core", service))
- || (0 == strcasecmp ("transport", service)) ) )
- {
- GNUNET_asprintf (&emsg, "Cannot stop %s service of peer with id: %u "
- "since it is required by existing operations",
- service, peer_id);
- goto err_ret;
- }
- ah = GNUNET_ARM_connect (peer->details.local.cfg, NULL, NULL);
+ && ((0 == strcasecmp("core", service))
+ || (0 == strcasecmp("transport", service))))
+ {
+ GNUNET_asprintf(&emsg, "Cannot stop %s service of peer with id: %u "
+ "since it is required by existing operations",
+ service, peer_id);
+ goto err_ret;
+ }
+ ah = GNUNET_ARM_connect(peer->details.local.cfg, NULL, NULL);
if (NULL == ah)
- {
- GNUNET_asprintf (&emsg,
- "Cannot connect to ARM service of peer with id: %u",
- peer_id);
- goto err_ret;
- }
- mctx = GNUNET_new (struct ManageServiceContext);
+ {
+ GNUNET_asprintf(&emsg,
+ "Cannot connect to ARM service of peer with id: %u",
+ peer_id);
+ goto err_ret;
+ }
+ mctx = GNUNET_new(struct ManageServiceContext);
mctx->peer = peer;
peer->reference_cnt++;
mctx->op_id = op_id;
mctx->ah = ah;
mctx->client = client;
mctx->start = msg->start;
- mctx->service = GNUNET_strdup (service);
- GNUNET_CONTAINER_DLL_insert_tail (mctx_head,
- mctx_tail,
- mctx);
+ mctx->service = GNUNET_strdup(service);
+ GNUNET_CONTAINER_DLL_insert_tail(mctx_head,
+ mctx_tail,
+ mctx);
if (1 == mctx->start)
- GNUNET_ARM_request_service_start (mctx->ah,
- service,
- GNUNET_OS_INHERIT_STD_ERR,
- &service_manage_result_cb,
- mctx);
- else
- GNUNET_ARM_request_service_stop (mctx->ah, service,
+ GNUNET_ARM_request_service_start(mctx->ah,
+ service,
+ GNUNET_OS_INHERIT_STD_ERR,
&service_manage_result_cb,
mctx);
- GNUNET_SERVICE_client_continue (client);
+ else
+ GNUNET_ARM_request_service_stop(mctx->ah, service,
+ &service_manage_result_cb,
+ mctx);
+ GNUNET_SERVICE_client_continue(client);
return;
- err_ret:
- LOG (GNUNET_ERROR_TYPE_ERROR, "%s\n", emsg);
- GST_send_operation_fail_msg (client, op_id, emsg);
- GNUNET_free (emsg);
- GNUNET_SERVICE_client_continue (client);
+err_ret:
+ LOG(GNUNET_ERROR_TYPE_ERROR, "%s\n", emsg);
+ GST_send_operation_fail_msg(client, op_id, emsg);
+ GNUNET_free(emsg);
+ GNUNET_SERVICE_client_continue(client);
}
* Stops and destroys all peers
*/
void
-GST_destroy_peers ()
+GST_destroy_peers()
{
struct Peer *peer;
unsigned int id;
if (NULL == GST_peer_list)
return;
for (id = 0; id < GST_peer_list_size; id++)
- {
- peer = GST_peer_list[id];
- if (NULL == peer)
- continue;
- /* If destroy flag is set it means that this peer should have been
- * destroyed by a context which we destroy before */
- GNUNET_break (GNUNET_NO == peer->destroy_flag);
- /* counter should be zero as we free all contexts before */
- GNUNET_break (0 == peer->reference_cnt);
- if ((GNUNET_NO == peer->is_remote) &&
- (GNUNET_YES == peer->details.local.is_running))
- GNUNET_TESTING_peer_kill (peer->details.local.peer);
- }
+ {
+ peer = GST_peer_list[id];
+ if (NULL == peer)
+ continue;
+ /* If destroy flag is set it means that this peer should have been
+ * destroyed by a context which we destroy before */
+ GNUNET_break(GNUNET_NO == peer->destroy_flag);
+ /* counter should be zero as we free all contexts before */
+ GNUNET_break(0 == peer->reference_cnt);
+ if ((GNUNET_NO == peer->is_remote) &&
+ (GNUNET_YES == peer->details.local.is_running))
+ GNUNET_TESTING_peer_kill(peer->details.local.peer);
+ }
for (id = 0; id < GST_peer_list_size; id++)
- {
- peer = GST_peer_list[id];
- if (NULL == peer)
- continue;
- if (GNUNET_NO == peer->is_remote)
{
- if (GNUNET_YES == peer->details.local.is_running)
- GNUNET_TESTING_peer_wait (peer->details.local.peer);
- GNUNET_TESTING_peer_destroy (peer->details.local.peer);
- GNUNET_CONFIGURATION_destroy (peer->details.local.cfg);
+ peer = GST_peer_list[id];
+ if (NULL == peer)
+ continue;
+ if (GNUNET_NO == peer->is_remote)
+ {
+ if (GNUNET_YES == peer->details.local.is_running)
+ GNUNET_TESTING_peer_wait(peer->details.local.peer);
+ GNUNET_TESTING_peer_destroy(peer->details.local.peer);
+ GNUNET_CONFIGURATION_destroy(peer->details.local.cfg);
+ }
+ GNUNET_free(peer);
}
- GNUNET_free (peer);
- }
- GNUNET_free_non_null (GST_peer_list);
+ GNUNET_free_non_null(GST_peer_list);
GST_peer_list = NULL;
GST_peer_list_size = 0;
}
* @param msg the message to relay
*/
static void
-shutdown_peers_reply_cb (void *cls,
- const struct GNUNET_MessageHeader *msg)
+shutdown_peers_reply_cb(void *cls,
+ const struct GNUNET_MessageHeader *msg)
{
struct ForwardedOperationContext *fo_ctxt = cls;
struct HandlerContext_ShutdownPeers *hc;
hc = fo_ctxt->cls;
- GNUNET_assert (0 < hc->nslaves);
+ GNUNET_assert(0 < hc->nslaves);
hc->nslaves--;
if (GNUNET_MESSAGE_TYPE_TESTBED_GENERIC_OPERATION_SUCCESS !=
- ntohs (msg->type))
+ ntohs(msg->type))
hc->timeout = GNUNET_YES;
if (0 == hc->nslaves)
- {
- if (GNUNET_YES == hc->timeout)
- GST_send_operation_fail_msg (fo_ctxt->client,
- fo_ctxt->operation_id,
- "Timeout at a slave controller");
- else
- GST_send_operation_success_msg (fo_ctxt->client,
- fo_ctxt->operation_id);
- GNUNET_free (hc);
- hc = NULL;
- }
- GNUNET_CONTAINER_DLL_remove (fopcq_head,
- fopcq_tail,
- fo_ctxt);
- GNUNET_free (fo_ctxt);
+ {
+ if (GNUNET_YES == hc->timeout)
+ GST_send_operation_fail_msg(fo_ctxt->client,
+ fo_ctxt->operation_id,
+ "Timeout at a slave controller");
+ else
+ GST_send_operation_success_msg(fo_ctxt->client,
+ fo_ctxt->operation_id);
+ GNUNET_free(hc);
+ hc = NULL;
+ }
+ GNUNET_CONTAINER_DLL_remove(fopcq_head,
+ fopcq_tail,
+ fo_ctxt);
+ GNUNET_free(fo_ctxt);
}
* @param msg the actual message
*/
void
-handle_shutdown_peers (void *cls,
- const struct GNUNET_TESTBED_ShutdownPeersMessage *msg)
+handle_shutdown_peers(void *cls,
+ const struct GNUNET_TESTBED_ShutdownPeersMessage *msg)
{
struct GNUNET_SERVICE_Client *client = cls;
struct HandlerContext_ShutdownPeers *hc;
uint64_t op_id;
unsigned int cnt;
- LOG_DEBUG ("Received SHUTDOWN_PEERS\n");
- /* Stop and destroy all peers */
- GST_free_mctxq ();
- GST_free_occq ();
- GST_free_roccq ();
- GST_clear_fopcq ();
+ LOG_DEBUG("Received SHUTDOWN_PEERS\n");
+ /* Stop and destroy all peers */
+ GST_free_mctxq();
+ GST_free_occq();
+ GST_free_roccq();
+ GST_clear_fopcq();
/* Forward to all slaves which we have started */
- op_id = GNUNET_ntohll (msg->operation_id);
- hc = GNUNET_new (struct HandlerContext_ShutdownPeers);
+ op_id = GNUNET_ntohll(msg->operation_id);
+ hc = GNUNET_new(struct HandlerContext_ShutdownPeers);
/* FIXME: have a better implementation where we track which slaves are
started by this controller */
for (cnt = 0; cnt < GST_slave_list_size; cnt++)
- {
- slave = GST_slave_list[cnt];
- if (NULL == slave)
- continue;
- if (NULL == slave->controller_proc) /* We didn't start the slave */
- continue;
- LOG_DEBUG ("Forwarding SHUTDOWN_PEERS\n");
- hc->nslaves++;
- fo_ctxt = GNUNET_new (struct ForwardedOperationContext);
- fo_ctxt->client = client;
- fo_ctxt->operation_id = op_id;
- fo_ctxt->cls = hc;
- fo_ctxt->type = OP_SHUTDOWN_PEERS;
- fo_ctxt->opc =
- GNUNET_TESTBED_forward_operation_msg_ (slave->controller,
- fo_ctxt->operation_id,
- &msg->header,
- shutdown_peers_reply_cb,
- fo_ctxt);
- GNUNET_CONTAINER_DLL_insert_tail (fopcq_head,
- fopcq_tail,
- fo_ctxt);
- }
- LOG_DEBUG ("Shutting down peers\n");
- GST_destroy_peers ();
+ {
+ slave = GST_slave_list[cnt];
+ if (NULL == slave)
+ continue;
+ if (NULL == slave->controller_proc) /* We didn't start the slave */
+ continue;
+ LOG_DEBUG("Forwarding SHUTDOWN_PEERS\n");
+ hc->nslaves++;
+ fo_ctxt = GNUNET_new(struct ForwardedOperationContext);
+ fo_ctxt->client = client;
+ fo_ctxt->operation_id = op_id;
+ fo_ctxt->cls = hc;
+ fo_ctxt->type = OP_SHUTDOWN_PEERS;
+ fo_ctxt->opc =
+ GNUNET_TESTBED_forward_operation_msg_(slave->controller,
+ fo_ctxt->operation_id,
+ &msg->header,
+ shutdown_peers_reply_cb,
+ fo_ctxt);
+ GNUNET_CONTAINER_DLL_insert_tail(fopcq_head,
+ fopcq_tail,
+ fo_ctxt);
+ }
+ LOG_DEBUG("Shutting down peers\n");
+ GST_destroy_peers();
if (0 == hc->nslaves)
- {
- GST_send_operation_success_msg (client,
- op_id);
- GNUNET_free (hc);
- }
- GNUNET_SERVICE_client_continue (client);
+ {
+ GST_send_operation_success_msg(client,
+ op_id);
+ GNUNET_free(hc);
+ }
+ GNUNET_SERVICE_client_continue(client);
}
projects / oweals / gnunet.git / blobdiff