diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2013-08-15 16:28:50 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2013-08-15 16:28:50 +0000 |
commit | d025c2395b5696bc93d71fc3a81e19122c39d784 (patch) | |
tree | 949127d87a008184f4448c714f55bb81baf10763 /src/testbed/gnunet-service-testbed_oc.c | |
parent | 356d73f3e59d50ab3aeee64d6e5384089428747b (diff) | |
download | gnunet-d025c2395b5696bc93d71fc3a81e19122c39d784.tar.gz gnunet-d025c2395b5696bc93d71fc3a81e19122c39d784.zip |
- rename PEER_GET_CONFIGURATION to PEER_GET_INFORMATION
Diffstat (limited to 'src/testbed/gnunet-service-testbed_oc.c')
-rw-r--r-- | src/testbed/gnunet-service-testbed_oc.c | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/src/testbed/gnunet-service-testbed_oc.c b/src/testbed/gnunet-service-testbed_oc.c index 455de4178..06f35e865 100644 --- a/src/testbed/gnunet-service-testbed_oc.c +++ b/src/testbed/gnunet-service-testbed_oc.c | |||
@@ -1112,7 +1112,7 @@ overlay_connect_get_config (void *cls, const struct GNUNET_MessageHeader *msg) | |||
1112 | rp2c = &occ->p2ctx.remote; | 1112 | rp2c = &occ->p2ctx.remote; |
1113 | rp2c->opc = NULL; | 1113 | rp2c->opc = NULL; |
1114 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != occ->timeout_task); | 1114 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != occ->timeout_task); |
1115 | if (GNUNET_MESSAGE_TYPE_TESTBED_PEER_CONFIGURATION != ntohs (msg->type)) | 1115 | if (GNUNET_MESSAGE_TYPE_TESTBED_PEER_INFORMATION != ntohs (msg->type)) |
1116 | { | 1116 | { |
1117 | GNUNET_SCHEDULER_cancel (occ->timeout_task); | 1117 | GNUNET_SCHEDULER_cancel (occ->timeout_task); |
1118 | occ->timeout_task = | 1118 | occ->timeout_task = |
@@ -1353,7 +1353,7 @@ p2_controller_connect_cb (void *cls, struct GNUNET_TESTBED_Controller *c) | |||
1353 | cmsg.header.size = | 1353 | cmsg.header.size = |
1354 | htons (sizeof (struct GNUNET_TESTBED_PeerGetConfigurationMessage)); | 1354 | htons (sizeof (struct GNUNET_TESTBED_PeerGetConfigurationMessage)); |
1355 | cmsg.header.type = | 1355 | cmsg.header.type = |
1356 | htons (GNUNET_MESSAGE_TYPE_TESTBED_GET_PEER_CONFIGURATION); | 1356 | htons (GNUNET_MESSAGE_TYPE_TESTBED_GET_PEER_INFORMATION); |
1357 | cmsg.peer_id = htonl (occ->other_peer_id); | 1357 | cmsg.peer_id = htonl (occ->other_peer_id); |
1358 | cmsg.operation_id = GNUNET_htonll (occ->op_id); | 1358 | cmsg.operation_id = GNUNET_htonll (occ->op_id); |
1359 | rp2c->opc = | 1359 | rp2c->opc = |
@@ -1690,6 +1690,8 @@ GST_handle_remote_overlay_connect (void *cls, | |||
1690 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg; | 1690 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg; |
1691 | struct RemoteOverlayConnectCtx *rocc; | 1691 | struct RemoteOverlayConnectCtx *rocc; |
1692 | struct Peer *peer; | 1692 | struct Peer *peer; |
1693 | struct GNUNET_PeerIdentity pid; | ||
1694 | static char pid_str[16]; | ||
1693 | uint32_t peer_id; | 1695 | uint32_t peer_id; |
1694 | uint16_t msize; | 1696 | uint16_t msize; |
1695 | uint16_t hsize; | 1697 | uint16_t hsize; |
@@ -1740,13 +1742,15 @@ GST_handle_remote_overlay_connect (void *cls, | |||
1740 | GNUNET_CONTAINER_DLL_insert_tail (roccq_head, roccq_tail, rocc); | 1742 | GNUNET_CONTAINER_DLL_insert_tail (roccq_head, roccq_tail, rocc); |
1741 | memcpy (&rocc->a_id, &msg->peer_identity, | 1743 | memcpy (&rocc->a_id, &msg->peer_identity, |
1742 | sizeof (struct GNUNET_PeerIdentity)); | 1744 | sizeof (struct GNUNET_PeerIdentity)); |
1743 | LOG_DEBUG ("Received request for overlay connection with op_id: 0x%llx " | 1745 | GNUNET_TESTING_peer_get_identity (peer->details.local.peer, &pid); |
1744 | "from local peer %u to peer %4s with hello size: %u\n", | 1746 | (void) strncpy (pid_str, GNUNET_i2s (&pid), 15); |
1745 | rocc->op_id, peer_id, GNUNET_i2s (&rocc->a_id), hsize); | 1747 | LOG_DEBUG ("0x%llx: Remote overlay connect %4s to peer %4s with hello size: %u\n", |
1748 | rocc->op_id, pid_str, GNUNET_i2s (&rocc->a_id), hsize); | ||
1746 | rocc->peer = peer; | 1749 | rocc->peer = peer; |
1747 | rocc->peer->reference_cnt++; | 1750 | rocc->peer->reference_cnt++; |
1748 | rocc->hello = GNUNET_malloc (hsize); | 1751 | rocc->hello = GNUNET_malloc (hsize); |
1749 | memcpy (rocc->hello, msg->hello, hsize); | 1752 | memcpy (rocc->hello, msg->hello, hsize); |
1753 | rocc->tcc.op_id = rocc->op_id; | ||
1750 | rocc->tcc.cgh_th = | 1754 | rocc->tcc.cgh_th = |
1751 | GST_cache_get_handle_transport (peer_id, rocc->peer->details.local.cfg, | 1755 | GST_cache_get_handle_transport (peer_id, rocc->peer->details.local.cfg, |
1752 | &rocc_cache_get_handle_transport_cb, rocc, | 1756 | &rocc_cache_get_handle_transport_cb, rocc, |