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