diff options
author | t3sserakt <t3ss@posteo.de> | 2020-09-08 13:33:25 +0200 |
---|---|---|
committer | t3sserakt <t3ss@posteo.de> | 2020-09-08 13:33:25 +0200 |
commit | 9e012a7a5c3991d224018b2d390b09d8e32c57ae (patch) | |
tree | d0dafee8f74b2ee71b61782642e96dad76edbf99 /src/transport/test_communicator_basic.c | |
parent | 2c797708b38729effe82328484d67a2be02412ed (diff) | |
download | gnunet-9e012a7a5c3991d224018b2d390b09d8e32c57ae.tar.gz gnunet-9e012a7a5c3991d224018b2d390b09d8e32c57ae.zip |
- fixed socket clean up; added sync between start of service and communicator
Diffstat (limited to 'src/transport/test_communicator_basic.c')
-rw-r--r-- | src/transport/test_communicator_basic.c | 24 |
1 files changed, 20 insertions, 4 deletions
diff --git a/src/transport/test_communicator_basic.c b/src/transport/test_communicator_basic.c index e2d2eb73c..aa02bda93 100644 --- a/src/transport/test_communicator_basic.c +++ b/src/transport/test_communicator_basic.c | |||
@@ -124,6 +124,25 @@ communicator_available_cb (void *cls, | |||
124 | address_prefix); | 124 | address_prefix); |
125 | } | 125 | } |
126 | 126 | ||
127 | static void | ||
128 | open_queue (void *cls) | ||
129 | { | ||
130 | char *address = cls; | ||
131 | |||
132 | if (NULL != tc_hs[PEER_A]->c_mq) | ||
133 | { | ||
134 | queue_est = GNUNET_YES; | ||
135 | GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue (tc_hs[PEER_A], | ||
136 | &peer_id[PEER_B], | ||
137 | address); | ||
138 | } | ||
139 | else | ||
140 | { | ||
141 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, | ||
142 | &open_queue, | ||
143 | address); | ||
144 | } | ||
145 | } | ||
127 | 146 | ||
128 | static void | 147 | static void |
129 | add_address_cb (void *cls, | 148 | add_address_cb (void *cls, |
@@ -144,10 +163,7 @@ add_address_cb (void *cls, | |||
144 | if ((0 == strcmp ((char*) cls, cfg_peers_name[PEER_B])) && | 163 | if ((0 == strcmp ((char*) cls, cfg_peers_name[PEER_B])) && |
145 | (GNUNET_NO == queue_est)) | 164 | (GNUNET_NO == queue_est)) |
146 | { | 165 | { |
147 | queue_est = GNUNET_YES; | 166 | open_queue (address); |
148 | GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue (tc_hs[PEER_A], | ||
149 | &peer_id[PEER_B], | ||
150 | address); | ||
151 | } | 167 | } |
152 | } | 168 | } |
153 | 169 | ||