diff options
author | Bart Polot <bart@net.in.tum.de> | 2011-08-22 17:35:24 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2011-08-22 17:35:24 +0000 |
commit | 6aae69bbb5a389a2e47478b46fa1d5620c2cfbcd (patch) | |
tree | 0c5fcbe071884d54d02b149483854152c314845b /src/mesh/test_mesh_api.c | |
parent | f38f964610d4abe9e8b8aa8d20ce5bd6af67da15 (diff) | |
download | gnunet-6aae69bbb5a389a2e47478b46fa1d5620c2cfbcd.tar.gz gnunet-6aae69bbb5a389a2e47478b46fa1d5620c2cfbcd.zip |
Various changes, can't get indent to work
Diffstat (limited to 'src/mesh/test_mesh_api.c')
-rw-r--r-- | src/mesh/test_mesh_api.c | 49 |
1 files changed, 29 insertions, 20 deletions
diff --git a/src/mesh/test_mesh_api.c b/src/mesh/test_mesh_api.c index c5f0e9f0f..af6b5e3e7 100644 --- a/src/mesh/test_mesh_api.c +++ b/src/mesh/test_mesh_api.c | |||
@@ -67,25 +67,33 @@ static struct GNUNET_MESH_MessageHandler handlers[] = { {&callback, 1, 0}, | |||
67 | static void | 67 | static void |
68 | do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 68 | do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
69 | { | 69 | { |
70 | fprintf(stderr, "++++++++ STARTING SHUTDOWN\n"); | ||
71 | fprintf(stderr, "+++++++++ ABORT TASK\n"); | ||
70 | if (0 != abort_task) | 72 | if (0 != abort_task) |
71 | { | 73 | { |
72 | GNUNET_SCHEDULER_cancel (abort_task); | 74 | GNUNET_SCHEDULER_cancel (abort_task); |
73 | } | 75 | } |
76 | fprintf(stderr, "+++++++++ DISCONNECT MESH\n"); | ||
74 | if (NULL != mesh) | 77 | if (NULL != mesh) |
75 | { | 78 | { |
76 | GNUNET_MESH_disconnect (mesh); | 79 | GNUNET_MESH_disconnect (mesh); |
77 | } | 80 | } |
81 | fprintf(stderr, "+++++++++ KILL PROCESS\n"); | ||
78 | if (0 != GNUNET_OS_process_kill (arm_pid, SIGTERM)) | 82 | if (0 != GNUNET_OS_process_kill (arm_pid, SIGTERM)) |
79 | { | 83 | { |
80 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); | 84 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); |
81 | } | 85 | } |
86 | fprintf(stderr, "+++++++++ WAIT\n"); | ||
82 | GNUNET_assert (GNUNET_OK == GNUNET_OS_process_wait (arm_pid)); | 87 | GNUNET_assert (GNUNET_OK == GNUNET_OS_process_wait (arm_pid)); |
88 | fprintf(stderr, "+++++++++ PROCESS CLOSE\n"); | ||
83 | GNUNET_OS_process_close (arm_pid); | 89 | GNUNET_OS_process_close (arm_pid); |
90 | fprintf(stderr, "++++++++ END SHUTDOWN\n"); | ||
84 | } | 91 | } |
85 | 92 | ||
86 | static void | 93 | static void |
87 | do_abort (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 94 | do_abort (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
88 | { | 95 | { |
96 | fprintf(stderr, "++++++++ STARTING ABORT\n"); | ||
89 | if (0 != test_task) | 97 | if (0 != test_task) |
90 | { | 98 | { |
91 | GNUNET_SCHEDULER_cancel (test_task); | 99 | GNUNET_SCHEDULER_cancel (test_task); |
@@ -93,19 +101,18 @@ do_abort (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
93 | result = GNUNET_SYSERR; | 101 | result = GNUNET_SYSERR; |
94 | abort_task = 0; | 102 | abort_task = 0; |
95 | do_shutdown (cls, tc); | 103 | do_shutdown (cls, tc); |
104 | fprintf(stderr, "++++++++ END ABORT\n"); | ||
96 | } | 105 | } |
97 | 106 | ||
98 | static void | 107 | static void |
99 | test (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 108 | test (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
100 | { | 109 | { |
101 | struct GNUNET_CONFIGURATION_Handle *cfg = cls; | 110 | struct GNUNET_CONFIGURATION_Handle *cfg = cls; |
102 | GNUNET_MESH_ApplicationType app[3]; | 111 | static const GNUNET_MESH_ApplicationType app[] = {1,2,3,0}; |
103 | 112 | ||
113 | fprintf(stderr, "++++++++ STARTING TEST\n"); | ||
104 | test_task = (GNUNET_SCHEDULER_TaskIdentifier) 0; | 114 | test_task = (GNUNET_SCHEDULER_TaskIdentifier) 0; |
105 | app[0] = (GNUNET_MESH_ApplicationType) 1; | 115 | mesh = GNUNET_MESH_connect (cfg, NULL, NULL, handlers, app); |
106 | app[1] = (GNUNET_MESH_ApplicationType) 2; | ||
107 | app[2] = (GNUNET_MESH_ApplicationType) 0; | ||
108 | mesh = GNUNET_MESH_connect (cfg, NULL, NULL, handlers, &app); | ||
109 | if (NULL == mesh) | 116 | if (NULL == mesh) |
110 | { | 117 | { |
111 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Couldn't connect to mesh :(\n"); | 118 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Couldn't connect to mesh :(\n"); |
@@ -116,9 +123,8 @@ test (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
116 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "YAY! CONNECTED TO MESH :D\n"); | 123 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "YAY! CONNECTED TO MESH :D\n"); |
117 | } | 124 | } |
118 | 125 | ||
119 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply | 126 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 3), &do_shutdown, NULL); |
120 | (GNUNET_TIME_UNIT_SECONDS, 1), &do_shutdown, | 127 | fprintf(stderr, "++++++++ END TEST\n"); |
121 | NULL); | ||
122 | } | 128 | } |
123 | 129 | ||
124 | 130 | ||
@@ -126,6 +132,14 @@ static void | |||
126 | run (void *cls, char *const *args, const char *cfgfile, | 132 | run (void *cls, char *const *args, const char *cfgfile, |
127 | const struct GNUNET_CONFIGURATION_Handle *cfg) | 133 | const struct GNUNET_CONFIGURATION_Handle *cfg) |
128 | { | 134 | { |
135 | fprintf(stderr, "++++++++ STARTING RUN\n"); | ||
136 | GNUNET_log_setup ("test_mesh_small", | ||
137 | #if VERBOSE | ||
138 | "DEBUG", | ||
139 | #else | ||
140 | "WARNING", | ||
141 | #endif | ||
142 | NULL); | ||
129 | arm_pid = | 143 | arm_pid = |
130 | GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", | 144 | GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", |
131 | "gnunet-service-arm", | 145 | "gnunet-service-arm", |
@@ -138,11 +152,10 @@ run (void *cls, char *const *args, const char *cfgfile, | |||
138 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply | 152 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply |
139 | (GNUNET_TIME_UNIT_SECONDS, 20), &do_abort, | 153 | (GNUNET_TIME_UNIT_SECONDS, 20), &do_abort, |
140 | NULL); | 154 | NULL); |
141 | test_task = | 155 | test_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &test, (void *)cfg); |
142 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply | 156 | // GNUNET_SCHEDULER_add_now (&test, (void *)cfg); |
143 | (GNUNET_TIME_UNIT_SECONDS, 1), &test, | ||
144 | (void *) cfg); | ||
145 | 157 | ||
158 | fprintf(stderr, "++++++++ END RUN\n"); | ||
146 | } | 159 | } |
147 | 160 | ||
148 | 161 | ||
@@ -150,7 +163,6 @@ int | |||
150 | main (int argc, char *argv[]) | 163 | main (int argc, char *argv[]) |
151 | { | 164 | { |
152 | int ret; | 165 | int ret; |
153 | |||
154 | char *const argv2[] = { "test-mesh-api", | 166 | char *const argv2[] = { "test-mesh-api", |
155 | "-c", "test_mesh.conf", | 167 | "-c", "test_mesh.conf", |
156 | #if VERBOSE | 168 | #if VERBOSE |
@@ -161,13 +173,8 @@ main (int argc, char *argv[]) | |||
161 | struct GNUNET_GETOPT_CommandLineOption options[] = { | 173 | struct GNUNET_GETOPT_CommandLineOption options[] = { |
162 | GNUNET_GETOPT_OPTION_END | 174 | GNUNET_GETOPT_OPTION_END |
163 | }; | 175 | }; |
164 | GNUNET_log_setup ("test-mesh-api", | 176 | |
165 | #if VERBOSE | 177 | fprintf(stderr, "++++++++ STARTING TEST_API\n"); |
166 | "DEBUG", | ||
167 | #else | ||
168 | "WARNING", | ||
169 | #endif | ||
170 | NULL); | ||
171 | ret = | 178 | ret = |
172 | GNUNET_PROGRAM_run ((sizeof (argv2) / sizeof (char *)) - 1, argv2, | 179 | GNUNET_PROGRAM_run ((sizeof (argv2) / sizeof (char *)) - 1, argv2, |
173 | "test-mesh-api", "nohelp", options, &run, NULL); | 180 | "test-mesh-api", "nohelp", options, &run, NULL); |
@@ -183,5 +190,7 @@ main (int argc, char *argv[]) | |||
183 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "test failed\n"); | 190 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "test failed\n"); |
184 | return 1; | 191 | return 1; |
185 | } | 192 | } |
193 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "test ok\n"); | ||
194 | fprintf(stderr, "++++++++ END TEST_API\n"); | ||
186 | return 0; | 195 | return 0; |
187 | } | 196 | } |