aboutsummaryrefslogtreecommitdiff
path: root/src/testbed/gnunet-service-testbed_oc.c
diff options
context:
space:
mode:
authorSree Harsha Totakura <totakura@in.tum.de>2013-08-15 16:28:50 +0000
committerSree Harsha Totakura <totakura@in.tum.de>2013-08-15 16:28:50 +0000
commitd025c2395b5696bc93d71fc3a81e19122c39d784 (patch)
tree949127d87a008184f4448c714f55bb81baf10763 /src/testbed/gnunet-service-testbed_oc.c
parent356d73f3e59d50ab3aeee64d6e5384089428747b (diff)
downloadgnunet-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.c14
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,