diff options
Diffstat (limited to 'src/util/test_connection_receive_cancel.c')
-rw-r--r-- | src/util/test_connection_receive_cancel.c | 30 |
1 files changed, 19 insertions, 11 deletions
diff --git a/src/util/test_connection_receive_cancel.c b/src/util/test_connection_receive_cancel.c index 9ec96d8a6..9c0ab699e 100644 --- a/src/util/test_connection_receive_cancel.c +++ b/src/util/test_connection_receive_cancel.c | |||
@@ -60,7 +60,8 @@ open_listen_socket () | |||
60 | GNUNET_assert (desc != NULL); | 60 | GNUNET_assert (desc != NULL); |
61 | if (GNUNET_NETWORK_socket_setsockopt | 61 | if (GNUNET_NETWORK_socket_setsockopt |
62 | (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) != GNUNET_OK) | 62 | (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) != GNUNET_OK) |
63 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK, "setsockopt"); | 63 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK, |
64 | "setsockopt"); | ||
64 | GNUNET_assert (GNUNET_OK == | 65 | GNUNET_assert (GNUNET_OK == |
65 | GNUNET_NETWORK_socket_bind (desc, (const struct sockaddr *) &sa, | 66 | GNUNET_NETWORK_socket_bind (desc, (const struct sockaddr *) &sa, |
66 | sizeof (sa))); | 67 | sizeof (sa))); |
@@ -69,10 +70,13 @@ open_listen_socket () | |||
69 | } | 70 | } |
70 | 71 | ||
71 | 72 | ||
72 | |||
73 | static void | 73 | static void |
74 | dead_receive (void *cls, const void *buf, size_t available, | 74 | dead_receive (void *cls, |
75 | const struct sockaddr *addr, socklen_t addrlen, int errCode) | 75 | const void *buf, |
76 | size_t available, | ||
77 | const struct sockaddr *addr, | ||
78 | socklen_t addrlen, | ||
79 | int errCode) | ||
76 | { | 80 | { |
77 | GNUNET_assert (0); | 81 | GNUNET_assert (0); |
78 | } | 82 | } |
@@ -87,7 +91,8 @@ run_accept_cancel (void *cls) | |||
87 | GNUNET_CONNECTION_destroy (lsock); | 91 | GNUNET_CONNECTION_destroy (lsock); |
88 | GNUNET_CONNECTION_receive (asock, 1024, | 92 | GNUNET_CONNECTION_receive (asock, 1024, |
89 | GNUNET_TIME_relative_multiply | 93 | GNUNET_TIME_relative_multiply |
90 | (GNUNET_TIME_UNIT_SECONDS, 5), &dead_receive, cls); | 94 | (GNUNET_TIME_UNIT_SECONDS, 5), |
95 | &dead_receive, cls); | ||
91 | } | 96 | } |
92 | 97 | ||
93 | 98 | ||
@@ -103,7 +108,6 @@ receive_cancel_task (void *cls) | |||
103 | } | 108 | } |
104 | 109 | ||
105 | 110 | ||
106 | |||
107 | static void | 111 | static void |
108 | task_receive_cancel (void *cls) | 112 | task_receive_cancel (void *cls) |
109 | { | 113 | { |
@@ -112,14 +116,16 @@ task_receive_cancel (void *cls) | |||
112 | GNUNET_assert (lsock != NULL); | 116 | GNUNET_assert (lsock != NULL); |
113 | csock = GNUNET_CONNECTION_create_from_connect (cfg, "localhost", PORT); | 117 | csock = GNUNET_CONNECTION_create_from_connect (cfg, "localhost", PORT); |
114 | GNUNET_assert (csock != NULL); | 118 | GNUNET_assert (csock != NULL); |
115 | GNUNET_SCHEDULER_add_read_net (GNUNET_TIME_UNIT_FOREVER_REL, ls, | 119 | GNUNET_SCHEDULER_add_read_net (GNUNET_TIME_UNIT_FOREVER_REL, |
116 | &run_accept_cancel, cls); | 120 | ls, |
117 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &receive_cancel_task, | 121 | &run_accept_cancel, |
122 | cls); | ||
123 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, | ||
124 | &receive_cancel_task, | ||
118 | cls); | 125 | cls); |
119 | } | 126 | } |
120 | 127 | ||
121 | 128 | ||
122 | |||
123 | /** | 129 | /** |
124 | * Main method, starts scheduler with task_timeout. | 130 | * Main method, starts scheduler with task_timeout. |
125 | */ | 131 | */ |
@@ -130,7 +136,9 @@ check_receive_cancel () | |||
130 | 136 | ||
131 | ok = 1; | 137 | ok = 1; |
132 | cfg = GNUNET_CONFIGURATION_create (); | 138 | cfg = GNUNET_CONFIGURATION_create (); |
133 | GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME", | 139 | GNUNET_CONFIGURATION_set_value_string (cfg, |
140 | "resolver", | ||
141 | "HOSTNAME", | ||
134 | "localhost"); | 142 | "localhost"); |
135 | GNUNET_SCHEDULER_run (&task_receive_cancel, &ok); | 143 | GNUNET_SCHEDULER_run (&task_receive_cancel, &ok); |
136 | GNUNET_CONFIGURATION_destroy (cfg); | 144 | GNUNET_CONFIGURATION_destroy (cfg); |