aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_api_manipulation_send_tcp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/test_transport_api_manipulation_send_tcp.c')
-rw-r--r--src/transport/test_transport_api_manipulation_send_tcp.c20
1 files changed, 10 insertions, 10 deletions
diff --git a/src/transport/test_transport_api_manipulation_send_tcp.c b/src/transport/test_transport_api_manipulation_send_tcp.c
index 95a6b5140..fbb7ccbdb 100644
--- a/src/transport/test_transport_api_manipulation_send_tcp.c
+++ b/src/transport/test_transport_api_manipulation_send_tcp.c
@@ -78,11 +78,11 @@ sendtask (void *cls)
78 { 78 {
79 memset (&prop, 0, sizeof (prop)); 79 memset (&prop, 0, sizeof (prop));
80 delay = GNUNET_TIME_UNIT_SECONDS; 80 delay = GNUNET_TIME_UNIT_SECONDS;
81 GNUNET_TRANSPORT_set_traffic_metric (ccc->p[0]->th, 81 GNUNET_TRANSPORT_manipulation_set (ccc->p[0]->tmh,
82 &ccc->p[1]->id, 82 &ccc->p[1]->id,
83 &prop, 83 &prop,
84 GNUNET_TIME_UNIT_ZERO, 84 GNUNET_TIME_UNIT_ZERO,
85 delay); 85 delay);
86 start_delayed = GNUNET_TIME_absolute_get(); 86 start_delayed = GNUNET_TIME_absolute_get();
87 } 87 }
88 GNUNET_TRANSPORT_TESTING_large_send (sc); 88 GNUNET_TRANSPORT_TESTING_large_send (sc);
@@ -93,7 +93,7 @@ static void
93notify_receive (void *cls, 93notify_receive (void *cls,
94 struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, 94 struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver,
95 const struct GNUNET_PeerIdentity *sender, 95 const struct GNUNET_PeerIdentity *sender,
96 const struct GNUNET_MessageHeader *message) 96 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
97{ 97{
98 { 98 {
99 char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id)); 99 char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id));
@@ -102,14 +102,14 @@ notify_receive (void *cls,
102 "Peer %u (`%s') received message of type %d and size %u size from peer %s)!\n", 102 "Peer %u (`%s') received message of type %d and size %u size from peer %s)!\n",
103 receiver->no, 103 receiver->no,
104 ps, 104 ps,
105 ntohs (message->type), 105 ntohs (message->header.type),
106 ntohs (message->size), 106 ntohs (message->header.size),
107 GNUNET_i2s (sender)); 107 GNUNET_i2s (sender));
108 GNUNET_free (ps); 108 GNUNET_free (ps);
109 } 109 }
110 110
111 if ( (GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE != ntohs (message->type)) || 111 if ( (GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE != ntohs (message->header.type)) ||
112 (GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE != ntohs (message->size)) ) 112 (GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE != ntohs (message->header.size)) )
113 { 113 {
114 GNUNET_break (0); 114 GNUNET_break (0);
115 ccc->global_ret = GNUNET_SYSERR; 115 ccc->global_ret = GNUNET_SYSERR;