diff options
Diffstat (limited to 'src/transport/transport-testing.h')
-rw-r--r-- | src/transport/transport-testing.h | 78 |
1 files changed, 42 insertions, 36 deletions
diff --git a/src/transport/transport-testing.h b/src/transport/transport-testing.h index fc39646b2..0f7c51ce5 100644 --- a/src/transport/transport-testing.h +++ b/src/transport/transport-testing.h | |||
@@ -51,7 +51,8 @@ struct GNUNET_TRANSPORT_TESTING_Handle; | |||
51 | /** | 51 | /** |
52 | * Context for a single peer | 52 | * Context for a single peer |
53 | */ | 53 | */ |
54 | struct GNUNET_TRANSPORT_TESTING_PeerContext { | 54 | struct GNUNET_TRANSPORT_TESTING_PeerContext |
55 | { | ||
55 | /** | 56 | /** |
56 | * Next element in the DLL | 57 | * Next element in the DLL |
57 | */ | 58 | */ |
@@ -152,7 +153,8 @@ struct GNUNET_TRANSPORT_TESTING_PeerContext { | |||
152 | /** | 153 | /** |
153 | * Handle for a request to connect two peers. | 154 | * Handle for a request to connect two peers. |
154 | */ | 155 | */ |
155 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest { | 156 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest |
157 | { | ||
156 | /** | 158 | /** |
157 | * Kept in a DLL. | 159 | * Kept in a DLL. |
158 | */ | 160 | */ |
@@ -224,7 +226,8 @@ struct GNUNET_TRANSPORT_TESTING_ConnectRequest { | |||
224 | /** | 226 | /** |
225 | * Handle for a test run. | 227 | * Handle for a test run. |
226 | */ | 228 | */ |
227 | struct GNUNET_TRANSPORT_TESTING_Handle { | 229 | struct GNUNET_TRANSPORT_TESTING_Handle |
230 | { | ||
228 | /** | 231 | /** |
229 | * Testing library system handle | 232 | * Testing library system handle |
230 | */ | 233 | */ |
@@ -258,7 +261,7 @@ struct GNUNET_TRANSPORT_TESTING_Handle { | |||
258 | * @return transport testing handle | 261 | * @return transport testing handle |
259 | */ | 262 | */ |
260 | struct GNUNET_TRANSPORT_TESTING_Handle * | 263 | struct GNUNET_TRANSPORT_TESTING_Handle * |
261 | GNUNET_TRANSPORT_TESTING_init(void); | 264 | GNUNET_TRANSPORT_TESTING_init (void); |
262 | 265 | ||
263 | 266 | ||
264 | /** | 267 | /** |
@@ -267,7 +270,7 @@ GNUNET_TRANSPORT_TESTING_init(void); | |||
267 | * @param tth transport testing handle | 270 | * @param tth transport testing handle |
268 | */ | 271 | */ |
269 | void | 272 | void |
270 | GNUNET_TRANSPORT_TESTING_done(struct GNUNET_TRANSPORT_TESTING_Handle *tth); | 273 | GNUNET_TRANSPORT_TESTING_done (struct GNUNET_TRANSPORT_TESTING_Handle *tth); |
271 | 274 | ||
272 | 275 | ||
273 | /** | 276 | /** |
@@ -285,7 +288,7 @@ GNUNET_TRANSPORT_TESTING_done(struct GNUNET_TRANSPORT_TESTING_Handle *tth); | |||
285 | * @return the peer context | 288 | * @return the peer context |
286 | */ | 289 | */ |
287 | struct GNUNET_TRANSPORT_TESTING_PeerContext * | 290 | struct GNUNET_TRANSPORT_TESTING_PeerContext * |
288 | GNUNET_TRANSPORT_TESTING_start_peer( | 291 | GNUNET_TRANSPORT_TESTING_start_peer ( |
289 | struct GNUNET_TRANSPORT_TESTING_Handle *tth, | 292 | struct GNUNET_TRANSPORT_TESTING_Handle *tth, |
290 | const char *cfgname, | 293 | const char *cfgname, |
291 | int peer_id, | 294 | int peer_id, |
@@ -303,7 +306,7 @@ GNUNET_TRANSPORT_TESTING_start_peer( | |||
303 | * @param p the peer | 306 | * @param p the peer |
304 | */ | 307 | */ |
305 | void | 308 | void |
306 | GNUNET_TRANSPORT_TESTING_stop_peer( | 309 | GNUNET_TRANSPORT_TESTING_stop_peer ( |
307 | struct GNUNET_TRANSPORT_TESTING_PeerContext *pc); | 310 | struct GNUNET_TRANSPORT_TESTING_PeerContext *pc); |
308 | 311 | ||
309 | 312 | ||
@@ -316,7 +319,7 @@ GNUNET_TRANSPORT_TESTING_stop_peer( | |||
316 | * @return #GNUNET_OK in success otherwise #GNUNET_SYSERR | 319 | * @return #GNUNET_OK in success otherwise #GNUNET_SYSERR |
317 | */ | 320 | */ |
318 | int | 321 | int |
319 | GNUNET_TRANSPORT_TESTING_restart_peer( | 322 | GNUNET_TRANSPORT_TESTING_restart_peer ( |
320 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p, | 323 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p, |
321 | GNUNET_SCHEDULER_TaskCallback restart_cb, | 324 | GNUNET_SCHEDULER_TaskCallback restart_cb, |
322 | void *restart_cb_cls); | 325 | void *restart_cb_cls); |
@@ -335,7 +338,7 @@ GNUNET_TRANSPORT_TESTING_restart_peer( | |||
335 | * @return a connect request handle | 338 | * @return a connect request handle |
336 | */ | 339 | */ |
337 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest * | 340 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest * |
338 | GNUNET_TRANSPORT_TESTING_connect_peers( | 341 | GNUNET_TRANSPORT_TESTING_connect_peers ( |
339 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p1, | 342 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p1, |
340 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p2, | 343 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p2, |
341 | GNUNET_SCHEDULER_TaskCallback cb, | 344 | GNUNET_SCHEDULER_TaskCallback cb, |
@@ -350,7 +353,7 @@ GNUNET_TRANSPORT_TESTING_connect_peers( | |||
350 | * @param cc a connect request handle | 353 | * @param cc a connect request handle |
351 | */ | 354 | */ |
352 | void | 355 | void |
353 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel( | 356 | GNUNET_TRANSPORT_TESTING_connect_peers_cancel ( |
354 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc); | 357 | struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc); |
355 | 358 | ||
356 | 359 | ||
@@ -374,7 +377,7 @@ typedef void (*GNUNET_TRANSPORT_TESTING_ConnectContextCallback) ( | |||
374 | * @param cb_cls closure for @a cb | 377 | * @param cb_cls closure for @a cb |
375 | */ | 378 | */ |
376 | void | 379 | void |
377 | GNUNET_TRANSPORT_TESTING_find_connecting_context( | 380 | GNUNET_TRANSPORT_TESTING_find_connecting_context ( |
378 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p1, | 381 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p1, |
379 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p2, | 382 | struct GNUNET_TRANSPORT_TESTING_PeerContext *p2, |
380 | GNUNET_TRANSPORT_TESTING_ConnectContextCallback cb, | 383 | GNUNET_TRANSPORT_TESTING_ConnectContextCallback cb, |
@@ -410,7 +413,8 @@ struct GNUNET_TRANSPORT_TESTING_InternalPeerContext; | |||
410 | 413 | ||
411 | 414 | ||
412 | GNUNET_NETWORK_STRUCT_BEGIN | 415 | GNUNET_NETWORK_STRUCT_BEGIN |
413 | struct GNUNET_TRANSPORT_TESTING_TestMessage { | 416 | struct GNUNET_TRANSPORT_TESTING_TestMessage |
417 | { | ||
414 | /** | 418 | /** |
415 | * Type is (usually) #GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE. | 419 | * Type is (usually) #GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE. |
416 | */ | 420 | */ |
@@ -471,7 +475,8 @@ typedef void (*GNUNET_TRANSPORT_TESTING_NotifyDisconnect) ( | |||
471 | * Closure that must be passed to | 475 | * Closure that must be passed to |
472 | * #GNUNET_TRANSPORT_TESTING_connect_check. | 476 | * #GNUNET_TRANSPORT_TESTING_connect_check. |
473 | */ | 477 | */ |
474 | struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext { | 478 | struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext |
479 | { | ||
475 | /** | 480 | /** |
476 | * How should we continue after the connect? | 481 | * How should we continue after the connect? |
477 | */ | 482 | */ |
@@ -634,7 +639,7 @@ struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext { | |||
634 | * @return NULL if @a peer was not found | 639 | * @return NULL if @a peer was not found |
635 | */ | 640 | */ |
636 | struct GNUNET_TRANSPORT_TESTING_PeerContext * | 641 | struct GNUNET_TRANSPORT_TESTING_PeerContext * |
637 | GNUNET_TRANSPORT_TESTING_find_peer( | 642 | GNUNET_TRANSPORT_TESTING_find_peer ( |
638 | struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc, | 643 | struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc, |
639 | const struct GNUNET_PeerIdentity *peer); | 644 | const struct GNUNET_PeerIdentity *peer); |
640 | 645 | ||
@@ -656,7 +661,7 @@ GNUNET_TRANSPORT_TESTING_find_peer( | |||
656 | * @return #GNUNET_SYSERR on error | 661 | * @return #GNUNET_SYSERR on error |
657 | */ | 662 | */ |
658 | int | 663 | int |
659 | GNUNET_TRANSPORT_TESTING_connect_check( | 664 | GNUNET_TRANSPORT_TESTING_connect_check ( |
660 | void *cls, | 665 | void *cls, |
661 | struct GNUNET_TRANSPORT_TESTING_Handle *tth_, | 666 | struct GNUNET_TRANSPORT_TESTING_Handle *tth_, |
662 | const char *test_plugin_, | 667 | const char *test_plugin_, |
@@ -697,11 +702,11 @@ typedef int (*GNUNET_TRANSPORT_TESTING_CheckCallback) ( | |||
697 | * @return #GNUNET_OK on success | 702 | * @return #GNUNET_OK on success |
698 | */ | 703 | */ |
699 | int | 704 | int |
700 | GNUNET_TRANSPORT_TESTING_main_(const char *argv0, | 705 | GNUNET_TRANSPORT_TESTING_main_ (const char *argv0, |
701 | const char *filename, | 706 | const char *filename, |
702 | unsigned int num_peers, | 707 | unsigned int num_peers, |
703 | GNUNET_TRANSPORT_TESTING_CheckCallback check, | 708 | GNUNET_TRANSPORT_TESTING_CheckCallback check, |
704 | void *check_cls); | 709 | void *check_cls); |
705 | 710 | ||
706 | 711 | ||
707 | /** | 712 | /** |
@@ -713,11 +718,11 @@ GNUNET_TRANSPORT_TESTING_main_(const char *argv0, | |||
713 | * @return #GNUNET_OK on success | 718 | * @return #GNUNET_OK on success |
714 | */ | 719 | */ |
715 | #define GNUNET_TRANSPORT_TESTING_main(num_peers, check, check_cls) \ | 720 | #define GNUNET_TRANSPORT_TESTING_main(num_peers, check, check_cls) \ |
716 | GNUNET_TRANSPORT_TESTING_main_(argv[0], \ | 721 | GNUNET_TRANSPORT_TESTING_main_ (argv[0], \ |
717 | __FILE__, \ | 722 | __FILE__, \ |
718 | num_peers, \ | 723 | num_peers, \ |
719 | check, \ | 724 | check, \ |
720 | check_cls) | 725 | check_cls) |
721 | 726 | ||
722 | /* ***************** Convenience functions for sending ********* */ | 727 | /* ***************** Convenience functions for sending ********* */ |
723 | 728 | ||
@@ -739,7 +744,7 @@ GNUNET_TRANSPORT_TESTING_main_(const char *argv0, | |||
739 | * #GNUNET_SYSERR if @a msize is illegal | 744 | * #GNUNET_SYSERR if @a msize is illegal |
740 | */ | 745 | */ |
741 | int | 746 | int |
742 | GNUNET_TRANSPORT_TESTING_send( | 747 | GNUNET_TRANSPORT_TESTING_send ( |
743 | struct GNUNET_TRANSPORT_TESTING_PeerContext *sender, | 748 | struct GNUNET_TRANSPORT_TESTING_PeerContext *sender, |
744 | struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, | 749 | struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, |
745 | uint16_t mtype, | 750 | uint16_t mtype, |
@@ -765,7 +770,8 @@ GNUNET_TRANSPORT_TESTING_send( | |||
765 | * #GNUNET_TRANSPORT_TESTING_simple_send() and | 770 | * #GNUNET_TRANSPORT_TESTING_simple_send() and |
766 | * #GNUNET_TRANSPORT_TESTING_large_send(). | 771 | * #GNUNET_TRANSPORT_TESTING_large_send(). |
767 | */ | 772 | */ |
768 | struct GNUNET_TRANSPORT_TESTING_SendClosure { | 773 | struct GNUNET_TRANSPORT_TESTING_SendClosure |
774 | { | ||
769 | /** | 775 | /** |
770 | * Context for the transmission. | 776 | * Context for the transmission. |
771 | */ | 777 | */ |
@@ -805,7 +811,7 @@ struct GNUNET_TRANSPORT_TESTING_SendClosure { | |||
805 | * of which should be currently connected | 811 | * of which should be currently connected |
806 | */ | 812 | */ |
807 | void | 813 | void |
808 | GNUNET_TRANSPORT_TESTING_simple_send(void *cls); | 814 | GNUNET_TRANSPORT_TESTING_simple_send (void *cls); |
809 | 815 | ||
810 | /** | 816 | /** |
811 | * Size of a message sent with | 817 | * Size of a message sent with |
@@ -823,7 +829,7 @@ GNUNET_TRANSPORT_TESTING_simple_send(void *cls); | |||
823 | * of which should be currently connected | 829 | * of which should be currently connected |
824 | */ | 830 | */ |
825 | void | 831 | void |
826 | GNUNET_TRANSPORT_TESTING_large_send(void *cls); | 832 | GNUNET_TRANSPORT_TESTING_large_send (void *cls); |
827 | 833 | ||
828 | 834 | ||
829 | /* ********************** log-only convenience functions ************* */ | 835 | /* ********************** log-only convenience functions ************* */ |
@@ -837,7 +843,7 @@ GNUNET_TRANSPORT_TESTING_large_send(void *cls); | |||
837 | * @param other peer that connected. | 843 | * @param other peer that connected. |
838 | */ | 844 | */ |
839 | void | 845 | void |
840 | GNUNET_TRANSPORT_TESTING_log_connect( | 846 | GNUNET_TRANSPORT_TESTING_log_connect ( |
841 | void *cls, | 847 | void *cls, |
842 | struct GNUNET_TRANSPORT_TESTING_PeerContext *me, | 848 | struct GNUNET_TRANSPORT_TESTING_PeerContext *me, |
843 | const struct GNUNET_PeerIdentity *other); | 849 | const struct GNUNET_PeerIdentity *other); |
@@ -851,7 +857,7 @@ GNUNET_TRANSPORT_TESTING_log_connect( | |||
851 | * @param other peer that disconnected. | 857 | * @param other peer that disconnected. |
852 | */ | 858 | */ |
853 | void | 859 | void |
854 | GNUNET_TRANSPORT_TESTING_log_disconnect( | 860 | GNUNET_TRANSPORT_TESTING_log_disconnect ( |
855 | void *cls, | 861 | void *cls, |
856 | struct GNUNET_TRANSPORT_TESTING_PeerContext *me, | 862 | struct GNUNET_TRANSPORT_TESTING_PeerContext *me, |
857 | const struct GNUNET_PeerIdentity *other); | 863 | const struct GNUNET_PeerIdentity *other); |
@@ -868,7 +874,7 @@ GNUNET_TRANSPORT_TESTING_log_disconnect( | |||
868 | * @return resulting test name | 874 | * @return resulting test name |
869 | */ | 875 | */ |
870 | char * | 876 | char * |
871 | GNUNET_TRANSPORT_TESTING_get_test_name(const char *file); | 877 | GNUNET_TRANSPORT_TESTING_get_test_name (const char *file); |
872 | 878 | ||
873 | 879 | ||
874 | /** | 880 | /** |
@@ -880,7 +886,7 @@ GNUNET_TRANSPORT_TESTING_get_test_name(const char *file); | |||
880 | * @return configuration name to use | 886 | * @return configuration name to use |
881 | */ | 887 | */ |
882 | char * | 888 | char * |
883 | GNUNET_TRANSPORT_TESTING_get_config_name(const char *file, int count); | 889 | GNUNET_TRANSPORT_TESTING_get_config_name (const char *file, int count); |
884 | 890 | ||
885 | 891 | ||
886 | /** | 892 | /** |
@@ -890,8 +896,8 @@ GNUNET_TRANSPORT_TESTING_get_config_name(const char *file, int count); | |||
890 | * @return the plugin name | 896 | * @return the plugin name |
891 | */ | 897 | */ |
892 | char * | 898 | char * |
893 | GNUNET_TRANSPORT_TESTING_get_test_plugin_name(const char *executable, | 899 | GNUNET_TRANSPORT_TESTING_get_test_plugin_name (const char *executable, |
894 | const char *testname); | 900 | const char *testname); |
895 | 901 | ||
896 | 902 | ||
897 | /** | 903 | /** |
@@ -902,7 +908,7 @@ GNUNET_TRANSPORT_TESTING_get_test_plugin_name(const char *executable, | |||
902 | * @return the source name | 908 | * @return the source name |
903 | */ | 909 | */ |
904 | char * | 910 | char * |
905 | GNUNET_TRANSPORT_TESTING_get_test_source_name(const char *file); | 911 | GNUNET_TRANSPORT_TESTING_get_test_source_name (const char *file); |
906 | 912 | ||
907 | #endif | 913 | #endif |
908 | /* end of transport_testing.h */ | 914 | /* end of transport_testing.h */ |