diff options
Diffstat (limited to 'src/testbed/gnunet-service-testbed.c')
-rw-r--r-- | src/testbed/gnunet-service-testbed.c | 18 |
1 files changed, 14 insertions, 4 deletions
diff --git a/src/testbed/gnunet-service-testbed.c b/src/testbed/gnunet-service-testbed.c index d254b2b28..1bd22958e 100644 --- a/src/testbed/gnunet-service-testbed.c +++ b/src/testbed/gnunet-service-testbed.c | |||
@@ -2042,8 +2042,20 @@ handle_peer_get_config (void *cls, struct GNUNET_SERVER_Client *client, | |||
2042 | peer = peer_list[peer_id]; | 2042 | peer = peer_list[peer_id]; |
2043 | if (GNUNET_YES == peer->is_remote) | 2043 | if (GNUNET_YES == peer->is_remote) |
2044 | { | 2044 | { |
2045 | /* FIXME: forward to sub controller */ | 2045 | struct ForwardedOperationContext *fopc; |
2046 | GNUNET_break (0); | 2046 | |
2047 | fopc = GNUNET_malloc (sizeof (struct ForwardedOperationContext)); | ||
2048 | GNUNET_SERVER_client_keep (client); | ||
2049 | fopc->client = client; | ||
2050 | fopc->operation_id = GNUNET_ntohll (msg->operation_id); | ||
2051 | fopc->opc = | ||
2052 | GNUNET_TESTBED_forward_operation_msg_ (peer->details.remote.controller, | ||
2053 | fopc->operation_id, &msg->header, | ||
2054 | &forwarded_operation_reply_relay, | ||
2055 | fopc); | ||
2056 | fopc->timeout_task = | ||
2057 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, &forwarded_operation_timeout, | ||
2058 | fopc); | ||
2047 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 2059 | GNUNET_SERVER_receive_done (client, GNUNET_OK); |
2048 | return; | 2060 | return; |
2049 | } | 2061 | } |
@@ -2683,8 +2695,6 @@ handle_overlay_request_connect (void *cls, struct GNUNET_SERVER_Client *client, | |||
2683 | sizeof (struct GNUNET_PeerIdentity)); | 2695 | sizeof (struct GNUNET_PeerIdentity)); |
2684 | rocc->hello = GNUNET_malloc (hsize); | 2696 | rocc->hello = GNUNET_malloc (hsize); |
2685 | memcpy (rocc->hello, msg->hello, hsize); | 2697 | memcpy (rocc->hello, msg->hello, hsize); |
2686 | /* GNUNET_TRANSPORT_offer_hello (th, msg->hello, NULL, NULL); */ | ||
2687 | /* GNUNET_TRANSPORT_try_connect (th, &msg->peer_identity); */ | ||
2688 | rocc->attempt_connect_task_id = | 2698 | rocc->attempt_connect_task_id = |
2689 | GNUNET_SCHEDULER_add_now (&attempt_connect_task, rocc); | 2699 | GNUNET_SCHEDULER_add_now (&attempt_connect_task, rocc); |
2690 | rocc->timeout_rocc_task_id = | 2700 | rocc->timeout_rocc_task_id = |