diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-07-25 00:30:00 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-07-25 00:30:00 +0000 |
commit | d0701eb6315fc3f5aca74415bbf0ff7418409f87 (patch) | |
tree | fcacb97bbcca542ce9493001c825fd265cb8a801 /src/transport/test_transport_api_restart_reconnect.c | |
parent | 9bfb8bff3fd253407530c76c7590b33bacf033f1 (diff) | |
download | gnunet-d0701eb6315fc3f5aca74415bbf0ff7418409f87.tar.gz gnunet-d0701eb6315fc3f5aca74415bbf0ff7418409f87.zip |
switching transport tests to new MQ-based transport API
Diffstat (limited to 'src/transport/test_transport_api_restart_reconnect.c')
-rw-r--r-- | src/transport/test_transport_api_restart_reconnect.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/transport/test_transport_api_restart_reconnect.c b/src/transport/test_transport_api_restart_reconnect.c index 6fd969918..477b8b54d 100644 --- a/src/transport/test_transport_api_restart_reconnect.c +++ b/src/transport/test_transport_api_restart_reconnect.c | |||
@@ -58,11 +58,11 @@ custom_shutdown (void *cls) | |||
58 | 58 | ||
59 | 59 | ||
60 | static void | 60 | static void |
61 | restart_cb (struct GNUNET_TRANSPORT_TESTING_PeerContext *p, | 61 | restart_cb (void *cls) |
62 | void *cls) | ||
63 | { | 62 | { |
64 | static unsigned int c; | 63 | static unsigned int c; |
65 | 64 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls; | |
65 | |||
66 | c++; | 66 | c++; |
67 | if ( (2 != c) && | 67 | if ( (2 != c) && |
68 | (NULL != strstr (ccc->test_name, | 68 | (NULL != strstr (ccc->test_name, |
@@ -96,7 +96,7 @@ static void | |||
96 | notify_receive (void *cls, | 96 | notify_receive (void *cls, |
97 | struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, | 97 | struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, |
98 | const struct GNUNET_PeerIdentity *sender, | 98 | const struct GNUNET_PeerIdentity *sender, |
99 | const struct GNUNET_MessageHeader *message) | 99 | const struct GNUNET_TRANSPORT_TESTING_TestMessage *message) |
100 | { | 100 | { |
101 | { | 101 | { |
102 | char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id)); | 102 | char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id)); |
@@ -105,13 +105,13 @@ notify_receive (void *cls, | |||
105 | "Peer %u (`%s') received message of type %d and size %u size from peer %s!\n", | 105 | "Peer %u (`%s') received message of type %d and size %u size from peer %s!\n", |
106 | receiver->no, | 106 | receiver->no, |
107 | ps, | 107 | ps, |
108 | ntohs (message->type), | 108 | ntohs (message->header.type), |
109 | ntohs (message->size), | 109 | ntohs (message->header.size), |
110 | GNUNET_i2s (sender)); | 110 | GNUNET_i2s (sender)); |
111 | GNUNET_free (ps); | 111 | GNUNET_free (ps); |
112 | } | 112 | } |
113 | if ( (GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE == ntohs (message->type)) && | 113 | if ( (GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE == ntohs (message->header.type)) && |
114 | (sizeof (struct GNUNET_TRANSPORT_TESTING_TestMessage) == ntohs (message->size)) ) | 114 | (sizeof (struct GNUNET_TRANSPORT_TESTING_TestMessage) == ntohs (message->header.size)) ) |
115 | { | 115 | { |
116 | if (GNUNET_NO == restarted) | 116 | if (GNUNET_NO == restarted) |
117 | { | 117 | { |