diff options
-rw-r--r-- | po/POTFILES.in | 116 | ||||
-rw-r--r-- | src/conversation/test_conversation_api.c | 174 | ||||
-rw-r--r-- | src/conversation/test_conversation_api_reject.c | 96 | ||||
-rw-r--r-- | src/conversation/test_conversation_api_twocalls.c | 205 |
4 files changed, 230 insertions, 361 deletions
diff --git a/po/POTFILES.in b/po/POTFILES.in index 7b6741bf7..fe69ea13e 100644 --- a/po/POTFILES.in +++ b/po/POTFILES.in | |||
@@ -4,14 +4,6 @@ src/arm/arm_monitor_api.c | |||
4 | src/arm/gnunet-arm.c | 4 | src/arm/gnunet-arm.c |
5 | src/arm/gnunet-service-arm.c | 5 | src/arm/gnunet-service-arm.c |
6 | src/arm/mockup-service.c | 6 | src/arm/mockup-service.c |
7 | src/ats-tests/ats-testing-experiment.c | ||
8 | src/ats-tests/ats-testing-log.c | ||
9 | src/ats-tests/ats-testing-preferences.c | ||
10 | src/ats-tests/ats-testing-traffic.c | ||
11 | src/ats-tests/ats-testing.c | ||
12 | src/ats-tests/gnunet-ats-sim.c | ||
13 | src/ats-tests/gnunet-solver-eval.c | ||
14 | src/ats-tool/gnunet-ats.c | ||
15 | src/ats/ats_api2_application.c | 7 | src/ats/ats_api2_application.c |
16 | src/ats/ats_api2_transport.c | 8 | src/ats/ats_api2_transport.c |
17 | src/ats/ats_api_connectivity.c | 9 | src/ats/ats_api_connectivity.c |
@@ -19,10 +11,10 @@ src/ats/ats_api_performance.c | |||
19 | src/ats/ats_api_scanner.c | 11 | src/ats/ats_api_scanner.c |
20 | src/ats/ats_api_scheduling.c | 12 | src/ats/ats_api_scheduling.c |
21 | src/ats/gnunet-ats-solver-eval.c | 13 | src/ats/gnunet-ats-solver-eval.c |
22 | src/ats/gnunet-service-ats-new.c | ||
23 | src/ats/gnunet-service-ats.c | ||
24 | src/ats/gnunet-service-ats_addresses.c | 14 | src/ats/gnunet-service-ats_addresses.c |
15 | src/ats/gnunet-service-ats.c | ||
25 | src/ats/gnunet-service-ats_connectivity.c | 16 | src/ats/gnunet-service-ats_connectivity.c |
17 | src/ats/gnunet-service-ats-new.c | ||
26 | src/ats/gnunet-service-ats_normalization.c | 18 | src/ats/gnunet-service-ats_normalization.c |
27 | src/ats/gnunet-service-ats_performance.c | 19 | src/ats/gnunet-service-ats_performance.c |
28 | src/ats/gnunet-service-ats_plugins.c | 20 | src/ats/gnunet-service-ats_plugins.c |
@@ -34,6 +26,14 @@ src/ats/plugin_ats2_simple.c | |||
34 | src/ats/plugin_ats_mlp.c | 26 | src/ats/plugin_ats_mlp.c |
35 | src/ats/plugin_ats_proportional.c | 27 | src/ats/plugin_ats_proportional.c |
36 | src/ats/plugin_ats_ril.c | 28 | src/ats/plugin_ats_ril.c |
29 | src/ats-tests/ats-testing.c | ||
30 | src/ats-tests/ats-testing-experiment.c | ||
31 | src/ats-tests/ats-testing-log.c | ||
32 | src/ats-tests/ats-testing-preferences.c | ||
33 | src/ats-tests/ats-testing-traffic.c | ||
34 | src/ats-tests/gnunet-ats-sim.c | ||
35 | src/ats-tests/gnunet-solver-eval.c | ||
36 | src/ats-tool/gnunet-ats.c | ||
37 | src/auction/gnunet-auction-create.c | 37 | src/auction/gnunet-auction-create.c |
38 | src/auction/gnunet-auction-info.c | 38 | src/auction/gnunet-auction-info.c |
39 | src/auction/gnunet-auction-join.c | 39 | src/auction/gnunet-auction-join.c |
@@ -50,8 +50,8 @@ src/cadet/cadet_api_list_peers.c | |||
50 | src/cadet/cadet_api_list_tunnels.c | 50 | src/cadet/cadet_api_list_tunnels.c |
51 | src/cadet/cadet_test_lib.c | 51 | src/cadet/cadet_test_lib.c |
52 | src/cadet/desirability_table.c | 52 | src/cadet/desirability_table.c |
53 | src/cadet/gnunet-cadet-profiler.c | ||
54 | src/cadet/gnunet-cadet.c | 53 | src/cadet/gnunet-cadet.c |
54 | src/cadet/gnunet-cadet-profiler.c | ||
55 | src/cadet/gnunet-service-cadet.c | 55 | src/cadet/gnunet-service-cadet.c |
56 | src/cadet/gnunet-service-cadet_channel.c | 56 | src/cadet/gnunet-service-cadet_channel.c |
57 | src/cadet/gnunet-service-cadet_connection.c | 57 | src/cadet/gnunet-service-cadet_connection.c |
@@ -67,15 +67,15 @@ src/consensus/gnunet-service-consensus.c | |||
67 | src/consensus/plugin_block_consensus.c | 67 | src/consensus/plugin_block_consensus.c |
68 | src/conversation/conversation_api.c | 68 | src/conversation/conversation_api.c |
69 | src/conversation/conversation_api_call.c | 69 | src/conversation/conversation_api_call.c |
70 | src/conversation/gnunet-conversation-test.c | ||
71 | src/conversation/gnunet-conversation.c | 70 | src/conversation/gnunet-conversation.c |
72 | src/conversation/gnunet-helper-audio-playback-gst.c | 71 | src/conversation/gnunet-conversation-test.c |
72 | src/conversation/gnunet_gst.c | ||
73 | src/conversation/gnunet_gst_test.c | ||
73 | src/conversation/gnunet-helper-audio-playback.c | 74 | src/conversation/gnunet-helper-audio-playback.c |
74 | src/conversation/gnunet-helper-audio-record-gst.c | 75 | src/conversation/gnunet-helper-audio-playback-gst.c |
75 | src/conversation/gnunet-helper-audio-record.c | 76 | src/conversation/gnunet-helper-audio-record.c |
77 | src/conversation/gnunet-helper-audio-record-gst.c | ||
76 | src/conversation/gnunet-service-conversation.c | 78 | src/conversation/gnunet-service-conversation.c |
77 | src/conversation/gnunet_gst.c | ||
78 | src/conversation/gnunet_gst_test.c | ||
79 | src/conversation/microphone.c | 79 | src/conversation/microphone.c |
80 | src/conversation/plugin_gnsrecord_conversation.c | 80 | src/conversation/plugin_gnsrecord_conversation.c |
81 | src/conversation/speaker.c | 81 | src/conversation/speaker.c |
@@ -112,6 +112,7 @@ src/dht/dht_api.c | |||
112 | src/dht/dht_test_lib.c | 112 | src/dht/dht_test_lib.c |
113 | src/dht/gnunet-dht-get.c | 113 | src/dht/gnunet-dht-get.c |
114 | src/dht/gnunet-dht-monitor.c | 114 | src/dht/gnunet-dht-monitor.c |
115 | src/dht/gnunet_dht_profiler.c | ||
115 | src/dht/gnunet-dht-put.c | 116 | src/dht/gnunet-dht-put.c |
116 | src/dht/gnunet-service-dht.c | 117 | src/dht/gnunet-service-dht.c |
117 | src/dht/gnunet-service-dht_clients.c | 118 | src/dht/gnunet-service-dht_clients.c |
@@ -120,7 +121,6 @@ src/dht/gnunet-service-dht_hello.c | |||
120 | src/dht/gnunet-service-dht_neighbours.c | 121 | src/dht/gnunet-service-dht_neighbours.c |
121 | src/dht/gnunet-service-dht_nse.c | 122 | src/dht/gnunet-service-dht_nse.c |
122 | src/dht/gnunet-service-dht_routing.c | 123 | src/dht/gnunet-service-dht_routing.c |
123 | src/dht/gnunet_dht_profiler.c | ||
124 | src/dht/plugin_block_dht.c | 124 | src/dht/plugin_block_dht.c |
125 | src/dns/dns_api.c | 125 | src/dns/dns_api.c |
126 | src/dns/gnunet-dns-monitor.c | 126 | src/dns/gnunet-dns-monitor.c |
@@ -130,8 +130,8 @@ src/dns/gnunet-service-dns.c | |||
130 | src/dns/gnunet-zonewalk.c | 130 | src/dns/gnunet-zonewalk.c |
131 | src/dns/plugin_block_dns.c | 131 | src/dns/plugin_block_dns.c |
132 | src/exit/gnunet-daemon-exit.c | 132 | src/exit/gnunet-daemon-exit.c |
133 | src/exit/gnunet-helper-exit-windows.c | ||
134 | src/exit/gnunet-helper-exit.c | 133 | src/exit/gnunet-helper-exit.c |
134 | src/exit/gnunet-helper-exit-windows.c | ||
135 | src/fragmentation/defragmentation.c | 135 | src/fragmentation/defragmentation.c |
136 | src/fragmentation/fragmentation.c | 136 | src/fragmentation/fragmentation.c |
137 | src/fs/fs_api.c | 137 | src/fs/fs_api.c |
@@ -156,8 +156,8 @@ src/fs/gnunet-auto-share.c | |||
156 | src/fs/gnunet-daemon-fsprofiler.c | 156 | src/fs/gnunet-daemon-fsprofiler.c |
157 | src/fs/gnunet-directory.c | 157 | src/fs/gnunet-directory.c |
158 | src/fs/gnunet-download.c | 158 | src/fs/gnunet-download.c |
159 | src/fs/gnunet-fs-profiler.c | ||
160 | src/fs/gnunet-fs.c | 159 | src/fs/gnunet-fs.c |
160 | src/fs/gnunet-fs-profiler.c | ||
161 | src/fs/gnunet-helper-fs-publish.c | 161 | src/fs/gnunet-helper-fs-publish.c |
162 | src/fs/gnunet-publish.c | 162 | src/fs/gnunet-publish.c |
163 | src/fs/gnunet-search.c | 163 | src/fs/gnunet-search.c |
@@ -177,10 +177,10 @@ src/gns/gns_tld_api.c | |||
177 | src/gns/gnunet-bcd.c | 177 | src/gns/gnunet-bcd.c |
178 | src/gns/gnunet-dns2gns.c | 178 | src/gns/gnunet-dns2gns.c |
179 | src/gns/gnunet-gns-benchmark.c | 179 | src/gns/gnunet-gns-benchmark.c |
180 | src/gns/gnunet-gns.c | ||
180 | src/gns/gnunet-gns-helper-service-w32.c | 181 | src/gns/gnunet-gns-helper-service-w32.c |
181 | src/gns/gnunet-gns-import.c | 182 | src/gns/gnunet-gns-import.c |
182 | src/gns/gnunet-gns-proxy.c | 183 | src/gns/gnunet-gns-proxy.c |
183 | src/gns/gnunet-gns.c | ||
184 | src/gns/gnunet-service-gns.c | 184 | src/gns/gnunet-service-gns.c |
185 | src/gns/gnunet-service-gns_interceptor.c | 185 | src/gns/gnunet-service-gns_interceptor.c |
186 | src/gns/gnunet-service-gns_resolver.c | 186 | src/gns/gnunet-service-gns_resolver.c |
@@ -189,19 +189,19 @@ src/gns/nss/nss_gns_query.c | |||
189 | src/gns/plugin_block_gns.c | 189 | src/gns/plugin_block_gns.c |
190 | src/gns/plugin_gnsrecord_gns.c | 190 | src/gns/plugin_gnsrecord_gns.c |
191 | src/gns/plugin_rest_gns.c | 191 | src/gns/plugin_rest_gns.c |
192 | src/gns/w32nsp-install.c | ||
193 | src/gns/w32nsp-resolve.c | ||
194 | src/gns/w32nsp-uninstall.c | ||
195 | src/gns/w32nsp.c | ||
196 | src/gnsrecord/gnsrecord.c | 192 | src/gnsrecord/gnsrecord.c |
197 | src/gnsrecord/gnsrecord_crypto.c | 193 | src/gnsrecord/gnsrecord_crypto.c |
198 | src/gnsrecord/gnsrecord_misc.c | 194 | src/gnsrecord/gnsrecord_misc.c |
199 | src/gnsrecord/gnsrecord_serialization.c | 195 | src/gnsrecord/gnsrecord_serialization.c |
200 | src/gnsrecord/plugin_gnsrecord_dns.c | 196 | src/gnsrecord/plugin_gnsrecord_dns.c |
197 | src/gns/w32nsp.c | ||
198 | src/gns/w32nsp-install.c | ||
199 | src/gns/w32nsp-resolve.c | ||
200 | src/gns/w32nsp-uninstall.c | ||
201 | src/hello/address.c | 201 | src/hello/address.c |
202 | src/hello/gnunet-hello.c | 202 | src/hello/gnunet-hello.c |
203 | src/hello/hello-ng.c | ||
204 | src/hello/hello.c | 203 | src/hello/hello.c |
204 | src/hello/hello-ng.c | ||
205 | src/hostlist/gnunet-daemon-hostlist.c | 205 | src/hostlist/gnunet-daemon-hostlist.c |
206 | src/hostlist/gnunet-daemon-hostlist_client.c | 206 | src/hostlist/gnunet-daemon-hostlist_client.c |
207 | src/hostlist/gnunet-daemon-hostlist_server.c | 207 | src/hostlist/gnunet-daemon-hostlist_server.c |
@@ -225,8 +225,8 @@ src/namecache/namecache_api.c | |||
225 | src/namecache/plugin_namecache_flat.c | 225 | src/namecache/plugin_namecache_flat.c |
226 | src/namecache/plugin_namecache_postgres.c | 226 | src/namecache/plugin_namecache_postgres.c |
227 | src/namecache/plugin_namecache_sqlite.c | 227 | src/namecache/plugin_namecache_sqlite.c |
228 | src/namestore/gnunet-namestore-fcfsd.c | ||
229 | src/namestore/gnunet-namestore.c | 228 | src/namestore/gnunet-namestore.c |
229 | src/namestore/gnunet-namestore-fcfsd.c | ||
230 | src/namestore/gnunet-service-namestore.c | 230 | src/namestore/gnunet-service-namestore.c |
231 | src/namestore/gnunet-zoneimport.c | 231 | src/namestore/gnunet-zoneimport.c |
232 | src/namestore/namestore_api.c | 232 | src/namestore/namestore_api.c |
@@ -242,10 +242,10 @@ src/nat-auto/gnunet-service-nat-auto.c | |||
242 | src/nat-auto/gnunet-service-nat-auto_legacy.c | 242 | src/nat-auto/gnunet-service-nat-auto_legacy.c |
243 | src/nat-auto/nat_auto_api.c | 243 | src/nat-auto/nat_auto_api.c |
244 | src/nat-auto/nat_auto_api_test.c | 244 | src/nat-auto/nat_auto_api_test.c |
245 | src/nat/gnunet-helper-nat-client-windows.c | ||
246 | src/nat/gnunet-helper-nat-client.c | 245 | src/nat/gnunet-helper-nat-client.c |
247 | src/nat/gnunet-helper-nat-server-windows.c | 246 | src/nat/gnunet-helper-nat-client-windows.c |
248 | src/nat/gnunet-helper-nat-server.c | 247 | src/nat/gnunet-helper-nat-server.c |
248 | src/nat/gnunet-helper-nat-server-windows.c | ||
249 | src/nat/gnunet-nat.c | 249 | src/nat/gnunet-nat.c |
250 | src/nat/gnunet-service-nat.c | 250 | src/nat/gnunet-service-nat.c |
251 | src/nat/gnunet-service-nat_externalip.c | 251 | src/nat/gnunet-service-nat_externalip.c |
@@ -254,17 +254,17 @@ src/nat/gnunet-service-nat_mini.c | |||
254 | src/nat/gnunet-service-nat_stun.c | 254 | src/nat/gnunet-service-nat_stun.c |
255 | src/nat/nat_api.c | 255 | src/nat/nat_api.c |
256 | src/nat/nat_api_stun.c | 256 | src/nat/nat_api_stun.c |
257 | src/nse/gnunet-nse-profiler.c | ||
258 | src/nse/gnunet-nse.c | 257 | src/nse/gnunet-nse.c |
258 | src/nse/gnunet-nse-profiler.c | ||
259 | src/nse/gnunet-service-nse.c | 259 | src/nse/gnunet-service-nse.c |
260 | src/nse/nse_api.c | 260 | src/nse/nse_api.c |
261 | src/nt/nt.c | 261 | src/nt/nt.c |
262 | src/peerinfo-tool/gnunet-peerinfo.c | ||
263 | src/peerinfo-tool/gnunet-peerinfo_plugins.c | ||
264 | src/peerinfo-tool/plugin_rest_peerinfo.c | ||
265 | src/peerinfo/gnunet-service-peerinfo.c | 262 | src/peerinfo/gnunet-service-peerinfo.c |
266 | src/peerinfo/peerinfo_api.c | 263 | src/peerinfo/peerinfo_api.c |
267 | src/peerinfo/peerinfo_api_notify.c | 264 | src/peerinfo/peerinfo_api_notify.c |
265 | src/peerinfo-tool/gnunet-peerinfo.c | ||
266 | src/peerinfo-tool/gnunet-peerinfo_plugins.c | ||
267 | src/peerinfo-tool/plugin_rest_peerinfo.c | ||
268 | src/peerstore/gnunet-peerstore.c | 268 | src/peerstore/gnunet-peerstore.c |
269 | src/peerstore/gnunet-service-peerstore.c | 269 | src/peerstore/gnunet-service-peerstore.c |
270 | src/peerstore/peerstore_api.c | 270 | src/peerstore/peerstore_api.c |
@@ -312,22 +312,22 @@ src/revocation/gnunet-revocation.c | |||
312 | src/revocation/gnunet-service-revocation.c | 312 | src/revocation/gnunet-service-revocation.c |
313 | src/revocation/plugin_block_revocation.c | 313 | src/revocation/plugin_block_revocation.c |
314 | src/revocation/revocation_api.c | 314 | src/revocation/revocation_api.c |
315 | src/rps/gnunet-rps-profiler.c | ||
316 | src/rps/gnunet-rps.c | 315 | src/rps/gnunet-rps.c |
316 | src/rps/gnunet-rps-profiler.c | ||
317 | src/rps/gnunet-service-rps.c | 317 | src/rps/gnunet-service-rps.c |
318 | src/rps/gnunet-service-rps_custommap.c | 318 | src/rps/gnunet-service-rps_custommap.c |
319 | src/rps/gnunet-service-rps_sampler.c | 319 | src/rps/gnunet-service-rps_sampler.c |
320 | src/rps/gnunet-service-rps_sampler_elem.c | 320 | src/rps/gnunet-service-rps_sampler_elem.c |
321 | src/rps/gnunet-service-rps_view.c | 321 | src/rps/gnunet-service-rps_view.c |
322 | src/rps/rps_api.c | ||
322 | src/rps/rps-sampler_client.c | 323 | src/rps/rps-sampler_client.c |
323 | src/rps/rps-sampler_common.c | 324 | src/rps/rps-sampler_common.c |
324 | src/rps/rps-test_util.c | 325 | src/rps/rps-test_util.c |
325 | src/rps/rps_api.c | ||
326 | src/scalarproduct/gnunet-scalarproduct.c | 326 | src/scalarproduct/gnunet-scalarproduct.c |
327 | src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c | ||
328 | src/scalarproduct/gnunet-service-scalarproduct-ecc_bob.c | ||
329 | src/scalarproduct/gnunet-service-scalarproduct_alice.c | 327 | src/scalarproduct/gnunet-service-scalarproduct_alice.c |
330 | src/scalarproduct/gnunet-service-scalarproduct_bob.c | 328 | src/scalarproduct/gnunet-service-scalarproduct_bob.c |
329 | src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c | ||
330 | src/scalarproduct/gnunet-service-scalarproduct-ecc_bob.c | ||
331 | src/scalarproduct/scalarproduct_api.c | 331 | src/scalarproduct/scalarproduct_api.c |
332 | src/secretsharing/gnunet-secretsharing-profiler.c | 332 | src/secretsharing/gnunet-secretsharing-profiler.c |
333 | src/secretsharing/gnunet-service-secretsharing.c | 333 | src/secretsharing/gnunet-service-secretsharing.c |
@@ -353,16 +353,15 @@ src/statistics/gnunet-statistics.c | |||
353 | src/statistics/statistics_api.c | 353 | src/statistics/statistics_api.c |
354 | src/template/gnunet-service-template.c | 354 | src/template/gnunet-service-template.c |
355 | src/template/gnunet-template.c | 355 | src/template/gnunet-template.c |
356 | src/testbed-logger/gnunet-service-testbed-logger.c | ||
357 | src/testbed-logger/testbed_logger_api.c | ||
358 | src/testbed/generate-underlay-topology.c | 356 | src/testbed/generate-underlay-topology.c |
359 | src/testbed/gnunet-daemon-latency-logger.c | 357 | src/testbed/gnunet-daemon-latency-logger.c |
360 | src/testbed/gnunet-daemon-testbed-blacklist.c | 358 | src/testbed/gnunet-daemon-testbed-blacklist.c |
361 | src/testbed/gnunet-daemon-testbed-underlay.c | 359 | src/testbed/gnunet-daemon-testbed-underlay.c |
362 | src/testbed/gnunet-helper-testbed.c | 360 | src/testbed/gnunet-helper-testbed.c |
361 | src/testbed/gnunet_mpi_test.c | ||
363 | src/testbed/gnunet-service-test-barriers.c | 362 | src/testbed/gnunet-service-test-barriers.c |
364 | src/testbed/gnunet-service-testbed.c | ||
365 | src/testbed/gnunet-service-testbed_barriers.c | 363 | src/testbed/gnunet-service-testbed_barriers.c |
364 | src/testbed/gnunet-service-testbed.c | ||
366 | src/testbed/gnunet-service-testbed_cache.c | 365 | src/testbed/gnunet-service-testbed_cache.c |
367 | src/testbed/gnunet-service-testbed_connectionpool.c | 366 | src/testbed/gnunet-service-testbed_connectionpool.c |
368 | src/testbed/gnunet-service-testbed_cpustatus.c | 367 | src/testbed/gnunet-service-testbed_cpustatus.c |
@@ -370,19 +369,20 @@ src/testbed/gnunet-service-testbed_links.c | |||
370 | src/testbed/gnunet-service-testbed_meminfo.c | 369 | src/testbed/gnunet-service-testbed_meminfo.c |
371 | src/testbed/gnunet-service-testbed_oc.c | 370 | src/testbed/gnunet-service-testbed_oc.c |
372 | src/testbed/gnunet-service-testbed_peers.c | 371 | src/testbed/gnunet-service-testbed_peers.c |
373 | src/testbed/gnunet-testbed-profiler.c | ||
374 | src/testbed/gnunet_mpi_test.c | ||
375 | src/testbed/gnunet_testbed_mpi_spawn.c | 372 | src/testbed/gnunet_testbed_mpi_spawn.c |
376 | src/testbed/testbed_api.c | 373 | src/testbed/gnunet-testbed-profiler.c |
374 | src/testbed-logger/gnunet-service-testbed-logger.c | ||
375 | src/testbed-logger/testbed_logger_api.c | ||
377 | src/testbed/testbed_api_barriers.c | 376 | src/testbed/testbed_api_barriers.c |
377 | src/testbed/testbed_api.c | ||
378 | src/testbed/testbed_api_hosts.c | 378 | src/testbed/testbed_api_hosts.c |
379 | src/testbed/testbed_api_operations.c | 379 | src/testbed/testbed_api_operations.c |
380 | src/testbed/testbed_api_peers.c | 380 | src/testbed/testbed_api_peers.c |
381 | src/testbed/testbed_api_sd.c | 381 | src/testbed/testbed_api_sd.c |
382 | src/testbed/testbed_api_services.c | 382 | src/testbed/testbed_api_services.c |
383 | src/testbed/testbed_api_statistics.c | 383 | src/testbed/testbed_api_statistics.c |
384 | src/testbed/testbed_api_test.c | ||
385 | src/testbed/testbed_api_testbed.c | 384 | src/testbed/testbed_api_testbed.c |
385 | src/testbed/testbed_api_test.c | ||
386 | src/testbed/testbed_api_topology.c | 386 | src/testbed/testbed_api_topology.c |
387 | src/testbed/testbed_api_underlay.c | 387 | src/testbed/testbed_api_underlay.c |
388 | src/testing/gnunet-testing.c | 388 | src/testing/gnunet-testing.c |
@@ -394,41 +394,35 @@ src/transport/gnunet-communicator-tcp.c | |||
394 | src/transport/gnunet-communicator-udp.c | 394 | src/transport/gnunet-communicator-udp.c |
395 | src/transport/gnunet-communicator-unix.c | 395 | src/transport/gnunet-communicator-unix.c |
396 | src/transport/gnunet-helper-transport-bluetooth.c | 396 | src/transport/gnunet-helper-transport-bluetooth.c |
397 | src/transport/gnunet-helper-transport-wlan-dummy.c | ||
398 | src/transport/gnunet-helper-transport-wlan.c | 397 | src/transport/gnunet-helper-transport-wlan.c |
398 | src/transport/gnunet-helper-transport-wlan-dummy.c | ||
399 | src/transport/gnunet-service-tng.c | 399 | src/transport/gnunet-service-tng.c |
400 | src/transport/gnunet-service-transport.c | ||
401 | src/transport/gnunet-service-transport_ats.c | 400 | src/transport/gnunet-service-transport_ats.c |
401 | src/transport/gnunet-service-transport.c | ||
402 | src/transport/gnunet-service-transport_hello.c | 402 | src/transport/gnunet-service-transport_hello.c |
403 | src/transport/gnunet-service-transport_manipulation.c | 403 | src/transport/gnunet-service-transport_manipulation.c |
404 | src/transport/gnunet-service-transport_neighbours.c | 404 | src/transport/gnunet-service-transport_neighbours.c |
405 | src/transport/gnunet-service-transport_plugins.c | 405 | src/transport/gnunet-service-transport_plugins.c |
406 | src/transport/gnunet-service-transport_validation.c | 406 | src/transport/gnunet-service-transport_validation.c |
407 | src/transport/gnunet-transport.c | ||
407 | src/transport/gnunet-transport-certificate-creation.c | 408 | src/transport/gnunet-transport-certificate-creation.c |
408 | src/transport/gnunet-transport-profiler.c | 409 | src/transport/gnunet-transport-profiler.c |
409 | src/transport/gnunet-transport-wlan-receiver.c | 410 | src/transport/gnunet-transport-wlan-receiver.c |
410 | src/transport/gnunet-transport-wlan-sender.c | 411 | src/transport/gnunet-transport-wlan-sender.c |
411 | src/transport/gnunet-transport.c | ||
412 | src/transport/plugin_transport_http_client.c | 412 | src/transport/plugin_transport_http_client.c |
413 | src/transport/plugin_transport_http_common.c | 413 | src/transport/plugin_transport_http_common.c |
414 | src/transport/plugin_transport_http_server.c | 414 | src/transport/plugin_transport_http_server.c |
415 | src/transport/plugin_transport_smtp.c | 415 | src/transport/plugin_transport_smtp.c |
416 | src/transport/plugin_transport_tcp.c | 416 | src/transport/plugin_transport_tcp.c |
417 | src/transport/plugin_transport_template.c | 417 | src/transport/plugin_transport_template.c |
418 | src/transport/plugin_transport_udp.c | ||
419 | src/transport/plugin_transport_udp_broadcasting.c | 418 | src/transport/plugin_transport_udp_broadcasting.c |
419 | src/transport/plugin_transport_udp.c | ||
420 | src/transport/plugin_transport_unix.c | 420 | src/transport/plugin_transport_unix.c |
421 | src/transport/plugin_transport_wlan.c | 421 | src/transport/plugin_transport_wlan.c |
422 | src/transport/tcp_connection_legacy.c | 422 | src/transport/tcp_connection_legacy.c |
423 | src/transport/tcp_server_legacy.c | 423 | src/transport/tcp_server_legacy.c |
424 | src/transport/tcp_server_mst_legacy.c | 424 | src/transport/tcp_server_mst_legacy.c |
425 | src/transport/tcp_service_legacy.c | 425 | src/transport/tcp_service_legacy.c |
426 | src/transport/transport-testing-filenames.c | ||
427 | src/transport/transport-testing-loggers.c | ||
428 | src/transport/transport-testing-main.c | ||
429 | src/transport/transport-testing-send.c | ||
430 | src/transport/transport-testing.c | ||
431 | src/transport/transport-testing2.c | ||
432 | src/transport/transport_api2_application.c | 426 | src/transport/transport_api2_application.c |
433 | src/transport/transport_api2_communication.c | 427 | src/transport/transport_api2_communication.c |
434 | src/transport/transport_api2_core.c | 428 | src/transport/transport_api2_core.c |
@@ -441,6 +435,12 @@ src/transport/transport_api_manipulation.c | |||
441 | src/transport/transport_api_monitor_peers.c | 435 | src/transport/transport_api_monitor_peers.c |
442 | src/transport/transport_api_monitor_plugins.c | 436 | src/transport/transport_api_monitor_plugins.c |
443 | src/transport/transport_api_offer_hello.c | 437 | src/transport/transport_api_offer_hello.c |
438 | src/transport/transport-testing2.c | ||
439 | src/transport/transport-testing.c | ||
440 | src/transport/transport-testing-filenames.c | ||
441 | src/transport/transport-testing-loggers.c | ||
442 | src/transport/transport-testing-main.c | ||
443 | src/transport/transport-testing-send.c | ||
444 | src/util/bandwidth.c | 444 | src/util/bandwidth.c |
445 | src/util/benchmark.c | 445 | src/util/benchmark.c |
446 | src/util/bio.c | 446 | src/util/bio.c |
@@ -453,8 +453,8 @@ src/util/configuration_loader.c | |||
453 | src/util/container_bloomfilter.c | 453 | src/util/container_bloomfilter.c |
454 | src/util/container_heap.c | 454 | src/util/container_heap.c |
455 | src/util/container_meta_data.c | 455 | src/util/container_meta_data.c |
456 | src/util/container_multihashmap.c | ||
457 | src/util/container_multihashmap32.c | 456 | src/util/container_multihashmap32.c |
457 | src/util/container_multihashmap.c | ||
458 | src/util/container_multipeermap.c | 458 | src/util/container_multipeermap.c |
459 | src/util/container_multishortmap.c | 459 | src/util/container_multishortmap.c |
460 | src/util/crypto_abe.c | 460 | src/util/crypto_abe.c |
@@ -476,16 +476,16 @@ src/util/dnsparser.c | |||
476 | src/util/dnsstub.c | 476 | src/util/dnsstub.c |
477 | src/util/getopt.c | 477 | src/util/getopt.c |
478 | src/util/getopt_helpers.c | 478 | src/util/getopt_helpers.c |
479 | src/util/gnunet-config-diff.c | ||
480 | src/util/gnunet-config.c | 479 | src/util/gnunet-config.c |
480 | src/util/gnunet-config-diff.c | ||
481 | src/util/gnunet-ecc.c | 481 | src/util/gnunet-ecc.c |
482 | src/util/gnunet-helper-w32-console.c | 482 | src/util/gnunet-helper-w32-console.c |
483 | src/util/gnunet-qr.c | 483 | src/util/gnunet-qr.c |
484 | src/util/gnunet-resolver.c | 484 | src/util/gnunet-resolver.c |
485 | src/util/gnunet-scrypt.c | 485 | src/util/gnunet-scrypt.c |
486 | src/util/gnunet-service-resolver.c | 486 | src/util/gnunet-service-resolver.c |
487 | src/util/gnunet-timeout-w32.c | ||
488 | src/util/gnunet-timeout.c | 487 | src/util/gnunet-timeout.c |
488 | src/util/gnunet-timeout-w32.c | ||
489 | src/util/gnunet-uri.c | 489 | src/util/gnunet-uri.c |
490 | src/util/helper.c | 490 | src/util/helper.c |
491 | src/util/load.c | 491 | src/util/load.c |
@@ -514,13 +514,13 @@ src/util/tun.c | |||
514 | src/util/w32cat.c | 514 | src/util/w32cat.c |
515 | src/util/win.c | 515 | src/util/win.c |
516 | src/util/winproc.c | 516 | src/util/winproc.c |
517 | src/vpn/gnunet-helper-vpn-windows.c | ||
518 | src/vpn/gnunet-helper-vpn.c | 517 | src/vpn/gnunet-helper-vpn.c |
518 | src/vpn/gnunet-helper-vpn-windows.c | ||
519 | src/vpn/gnunet-service-vpn.c | 519 | src/vpn/gnunet-service-vpn.c |
520 | src/vpn/gnunet-vpn.c | 520 | src/vpn/gnunet-vpn.c |
521 | src/vpn/vpn_api.c | 521 | src/vpn/vpn_api.c |
522 | src/zonemaster/gnunet-service-zonemaster-monitor.c | ||
523 | src/zonemaster/gnunet-service-zonemaster.c | 522 | src/zonemaster/gnunet-service-zonemaster.c |
523 | src/zonemaster/gnunet-service-zonemaster-monitor.c | ||
524 | src/fs/fs_api.h | 524 | src/fs/fs_api.h |
525 | src/include/compat.h | 525 | src/include/compat.h |
526 | src/include/gnunet_common.h | 526 | src/include/gnunet_common.h |
diff --git a/src/conversation/test_conversation_api.c b/src/conversation/test_conversation_api.c index 0e3dd975b..a51570127 100644 --- a/src/conversation/test_conversation_api.c +++ b/src/conversation/test_conversation_api.c | |||
@@ -11,7 +11,7 @@ | |||
11 | WITHOUT ANY WARRANTY; without even the implied warranty of | 11 | WITHOUT ANY WARRANTY; without even the implied warranty of |
12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
13 | Affero General Public License for more details. | 13 | Affero General Public License for more details. |
14 | 14 | ||
15 | You should have received a copy of the GNU Affero General Public License | 15 | You should have received a copy of the GNU Affero General Public License |
16 | along with this program. If not, see <http://www.gnu.org/licenses/>. | 16 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | ||
@@ -82,8 +82,7 @@ phone_send (void *cls) | |||
82 | GNUNET_assert (NULL != phone_rdc); | 82 | GNUNET_assert (NULL != phone_rdc); |
83 | GNUNET_snprintf (buf, sizeof (buf), "phone-%u", i++); | 83 | GNUNET_snprintf (buf, sizeof (buf), "phone-%u", i++); |
84 | phone_rdc (phone_rdc_cls, strlen (buf) + 1, buf); | 84 | phone_rdc (phone_rdc_cls, strlen (buf) + 1, buf); |
85 | phone_task = GNUNET_SCHEDULER_add_delayed (FREQ, | 85 | phone_task = GNUNET_SCHEDULER_add_delayed (FREQ, &phone_send, NULL); |
86 | &phone_send, NULL); | ||
87 | } | 86 | } |
88 | 87 | ||
89 | 88 | ||
@@ -97,8 +96,7 @@ call_send (void *cls) | |||
97 | GNUNET_assert (NULL != call_rdc); | 96 | GNUNET_assert (NULL != call_rdc); |
98 | GNUNET_snprintf (buf, sizeof (buf), "call-%u", i++); | 97 | GNUNET_snprintf (buf, sizeof (buf), "call-%u", i++); |
99 | call_rdc (call_rdc_cls, strlen (buf) + 1, buf); | 98 | call_rdc (call_rdc_cls, strlen (buf) + 1, buf); |
100 | call_task = GNUNET_SCHEDULER_add_delayed (FREQ, | 99 | call_task = GNUNET_SCHEDULER_add_delayed (FREQ, &call_send, NULL); |
101 | &call_send, NULL); | ||
102 | } | 100 | } |
103 | 101 | ||
104 | 102 | ||
@@ -107,9 +105,7 @@ enable_speaker (void *cls) | |||
107 | { | 105 | { |
108 | const char *origin = cls; | 106 | const char *origin = cls; |
109 | 107 | ||
110 | fprintf (stderr, | 108 | fprintf (stderr, "Speaker %s enabled\n", origin); |
111 | "Speaker %s enabled\n", | ||
112 | origin); | ||
113 | return GNUNET_OK; | 109 | return GNUNET_OK; |
114 | } | 110 | } |
115 | 111 | ||
@@ -119,16 +115,12 @@ disable_speaker (void *cls) | |||
119 | { | 115 | { |
120 | const char *origin = cls; | 116 | const char *origin = cls; |
121 | 117 | ||
122 | fprintf (stderr, | 118 | fprintf (stderr, "Speaker %s disabled\n", origin); |
123 | "Speaker %s disabled\n", | ||
124 | origin); | ||
125 | } | 119 | } |
126 | 120 | ||
127 | 121 | ||
128 | static void | 122 | static void |
129 | play (void *cls, | 123 | play (void *cls, size_t data_size, const void *data) |
130 | size_t data_size, | ||
131 | const void *data) | ||
132 | { | 124 | { |
133 | const char *origin = cls; | 125 | const char *origin = cls; |
134 | static unsigned int phone_i = 1; | 126 | static unsigned int phone_i = 1; |
@@ -136,17 +128,10 @@ play (void *cls, | |||
136 | char buf[32]; | 128 | char buf[32]; |
137 | 129 | ||
138 | if (0 == strcmp (origin, "phone")) | 130 | if (0 == strcmp (origin, "phone")) |
139 | GNUNET_snprintf (buf, | 131 | GNUNET_snprintf (buf, sizeof (buf), "call-%u", call_i++); |
140 | sizeof (buf), | ||
141 | "call-%u", | ||
142 | call_i++); | ||
143 | else | 132 | else |
144 | GNUNET_snprintf (buf, | 133 | GNUNET_snprintf (buf, sizeof (buf), "phone-%u", phone_i++); |
145 | sizeof (buf), | 134 | if ((data_size != strlen (buf) + 1) || (0 != strncmp (buf, data, data_size))) |
146 | "phone-%u", | ||
147 | phone_i++); | ||
148 | if ( (data_size != strlen (buf) + 1) || | ||
149 | (0 != strncmp (buf, data, data_size)) ) | ||
150 | { | 135 | { |
151 | fprintf (stderr, | 136 | fprintf (stderr, |
152 | "Expected %s, received %.*s\n", | 137 | "Expected %s, received %.*s\n", |
@@ -158,9 +143,7 @@ play (void *cls, | |||
158 | { | 143 | { |
159 | fprintf (stderr, "."); | 144 | fprintf (stderr, "."); |
160 | } | 145 | } |
161 | if ( (20 < call_i) && | 146 | if ((20 < call_i) && (20 < phone_i) && (NULL != call)) |
162 | (20 < phone_i) && | ||
163 | (NULL != call) ) | ||
164 | { | 147 | { |
165 | /* time to hang up ... */ | 148 | /* time to hang up ... */ |
166 | GNUNET_CONVERSATION_call_stop (call); | 149 | GNUNET_CONVERSATION_call_stop (call); |
@@ -178,22 +161,18 @@ destroy_speaker (void *cls) | |||
178 | } | 161 | } |
179 | 162 | ||
180 | 163 | ||
181 | static struct GNUNET_SPEAKER_Handle call_speaker = { | 164 | static struct GNUNET_SPEAKER_Handle call_speaker = {&enable_speaker, |
182 | &enable_speaker, | 165 | &play, |
183 | &play, | 166 | &disable_speaker, |
184 | &disable_speaker, | 167 | &destroy_speaker, |
185 | &destroy_speaker, | 168 | "caller"}; |
186 | "caller" | ||
187 | }; | ||
188 | 169 | ||
189 | 170 | ||
190 | static struct GNUNET_SPEAKER_Handle phone_speaker = { | 171 | static struct GNUNET_SPEAKER_Handle phone_speaker = {&enable_speaker, |
191 | &enable_speaker, | 172 | &play, |
192 | &play, | 173 | &disable_speaker, |
193 | &disable_speaker, | 174 | &destroy_speaker, |
194 | &destroy_speaker, | 175 | "phone"}; |
195 | "phone" | ||
196 | }; | ||
197 | 176 | ||
198 | 177 | ||
199 | static int | 178 | static int |
@@ -203,9 +182,7 @@ enable_mic (void *cls, | |||
203 | { | 182 | { |
204 | const char *origin = cls; | 183 | const char *origin = cls; |
205 | 184 | ||
206 | fprintf (stderr, | 185 | fprintf (stderr, "Mic %s enabled\n", origin); |
207 | "Mic %s enabled\n", | ||
208 | origin); | ||
209 | if (0 == strcmp (origin, "phone")) | 186 | if (0 == strcmp (origin, "phone")) |
210 | { | 187 | { |
211 | phone_rdc = rdc; | 188 | phone_rdc = rdc; |
@@ -227,9 +204,7 @@ disable_mic (void *cls) | |||
227 | { | 204 | { |
228 | const char *origin = cls; | 205 | const char *origin = cls; |
229 | 206 | ||
230 | fprintf (stderr, | 207 | fprintf (stderr, "Mic %s disabled\n", origin); |
231 | "Mic %s disabled\n", | ||
232 | origin); | ||
233 | if (0 == strcmp (origin, "phone")) | 208 | if (0 == strcmp (origin, "phone")) |
234 | { | 209 | { |
235 | phone_rdc = NULL; | 210 | phone_rdc = NULL; |
@@ -252,26 +227,20 @@ destroy_mic (void *cls) | |||
252 | { | 227 | { |
253 | const char *origin = cls; | 228 | const char *origin = cls; |
254 | 229 | ||
255 | fprintf (stderr, | 230 | fprintf (stderr, "Mic %s destroyed\n", origin); |
256 | "Mic %s destroyed\n", | ||
257 | origin); | ||
258 | } | 231 | } |
259 | 232 | ||
260 | 233 | ||
261 | static struct GNUNET_MICROPHONE_Handle call_mic = { | 234 | static struct GNUNET_MICROPHONE_Handle call_mic = {&enable_mic, |
262 | &enable_mic, | 235 | &disable_mic, |
263 | &disable_mic, | 236 | &destroy_mic, |
264 | &destroy_mic, | 237 | "caller"}; |
265 | "caller" | ||
266 | }; | ||
267 | 238 | ||
268 | 239 | ||
269 | static struct GNUNET_MICROPHONE_Handle phone_mic = { | 240 | static struct GNUNET_MICROPHONE_Handle phone_mic = {&enable_mic, |
270 | &enable_mic, | 241 | &disable_mic, |
271 | &disable_mic, | 242 | &destroy_mic, |
272 | &destroy_mic, | 243 | "phone"}; |
273 | "phone" | ||
274 | }; | ||
275 | 244 | ||
276 | 245 | ||
277 | /** | 246 | /** |
@@ -319,17 +288,14 @@ end_test (void *cls) | |||
319 | 288 | ||
320 | 289 | ||
321 | static void | 290 | static void |
322 | caller_event_handler (void *cls, | 291 | caller_event_handler (void *cls, enum GNUNET_CONVERSATION_CallerEventCode code) |
323 | enum GNUNET_CONVERSATION_CallerEventCode code) | ||
324 | { | 292 | { |
325 | (void) cls; | 293 | (void) cls; |
326 | switch (code) | 294 | switch (code) |
327 | { | 295 | { |
328 | case GNUNET_CONVERSATION_EC_CALLER_SUSPEND: | 296 | case GNUNET_CONVERSATION_EC_CALLER_SUSPEND: |
329 | case GNUNET_CONVERSATION_EC_CALLER_RESUME: | 297 | case GNUNET_CONVERSATION_EC_CALLER_RESUME: |
330 | fprintf (stderr, | 298 | fprintf (stderr, "Unexpected caller code: %d\n", code); |
331 | "Unexpected caller code: %d\n", | ||
332 | code); | ||
333 | break; | 299 | break; |
334 | } | 300 | } |
335 | } | 301 | } |
@@ -341,8 +307,8 @@ phone_event_handler (void *cls, | |||
341 | struct GNUNET_CONVERSATION_Caller *caller, | 307 | struct GNUNET_CONVERSATION_Caller *caller, |
342 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) | 308 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) |
343 | { | 309 | { |
344 | static enum GNUNET_CONVERSATION_PhoneEventCode expect | 310 | static enum GNUNET_CONVERSATION_PhoneEventCode expect = |
345 | = GNUNET_CONVERSATION_EC_PHONE_RING; | 311 | GNUNET_CONVERSATION_EC_PHONE_RING; |
346 | 312 | ||
347 | (void) cls; | 313 | (void) cls; |
348 | (void) caller_id; | 314 | (void) caller_id; |
@@ -366,20 +332,17 @@ phone_event_handler (void *cls, | |||
366 | GNUNET_SCHEDULER_shutdown (); | 332 | GNUNET_SCHEDULER_shutdown (); |
367 | break; | 333 | break; |
368 | default: | 334 | default: |
369 | fprintf (stderr, | 335 | fprintf (stderr, "Unexpected phone code: %d\n", code); |
370 | "Unexpected phone code: %d\n", | ||
371 | code); | ||
372 | break; | 336 | break; |
373 | } | 337 | } |
374 | } | 338 | } |
375 | 339 | ||
376 | 340 | ||
377 | static void | 341 | static void |
378 | call_event_handler (void *cls, | 342 | call_event_handler (void *cls, enum GNUNET_CONVERSATION_CallEventCode code) |
379 | enum GNUNET_CONVERSATION_CallEventCode code) | ||
380 | { | 343 | { |
381 | static enum GNUNET_CONVERSATION_CallEventCode expect | 344 | static enum GNUNET_CONVERSATION_CallEventCode expect = |
382 | = GNUNET_CONVERSATION_EC_CALL_RINGING; | 345 | GNUNET_CONVERSATION_EC_CALL_RINGING; |
383 | 346 | ||
384 | (void) cls; | 347 | (void) cls; |
385 | GNUNET_break (code == expect); | 348 | GNUNET_break (code == expect); |
@@ -416,6 +379,7 @@ call_event_handler (void *cls, | |||
416 | 379 | ||
417 | static void | 380 | static void |
418 | caller_ego_create_cont (void *cls, | 381 | caller_ego_create_cont (void *cls, |
382 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, | ||
419 | const char *emsg) | 383 | const char *emsg) |
420 | { | 384 | { |
421 | (void) cls; | 385 | (void) cls; |
@@ -425,19 +389,14 @@ caller_ego_create_cont (void *cls, | |||
425 | 389 | ||
426 | 390 | ||
427 | static void | 391 | static void |
428 | namestore_put_cont (void *cls, | 392 | namestore_put_cont (void *cls, int32_t success, const char *emsg) |
429 | int32_t success, | ||
430 | const char *emsg) | ||
431 | { | 393 | { |
432 | (void) cls; | 394 | (void) cls; |
433 | qe = NULL; | 395 | qe = NULL; |
434 | GNUNET_assert (GNUNET_YES == success); | 396 | GNUNET_assert (GNUNET_YES == success); |
435 | GNUNET_assert (NULL == emsg); | 397 | GNUNET_assert (NULL == emsg); |
436 | GNUNET_assert (NULL == op); | 398 | GNUNET_assert (NULL == op); |
437 | op = GNUNET_IDENTITY_create (id, | 399 | op = GNUNET_IDENTITY_create (id, "caller-ego", &caller_ego_create_cont, NULL); |
438 | "caller-ego", | ||
439 | &caller_ego_create_cont, | ||
440 | NULL); | ||
441 | } | 400 | } |
442 | 401 | ||
443 | 402 | ||
@@ -462,23 +421,21 @@ identity_cb (void *cls, | |||
462 | GNUNET_asprintf (&gns_name, | 421 | GNUNET_asprintf (&gns_name, |
463 | "phone.%s", | 422 | "phone.%s", |
464 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); | 423 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); |
465 | phone = GNUNET_CONVERSATION_phone_create (cfg, | 424 | phone = |
466 | ego, | 425 | GNUNET_CONVERSATION_phone_create (cfg, ego, &phone_event_handler, NULL); |
467 | &phone_event_handler, | ||
468 | NULL); | ||
469 | GNUNET_assert (NULL != phone); | 426 | GNUNET_assert (NULL != phone); |
470 | memset (&rd, 0, sizeof (rd)); | 427 | memset (&rd, 0, sizeof (rd)); |
471 | GNUNET_CONVERSATION_phone_get_record (phone, | 428 | GNUNET_CONVERSATION_phone_get_record (phone, &rd); |
472 | &rd); | ||
473 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); | 429 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); |
474 | rd.expiration_time = UINT64_MAX; | 430 | rd.expiration_time = UINT64_MAX; |
475 | qe = GNUNET_NAMESTORE_records_store (ns, | 431 | qe = |
476 | GNUNET_IDENTITY_ego_get_private_key (ego), | 432 | GNUNET_NAMESTORE_records_store (ns, |
477 | "phone" /* GNS label */, | 433 | GNUNET_IDENTITY_ego_get_private_key (ego), |
478 | 1, | 434 | "phone" /* GNS label */, |
479 | &rd, | 435 | 1, |
480 | &namestore_put_cont, | 436 | &rd, |
481 | NULL); | 437 | &namestore_put_cont, |
438 | NULL); | ||
482 | return; | 439 | return; |
483 | } | 440 | } |
484 | if (0 == strcmp (name, "caller-ego")) | 441 | if (0 == strcmp (name, "caller-ego")) |
@@ -500,8 +457,7 @@ identity_cb (void *cls, | |||
500 | 457 | ||
501 | 458 | ||
502 | static void | 459 | static void |
503 | phone_ego_create_cont (void *cls, | 460 | phone_ego_create_cont (void *cls, const char *emsg) |
504 | const char *emsg) | ||
505 | { | 461 | { |
506 | (void) cls; | 462 | (void) cls; |
507 | op = NULL; | 463 | op = NULL; |
@@ -517,30 +473,22 @@ run (void *cls, | |||
517 | (void) cls; | 473 | (void) cls; |
518 | (void) peer; | 474 | (void) peer; |
519 | cfg = c; | 475 | cfg = c; |
520 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, | 476 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_test, NULL); |
521 | &end_test, | 477 | id = GNUNET_IDENTITY_connect (cfg, &identity_cb, NULL); |
522 | NULL); | 478 | op = GNUNET_IDENTITY_create (id, "phone-ego", &phone_ego_create_cont, NULL); |
523 | id = GNUNET_IDENTITY_connect (cfg, | ||
524 | &identity_cb, | ||
525 | NULL); | ||
526 | op = GNUNET_IDENTITY_create (id, | ||
527 | "phone-ego", | ||
528 | &phone_ego_create_cont, | ||
529 | NULL); | ||
530 | ns = GNUNET_NAMESTORE_connect (cfg); | 479 | ns = GNUNET_NAMESTORE_connect (cfg); |
531 | } | 480 | } |
532 | 481 | ||
533 | 482 | ||
534 | int | 483 | int |
535 | main (int argc, | 484 | main (int argc, char *argv[]) |
536 | char *argv[]) | ||
537 | { | 485 | { |
538 | (void) argc; | 486 | (void) argc; |
539 | (void) argv; | 487 | (void) argv; |
540 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api", | 488 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api", |
541 | "test_conversation.conf", | 489 | "test_conversation.conf", |
542 | &run, | 490 | &run, |
543 | NULL)) | 491 | NULL)) |
544 | return 1; | 492 | return 1; |
545 | return ok; | 493 | return ok; |
546 | } | 494 | } |
diff --git a/src/conversation/test_conversation_api_reject.c b/src/conversation/test_conversation_api_reject.c index dc4785258..49dc854ed 100644 --- a/src/conversation/test_conversation_api_reject.c +++ b/src/conversation/test_conversation_api_reject.c | |||
@@ -11,7 +11,7 @@ | |||
11 | WITHOUT ANY WARRANTY; without even the implied warranty of | 11 | WITHOUT ANY WARRANTY; without even the implied warranty of |
12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
13 | Affero General Public License for more details. | 13 | Affero General Public License for more details. |
14 | 14 | ||
15 | You should have received a copy of the GNU Affero General Public License | 15 | You should have received a copy of the GNU Affero General Public License |
16 | along with this program. If not, see <http://www.gnu.org/licenses/>. | 16 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | ||
@@ -74,9 +74,7 @@ disable_speaker (void *cls) | |||
74 | 74 | ||
75 | 75 | ||
76 | static void | 76 | static void |
77 | play (void *cls, | 77 | play (void *cls, size_t data_size, const void *data) |
78 | size_t data_size, | ||
79 | const void *data) | ||
80 | { | 78 | { |
81 | (void) cls; | 79 | (void) cls; |
82 | (void) data_size; | 80 | (void) data_size; |
@@ -92,13 +90,11 @@ destroy_speaker (void *cls) | |||
92 | } | 90 | } |
93 | 91 | ||
94 | 92 | ||
95 | static struct GNUNET_SPEAKER_Handle call_speaker = { | 93 | static struct GNUNET_SPEAKER_Handle call_speaker = {&enable_speaker, |
96 | &enable_speaker, | 94 | &play, |
97 | &play, | 95 | &disable_speaker, |
98 | &disable_speaker, | 96 | &destroy_speaker, |
99 | &destroy_speaker, | 97 | "caller"}; |
100 | "caller" | ||
101 | }; | ||
102 | 98 | ||
103 | 99 | ||
104 | static int | 100 | static int |
@@ -129,12 +125,10 @@ destroy_mic (void *cls) | |||
129 | } | 125 | } |
130 | 126 | ||
131 | 127 | ||
132 | static struct GNUNET_MICROPHONE_Handle call_mic = { | 128 | static struct GNUNET_MICROPHONE_Handle call_mic = {&enable_mic, |
133 | &enable_mic, | 129 | &disable_mic, |
134 | &disable_mic, | 130 | &destroy_mic, |
135 | &destroy_mic, | 131 | "caller"}; |
136 | "caller" | ||
137 | }; | ||
138 | 132 | ||
139 | 133 | ||
140 | /** | 134 | /** |
@@ -159,8 +153,7 @@ end_test (void *cls) | |||
159 | } | 153 | } |
160 | if (NULL != phone) | 154 | if (NULL != phone) |
161 | { | 155 | { |
162 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 156 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from PHONE service.\n"); |
163 | "Disconnecting from PHONE service.\n"); | ||
164 | GNUNET_CONVERSATION_phone_destroy (phone); | 157 | GNUNET_CONVERSATION_phone_destroy (phone); |
165 | phone = NULL; | 158 | phone = NULL; |
166 | } | 159 | } |
@@ -188,8 +181,8 @@ phone_event_handler (void *cls, | |||
188 | struct GNUNET_CONVERSATION_Caller *caller, | 181 | struct GNUNET_CONVERSATION_Caller *caller, |
189 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) | 182 | const struct GNUNET_CRYPTO_EcdsaPublicKey *caller_id) |
190 | { | 183 | { |
191 | static enum GNUNET_CONVERSATION_PhoneEventCode expect | 184 | static enum GNUNET_CONVERSATION_PhoneEventCode expect = |
192 | = GNUNET_CONVERSATION_EC_PHONE_RING; | 185 | GNUNET_CONVERSATION_EC_PHONE_RING; |
193 | 186 | ||
194 | (void) cls; | 187 | (void) cls; |
195 | (void) caller_id; | 188 | (void) caller_id; |
@@ -207,11 +200,10 @@ phone_event_handler (void *cls, | |||
207 | 200 | ||
208 | 201 | ||
209 | static void | 202 | static void |
210 | call_event_handler (void *cls, | 203 | call_event_handler (void *cls, enum GNUNET_CONVERSATION_CallEventCode code) |
211 | enum GNUNET_CONVERSATION_CallEventCode code) | ||
212 | { | 204 | { |
213 | static enum GNUNET_CONVERSATION_CallEventCode expect | 205 | static enum GNUNET_CONVERSATION_CallEventCode expect = |
214 | = GNUNET_CONVERSATION_EC_CALL_RINGING; | 206 | GNUNET_CONVERSATION_EC_CALL_RINGING; |
215 | 207 | ||
216 | (void) cls; | 208 | (void) cls; |
217 | GNUNET_break (code == expect); | 209 | GNUNET_break (code == expect); |
@@ -242,6 +234,7 @@ call_event_handler (void *cls, | |||
242 | 234 | ||
243 | static void | 235 | static void |
244 | caller_ego_create_cont (void *cls, | 236 | caller_ego_create_cont (void *cls, |
237 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, | ||
245 | const char *emsg) | 238 | const char *emsg) |
246 | { | 239 | { |
247 | (void) cls; | 240 | (void) cls; |
@@ -251,19 +244,14 @@ caller_ego_create_cont (void *cls, | |||
251 | 244 | ||
252 | 245 | ||
253 | static void | 246 | static void |
254 | namestore_put_cont (void *cls, | 247 | namestore_put_cont (void *cls, int32_t success, const char *emsg) |
255 | int32_t success, | ||
256 | const char *emsg) | ||
257 | { | 248 | { |
258 | (void) cls; | 249 | (void) cls; |
259 | qe = NULL; | 250 | qe = NULL; |
260 | GNUNET_assert (GNUNET_YES == success); | 251 | GNUNET_assert (GNUNET_YES == success); |
261 | GNUNET_assert (NULL == emsg); | 252 | GNUNET_assert (NULL == emsg); |
262 | GNUNET_assert (NULL == op); | 253 | GNUNET_assert (NULL == op); |
263 | op = GNUNET_IDENTITY_create (id, | 254 | op = GNUNET_IDENTITY_create (id, "caller-ego", &caller_ego_create_cont, NULL); |
264 | "caller-ego", | ||
265 | &caller_ego_create_cont, | ||
266 | NULL); | ||
267 | } | 255 | } |
268 | 256 | ||
269 | 257 | ||
@@ -288,23 +276,21 @@ identity_cb (void *cls, | |||
288 | GNUNET_asprintf (&gns_name, | 276 | GNUNET_asprintf (&gns_name, |
289 | "phone.%s", | 277 | "phone.%s", |
290 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); | 278 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); |
291 | phone = GNUNET_CONVERSATION_phone_create (cfg, | 279 | phone = |
292 | ego, | 280 | GNUNET_CONVERSATION_phone_create (cfg, ego, &phone_event_handler, NULL); |
293 | &phone_event_handler, | ||
294 | NULL); | ||
295 | GNUNET_assert (NULL != phone); | 281 | GNUNET_assert (NULL != phone); |
296 | memset (&rd, 0, sizeof (rd)); | 282 | memset (&rd, 0, sizeof (rd)); |
297 | GNUNET_CONVERSATION_phone_get_record (phone, | 283 | GNUNET_CONVERSATION_phone_get_record (phone, &rd); |
298 | &rd); | ||
299 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); | 284 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); |
300 | rd.expiration_time = UINT64_MAX; | 285 | rd.expiration_time = UINT64_MAX; |
301 | qe = GNUNET_NAMESTORE_records_store (ns, | 286 | qe = |
302 | GNUNET_IDENTITY_ego_get_private_key (ego), | 287 | GNUNET_NAMESTORE_records_store (ns, |
303 | "phone" /* GNS label */, | 288 | GNUNET_IDENTITY_ego_get_private_key (ego), |
304 | 1, | 289 | "phone" /* GNS label */, |
305 | &rd, | 290 | 1, |
306 | &namestore_put_cont, | 291 | &rd, |
307 | NULL); | 292 | &namestore_put_cont, |
293 | NULL); | ||
308 | return; | 294 | return; |
309 | } | 295 | } |
310 | if (0 == strcmp (name, "caller-ego")) | 296 | if (0 == strcmp (name, "caller-ego")) |
@@ -326,8 +312,7 @@ identity_cb (void *cls, | |||
326 | 312 | ||
327 | 313 | ||
328 | static void | 314 | static void |
329 | phone_ego_create_cont (void *cls, | 315 | phone_ego_create_cont (void *cls, const char *emsg) |
330 | const char *emsg) | ||
331 | { | 316 | { |
332 | (void) cls; | 317 | (void) cls; |
333 | op = NULL; | 318 | op = NULL; |
@@ -343,15 +328,9 @@ run (void *cls, | |||
343 | (void) cls; | 328 | (void) cls; |
344 | (void) peer; | 329 | (void) peer; |
345 | cfg = c; | 330 | cfg = c; |
346 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_test, | 331 | GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_test, NULL); |
347 | NULL); | 332 | id = GNUNET_IDENTITY_connect (cfg, &identity_cb, NULL); |
348 | id = GNUNET_IDENTITY_connect (cfg, | 333 | op = GNUNET_IDENTITY_create (id, "phone-ego", &phone_ego_create_cont, NULL); |
349 | &identity_cb, | ||
350 | NULL); | ||
351 | op = GNUNET_IDENTITY_create (id, | ||
352 | "phone-ego", | ||
353 | &phone_ego_create_cont, | ||
354 | NULL); | ||
355 | ns = GNUNET_NAMESTORE_connect (cfg); | 334 | ns = GNUNET_NAMESTORE_connect (cfg); |
356 | } | 335 | } |
357 | 336 | ||
@@ -362,8 +341,9 @@ main (int argc, char *argv[]) | |||
362 | (void) argc; | 341 | (void) argc; |
363 | (void) argv; | 342 | (void) argv; |
364 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api", | 343 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api", |
365 | "test_conversation.conf", | 344 | "test_conversation.conf", |
366 | &run, NULL)) | 345 | &run, |
346 | NULL)) | ||
367 | return 1; | 347 | return 1; |
368 | return ok; | 348 | return ok; |
369 | } | 349 | } |
diff --git a/src/conversation/test_conversation_api_twocalls.c b/src/conversation/test_conversation_api_twocalls.c index 0b19f4783..c0768f590 100644 --- a/src/conversation/test_conversation_api_twocalls.c +++ b/src/conversation/test_conversation_api_twocalls.c | |||
@@ -11,7 +11,7 @@ | |||
11 | WITHOUT ANY WARRANTY; without even the implied warranty of | 11 | WITHOUT ANY WARRANTY; without even the implied warranty of |
12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
13 | Affero General Public License for more details. | 13 | Affero General Public License for more details. |
14 | 14 | ||
15 | You should have received a copy of the GNU Affero General Public License | 15 | You should have received a copy of the GNU Affero General Public License |
16 | along with this program. If not, see <http://www.gnu.org/licenses/>. | 16 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | ||
@@ -39,11 +39,9 @@ | |||
39 | 39 | ||
40 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 25) | 40 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 25) |
41 | 41 | ||
42 | #define LOG(kind,...) \ | 42 | #define LOG(kind, ...) GNUNET_log (kind, __VA_ARGS__) |
43 | GNUNET_log (kind, __VA_ARGS__) | ||
44 | 43 | ||
45 | #define LOG_DEBUG(...) \ | 44 | #define LOG_DEBUG(...) GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
46 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) | ||
47 | 45 | ||
48 | static const struct GNUNET_CONFIGURATION_Handle *cfg; | 46 | static const struct GNUNET_CONFIGURATION_Handle *cfg; |
49 | 47 | ||
@@ -97,7 +95,7 @@ static const char *phone0 = "phone"; | |||
97 | #define CALLER2 &caller2 | 95 | #define CALLER2 &caller2 |
98 | #define PHONE0 &phone0 | 96 | #define PHONE0 &phone0 |
99 | 97 | ||
100 | #define CLS_STR(caller) (*((char **)caller)) | 98 | #define CLS_STR(caller) (*((char **) caller)) |
101 | 99 | ||
102 | 100 | ||
103 | /** | 101 | /** |
@@ -116,8 +114,7 @@ struct MicContext | |||
116 | 114 | ||
117 | void *rdc_cls; | 115 | void *rdc_cls; |
118 | 116 | ||
119 | struct GNUNET_SCHEDULER_Task * call_task; | 117 | struct GNUNET_SCHEDULER_Task *call_task; |
120 | |||
121 | }; | 118 | }; |
122 | 119 | ||
123 | static struct MicContext call1_mic_ctx; | 120 | static struct MicContext call1_mic_ctx; |
@@ -133,12 +130,8 @@ phone_send (void *cls) | |||
133 | (void) cls; | 130 | (void) cls; |
134 | GNUNET_assert (NULL != phone_rdc); | 131 | GNUNET_assert (NULL != phone_rdc); |
135 | GNUNET_snprintf (buf, sizeof (buf), "phone"); | 132 | GNUNET_snprintf (buf, sizeof (buf), "phone"); |
136 | phone_rdc (phone_rdc_cls, | 133 | phone_rdc (phone_rdc_cls, strlen (buf) + 1, buf); |
137 | strlen (buf) + 1, | 134 | phone_task = GNUNET_SCHEDULER_add_delayed (FREQ, &phone_send, NULL); |
138 | buf); | ||
139 | phone_task = GNUNET_SCHEDULER_add_delayed (FREQ, | ||
140 | &phone_send, | ||
141 | NULL); | ||
142 | } | 135 | } |
143 | 136 | ||
144 | 137 | ||
@@ -150,15 +143,9 @@ call_send (void *cls) | |||
150 | 143 | ||
151 | (void) cls; | 144 | (void) cls; |
152 | GNUNET_assert (NULL != mc->rdc); | 145 | GNUNET_assert (NULL != mc->rdc); |
153 | GNUNET_snprintf (buf, | 146 | GNUNET_snprintf (buf, sizeof (buf), "call"); |
154 | sizeof (buf), | 147 | mc->rdc (mc->rdc_cls, strlen (buf) + 1, buf); |
155 | "call"); | 148 | mc->call_task = GNUNET_SCHEDULER_add_delayed (FREQ, &call_send, mc); |
156 | mc->rdc (mc->rdc_cls, | ||
157 | strlen (buf) + 1, | ||
158 | buf); | ||
159 | mc->call_task = GNUNET_SCHEDULER_add_delayed (FREQ, | ||
160 | &call_send, | ||
161 | mc); | ||
162 | } | 149 | } |
163 | 150 | ||
164 | 151 | ||
@@ -168,8 +155,7 @@ enable_speaker (void *cls) | |||
168 | const char *origin = CLS_STR (cls); | 155 | const char *origin = CLS_STR (cls); |
169 | 156 | ||
170 | (void) cls; | 157 | (void) cls; |
171 | LOG_DEBUG ("Speaker %s enabled\n", | 158 | LOG_DEBUG ("Speaker %s enabled\n", origin); |
172 | origin); | ||
173 | return GNUNET_OK; | 159 | return GNUNET_OK; |
174 | } | 160 | } |
175 | 161 | ||
@@ -180,15 +166,12 @@ disable_speaker (void *cls) | |||
180 | const char *origin = CLS_STR (cls); | 166 | const char *origin = CLS_STR (cls); |
181 | 167 | ||
182 | (void) cls; | 168 | (void) cls; |
183 | LOG_DEBUG ("Speaker %s disabled\n", | 169 | LOG_DEBUG ("Speaker %s disabled\n", origin); |
184 | origin); | ||
185 | } | 170 | } |
186 | 171 | ||
187 | 172 | ||
188 | static void | 173 | static void |
189 | play (void *cls, | 174 | play (void *cls, size_t data_size, const void *data) |
190 | size_t data_size, | ||
191 | const void *data) | ||
192 | { | 175 | { |
193 | static unsigned int phone_i; | 176 | static unsigned int phone_i; |
194 | static unsigned int call_i; | 177 | static unsigned int call_i; |
@@ -206,9 +189,7 @@ play (void *cls, | |||
206 | (const char *) data); | 189 | (const char *) data); |
207 | } | 190 | } |
208 | 191 | ||
209 | if ( (20 < call_i) && | 192 | if ((20 < call_i) && (20 < phone_i) && (CALLER2 == cls)) |
210 | (20 < phone_i) && | ||
211 | (CALLER2 == cls) ) | ||
212 | { | 193 | { |
213 | /* time to hang up ... */ | 194 | /* time to hang up ... */ |
214 | GNUNET_CONVERSATION_call_stop (call2); | 195 | GNUNET_CONVERSATION_call_stop (call2); |
@@ -218,9 +199,7 @@ play (void *cls, | |||
218 | phone_i = 0; | 199 | phone_i = 0; |
219 | call2_finished = GNUNET_YES; | 200 | call2_finished = GNUNET_YES; |
220 | } | 201 | } |
221 | if ( (20 < call_i) && | 202 | if ((20 < call_i) && (20 < phone_i) && (CALLER1 == cls)) |
222 | (20 < phone_i) && | ||
223 | (CALLER1 == cls) ) | ||
224 | { | 203 | { |
225 | /* time to hang up ... */ | 204 | /* time to hang up ... */ |
226 | GNUNET_CONVERSATION_call_stop (call1); | 205 | GNUNET_CONVERSATION_call_stop (call1); |
@@ -241,31 +220,25 @@ destroy_speaker (void *cls) | |||
241 | } | 220 | } |
242 | 221 | ||
243 | 222 | ||
244 | static struct GNUNET_SPEAKER_Handle call1_speaker = { | 223 | static struct GNUNET_SPEAKER_Handle call1_speaker = {&enable_speaker, |
245 | &enable_speaker, | 224 | &play, |
246 | &play, | 225 | &disable_speaker, |
247 | &disable_speaker, | 226 | &destroy_speaker, |
248 | &destroy_speaker, | 227 | CALLER1}; |
249 | CALLER1 | ||
250 | }; | ||
251 | 228 | ||
252 | 229 | ||
253 | static struct GNUNET_SPEAKER_Handle call2_speaker = { | 230 | static struct GNUNET_SPEAKER_Handle call2_speaker = {&enable_speaker, |
254 | &enable_speaker, | 231 | &play, |
255 | &play, | 232 | &disable_speaker, |
256 | &disable_speaker, | 233 | &destroy_speaker, |
257 | &destroy_speaker, | 234 | CALLER2}; |
258 | CALLER2 | ||
259 | }; | ||
260 | 235 | ||
261 | 236 | ||
262 | static struct GNUNET_SPEAKER_Handle phone_speaker = { | 237 | static struct GNUNET_SPEAKER_Handle phone_speaker = {&enable_speaker, |
263 | &enable_speaker, | 238 | &play, |
264 | &play, | 239 | &disable_speaker, |
265 | &disable_speaker, | 240 | &destroy_speaker, |
266 | &destroy_speaker, | 241 | PHONE0}; |
267 | PHONE0 | ||
268 | }; | ||
269 | 242 | ||
270 | 243 | ||
271 | static int | 244 | static int |
@@ -276,8 +249,7 @@ enable_mic (void *cls, | |||
276 | const char *origin = CLS_STR (cls); | 249 | const char *origin = CLS_STR (cls); |
277 | struct MicContext *mc; | 250 | struct MicContext *mc; |
278 | 251 | ||
279 | LOG_DEBUG ("Mic %s enabled\n", | 252 | LOG_DEBUG ("Mic %s enabled\n", origin); |
280 | origin); | ||
281 | if (PHONE0 == cls) | 253 | if (PHONE0 == cls) |
282 | { | 254 | { |
283 | phone_rdc = rdc; | 255 | phone_rdc = rdc; |
@@ -301,8 +273,7 @@ disable_mic (void *cls) | |||
301 | const char *origin = CLS_STR (cls); | 273 | const char *origin = CLS_STR (cls); |
302 | struct MicContext *mc; | 274 | struct MicContext *mc; |
303 | 275 | ||
304 | LOG_DEBUG ("Mic %s disabled\n", | 276 | LOG_DEBUG ("Mic %s disabled\n", origin); |
305 | origin); | ||
306 | if (PHONE0 == cls) | 277 | if (PHONE0 == cls) |
307 | { | 278 | { |
308 | phone_rdc = NULL; | 279 | phone_rdc = NULL; |
@@ -324,33 +295,26 @@ destroy_mic (void *cls) | |||
324 | { | 295 | { |
325 | const char *origin = CLS_STR (cls); | 296 | const char *origin = CLS_STR (cls); |
326 | 297 | ||
327 | LOG_DEBUG ("Mic %s destroyed\n", | 298 | LOG_DEBUG ("Mic %s destroyed\n", origin); |
328 | origin); | ||
329 | } | 299 | } |
330 | 300 | ||
331 | 301 | ||
332 | static struct GNUNET_MICROPHONE_Handle call1_mic = { | 302 | static struct GNUNET_MICROPHONE_Handle call1_mic = {&enable_mic, |
333 | &enable_mic, | 303 | &disable_mic, |
334 | &disable_mic, | 304 | &destroy_mic, |
335 | &destroy_mic, | 305 | CALLER1}; |
336 | CALLER1 | ||
337 | }; | ||
338 | 306 | ||
339 | 307 | ||
340 | static struct GNUNET_MICROPHONE_Handle call2_mic = { | 308 | static struct GNUNET_MICROPHONE_Handle call2_mic = {&enable_mic, |
341 | &enable_mic, | 309 | &disable_mic, |
342 | &disable_mic, | 310 | &destroy_mic, |
343 | &destroy_mic, | 311 | CALLER2}; |
344 | CALLER2 | ||
345 | }; | ||
346 | 312 | ||
347 | 313 | ||
348 | static struct GNUNET_MICROPHONE_Handle phone_mic = { | 314 | static struct GNUNET_MICROPHONE_Handle phone_mic = {&enable_mic, |
349 | &enable_mic, | 315 | &disable_mic, |
350 | &disable_mic, | 316 | &destroy_mic, |
351 | &destroy_mic, | 317 | PHONE0}; |
352 | PHONE0 | ||
353 | }; | ||
354 | 318 | ||
355 | 319 | ||
356 | /** | 320 | /** |
@@ -363,8 +327,7 @@ end_test (void *cls) | |||
363 | { | 327 | { |
364 | (void) cls; | 328 | (void) cls; |
365 | timeout_task = NULL; | 329 | timeout_task = NULL; |
366 | fprintf (stderr, | 330 | fprintf (stderr, "Timeout!\n"); |
367 | "Timeout!\n"); | ||
368 | GNUNET_SCHEDULER_shutdown (); | 331 | GNUNET_SCHEDULER_shutdown (); |
369 | } | 332 | } |
370 | 333 | ||
@@ -423,17 +386,14 @@ do_shutdown (void *cls) | |||
423 | 386 | ||
424 | 387 | ||
425 | static void | 388 | static void |
426 | caller_event_handler (void *cls, | 389 | caller_event_handler (void *cls, enum GNUNET_CONVERSATION_CallerEventCode code) |
427 | enum GNUNET_CONVERSATION_CallerEventCode code) | ||
428 | { | 390 | { |
429 | (void) cls; | 391 | (void) cls; |
430 | switch (code) | 392 | switch (code) |
431 | { | 393 | { |
432 | case GNUNET_CONVERSATION_EC_CALLER_SUSPEND: | 394 | case GNUNET_CONVERSATION_EC_CALLER_SUSPEND: |
433 | case GNUNET_CONVERSATION_EC_CALLER_RESUME: | 395 | case GNUNET_CONVERSATION_EC_CALLER_RESUME: |
434 | LOG (GNUNET_ERROR_TYPE_WARNING, | 396 | LOG (GNUNET_ERROR_TYPE_WARNING, "Unexpected caller code: %d\n", code); |
435 | "Unexpected caller code: %d\n", | ||
436 | code); | ||
437 | break; | 397 | break; |
438 | } | 398 | } |
439 | } | 399 | } |
@@ -490,17 +450,14 @@ phone_event_handler (void *cls, | |||
490 | } | 450 | } |
491 | break; | 451 | break; |
492 | default: | 452 | default: |
493 | LOG (GNUNET_ERROR_TYPE_WARNING, | 453 | LOG (GNUNET_ERROR_TYPE_WARNING, "Unexpected phone code: %d\n", code); |
494 | "Unexpected phone code: %d\n", | ||
495 | code); | ||
496 | break; | 454 | break; |
497 | } | 455 | } |
498 | } | 456 | } |
499 | 457 | ||
500 | 458 | ||
501 | static void | 459 | static void |
502 | call_event_handler (void *cls, | 460 | call_event_handler (void *cls, enum GNUNET_CONVERSATION_CallEventCode code) |
503 | enum GNUNET_CONVERSATION_CallEventCode code) | ||
504 | { | 461 | { |
505 | const char *cid = cls; | 462 | const char *cid = cls; |
506 | 463 | ||
@@ -541,6 +498,7 @@ call_event_handler (void *cls, | |||
541 | 498 | ||
542 | static void | 499 | static void |
543 | caller_ego_create_cont (void *cls, | 500 | caller_ego_create_cont (void *cls, |
501 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *pk, | ||
544 | const char *emsg) | 502 | const char *emsg) |
545 | { | 503 | { |
546 | (void) cls; | 504 | (void) cls; |
@@ -550,19 +508,14 @@ caller_ego_create_cont (void *cls, | |||
550 | 508 | ||
551 | 509 | ||
552 | static void | 510 | static void |
553 | namestore_put_cont (void *cls, | 511 | namestore_put_cont (void *cls, int32_t success, const char *emsg) |
554 | int32_t success, | ||
555 | const char *emsg) | ||
556 | { | 512 | { |
557 | (void) cls; | 513 | (void) cls; |
558 | qe = NULL; | 514 | qe = NULL; |
559 | GNUNET_assert (GNUNET_YES == success); | 515 | GNUNET_assert (GNUNET_YES == success); |
560 | GNUNET_assert (NULL == emsg); | 516 | GNUNET_assert (NULL == emsg); |
561 | GNUNET_assert (NULL == op); | 517 | GNUNET_assert (NULL == op); |
562 | op = GNUNET_IDENTITY_create (id, | 518 | op = GNUNET_IDENTITY_create (id, "caller-ego", &caller_ego_create_cont, NULL); |
563 | "caller-ego", | ||
564 | &caller_ego_create_cont, | ||
565 | NULL); | ||
566 | } | 519 | } |
567 | 520 | ||
568 | 521 | ||
@@ -587,23 +540,21 @@ identity_cb (void *cls, | |||
587 | GNUNET_asprintf (&gns_name, | 540 | GNUNET_asprintf (&gns_name, |
588 | "phone.%s", | 541 | "phone.%s", |
589 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); | 542 | GNUNET_GNSRECORD_pkey_to_zkey (&pub)); |
590 | phone = GNUNET_CONVERSATION_phone_create (cfg, | 543 | phone = |
591 | ego, | 544 | GNUNET_CONVERSATION_phone_create (cfg, ego, &phone_event_handler, NULL); |
592 | &phone_event_handler, | ||
593 | NULL); | ||
594 | GNUNET_assert (NULL != phone); | 545 | GNUNET_assert (NULL != phone); |
595 | memset (&rd, 0, sizeof (rd)); | 546 | memset (&rd, 0, sizeof (rd)); |
596 | GNUNET_CONVERSATION_phone_get_record (phone, | 547 | GNUNET_CONVERSATION_phone_get_record (phone, &rd); |
597 | &rd); | ||
598 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); | 548 | GNUNET_assert (rd.record_type == GNUNET_GNSRECORD_TYPE_PHONE); |
599 | rd.expiration_time = UINT64_MAX; | 549 | rd.expiration_time = UINT64_MAX; |
600 | qe = GNUNET_NAMESTORE_records_store (ns, | 550 | qe = |
601 | GNUNET_IDENTITY_ego_get_private_key (ego), | 551 | GNUNET_NAMESTORE_records_store (ns, |
602 | "phone" /* GNS label */, | 552 | GNUNET_IDENTITY_ego_get_private_key (ego), |
603 | 1, | 553 | "phone" /* GNS label */, |
604 | &rd, | 554 | 1, |
605 | &namestore_put_cont, | 555 | &rd, |
606 | NULL); | 556 | &namestore_put_cont, |
557 | NULL); | ||
607 | return; | 558 | return; |
608 | } | 559 | } |
609 | if (0 == strcmp (name, "caller-ego")) | 560 | if (0 == strcmp (name, "caller-ego")) |
@@ -632,8 +583,7 @@ identity_cb (void *cls, | |||
632 | 583 | ||
633 | 584 | ||
634 | static void | 585 | static void |
635 | phone_ego_create_cont (void *cls, | 586 | phone_ego_create_cont (void *cls, const char *emsg) |
636 | const char *emsg) | ||
637 | { | 587 | { |
638 | (void) cls; | 588 | (void) cls; |
639 | op = NULL; | 589 | op = NULL; |
@@ -649,32 +599,23 @@ run (void *cls, | |||
649 | (void) cls; | 599 | (void) cls; |
650 | (void) peer; | 600 | (void) peer; |
651 | cfg = c; | 601 | cfg = c; |
652 | timeout_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, | 602 | timeout_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_test, NULL); |
653 | &end_test, | 603 | GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL); |
654 | NULL); | 604 | id = GNUNET_IDENTITY_connect (cfg, &identity_cb, NULL); |
655 | GNUNET_SCHEDULER_add_shutdown (&do_shutdown, | 605 | op = GNUNET_IDENTITY_create (id, "phone-ego", &phone_ego_create_cont, NULL); |
656 | NULL); | ||
657 | id = GNUNET_IDENTITY_connect (cfg, | ||
658 | &identity_cb, | ||
659 | NULL); | ||
660 | op = GNUNET_IDENTITY_create (id, | ||
661 | "phone-ego", | ||
662 | &phone_ego_create_cont, | ||
663 | NULL); | ||
664 | ns = GNUNET_NAMESTORE_connect (cfg); | 606 | ns = GNUNET_NAMESTORE_connect (cfg); |
665 | } | 607 | } |
666 | 608 | ||
667 | 609 | ||
668 | int | 610 | int |
669 | main (int argc, | 611 | main (int argc, char *argv[]) |
670 | char *argv[]) | ||
671 | { | 612 | { |
672 | (void) argc; | 613 | (void) argc; |
673 | (void) argv; | 614 | (void) argv; |
674 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api_twocalls", | 615 | if (0 != GNUNET_TESTING_peer_run ("test_conversation_api_twocalls", |
675 | "test_conversation.conf", | 616 | "test_conversation.conf", |
676 | &run, | 617 | &run, |
677 | NULL)) | 618 | NULL)) |
678 | return 1; | 619 | return 1; |
679 | if (call1_finished && call2_finished) | 620 | if (call1_finished && call2_finished) |
680 | return 0; | 621 | return 0; |