diff options
Diffstat (limited to 'src/transport/test_transport_api_manipulation_recv_tcp.c')
-rw-r--r-- | src/transport/test_transport_api_manipulation_recv_tcp.c | 20 |
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 | |||
94 | notify_receive (void *cls, | 94 | notify_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; |