5 * Copyright (C) 2011 BWM CarIT GmbH. All rights reserved.
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
28 #include "gdbus/gdbus.h"
30 #include "test-connman.h"
32 enum test_session_state {
33 TEST_SESSION_STATE_0 = 0,
34 TEST_SESSION_STATE_1 = 1,
35 TEST_SESSION_STATE_2 = 2,
36 TEST_SESSION_STATE_3 = 3,
39 static enum test_session_state get_session_state(struct test_session *session)
41 return GPOINTER_TO_UINT(session->fix->user_data);
44 static void set_session_state(struct test_session *session,
45 enum test_session_state state)
47 session->fix->user_data = GUINT_TO_POINTER(state);
50 static struct test_session *get_session(struct test_session *session,
53 return &session->fix->session[index];
56 static gboolean test_session_create_no_notify(gpointer data)
58 struct test_fix *fix = data;
61 util_session_create(fix, 1);
63 msg = manager_create_session(fix->session->connection,
64 fix->session->info, "/foo");
65 g_assert(msg != NULL);
66 g_assert(dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_ERROR);
68 dbus_message_unref(msg);
70 util_idle_call(fix, util_quit_loop, util_session_destroy);
75 static gboolean test_session_destroy_no_notify(gpointer data)
77 struct test_fix *fix = data;
80 util_session_create(fix, 1);
82 msg = manager_destroy_session(fix->session->connection, "/foo");
83 g_assert(msg == NULL);
85 util_idle_call(fix, util_quit_loop, util_session_destroy);
90 static void test_session_create_notify(struct test_session *session)
92 LOG("session %p", session);
94 util_idle_call(session->fix, util_quit_loop, util_session_destroy);
97 static gboolean test_session_create(gpointer data)
99 struct test_fix *fix = data;
100 struct test_session *session;
104 util_session_create(fix, 1);
105 session = fix->session;
107 session->notify_path = "/foo";
108 session->notify = test_session_create_notify;
110 err = session_notify_register(session, session->notify_path);
113 msg = manager_create_session(session->connection,
115 session->notify_path);
116 g_assert(msg != NULL);
117 g_assert(dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_ERROR);
119 dbus_message_unref(msg);
124 static gboolean test_session_create_destroy(gpointer data)
126 struct test_fix *fix = data;
127 struct test_session *session;
129 util_session_create(fix, 1);
130 session = fix->session;
132 session->notify_path = g_strdup("/foo");
134 util_session_init(fix->session);
135 util_session_cleanup(fix->session);
137 util_idle_call(fix, util_quit_loop, util_session_destroy);
142 static gboolean test_session_create_already_exists(gpointer data)
144 struct test_fix *fix = data;
145 struct test_session *session0, *session1;
148 util_session_create(fix, 2);
149 session0 = &fix->session[0];
150 session1 = &fix->session[1];
152 session0->notify_path = g_strdup("/foo");
153 session1->notify_path = session0->notify_path;
155 util_session_init(session0);
157 msg = manager_create_session(session1->connection,
159 session1->notify_path);
160 g_assert(msg == NULL);
162 util_session_cleanup(session0);
164 util_idle_call(fix, util_quit_loop, util_session_destroy);
169 static void test_session_create_many_notify(struct test_session *session)
173 LOG("session %p", session);
175 nr = GPOINTER_TO_UINT(session->fix->user_data);
177 session->fix->user_data = GUINT_TO_POINTER(nr);
182 util_idle_call(session->fix, util_quit_loop, util_session_destroy);
185 static gboolean test_session_create_many(gpointer data)
187 struct test_fix *fix = data;
188 struct test_session *session;
193 fix->user_data = GUINT_TO_POINTER(max);
195 util_session_create(fix, max);
197 for (i = 0; i < max; i++) {
198 session = &fix->session[i];
200 session->notify_path = g_strdup_printf("/foo/%d", i);
201 session->notify = test_session_create_many_notify;
203 util_session_init(session);
209 static void set_session_mode(struct test_fix *fix,
210 connman_bool_t enable)
214 msg = manager_set_session_mode(fix->main_connection, enable);
215 g_assert(msg != NULL);
216 g_assert(dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_ERROR);
218 dbus_message_unref(msg);
221 static void test_session_connect_notify(struct test_session *session)
223 LOG("session %p online %d", session, session->info->online);
225 if (session->info->online != TRUE)
228 util_session_cleanup(session);
230 util_idle_call(session->fix, util_quit_loop, util_session_destroy);
233 static gboolean test_session_connect(gpointer data)
235 struct test_fix *fix = data;
236 struct test_session *session;
239 util_session_create(fix, 1);
240 session = fix->session;
242 session->notify_path = g_strdup("/foo");
243 session->notify = test_session_connect_notify;
244 util_session_init(session);
246 msg = session_connect(session->connection, session);
247 g_assert(msg != NULL);
248 g_assert(dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_ERROR);
250 dbus_message_unref(msg);
255 static void test_session_disconnect_notify(struct test_session *session)
257 LOG("session %p online %d", session, session->info->online);
259 if (session->info->online != FALSE)
262 util_session_cleanup(session);
264 util_idle_call(session->fix, util_quit_loop, util_session_destroy);
267 static gboolean test_session_disconnect(gpointer data)
269 struct test_fix *fix = data;
270 struct test_session *session;
273 util_session_create(fix, 1);
274 session = fix->session;
276 session->notify_path = g_strdup("/foo");
277 session->notify = test_session_disconnect_notify;
278 util_session_init(session);
280 msg = session_disconnect(session->connection, session);
281 g_assert(msg != NULL);
282 dbus_message_unref(msg);
287 static void test_session_connect_disconnect_notify(struct test_session *session)
291 LOG("session %p online %d", session, session->info->online);
293 if (session->info->online != TRUE)
296 msg = session_disconnect(session->connection, session);
297 g_assert(msg != NULL);
298 dbus_message_unref(msg);
300 util_session_cleanup(session);
302 util_idle_call(session->fix, util_quit_loop, util_session_destroy);
305 static gboolean test_session_connect_disconnect(gpointer data)
307 struct test_fix *fix = data;
308 struct test_session *session;
311 util_session_create(fix, 1);
312 session = fix->session;
314 session->notify_path = g_strdup("/foo");
315 session->notify = test_session_connect_disconnect_notify;
316 util_session_init(session);
318 msg = session_connect(session->connection, session);
319 g_assert(msg != NULL);
320 g_assert(dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_ERROR);
322 dbus_message_unref(msg);
327 static void test_session_connect_free_ride_notify(struct test_session *session)
329 struct test_session *session0 = get_session(session, 0);
330 struct test_session *session1 = get_session(session, 1);
331 enum test_session_state state = get_session_state(session);
332 enum test_session_state next_state = state;
335 LOG("state %d session %p %s online %d", state, session,
336 session->notify_path, session->info->online);
339 case TEST_SESSION_STATE_0:
340 if (session0->info->online == FALSE &&
341 session1->info->online == FALSE) {
342 next_state = TEST_SESSION_STATE_1;
346 case TEST_SESSION_STATE_1:
347 if (session0->info->online == TRUE &&
348 session1->info->online == TRUE) {
349 next_state = TEST_SESSION_STATE_2;
353 case TEST_SESSION_STATE_2:
354 if (session0->info->online == FALSE &&
355 session1->info->online == FALSE) {
356 next_state = TEST_SESSION_STATE_3;
360 case TEST_SESSION_STATE_3:
365 if (state == next_state)
368 set_session_state(session, next_state);
370 LOG("next_state %d", next_state);
372 switch (next_state) {
373 case TEST_SESSION_STATE_0:
376 case TEST_SESSION_STATE_1:
377 msg = session_connect(session0->connection, session0);
378 g_assert(msg != NULL);
379 dbus_message_unref(msg);
383 case TEST_SESSION_STATE_2:
384 msg = session_disconnect(session0->connection, session0);
385 g_assert(msg != NULL);
386 dbus_message_unref(msg);
389 case TEST_SESSION_STATE_3:
390 util_session_cleanup(session0);
391 util_session_cleanup(session1);
393 util_idle_call(session0->fix, util_quit_loop,
394 util_session_destroy);
400 static gboolean test_session_connect_free_ride(gpointer data)
402 struct test_fix *fix = data;
403 struct test_session *session0, *session1;
406 * +-------------------+
408 * +-------------------+
412 * +-------------------+
414 * +-------------------+
418 * +-------------------+
419 * | FOO-BAR-CONNECTED |
420 * +-------------------+
424 * +-------------------+
426 * +-------------------+
429 util_session_create(fix, 2);
430 session0 = &fix->session[0];
431 session1 = &fix->session[1];
433 session0->notify_path = g_strdup("/foo");
434 session1->notify_path = g_strdup("/bar");
435 session0->notify = test_session_connect_free_ride_notify;
436 session1->notify = test_session_connect_free_ride_notify;
438 util_session_init(session0);
439 util_session_init(session1);
441 set_session_state(session0, TEST_SESSION_STATE_0);
446 static connman_bool_t is_online(struct test_fix *fix)
448 if (g_strcmp0(fix->manager.state, "online") == 0)
454 static gboolean enable_session_mode(gpointer data)
456 struct test_fix *fix = data;
458 set_session_mode(fix, TRUE);
460 if (is_online(fix) == FALSE)
461 util_idle_call(fix, util_quit_loop, NULL);
466 static gboolean manager_state_changed(gpointer data)
468 struct test_fix *fix = data;
470 if (is_online(fix) == FALSE) {
471 fix->manager_changed = NULL;
472 util_idle_call(fix, util_quit_loop, NULL);
478 static gboolean disable_session_mode(gpointer data)
480 struct test_fix *fix = data;
482 set_session_mode(fix, FALSE);
487 static void setup_cb(struct test_fix *fix, gconstpointer data)
489 fix->manager_changed = manager_state_changed;
491 util_setup(fix, data);
492 util_call(fix, enable_session_mode, NULL);
494 g_main_loop_run(fix->main_loop);
496 fix->manager_changed = NULL;
499 static void teardown_cb(struct test_fix *fix, gconstpointer data)
501 util_call(fix, disable_session_mode, NULL);
502 util_idle_call(fix, util_quit_loop, NULL);
504 g_main_loop_run(fix->main_loop);
506 util_teardown(fix, data);
509 int main(int argc, char *argv[])
511 g_test_init(&argc, &argv, NULL);
513 util_test_add("/manager/session create no notify",
514 test_session_create_no_notify, setup_cb, teardown_cb);
515 util_test_add("/manager/session destroy no notify",
516 test_session_destroy_no_notify, setup_cb, teardown_cb);
517 util_test_add("/manager/session create",
518 test_session_create, setup_cb, teardown_cb);
519 util_test_add("/manager/session create destroy",
520 test_session_create_destroy, setup_cb, teardown_cb);
521 util_test_add("/manager/session create already exists",
522 test_session_create_already_exists, setup_cb, teardown_cb);
523 util_test_add("/manager/session create many",
524 test_session_create_many, setup_cb, teardown_cb);
526 util_test_add("/session/connect",
527 test_session_connect, setup_cb, teardown_cb);
528 util_test_add("/session/disconnect",
529 test_session_disconnect, setup_cb, teardown_cb);
530 util_test_add("/session/connect disconnect",
531 test_session_connect_disconnect, setup_cb, teardown_cb);
532 util_test_add("/session/connect free-ride",
533 test_session_connect_free_ride, setup_cb, teardown_cb);