aboutsummaryrefslogtreecommitdiff
path: root/src/mesh/test_mesh_api.c
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2011-08-22 17:35:24 +0000
committerBart Polot <bart@net.in.tum.de>2011-08-22 17:35:24 +0000
commit6aae69bbb5a389a2e47478b46fa1d5620c2cfbcd (patch)
tree0c5fcbe071884d54d02b149483854152c314845b /src/mesh/test_mesh_api.c
parentf38f964610d4abe9e8b8aa8d20ce5bd6af67da15 (diff)
downloadgnunet-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.c49
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},
67static void 67static void
68do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 68do_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
86static void 93static void
87do_abort (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 94do_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
98static void 107static void
99test (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 108test (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
126run (void *cls, char *const *args, const char *cfgfile, 132run (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
150main (int argc, char *argv[]) 163main (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}