aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_connection_receive_cancel.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/test_connection_receive_cancel.c')
-rw-r--r--src/util/test_connection_receive_cancel.c30
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
73static void 73static void
74dead_receive (void *cls, const void *buf, size_t available, 74dead_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
107static void 111static void
108task_receive_cancel (void *cls) 112task_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);