X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fclient.c;h=92a4c1be7dcb372cba47f7eb51393bb15a277cf1;hb=f02df5cadb44ba0c22bcac1448877a0ab97a3417;hp=e3370cc9922a049b686cc973c7a3262201086914;hpb=1915944082905af6f8670ee50465cc168a432a1b;p=platform%2Fframework%2Fweb%2Flivebox-viewer.git diff --git a/src/client.c b/src/client.c index e3370cc..92a4c1b 100644 --- a/src/client.c +++ b/src/client.c @@ -1,11 +1,11 @@ /* - * Copyright 2012 Samsung Electronics Co., Ltd + * Copyright 2013 Samsung Electronics Co., Ltd * - * Licensed under the Flora License, Version 1.0 (the "License"); + * Licensed under the Flora License, Version 1.1 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * - * http://www.tizenopensource.org/license + * http://floralicense.org/license/ * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, @@ -23,9 +23,13 @@ #include #include +#include +#include + #include #include #include +#include #include "debug.h" #include "client.h" @@ -38,14 +42,12 @@ #include "conf.h" #include "critical_log.h" -static inline void make_connection(void); - static struct info { int fd; - guint reconnector; + guint timer_id; } s_info = { .fd = -1, - .reconnector = 0, + .timer_id = 0, }; static struct packet *master_fault_package(pid_t pid, int handle, const struct packet *packet) @@ -61,7 +63,33 @@ static struct packet *master_fault_package(pid_t pid, int handle, const struct p master_rpc_clear_fault_package(pkgname); lb_invoke_fault_handler(LB_FAULT_DEACTIVATED, pkgname, id, function); - DbgPrint("%s(%s) is deactivated\n", pkgname, id); + return NULL; +} + +static struct packet *master_hold_scroll(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + int seize; + int ret; + + ret = packet_get(packet, "ssi", &pkgname, &id, &seize); + if (ret != 3) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance(%s) is not exists\n", id); + goto out; + } + + DbgPrint("HOLD: %s %d\n", id, seize); + lb_invoke_event_handler(handler, seize ? LB_EVENT_HOLD_SCROLL : LB_EVENT_RELEASE_SCROLL); + +out: return NULL; } @@ -73,22 +101,22 @@ static struct packet *master_pinup(pid_t pid, int handle, const struct packet *p struct livebox *handler; char *new_content; int ret; + int status; int pinup; - ret = packet_get(packet, "iisss", &ret, &pinup, &pkgname, &id, &content); + ret = packet_get(packet, "iisss", &status, &pinup, &pkgname, &id, &content); if (ret != 5) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("Instance (%s) is not exists\n", id); goto out; } - if (ret == 0) { + if (status == 0) { new_content = strdup(content); if (new_content) { free(handler->content); @@ -96,20 +124,26 @@ static struct packet *master_pinup(pid_t pid, int handle, const struct packet *p handler->is_pinned_up = pinup; } else { ErrPrint("Heap: %s\n", strerror(errno)); - ret = -ENOMEM; + status = LB_STATUS_ERROR_MEMORY; } } if (handler->pinup_cb) { - handler->pinup_cb(handler, ret, handler->pinup_cbdata); + ret_cb_t cb; + void *cbdata; - handler->pinup_cb = NULL; /*!< Reset pinup cb */ + /* Make sure that user can call pinup API in its result callback */ + cb = handler->pinup_cb; + cbdata = handler->pinup_cbdata; + + handler->pinup_cb = NULL; handler->pinup_cbdata = NULL; - } else { + + cb(handler, status, cbdata); + } else if (status == 0) { lb_invoke_event_handler(handler, LB_EVENT_PINUP_CHANGED); } - ret = 0; out: return NULL; } @@ -149,6 +183,8 @@ static struct packet *master_deleted(pid_t pid, int handle, const struct packet } if (handler->created_cb) { + ret_cb_t cb; + void *cbdata; /*! * \note * @@ -169,25 +205,30 @@ static struct packet *master_deleted(pid_t pid, int handle, const struct packet handler->deleted_cbdata = NULL; } - DbgPrint("Call the created cb with -ECANCELED\n"); - handler->created_cb(handler, -ECANCELED, handler->created_cbdata); + cb = handler->created_cb; + cbdata = handler->created_cbdata; + handler->created_cb = NULL; handler->created_cbdata = NULL; + + cb(handler, LB_STATUS_ERROR_CANCEL, cbdata); } else if (handler->id) { if (handler->deleted_cb) { - DbgPrint("Call the deleted cb\n"); - handler->deleted_cb(handler, 0, handler->deleted_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->deleted_cb; + cbdata = handler->deleted_cbdata; handler->deleted_cb = NULL; handler->deleted_cbdata = NULL; + + cb(handler, LB_STATUS_SUCCESS, cbdata); } else { - DbgPrint("Call the lb,deleted\n"); lb_invoke_event_handler(handler, LB_EVENT_DELETED); } } - DbgPrint("[%p] %s(%s) is deleted\n", handler, pkgname, id); - /* Just try to delete it, if a user didn't remove it from the live box list */ lb_unref(handler); @@ -195,6 +236,213 @@ out: return NULL; } +static struct packet *master_lb_update_begin(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + const char *content; + const char *title; + const char *fbfile; + double priority; + int ret; + + ret = packet_get(packet, "ssdsss", &pkgname, &id, &priority, &content, &title, &fbfile); + if (ret != 6) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance[%s] is not exists\n", id); + goto out; + } + + if (handler->state != CREATE) { + ErrPrint("(%s) is not created\n", id); + goto out; + } + + lb_set_priority(handler, priority); + lb_set_content(handler, content); + lb_set_title(handler, title); + + /*! + * \NOTE + * Width & Height is not changed in this case. + * If the active update is began, the size should not be changed, + * And if the size is changed, the provider should finish the updating first. + * And then begin updating again after change its size. + */ + if (lb_get_lb_fb(handler)) { + lb_set_lb_fb(handler, fbfile); + + ret = fb_sync(lb_get_lb_fb(handler)); + if (ret != LB_STATUS_SUCCESS) + ErrPrint("Failed to do sync FB (%s - %s) (%d)\n", pkgname, fbfile, ret); + else + lb_invoke_event_handler(handler, LB_EVENT_LB_UPDATE_BEGIN); + } else { + ErrPrint("Invalid request[%s], %s\n", id, fbfile); + } + +out: + return NULL; +} + +static struct packet *master_pd_update_begin(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + const char *fbfile; + int ret; + + ret = packet_get(packet, "sss", &pkgname, &id, &fbfile); + if (ret != 2) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance[%s] is not exists\n", id); + goto out; + } + + if (handler->state != CREATE) { + ErrPrint("[%s] is not created\n", id); + goto out; + } + + if (lb_get_pd_fb(handler)) { + lb_set_lb_fb(handler, fbfile); + + ret = fb_sync(lb_get_lb_fb(handler)); + if (ret != LB_STATUS_SUCCESS) + ErrPrint("Failed to do sync FB (%s - %s) (%d)\n", pkgname, fbfile, ret); + else + lb_invoke_event_handler(handler, LB_EVENT_PD_UPDATE_BEGIN); + } else { + ErrPrint("Invalid request[%s], %s\n", id, fbfile); + } + +out: + return NULL; +} + +static struct packet *master_lb_update_end(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + int ret; + + ret = packet_get(packet, "ss", &pkgname, &id); + if (ret != 2) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance[%s] is not exists\n", id); + goto out; + } + + if (handler->state != CREATE) { + ErrPrint("[%s] is not created\n", id); + goto out; + } + + if (lb_get_lb_fb(handler)) { + lb_invoke_event_handler(handler, LB_EVENT_LB_UPDATE_END); + } else { + ErrPrint("Invalid request[%s]\n", id); + } + +out: + return NULL; +} + +static struct packet *master_access_status(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + int ret; + int status; + + ret = packet_get(packet, "ssi", &pkgname, &id, &status); + if (ret != 3) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance[%s] is not exists\n", id); + goto out; + } + + if (handler->state != CREATE) { + ErrPrint("[%s] is not created\n", id); + goto out; + } + + if (handler->access_event_cb) { + ret_cb_t cb; + void *cbdata; + + cb = handler->access_event_cb; + cbdata = handler->access_event_cbdata; + + handler->access_event_cb = NULL; + handler->access_event_cbdata = NULL; + + cb(handler, status, cbdata); + } else { + ErrPrint("Invalid event[%s]\n", id); + } +out: + return NULL; +} + +static struct packet *master_pd_update_end(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + int ret; + + ret = packet_get(packet, "ss", &pkgname, &id); + if (ret != 2) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Instance[%s] is not exists\n", id); + goto out; + } + + if (handler->state != CREATE) { + ErrPrint("[%s] is not created\n", id); + goto out; + } + + if (lb_get_lb_fb(handler)) { + lb_invoke_event_handler(handler, LB_EVENT_PD_UPDATE_END); + } else { + ErrPrint("Invalid request[%s]", id); + } + +out: + return NULL; +} + static struct packet *master_lb_updated(pid_t pid, int handle, const struct packet *packet) { const char *pkgname; @@ -214,13 +462,12 @@ static struct packet *master_lb_updated(pid_t pid, int handle, const struct pack &priority, &content, &title); if (ret != 8) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("instance(%s) is not exists\n", id); goto out; } @@ -231,34 +478,33 @@ static struct packet *master_lb_updated(pid_t pid, int handle, const struct pack * Don't try to notice anything with this, Just ignore all events * Beacuse the user doesn't wants know about this anymore */ - ret = -EPERM; + ErrPrint("(%s) is not exists, but updated\n", id); goto out; } lb_set_priority(handler, priority); lb_set_content(handler, content); lb_set_title(handler, title); + lb_set_size(handler, lb_w, lb_h); if (lb_text_lb(handler)) { - lb_set_size(handler, lb_w, lb_h); - ret = parse_desc(handler, livebox_filename(handler), 0); + (void)parse_desc(handler, livebox_filename(handler), 0); /*! * \note * DESC parser will call the "text event callback". + * Don't need to call global event callback in this case. */ goto out; } else if (lb_get_lb_fb(handler)) { - lb_set_size(handler, lb_w, lb_h); lb_set_lb_fb(handler, fbfile); ret = fb_sync(lb_get_lb_fb(handler)); - if (ret < 0) - ErrPrint("Failed to do sync FB (%s - %s)\n", pkgname, util_basename(util_uri_to_path(id))); + if (ret != LB_STATUS_SUCCESS) + ErrPrint("Failed to do sync FB (%s - %s) (%d)\n", pkgname, util_basename(util_uri_to_path(id)), ret); } else { - lb_set_size(handler, lb_w, lb_h); - ret = 0; + ret = LB_STATUS_SUCCESS; } - if (ret == 0) + if (ret == LB_STATUS_SUCCESS) lb_invoke_event_handler(handler, LB_EVENT_LB_UPDATED); out: @@ -284,12 +530,12 @@ static struct packet *master_pd_created(pid_t pid, int handle, const struct pack handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("Instance(%s) is not exists\n", id); goto out; } if (handler->state != CREATE) { - ret = -EPERM; + ErrPrint("Instance(%s) is not created\n", id); goto out; } @@ -299,27 +545,33 @@ static struct packet *master_pd_created(pid_t pid, int handle, const struct pack } else { (void)lb_set_pd_fb(handler, buf_id); ret = fb_sync(lb_get_pd_fb(handler)); - if (ret < 0) { - ErrPrint("Failed to do sync FB (%s - %s)\n", - pkgname, - util_basename(util_uri_to_path(id))); - } + if (ret < 0) + ErrPrint("Failed to do sync FB (%s - %s)\n", pkgname, util_basename(util_uri_to_path(id))); } handler->is_pd_created = (status == 0); if (handler->pd_created_cb) { - DbgPrint("pd_created_cb (%s) - %d\n", buf_id, status); - handler->pd_created_cb(handler, status, handler->pd_created_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->pd_created_cb; + cbdata = handler->pd_created_cbdata; handler->pd_created_cb = NULL; handler->pd_created_cbdata = NULL; - } else if (status == 0) { - DbgPrint("LB_EVENT_PD_CREATED (%s) - %d\n", buf_id, status); + + /*! + * Before call the Callback function, + * pd_create_cb must be reset. + * Because, in the create callback, user can call create_pd function again. + */ + DbgPrint("PERF_DBOX\n"); + cb(handler, status, cbdata); + } else if (handler->is_pd_created) { lb_invoke_event_handler(handler, LB_EVENT_PD_CREATED); } - ret = 0; out: return NULL; } @@ -340,29 +592,37 @@ static struct packet *master_pd_destroyed(pid_t pid, int handle, const struct pa handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("Instance(%s) is not exists\n", id); goto out; } if (handler->state != CREATE) { - ret = -EPERM; + ErrPrint("Instance(%s) is not created\n", id); goto out; } handler->is_pd_created = 0; if (handler->pd_destroyed_cb) { - DbgPrint("Invoke the PD Destroyed CB\n"); - handler->pd_destroyed_cb(handler, status, handler->pd_destroyed_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->pd_destroyed_cb; + cbdata = handler->pd_destroyed_cbdata; handler->pd_destroyed_cb = NULL; handler->pd_destroyed_cbdata = NULL; + + /*! + * Before call the Callback function, + * pd_destroyed_cb must be reset. + * Because, in the create callback, user can call destroy_pd function again. + */ + cb(handler, status, cbdata); } else if (status == 0) { - DbgPrint("Invoke the LB_EVENT_PD_DESTROYED event\n"); lb_invoke_event_handler(handler, LB_EVENT_PD_DESTROYED); } - ret = 0; out: return NULL; } @@ -384,13 +644,12 @@ static struct packet *master_pd_updated(pid_t pid, int handle, const struct pack &pd_w, &pd_h); if (ret != 6) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("Instance(%s) is not exists\n", id); goto out; } @@ -401,27 +660,75 @@ static struct packet *master_pd_updated(pid_t pid, int handle, const struct pack * So don't try to notice anything about this anymore. * Just ignore all events. */ - ret = -EPERM; + ErrPrint("Instance(%s) is not created\n", id); goto out; } lb_set_pdsize(handler, pd_w, pd_h); if (lb_text_pd(handler)) { - ret = parse_desc(handler, descfile, 1); + (void)parse_desc(handler, descfile, 1); } else { (void)lb_set_pd_fb(handler, fbfile); ret = fb_sync(lb_get_pd_fb(handler)); - if (ret < 0) { - ErrPrint("Failed to do sync FB (%s - %s)\n", - pkgname, - util_basename(util_uri_to_path(id))); - goto out; - } + if (ret < 0) + ErrPrint("Failed to do sync FB (%s - %s), %d\n", pkgname, util_basename(util_uri_to_path(id)), ret); + else + lb_invoke_event_handler(handler, LB_EVENT_PD_UPDATED); + } + +out: + return NULL; +} + +static struct packet *master_update_mode(pid_t pid, int handle, const struct packet *packet) +{ + struct livebox *handler; + const char *pkgname; + const char *id; + int active_mode; + int status; + int ret; + + if (!packet) { + ErrPrint("Invalid packet\n"); + goto out; + } + + ret = packet_get(packet, "ssii", &pkgname, &id, &status, &active_mode); + if (ret != 4) { + ErrPrint("Invalid argument\n"); + goto out; + } + + handler = lb_find_livebox(pkgname, id); + if (!handler) { + ErrPrint("Livebox(%s) is not found\n", id); + goto out; + } - lb_invoke_event_handler(handler, LB_EVENT_PD_UPDATED); - ret = 0; + if (handler->state != CREATE) { + ErrPrint("Livebox(%s) is not created yet\n", id); + goto out; + } + + if (status == LB_STATUS_SUCCESS) + lb_set_update_mode(handler, active_mode); + + if (handler->update_mode_cb) { + ret_cb_t cb; + void *cbdata; + + cb = handler->update_mode_cb; + cbdata = handler->update_mode_cbdata; + + handler->update_mode_cb = NULL; + handler->update_mode_cbdata = NULL; + + cb(handler, status, cbdata); + } else { + lb_invoke_event_handler(handler, LB_EVENT_UPDATE_MODE_CHANGED); } out: @@ -433,6 +740,7 @@ static struct packet *master_size_changed(pid_t pid, int handle, const struct pa struct livebox *handler; const char *pkgname; const char *id; + const char *fbfile; int status; int ret; int w; @@ -441,34 +749,27 @@ static struct packet *master_size_changed(pid_t pid, int handle, const struct pa if (!packet) { ErrPrint("Invalid packet\n"); - ret = -EINVAL; goto out; } - ret = packet_get(packet, "ssiiii", &pkgname, &id, &is_pd, &w, &h, &status); - if (ret != 6) { + ret = packet_get(packet, "sssiiii", &pkgname, &id, &fbfile, &is_pd, &w, &h, &status); + if (ret != 7) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } - DbgPrint("Size is changed: %dx%d (%s)\n", w, h, id); - handler = lb_find_livebox(pkgname, id); if (!handler) { - ErrPrint("Livebox(%s - %s) is not found\n", pkgname, id); - ret = -ENOENT; + ErrPrint("Livebox(%s) is not found\n", id); goto out; } if (handler->state != CREATE) { - ErrPrint("Hander is not created yet\n"); - ret = -EPERM; + ErrPrint("Livebox(%s) is not created yet\n", id); goto out; } if (is_pd) { - DbgPrint("PD is resized\n"); /*! * \NOTE * PD is not able to resized by the client. @@ -480,11 +781,10 @@ static struct packet *master_size_changed(pid_t pid, int handle, const struct pa lb_set_pdsize(handler, w, h); lb_invoke_event_handler(handler, LB_EVENT_PD_SIZE_CHANGED); } else { - ErrPrint("This is not possible. PD Size is changed but the return value is not ZERO\n"); + ErrPrint("This is not possible. PD Size is changed but the return value is not ZERO (%d)\n", status); } } else { if (status == 0) { - DbgPrint("LB is successfully resized (%dx%d)\n", w, h); lb_set_size(handler, w, h); /*! @@ -492,8 +792,15 @@ static struct packet *master_size_changed(pid_t pid, int handle, const struct pa * If there is a created LB FB, * Update it too. */ - if (lb_get_lb_fb(handler)) - lb_set_lb_fb(handler, id); + if (lb_get_lb_fb(handler)) { + lb_set_lb_fb(handler, fbfile); + + ret = fb_sync(lb_get_lb_fb(handler)); + if (ret < 0) + ErrPrint("Failed to do sync FB (%s - %s)\n", pkgname, util_basename(util_uri_to_path(id))); + + /* Just update the size info only. */ + } /*! * \NOTE @@ -501,20 +808,31 @@ static struct packet *master_size_changed(pid_t pid, int handle, const struct pa * So I added some log before & after call the user callback. */ if (handler->size_changed_cb) { - handler->size_changed_cb(handler, status, handler->size_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->size_changed_cb; + cbdata = handler->size_cbdata; handler->size_changed_cb = NULL; handler->size_cbdata = NULL; + + cb(handler, status, cbdata); } else { lb_invoke_event_handler(handler, LB_EVENT_LB_SIZE_CHANGED); } } else { - DbgPrint("LB is not resized: %dx%d (%d)\n", w, h, status); if (handler->size_changed_cb) { - handler->size_changed_cb(handler, status, handler->size_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->size_changed_cb; + cbdata = handler->size_cbdata; handler->size_changed_cb = NULL; handler->size_cbdata = NULL; + + cb(handler, status, cbdata); } } } @@ -535,37 +853,38 @@ static struct packet *master_period_changed(pid_t pid, int handle, const struct ret = packet_get(packet, "idss", &status, &period, &pkgname, &id); if (ret != 4) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } handler = lb_find_livebox(pkgname, id); if (!handler) { - ErrPrint("Livebox(%s - %s) is not found\n", pkgname, id); - ret = -ENOENT; + ErrPrint("Livebox(%s) is not found\n", id); goto out; } if (handler->state != CREATE) { - ret = -EPERM; + ErrPrint("Livebox(%s) is not created\n", id); goto out; } - DbgPrint("Update period is changed? %lf (%d)\n", period, status); if (status == 0) lb_set_period(handler, period); if (handler->period_changed_cb) { - handler->period_changed_cb(handler, status, handler->group_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->period_changed_cb; + cbdata = handler->period_cbdata; handler->period_changed_cb = NULL; handler->period_cbdata = NULL; - } else { + + cb(handler, status, cbdata); + } else if (status == 0) { lb_invoke_event_handler(handler, LB_EVENT_PERIOD_CHANGED); } - ret = 0; - out: return NULL; } @@ -583,13 +902,12 @@ static struct packet *master_group_changed(pid_t pid, int handle, const struct p ret = packet_get(packet, "ssiss", &pkgname, &id, &status, &cluster, &category); if (ret != 5) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; goto out; } handler = lb_find_livebox(pkgname, id); if (!handler) { - ret = -ENOENT; + ErrPrint("Livebox(%s) is not exists\n", id); goto out; } @@ -599,25 +917,28 @@ static struct packet *master_group_changed(pid_t pid, int handle, const struct p * Do no access this handler, * You cannot believe this handler anymore. */ - ret = -EPERM; + ErrPrint("Livebox(%s) is not created\n", id); goto out; } - DbgPrint("Group is changed? [%s] / [%s] (%d)\n", cluster, category, status); if (status == 0) - lb_set_group(handler, cluster, category); + (void)lb_set_group(handler, cluster, category); if (handler->group_changed_cb) { - handler->group_changed_cb(handler, status, handler->group_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->group_changed_cb; + cbdata = handler->group_cbdata; handler->group_changed_cb = NULL; handler->group_cbdata = NULL; - } else { + + cb(handler, status, cbdata); + } else if (status == 0) { lb_invoke_event_handler(handler, LB_EVENT_GROUP_CHANGED); } - ret = 0; - out: return NULL; } @@ -664,7 +985,7 @@ static struct packet *master_created(pid_t pid, int handle, const struct packet &lb_type, &pd_type, &period, &title, &is_pinned_up); if (ret != 22) { ErrPrint("Invalid argument\n"); - ret = -EINVAL; + ret = LB_STATUS_ERROR_INVALID; goto out; } @@ -684,7 +1005,7 @@ static struct packet *master_created(pid_t pid, int handle, const struct packet handler = lb_new_livebox(pkgname, id, timestamp); if (!handler) { ErrPrint("Failed to create a new livebox\n"); - ret = -EFAULT; + ret = LB_STATUS_ERROR_FAULT; goto out; } @@ -697,7 +1018,7 @@ static struct packet *master_created(pid_t pid, int handle, const struct packet * This is not possible!!! */ ErrPrint("Invalid handler\n"); - ret = -EINVAL; + ret = LB_STATUS_ERROR_INVALID; goto out; } @@ -718,7 +1039,7 @@ static struct packet *master_created(pid_t pid, int handle, const struct packet content, cluster, category, lb_fname, pd_fname); - ret = -EALREADY; + ret = LB_STATUS_ERROR_ALREADY; goto out; } @@ -794,20 +1115,23 @@ static struct packet *master_created(pid_t pid, int handle, const struct packet */ if (handler->created_cb) { - DbgPrint("Invoke the created_cb\n"); - handler->created_cb(handler, ret, handler->created_cbdata); + ret_cb_t cb; + void *cbdata; + + cb = handler->created_cb; + cbdata = handler->created_cbdata; handler->created_cb = NULL; handler->created_cbdata = NULL; + + cb(handler, ret, cbdata); } else { - DbgPrint("Invoke the lb,created\n"); lb_invoke_event_handler(handler, LB_EVENT_CREATED); } } out: if (ret == 0 && old_state == DELETE) { - DbgPrint("Send the delete request\n"); lb_send_delete(handler, handler->created_cb, handler->created_cbdata); /*! @@ -818,7 +1142,7 @@ out: * Do not clear this to use this from the deleted event callback. * if this value is not cleared when the deleted event callback check it, * it means that the created function is not called yet. - * Then the call the deleted event callback with -ECANCELED errno. + * Then the call the deleted event callback with LB_STATUS_ERROR_CANCEL errno. */ } @@ -871,6 +1195,39 @@ static struct method s_table[] = { .handler = master_pinup, }, { + .cmd = "scroll", + .handler = master_hold_scroll, + }, + + { + .cmd = "update_mode", + .handler = master_update_mode, + }, + + { + .cmd = "lb_update_begin", + .handler = master_lb_update_begin, + }, + { + .cmd = "lb_update_end", + .handler = master_lb_update_end, + }, + + { + .cmd = "pd_update_begin", + .handler = master_pd_update_begin, + }, + { + .cmd = "pd_update_end", + .handler = master_pd_update_end, + }, + + { + .cmd = "access_status", + .handler = master_access_status, + }, + + { .cmd = NULL, .handler = NULL, }, @@ -892,20 +1249,7 @@ static void acquire_cb(struct livebox *handler, const struct packet *result, voi return; } -static gboolean connector_cb(gpointer user_data) -{ - s_info.reconnector = 0; - - if (s_info.fd > 0) { - DbgPrint("Connection is already made\n"); - return FALSE; - } - - make_connection(); - return FALSE; -} - -static inline void make_connection(void) +static inline int make_connection(void) { struct packet *packet; int ret; @@ -914,20 +1258,15 @@ static inline void make_connection(void) s_info.fd = com_core_packet_client_init(CLIENT_SOCKET, 0, s_table); if (s_info.fd < 0) { - /*!< After 10 secs later, try to connect again */ - s_info.reconnector = g_timeout_add(RECONNECT_PERIOD, connector_cb, NULL); - if (s_info.reconnector == 0) - ErrPrint("Failed to fire the reconnector\n"); - - ErrPrint("Try this again A sec later\n"); - return; + ErrPrint("Try this again later\n"); + return LB_STATUS_ERROR_IO; } packet = packet_create("acquire", "d", util_timestamp()); if (!packet) { com_core_packet_client_fini(s_info.fd); s_info.fd = -1; - return; + return LB_STATUS_ERROR_FAULT; } ret = master_rpc_async_request(NULL, packet, 1, acquire_cb, NULL); @@ -935,8 +1274,10 @@ static inline void make_connection(void) ErrPrint("Master RPC returns %d\n", ret); com_core_packet_client_fini(s_info.fd); s_info.fd = -1; + return LB_STATUS_ERROR_IO; } + return LB_STATUS_SUCCESS; } static int connected_cb(int handle, void *data) @@ -945,6 +1286,34 @@ static int connected_cb(int handle, void *data) return 0; } +static void master_started_cb(keynode_t *node, void *data) +{ + int state = 0; + + if (vconf_get_bool(VCONFKEY_MASTER_STARTED, &state) < 0) + ErrPrint("Unable to get [%s]\n", VCONFKEY_MASTER_STARTED); + + DbgPrint("Master state: %d\n", state); + if (state == 1 && make_connection() == LB_STATUS_SUCCESS) { + int ret; + ret = vconf_ignore_key_changed(VCONFKEY_MASTER_STARTED, master_started_cb); + DbgPrint("master_started vconf key de-registered [%d]\n", ret); + } +} + +static gboolean timeout_cb(gpointer data) +{ + if (vconf_notify_key_changed(VCONFKEY_MASTER_STARTED, master_started_cb, NULL) < 0) + ErrPrint("Failed to add vconf for monitoring service state\n"); + else + DbgPrint("vconf event callback is registered\n"); + + master_started_cb(NULL, NULL); + + s_info.timer_id = 0; + return FALSE; +} + static int disconnected_cb(int handle, void *data) { if (s_info.fd != handle) { @@ -954,22 +1323,23 @@ static int disconnected_cb(int handle, void *data) s_info.fd = -1; /*!< Disconnected */ - if (s_info.reconnector > 0) { - DbgPrint("Reconnector already fired\n"); - return 0; - } - - /*!< After 10 secs later, try to connect again */ - s_info.reconnector = g_timeout_add(RECONNECT_PERIOD, connector_cb, NULL); - if (s_info.reconnector == 0) { - ErrPrint("Failed to fire the reconnector\n"); - make_connection(); - } - master_rpc_clear_all_request(); lb_invoke_fault_handler(LB_FAULT_PROVIDER_DISCONNECTED, MASTER_PKGNAME, "default", "disconnected"); lb_delete_all(); + + /* Try to reconnect after 1 sec later */ + if (!s_info.timer_id) { + DbgPrint("Reconnecting timer is added\n"); + s_info.timer_id = g_timeout_add(1000, timeout_cb, NULL); + if (s_info.timer_id == 0) { + ErrPrint("Unable to add reconnecting timer\n"); + return 0; + } + } else { + ErrPrint("Reconnecting timer is already exists\n"); + } + return 0; } @@ -977,7 +1347,12 @@ int client_init(void) { com_core_add_event_callback(CONNECTOR_DISCONNECTED, disconnected_cb, NULL); com_core_add_event_callback(CONNECTOR_CONNECTED, connected_cb, NULL); - make_connection(); + if (vconf_notify_key_changed(VCONFKEY_MASTER_STARTED, master_started_cb, NULL) < 0) + ErrPrint("Failed to add vconf for service state\n"); + else + DbgPrint("vconf event callback is registered\n"); + + master_started_cb(NULL, NULL); return 0; } @@ -993,11 +1368,15 @@ const char *client_addr(void) int client_fini(void) { - com_core_packet_client_fini(s_info.fd); + int ret; + ret = vconf_ignore_key_changed(VCONFKEY_MASTER_STARTED, master_started_cb); + if (ret < 0) + DbgPrint("Ignore vconf key: %d\n", ret); com_core_del_event_callback(CONNECTOR_DISCONNECTED, disconnected_cb, NULL); com_core_del_event_callback(CONNECTOR_CONNECTED, connected_cb, NULL); + com_core_packet_client_fini(s_info.fd); s_info.fd = -1; - return 0; + return LB_STATUS_SUCCESS; } /* End of a file */