#include <stdio.h>
#include <stdlib.h>
#include <string.h>
+#include <ctype.h>
#include <unistd.h>
+#include <pwd.h>
#include <sys/types.h>
#include <sys/wait.h>
-#include <sys/inotify.h>
#include <sys/stat.h>
-#include <sys/ioctl.h>
#include <dirent.h>
#include <sys/types.h>
#include <fcntl.h>
-#include <glib.h>
#include <signal.h>
-#include <Ecore.h>
-#include <Ecore_File.h>
-#include <ail.h>
-#include <pkgmgr-info.h>
-#include <pkgmgr/pkgmgr_parser.h>
-#include <security-server.h>
-
-#include <vconf.h>
+#include <glib.h>
+#include <gio/gio.h>
-/* For multi-user support */
+#include <pkgmgr-info.h>
+#include <pkgmgr/pkgmgr_parser.h>
#include <tzplatform_config.h>
-/* For notification popups */
-#include <notification.h>
-
#include "pkgmgr_installer.h"
-#include "comm_pkg_mgr_server.h"
#include "pkgmgr-server.h"
#include "pm-queue.h"
#include "comm_config.h"
+#include "package-manager.h"
-#define PACKAGE_RECOVERY_DIR tzplatform_mkpath(TZ_SYS_RW_PACKAGES, ".recovery/pkgmgr")
+#define BUFMAX 128
#define NO_MATCHING_FILE 11
-static int backend_flag = 0; /* 0 means that backend process is not running */
-static int drawing_popup = 0; /* 0 means that pkgmgr-server has no popup now */
+#define OWNER_ROOT 0
+#define GLOBAL_USER tzplatform_getuid(TZ_SYS_GLOBALAPP_USER)
typedef struct {
char **env;
} user_ctx;
-/* For pkgs with no desktop file, inotify callback wont be called.
-* To handle that case ail_db_update is initialized as 1
-* This flag will be used to ensure that pkgmgr server does not exit
-* before the db is updated. */
-int ail_db_update = 1;
-
/*
8 bit value to represent maximum 8 backends.
Each bit position corresponds to a queue slot which
is dynamically determined.
*/
char backend_busy = 0;
-/*
-8 bit value to represent quiet mode operation for maximum 8 backends
-1->quiet 0->non-quiet
-Each bit position corresponds to a queue slot which
-is dynamically determined.
-*/
-char backend_mode = 63; /*00111111*/
extern int num_of_backends;
+struct signal_info_t {
+ pid_t pid;
+ int status;
+};
+
+static int pipe_sig[2];
+static GIOChannel *pipe_io;
+static guint pipe_wid;
+
backend_info *begin;
extern queue_info_map *start;
extern int entries;
-int pos = 0;
-/*To store info in case of backend crash*/
-char pname[MAX_PKG_NAME_LEN] = {'\0'};
-char ptype[MAX_PKG_TYPE_LEN] = {'\0'};
-char args[MAX_PKG_ARGS_LEN] = {'\0'};
GMainLoop *mainloop = NULL;
OPERATION_MAX
} OPERATION_TYPE;
-typedef enum {
- PMSVC_ALL_APP = 0,
- PMSVC_UI_APP,
- PMSVC_SVC_APP
-}pkgmgr_svc_app_component;
-
-struct appdata {
- pm_dbus_msg *item;
- OPERATION_TYPE op_type;
-};
-
-
-static int __check_backend_status_for_exit();
-static int __check_queue_status_for_exit();
-static int __check_backend_mode();
+static int __check_backend_status_for_exit(void);
+static int __check_queue_status_for_exit(void);
static int __is_backend_busy(int position);
static void __set_backend_busy(int position);
static void __set_backend_free(int position);
-static int __is_backend_mode_quiet(int position);
-static void __set_backend_mode(int position);
-static void __unset_backend_mode(int position);
-static void response_cb1(void *data, void *event_info);
-static void response_cb2(void *data, void *event_info);
-static int create_popup(struct appdata *ad);
static void sighandler(int signo);
-static void _wait_backend(pid_t pid);
-static int __get_position_from_pkg_type(char *pkgtype);
-static int __is_efl_tpk_app(char *pkgpath);
-static int __xsystem(const char *argv[]);
-gboolean queue_job(void *data);
-gboolean send_fail_signal(void *data);
gboolean exit_server(void *data);
/* To check whether a particular backend is free/busy*/
{
backend_busy = backend_busy & ~(1<<position);
}
-/* To check whether a particular backend is running in quiet mode*/
-static int __is_backend_mode_quiet(int position)
-{
- return backend_mode & 1<<position;
-}
-/*To set a particular backend mode as quiet*/
-static void __set_backend_mode(int position)
+
+static int __is_global(uid_t uid)
{
- backend_mode = backend_mode | 1<<position;
+ return (uid == OWNER_ROOT || uid == GLOBAL_USER) ? 1 : 0;
}
-/*To unset a particular backend mode */
-static void __unset_backend_mode(int position)
+
+static const char *__get_recovery_file_path(uid_t uid)
{
- backend_mode = backend_mode & ~(1<<position);
+ const char *path;
+
+ if (!__is_global(uid))
+ tzplatform_set_user(uid);
+
+ path = tzplatform_getenv(__is_global(uid)
+ ? TZ_SYS_RW_PACKAGES : TZ_USER_PACKAGES);
+
+ tzplatform_reset_user();
+
+ return path;
}
-static void __set_recovery_mode(char *pkgid, char *pkg_type)
+static void __set_recovery_mode(uid_t uid, char *pkgid, char *pkg_type)
{
char recovery_file[MAX_PKG_NAME_LEN] = { 0, };
char buffer[MAX_PKG_NAME_LEN] = { 0 };
DBG("pkgid_tmp[%s] is null\n", pkgid);
return;
}
- snprintf(recovery_file, MAX_PKG_NAME_LEN, "%s/%s", PACKAGE_RECOVERY_DIR, pkgid_tmp);
+ snprintf(recovery_file, sizeof(recovery_file), "%s/%s", __get_recovery_file_path(uid), pkgid_tmp);
} else {
- snprintf(recovery_file, MAX_PKG_NAME_LEN, "%s/%s", PACKAGE_RECOVERY_DIR, pkgid);
+ snprintf(recovery_file, sizeof(recovery_file), "%s/%s", __get_recovery_file_path(uid), pkgid);
}
rev_file = fopen(recovery_file, "w");
fclose(rev_file);
}
-static void __unset_recovery_mode(char *pkgid, char *pkg_type)
+static void __unset_recovery_mode(uid_t uid, char *pkgid, char *pkg_type)
{
int ret = -1;
char recovery_file[MAX_PKG_NAME_LEN] = { 0, };
DBG("pkgid_tmp[%s] is null\n", pkgid);
return;
}
- snprintf(recovery_file, MAX_PKG_NAME_LEN, "%s/%s", PACKAGE_RECOVERY_DIR, pkgid_tmp);
+ snprintf(recovery_file, sizeof(recovery_file), "%s/%s", __get_recovery_file_path(uid), pkgid_tmp);
} else {
- snprintf(recovery_file, MAX_PKG_NAME_LEN, "%s/%s", PACKAGE_RECOVERY_DIR, pkgid);
+ snprintf(recovery_file, sizeof(recovery_file), "%s/%s", __get_recovery_file_path(uid), pkgid);
}
ret = remove(recovery_file);
DBG("remove recovery_file[%s] fail\n", recovery_file);
}
-static int __check_privilege_by_cookie(const char *e_cookie, int req_type)
+static void send_fail_signal(char *pname, char *ptype, char *args)
{
- guchar *cookie = NULL;
- gsize size;
- int ret = PMINFO_R_OK; //temp to success , it should be PMINFO_R_ERROR
-
- if (e_cookie == NULL) {
- DBG("e_cookie is NULL!!!\n");
- return PMINFO_R_ERROR;
- }
-
- cookie = g_base64_decode(e_cookie, &size);
- if (cookie == NULL) {
- DBG("Unable to decode cookie!!!\n");
- return PMINFO_R_ERROR;
- }
-
- switch (req_type) {
- case COMM_REQ_TO_INSTALLER:
- if (SECURITY_SERVER_API_SUCCESS == security_server_check_privilege_by_cookie(cookie, "pkgmgr::svc", "r"))
- ret = PMINFO_R_OK;
-
- break;
-
- case COMM_REQ_TO_MOVER:
- if (SECURITY_SERVER_API_SUCCESS == security_server_check_privilege_by_cookie(cookie, "pkgmgr::svc", "x"))
- ret = PMINFO_R_OK;
- break;
-
- case COMM_REQ_GET_SIZE:
- if (SECURITY_SERVER_API_SUCCESS == security_server_check_privilege_by_cookie(cookie, "pkgmgr::info", "r"))
- ret = PMINFO_R_OK;
- break;
-
- default:
- DBG("Check your request[%d]..\n", req_type);
- break;
- }
-
- DBG("security_server[req-type:%d] check cookie result = %d, \n", req_type, ret);
-
- if (cookie){
- g_free(cookie);
- cookie = NULL;
- }
-
- return ret;
-}
-
-static int __get_position_from_pkg_type(char *pkgtype)
-{
- int i = 0;
- queue_info_map *ptr;
- ptr = start;
- for(i = 0; i < entries; i++)
- {
- if (!strncmp(ptr->pkgtype, pkgtype, MAX_PKG_TYPE_LEN))
- return ptr->queue_slot;
- else
- ptr++;
-
- }
- return -1;
-}
-
-static int __xsystem(const char *argv[])
-{
- int err = 0;
- int status = 0;
- pid_t pid;
-
- pid = fork();
-
- switch (pid) {
- case -1:
- DBG("fork() failed");
- return -1;
- case 0:
- if (execvp(argv[0], (char *const *)argv) == -1) {
- DBG("execvp() failed");
- }
- _exit(100);
- default:
- /* parent */
- do {
- err = waitpid(pid, &status, WUNTRACED | WCONTINUED);
- if (err == -1) {
- DBG("waitpid failed\n");
- return -1;
- }
- } while (!WIFEXITED(status) && !WIFSIGNALED(status));
- break;
- }
- if (WIFEXITED(status))
- return WEXITSTATUS(status);
- else
- return -1;
-}
-
-static int __is_efl_tpk_app(char *pkgid)
-{
- int ret = 0;
- char *type = NULL;
- const char *unzip_argv[] = { "/usr/bin/unzip", "-j", pkgid, "usr/share/packages/*", "-d", "/tmp/efltpk-unzip", NULL };
- const char *unzip_opt_argv[] = { "/usr/bin/unzip", "-j", pkgid, "opt/share/packages/*", "-d", "/tmp/efltpk-unzip", NULL };
- const char *delete_argv[] = { "/bin/rm", "-rf", "/tmp/efltpk-unzip", NULL };
- pkgmgrinfo_pkginfo_h handle;
- /*Check for uninstall case. If we fail to get handle then request is for installation*/
- ret = pkgmgrinfo_pkginfo_get_pkginfo(pkgid, &handle);
- if (ret == PMINFO_R_OK) {
- ret = pkgmgrinfo_pkginfo_get_type(handle, &type);
- if (ret != PMINFO_R_OK) {
- DBG("Failed to get package type\n");
- pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
- return -1;
- }
- if (strcmp(type, "efltpk") == 0) {
- pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
- return 1;
- } else {
- pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
- return 0;
- }
- }
- /*Install request*/
- if (strstr(pkgid, ".tpk") == NULL) {
- DBG("TPK package");
- return 0;
- }
- __xsystem(delete_argv);
- ret = mkdir("/tmp/efltpk-unzip", 0755);
- if (ret != 0) {
- DBG("Failed to create temporary directory to unzip tpk package\n");
- return -1;
- }
- /*In case of installation request, pkgid contains the pkgpath*/
- ret = __xsystem(unzip_argv);
- if (ret) {
- ret = __xsystem(unzip_opt_argv);
- if (ret) {
- DBG("Unzip of tpk package failed. error:%d\n", ret);
- if (ret == NO_MATCHING_FILE) /*no matching file found*/
- ret = 0;
- else
- ret = -1;
- goto err;
- } else
- ret = 1;
- } else
- ret = 1;
-err:
- __xsystem(delete_argv);
- return ret;
-}
-
-static
-void response_cb1(void *data, void *event_info)
-{
- struct appdata *ad = (struct appdata *)data;
- int p = 0;
- int ret = 0;
- DBG("start of response_cb()\n");
-
- /* YES */
- DBG("Uninstalling... [%s]\n", ad->item->pkgid);
-
- if (strlen(ad->item->pkgid) == 0) {
- DBG("package_name is empty\n");
- }
-
- if (strlen(ad->item->pkg_type) == 0) {
- DBG("Fail : Uninstalling... [%s]\n",
- ad->item->pkgid);
- free(ad->item);
- drawing_popup = 0;
-
- return;
- }
-
- DBG("pkg_type = [%s]\n", ad->item->pkg_type);
-
- ret = _pm_queue_push(ad->item);
- p = __get_position_from_pkg_type(ad->item->pkg_type);
- __unset_backend_mode(p);
-
- /* Free resource */
- free(ad->item);
- /***************/
- if (ret == 0)
- g_idle_add(queue_job, NULL);
-
- DBG("end of response_cb()\n");
-
- drawing_popup = 0;
-
- return;
-}
-
-static
-void response_cb2(void *data, void *event_info)
-{
- int p = 0;
- struct appdata *ad = (struct appdata *)data;
-
- DBG("start of response_cb()\n");
-
- /* NO */
- pkgmgr_installer *pi;
+ DBG("send_fail_signal start\n");
gboolean ret_parse;
gint argcp;
gchar **argvp;
GError *gerr = NULL;
-
+ pkgmgr_installer *pi;
pi = pkgmgr_installer_new();
if (!pi) {
DBG("Failure in creating the pkgmgr_installer object");
return;
}
-
- ret_parse = g_shell_parse_argv(ad->item->args,
+ ret_parse = g_shell_parse_argv(args,
&argcp, &argvp, &gerr);
if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", ad->item->args);
+ DBG("Failed to split args: %s", args);
DBG("messsage: %s", gerr->message);
pkgmgr_installer_free(pi);
return;
}
pkgmgr_installer_receive_request(pi, argcp, argvp);
-
- pkgmgr_installer_send_signal(pi, ad->item->pkg_type,
- ad->item->pkgid, "end",
- "cancel");
-
+ pkgmgr_installer_send_signal(pi, ptype, pname, "end", "fail");
pkgmgr_installer_free(pi);
- p = __get_position_from_pkg_type(ad->item->pkg_type);
- __set_backend_mode(p);
-
- /* Free resource */
- free(ad->item);
- /***************/
- /* queue_job should be called for every request that is pushed
- into queue. In "NO" case, request is not pushed so no need of
- calling queue_job*/
-
- DBG("end of response_cb()\n");
-
- drawing_popup = 0;
-
return;
}
-#if 0
-static char *__get_exe_path(const char *pkgid)
+static gboolean pipe_io_handler(GIOChannel *io, GIOCondition cond, gpointer data)
{
- ail_appinfo_h handle;
- ail_error_e ret;
- char *str;
- char *exe_path;
-
- ret = ail_package_get_appinfo(pkgid, &handle);
- if (ret != AIL_ERROR_OK) {
- ERR("ail_package_get_appinfo() failed");
- return NULL;
- }
-
- ret = ail_appinfo_get_str(handle, AIL_PROP_X_SLP_EXE_PATH, &str);
- if (ret != AIL_ERROR_OK) {
- ERR("ail_appinfo_get_str() failed");
- ail_package_destroy_appinfo(handle);
- return NULL;
- }
-
- exe_path = strdup(str);
- if (exe_path == NULL) {
- ERR("strdup() failed");
- ail_package_destroy_appinfo(handle);
- return NULL;
+ int x;
+ GError *err = NULL;
+ GIOStatus s;
+ gsize len;
+ struct signal_info_t info;
+ backend_info *ptr = begin;
+
+ s = g_io_channel_read_chars(io, (gchar *)&info, sizeof(struct signal_info_t), &len, &err);
+ if (s != G_IO_STATUS_NORMAL) {
+ ERR("Signal pipe read failed: %s", err->message);
+ g_error_free(err);
+ return TRUE;
}
- ret = ail_package_destroy_appinfo(handle);
- if (ret != AIL_ERROR_OK) {
- ERR("ail_package_destroy_appinfo() failed");
- free(exe_path);
- return NULL;
+ for (x = 0; x < num_of_backends; x++, ptr++) {
+ if (ptr && ptr->pid == info.pid)
+ break;
}
- return exe_path;
-}
-#endif
-
-static
-int create_popup(struct appdata *ad)
-{
- DBG("start of create_popup()\n");
-
- drawing_popup = 1;
-
- char sentence[MAX_PKG_ARGS_LEN] = { '\0' };
- char *pkgid = NULL;
- char app_name[MAX_PKG_NAME_LEN] = { '\0' };
-
- notification_h noti = NULL;
- notification_error_e err = NOTIFICATION_ERROR_NONE;
-
- noti = notification_create(NOTIFICATION_TYPE_NOTI);
- if (!noti) {
- DBG("Failed to create a popup notification\n");
- drawing_popup = 0;
+ if (x == num_of_backends) {
+ ERR("Unknown child exit");
return -1;
}
- /* Sentence of popup */
- int ret;
-
- pkgid = strrchr(ad->item->pkgid, '/') == NULL ?
- ad->item->pkgid : strrchr(ad->item->pkgid, '/') + 1;
-
- if (ad->op_type == OPERATION_INSTALL) {
- snprintf(sentence, sizeof(sentence) - 1, "Install?");
- } else if (ad->op_type == OPERATION_UNINSTALL) {
- char *label = NULL;
- pkgmgrinfo_pkginfo_h handle;
- ret = pkgmgrinfo_pkginfo_get_usr_pkginfo(pkgid, ad->item->uid, &handle);
-
- if (ret < 0){
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
- }
- ret = pkgmgrinfo_pkginfo_get_label(handle, &label);
- if (ret < 0){
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
- }
-
- snprintf(app_name, sizeof(app_name) - 1, label);
- ret = pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
- if (ret < 0){
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
- }
-
- pkgid = app_name;
-
- snprintf(sentence, sizeof(sentence) - 1, "Uninstall?");
- } else if (ad->op_type == OPERATION_REINSTALL) {
- snprintf(sentence, sizeof(sentence) - 1, "Reinstall?");
- } else
- snprintf(sentence, sizeof(sentence) - 1, "Invalid request");
-
- /***********************************/
-
- err = notification_set_text(noti,
- NOTIFICATION_TEXT_TYPE_TITLE, pkgid,
- NULL, NOTIFICATION_VARIABLE_TYPE_NONE);
- if (err != NOTIFICATION_ERROR_NONE) {
- DBG("Failed to set popup notification title\n");
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
+ __set_backend_free(x);
+ __unset_recovery_mode(ptr->uid, ptr->pkgid, ptr->pkgtype);
+ if (WIFSIGNALED(info.status) || WEXITSTATUS(info.status)) {
+ send_fail_signal(ptr->pkgid, ptr->pkgtype, ptr->args);
+ DBG("backend[%s] exit with error", ptr->pkgtype);
+ } else {
+ DBG("backend[%s] exit", ptr->pkgtype);
}
- err = notification_set_text(noti,
- NOTIFICATION_TEXT_TYPE_CONTENT, sentence,
- NULL, NOTIFICATION_VARIABLE_TYPE_NONE);
- if (err != NOTIFICATION_ERROR_NONE) {
- DBG("Failed to set popup notification sentence\n");
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
- }
+ g_idle_add(queue_job, NULL);
- /* Details of popup (timeout, buttons...) */
- bundle *b = NULL;
+ return TRUE;
+}
- b = bundle_create();
- if (!b) {
- DBG("Failed to set popup notification details\n");
- drawing_popup = 0;
- notification_delete(noti);
- return -1;
- }
+static int __init_backend_info(void)
+{
+ backend_info *ptr;
- /* TRANSLATION DOES NOT WORK ; TO FIX ?
- char *button1_text = dgettext("sys_string", "IDS_COM_SK_YES");
- char *button2_text = dgettext("sys_string", "IDS_COM_SK_NO");
- */
- char *button1_text = "Yes";
- char *button2_text = "No";
- char *buttons_text = malloc(strlen(button1_text) +
- strlen(button2_text) + 2);
- strcpy(buttons_text, button1_text);
- strcat(buttons_text, ",");
- strcat(buttons_text, button2_text);
-
- bundle_add (b, "timeout", "0");
- bundle_add (b, "noresize", "1");
- bundle_add (b, "buttons", buttons_text);
-
- free(buttons_text);
-
- err = notification_set_execute_option (noti,
- NOTIFICATION_EXECUTE_TYPE_RESPONDING,
- NULL, NULL, b);
- if (err != NOTIFICATION_ERROR_NONE) {
- DBG("Failed to set popup notification as interactive\n");
- drawing_popup = 0;
- bundle_free(b);
- notification_delete(noti);
+ /*Allocate memory for holding pid, pkgtype and pkgid*/
+ ptr = (backend_info*)calloc(num_of_backends, sizeof(backend_info));
+ if (ptr == NULL) {
+ DBG("Malloc Failed\n");
return -1;
}
+ begin = ptr;
- /* Show the popup */
- err = notification_insert (noti, NULL);
- if (err != NOTIFICATION_ERROR_NONE) {
- DBG("Failed to set popup notification sentence\n");
- drawing_popup = 0;
- bundle_free(b);
- notification_delete(noti);
+ if (pipe(pipe_sig)) {
+ ERR("create pipe failed");
return -1;
}
- /* Catch user response */
- int button;
-
- err = notification_wait_response (noti, 10, &button, NULL);
- if (err != NOTIFICATION_ERROR_NONE) {
- DBG("Failed to wait for user response, defaulting to 'no'\n");
- button = 2;
- }
-
- if (button == 1) {
- response_cb1(ad, NULL);
- } else if (button == 2) {
- response_cb2(ad, NULL);
- }
-
- bundle_free(b);
- notification_delete(noti);
+ pipe_io = g_io_channel_unix_new(pipe_sig[0]);
+ g_io_channel_set_encoding(pipe_io, NULL, NULL);
+ g_io_channel_set_buffered(pipe_io, FALSE);
+ pipe_wid = g_io_add_watch(pipe_io, G_IO_IN, pipe_io_handler, NULL);
- DBG("end of create_popup()\n");
return 0;
}
-gboolean send_fail_signal(void *data)
-{
- DBG("send_fail_signal start\n");
- gboolean ret_parse;
- gint argcp;
- gchar **argvp;
- GError *gerr = NULL;
- pkgmgr_installer *pi;
- pi = pkgmgr_installer_new();
- if (!pi) {
- DBG("Failure in creating the pkgmgr_installer object");
- return FALSE;
- }
- ret_parse = g_shell_parse_argv(args,
- &argcp, &argvp, &gerr);
- if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", args);
- DBG("messsage: %s", gerr->message);
- pkgmgr_installer_free(pi);
- return FALSE;
- }
-
- pkgmgr_installer_receive_request(pi, argcp, argvp);
- pkgmgr_installer_send_signal(pi, ptype, pname, "end", "fail");
- pkgmgr_installer_free(pi);
- return FALSE;
-}
-
-static void _wait_backend(pid_t pid)
+static void __fini_backend_info(void)
{
- int status;
- pid_t cpid;
- int i = 0;
- backend_info *ptr = NULL;
- ptr = begin;
- cpid = waitpid(pid, &status, 0);
- if (cpid != pid)
- ERR("WaitBackend Faillure %d",cpid);
- else if (WIFEXITED(status)) {
- DBG("child NORMAL exit [%d]\n", cpid);
- for(i = 0; i < num_of_backends; i++)
- {
- if (cpid == (ptr + i)->pid) {
- __set_backend_free(i);
- __set_backend_mode(i);
- __unset_recovery_mode((ptr + i)->pkgid, (ptr + i)->pkgtype);
- ERR(" STATUS = %d \n",(WEXITSTATUS (status)));
- if (WEXITSTATUS (status) != 0) {
- strncpy(pname, (ptr + i)->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy(ptype, (ptr + i)->pkgtype, MAX_PKG_TYPE_LEN-1);
- strncpy(args, (ptr + i)->args, MAX_PKG_ARGS_LEN-1);
- g_idle_add(send_fail_signal, NULL);
- }
- break;
- }
- else
- DBG("PID of registered backend is [%d]\n", (ptr + i)->pid);
+ g_source_remove(pipe_wid);
+ g_io_channel_unref(pipe_io);
+ close(pipe_sig[0]);
+ close(pipe_sig[1]);
- }
- }
- else if (WIFSIGNALED(status)) {
- DBG("child SIGNALED exit [%d]\n", cpid);
- /*get the pkgid and pkgtype to send fail signal*/
- for(i = 0; i < num_of_backends; i++)
- {
- if (cpid == (ptr + i)->pid) {
- __set_backend_free(i);
- __set_backend_mode(i);
- __unset_recovery_mode((ptr + i)->pkgid, (ptr + i)->pkgtype);
- strncpy(pname, (ptr + i)->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy(ptype, (ptr + i)->pkgtype, MAX_PKG_TYPE_LEN-1);
- strncpy(args, (ptr + i)->args, MAX_PKG_ARGS_LEN-1);
- g_idle_add(send_fail_signal, NULL);
- break;
- }
- }
- }
+ /*Free backend info */
+ free(begin);
}
-
static void sighandler(int signo)
{
- int status;
- pid_t cpid;
- int i = 0;
- backend_info *ptr = NULL;
- ptr = begin;
-
- while ((cpid = waitpid(-1, &status, WNOHANG)) > 0) {
- DBG("child exit [%d]\n", cpid);
- if (WIFEXITED(status)) {
- DBG("child NORMAL exit [%d]\n", cpid);
- for(i = 0; i < num_of_backends; i++)
- {
- if (cpid == (ptr + i)->pid) {
- __set_backend_free(i);
- __set_backend_mode(i);
- __unset_recovery_mode((ptr + i)->pkgid, (ptr + i)->pkgtype);
-
- if (WEXITSTATUS (status) != 0) {
- strncpy(pname, (ptr + i)->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy(ptype, (ptr + i)->pkgtype, MAX_PKG_TYPE_LEN-1);
- strncpy(args, (ptr + i)->args, MAX_PKG_ARGS_LEN-1);
- g_idle_add(send_fail_signal, NULL);
- }
- break;
- }
- else
- DBG("PID of registered backend is [%d]\n", (ptr + i)->pid);
-
- }
- }
- else if (WIFSIGNALED(status)) {
- DBG("child SIGNALED exit [%d]\n", cpid);
- /*get the pkgid and pkgtype to send fail signal*/
- for(i = 0; i < num_of_backends; i++)
- {
- if (cpid == (ptr + i)->pid) {
- __set_backend_free(i);
- __set_backend_mode(i);
- __unset_recovery_mode((ptr + i)->pkgid, (ptr + i)->pkgtype);
- strncpy(pname, (ptr + i)->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy(ptype, (ptr + i)->pkgtype, MAX_PKG_TYPE_LEN-1);
- strncpy(args, (ptr + i)->args, MAX_PKG_ARGS_LEN-1);
- g_idle_add(send_fail_signal, NULL);
- break;
- }
- }
- }
- }
+ struct signal_info_t info;
+ info.pid = waitpid(-1, &info.status, WNOHANG);
+ if (write(pipe_sig[1], &info, sizeof(struct signal_info_t)) < 0)
+ ERR("failed to write result: %s", strerror(errno));
}
-void req_cb(void *cb_data, uid_t uid, const char *req_id, const int req_type,
- const char *pkg_type, const char *pkgid, const char *args,
- const char *cookie, int *ret)
+static int __register_signal_handler(void)
{
static int sig_reg = 0;
- int err = -1;
- int p = 0;
- int cookie_result = 0;
-
- DBG(">> in callback >> Got request: [%s] [%d] [%s] [%s] [%s] [%s]",
- req_id, req_type, pkg_type, pkgid, args, cookie);
-
- struct appdata *ad = (struct appdata *)cb_data;
-
- pm_dbus_msg *item = calloc(1, sizeof(pm_dbus_msg));
- memset(item, 0x00, sizeof(pm_dbus_msg));
-
- strncpy(item->req_id, req_id, sizeof(item->req_id) - 1);
- item->req_type = req_type;
- strncpy(item->pkg_type, pkg_type, sizeof(item->pkg_type) - 1);
- strncpy(item->pkgid, pkgid, sizeof(item->pkgid) - 1);
- strncpy(item->args, args, sizeof(item->args) - 1);
- strncpy(item->cookie, cookie, sizeof(item->cookie) - 1);
- item->uid = uid;
- /* uid equals to GLOBALUSER means that the installation or action is made at Global level.
- * At this time, we are not able to check the credentials of this dbus message (due to gdbus API to implement the pkgmgr-server)
- * So we cannot check if the user that makes request has permisssion to do it.
- * Note theses CAPI could be used by deamon (user is root or system user) or web/native API framework (user id is one of regular users)
- * In consequence a bug is filed :
- *
- * Logic has to be implmemented:
- * RUID means the id of the user that make the request (retreived from credential of the message)
- * UID is the uid in argument of the request
- *
- * if RUID == UID & UID is regular user == TRUE ==> Granted
- * if UID == GLOBAL_USER & RUID is ADMIN == TRUE ==> Granted
- * if RUID == (ROOT or System USER) & UID is Regular USER ==> Granted
- * if UID != Regular USER & UID != GLOBAL USER == TRUE ==> NOT GRANTED
- * if RUID == Regular USER & UID != RUID == True ==> NOT GRANTED
- * */
- if (sig_reg == 0) {
- struct sigaction act;
-
- act.sa_handler = sighandler;
- sigemptyset(&act.sa_mask);
- act.sa_flags = SA_NOCLDSTOP;
-
- if (sigaction(SIGCHLD, &act, NULL) < 0) {
- DBG("signal: SIGCHLD failed\n");
- } else
- DBG("signal: SIGCHLD succeed\n");
- if (g_timeout_add_seconds(2, exit_server, NULL))
- DBG("g_timeout_add_seconds() Added to Main Loop");
-
- sig_reg = 1;
- }
-
- DBG("req_type=(%d) drawing_popup=(%d) backend_flag=(%d)\n", req_type,
- drawing_popup, backend_flag);
-
- char *quiet = NULL;
-
- switch (item->req_type) {
- case COMM_REQ_TO_INSTALLER:
- /* check caller privilege */
- cookie_result = __check_privilege_by_cookie(cookie, item->req_type);
- if (cookie_result < 0){
- DBG("__check_privilege_by_cookie result fail[%d]\n", cookie_result);
- *ret = COMM_RET_ERROR;
- goto err;
- }
-
- /* -q option should be located at the end of command !! */
- if (((quiet = strstr(args, " -q")) &&
- (quiet[strlen(quiet)] == '\0')) ||
- ((quiet = strstr(args, " '-q'")) &&
- (quiet[strlen(quiet)] == '\0'))) {
- /* quiet mode */
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- __set_backend_mode(p);
- /* Free resource */
- free(item);
- if (err == 0)
- g_idle_add(queue_job, NULL);
- *ret = COMM_RET_OK;
- } else {
- /* non quiet mode */
- p = __get_position_from_pkg_type(item->pkg_type);
- if (drawing_popup == 0 &&
- !__is_backend_busy(p) &&
- __check_backend_mode()) {
- /* if there is no popup */
- ad->item = item;
-
- if (strstr(args, " -i ")
- || strstr(args, " '-i' "))
- ad->op_type = OPERATION_INSTALL;
- else if (strstr(args, " -d ")
- || strstr(args, " '-d' ")) {
- ad->op_type = OPERATION_UNINSTALL;
- } else if (strstr(args, " -r ")
- || strstr(args, " '-r' "))
- ad->op_type = OPERATION_REINSTALL;
- else
- ad->op_type = OPERATION_MAX;
-
- err = create_popup(ad);
- if (err != 0) {
- *ret = COMM_RET_ERROR;
- DBG("create popup failed\n");
- goto err;
- } else {
- *ret = COMM_RET_OK;
- }
- } else {
- DBG("info drawing_popup:%d, __is_backend_busy(p):%d, __check_backend_mode():%d\n",
- drawing_popup, __is_backend_busy(p), __check_backend_mode());
- /* if popup is already being drawn */
- *ret = COMM_RET_ERROR;
- goto err;
- }
- }
- break;
- case COMM_REQ_TO_ACTIVATOR:
- /* In case of activate, there is no popup */
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- __set_backend_mode(p);
- /* Free resource */
- free(item);
-
-/* g_idle_add(queue_job, NULL); */
- if (err == 0)
- queue_job(NULL);
- *ret = COMM_RET_OK;
- break;
- case COMM_REQ_TO_CLEARER:
- /* In case of clearer, there is no popup */
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- /*the backend shows the success/failure popup
- so this request is non quiet*/
- __unset_backend_mode(p);
- /* Free resource */
- free(item);
-
-/* g_idle_add(queue_job, NULL); */
- if (err == 0)
- queue_job(NULL);
- *ret = COMM_RET_OK;
- break;
- case COMM_REQ_TO_MOVER:
- /* check caller privilege */
- cookie_result = __check_privilege_by_cookie(cookie, item->req_type);
- if (cookie_result < 0){
- DBG("__check_privilege_by_cookie result fail[%d]\n", cookie_result);
- *ret = COMM_RET_ERROR;
- goto err;
- }
-
- /* In case of mover, there is no popup */
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- /*the backend shows the success/failure popup
- so this request is non quiet*/
- __unset_backend_mode(p);
- /* Free resource */
- free(item);
- if (err == 0)
- queue_job(NULL);
- *ret = COMM_RET_OK;
- break;
- case COMM_REQ_CANCEL:
- ad->item = item;
- _pm_queue_delete(ad->item);
- p = __get_position_from_pkg_type(item->pkg_type);
- __unset_backend_mode(p);
- free(item);
- *ret = COMM_RET_OK;
- break;
- case COMM_REQ_GET_SIZE:
- /* check caller privilege */
- cookie_result = __check_privilege_by_cookie(cookie, item->req_type);
- if (cookie_result < 0){
- DBG("__check_privilege_by_cookie result fail[%d]\n", cookie_result);
- *ret = COMM_RET_ERROR;
- goto err;
- }
+ struct sigaction act;
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- __set_backend_mode(p);
- /* Free resource */
- free(item);
- if (err == 0)
- g_idle_add(queue_job, NULL);
- *ret = COMM_RET_OK;
- break;
-
- case COMM_REQ_CHECK_APP:
- case COMM_REQ_KILL_APP:
- /* In case of activate, there is no popup */
- err = _pm_queue_push(item);
- p = __get_position_from_pkg_type(item->pkg_type);
- __set_backend_mode(p);
- /* Free resource */
- free(item);
-
-/* g_idle_add(queue_job, NULL); */
- if (err == 0)
- queue_job(NULL);
- *ret = COMM_RET_OK;
- break;
+ if (sig_reg)
+ return 0;
- default:
- DBG("Check your request..\n");
- *ret = COMM_RET_ERROR;
- break;
+ act.sa_handler = sighandler;
+ sigemptyset(&act.sa_mask);
+ act.sa_flags = SA_NOCLDSTOP;
+ if (sigaction(SIGCHLD, &act, NULL) < 0) {
+ ERR("signal: SIGCHLD failed\n");
+ return -1;
}
-err:
- if (*ret == COMM_RET_ERROR) {
- DBG("Failed to handle request %s %s\n",item->pkg_type, item->pkgid);
- pkgmgr_installer *pi;
- gboolean ret_parse;
- gint argcp;
- gchar **argvp;
- GError *gerr = NULL;
-
- pi = pkgmgr_installer_new();
- if (!pi) {
- DBG("Failure in creating the pkgmgr_installer object");
- free(item);
- return;
- }
-
- ret_parse = g_shell_parse_argv(args, &argcp, &argvp, &gerr);
- if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", args);
- DBG("messsage: %s", gerr->message);
- pkgmgr_installer_free(pi);
- free(item);
- return;
- }
-
- pkgmgr_installer_receive_request(pi, argcp, argvp);
- pkgmgr_installer_send_signal(pi, item->pkg_type,
- item->pkgid, "end",
- "fail");
+ g_timeout_add_seconds(2, exit_server, NULL);
- pkgmgr_installer_free(pi);
-
- free(item);
- }
- return;
-}
-
-static int __check_backend_mode()
-{
- int i = 0;
- for(i = 0; i < num_of_backends; i++)
- {
- if (__is_backend_mode_quiet(i))
- continue;
- else
- return 0;
- }
- return 1;
+ sig_reg = 1;
+ return 0;
}
-static int __check_backend_status_for_exit()
+
+static int __check_backend_status_for_exit(void)
{
int i = 0;
for(i = 0; i < num_of_backends; i++)
return 1;
}
-static int __check_queue_status_for_exit()
+static int __check_queue_status_for_exit(void)
{
pm_queue_data *head[MAX_QUEUE_NUM] = {NULL,};
queue_info_map *ptr = NULL;
}
return 1;
}
+
gboolean exit_server(void *data)
{
DBG("exit_server Start\n");
if (__check_backend_status_for_exit() &&
- __check_queue_status_for_exit() &&
- drawing_popup == 0) {
- if (!getenv("PMS_STANDALONE") && ail_db_update) {
- ecore_main_loop_quit();
- return FALSE;
- }
- }
- return TRUE;
-}
-
-
-int __app_func(const pkgmgrinfo_appinfo_h handle, void *user_data)
-{
- int ret = 0;
- char *appid = NULL;
- int *data = (int *)user_data;
-
- ret = pkgmgrinfo_appinfo_get_appid(handle, &appid);
- if (ret != PMINFO_R_OK) {
- perror("fail to activate/deactivte package");
- exit(1);
- }
-
- ret = pkgmgrinfo_appinfo_set_state_enabled(appid, (*data));
- if (ret != PMINFO_R_OK) {
- perror("fail to activate/deactivte package");
- exit(1);
- }
-
- ret = ail_desktop_appinfo_modify_bool(appid,
- AIL_PROP_X_SLP_ENABLED_BOOL,
- (*data), TRUE);
- if (ret != AIL_ERROR_OK) {
- perror("fail to activate/deactivte package");
- exit(1);
+ __check_queue_status_for_exit()) {
+ if (!getenv("PMS_STANDALONE")) {
+ g_main_loop_quit(mainloop);
+ return FALSE;
+ }
}
- return 0;
+ return TRUE;
}
static int __pkgcmd_read_proc(const char *path, char *buf, int size)
return 0;
}
+static void __make_pid_info_file(char *req_key, int pid)
+{
+ FILE* file;
+ int fd;
+ char buf[MAX_PKG_TYPE_LEN] = {0};
+ char info_file[PATH_MAX] = {'\0'};
+
+ if(req_key == NULL)
+ return;
+
+ snprintf(info_file, PATH_MAX, "/tmp/%s", req_key);
+
+ DBG("info_path(%s)", info_file);
+ file = fopen(info_file, "w");
+ if (file == NULL) {
+ ERR("Couldn't open the file(%s)", info_file);
+ return;
+ }
+
+ snprintf(buf, MAX_PKG_TYPE_LEN, "%d\n", pid);
+ fwrite(buf, 1, strlen(buf), file);
+
+ fflush(file);
+ fd = fileno(file);
+ fsync(fd);
+ fclose(file);
+}
+
static int __pkgcmd_app_cb(const pkgmgrinfo_appinfo_h handle, void *user_data)
{
- char *exec = NULL;
- int ret = 0;
+ char *pkgid;
+ char *exec;
+ int ret;
int pid = -1;
+
if (handle == NULL) {
perror("appinfo handle is NULL\n");
exit(1);
perror("Failed to get app exec path\n");
exit(1);
}
+ ret = pkgmgrinfo_appinfo_get_pkgid(handle, &pkgid);
+ if (ret) {
+ perror("Failed to get pkgid\n");
+ exit(1);
+ }
if (strcmp(user_data, "kill") == 0)
pid = __pkgcmd_proc_iter_kill_cmdline(exec, 1);
else if(strcmp(user_data, "check") == 0)
pid = __pkgcmd_proc_iter_kill_cmdline(exec, 0);
- vconf_set_int(VCONFKEY_PKGMGR_STATUS, pid);
+ __make_pid_info_file(pkgid, pid);
return 0;
}
free(ctx);
}
-int set_environement(user_ctx* ctx)
+int set_environement(user_ctx *ctx)
{
int i = 0;
int res = 0;
char **env = NULL;
if (!ctx)
- return;
- setgid(ctx->gid);
- setuid(ctx->uid);
+ return -1;;
+ if (setgid(ctx->gid)) {
+ ERR("setgid failed: %d", errno);
+ return -1;
+ }
+ if (setuid(ctx->uid)) {
+ ERR("setuid failed: %d", errno);
+ return -1;
+ }
env = ctx->env;
//env variable ends by NULL element
while (env[i]) {
- if( putenv(env[i]) != 0 )
+ if (putenv(env[i]) != 0)
res = -1;
i++;
}
* returned by getpwuid
*/
user_ctx *context_res;
- char ** env;
+ char **env = NULL;
struct passwd * pwd;
int len;
int ret = 0;
pwd = getpwuid(uid);
if (!pwd)
return NULL;
-
+
do {
context_res = (user_ctx *)malloc(sizeof(user_ctx));
if (!context_res) {
ret = -1;
break;
}
-
+
sprintf(env[1], "USER=%s", pwd->pw_name);
env[2] = NULL;
} while (0);
-
- if(ret == -1) {
+
+ if (ret == -1) {
free(context_res);
context_res = NULL;
int i = 0;
}
return context_res;
}
-
-gboolean queue_job(void *data)
+static char **__generate_argv(const char *args)
{
- /* DBG("queue_job start"); */
- pm_dbus_msg *item;
- backend_info *ptr = NULL;
- ptr = begin;
- int x = 0;
- int pos = 0;
- /* Pop a job from queue */
-pop:
- if (!__is_backend_busy(pos % num_of_backends)) {
- item = _pm_queue_pop(pos % num_of_backends);
- pos = (pos + 1) % num_of_backends;
- }
- else {
- pos = (pos + 1) % num_of_backends;
- goto pop;
- }
-
+ /* Create args vector
+ * req_id + pkgid + args
+ *
+ * vector size = # of args +
+ *(req_id + pkgid + NULL termination = 3)
+ * Last value must be NULL for execv.
+ */
+ gboolean ret_parse;
+ gint argcp;
+ gchar **argvp;
+ GError *gerr = NULL;
+ ret_parse = g_shell_parse_argv(args,
+ &argcp, &argvp, &gerr);
+ if (FALSE == ret_parse) {
+ DBG("Failed to split args: %s", args);
+ DBG("messsage: %s", gerr->message);
+ exit(1);
+ }
- int ret = 0;
- char *backend_cmd = NULL;
+ /* Setup argument !!! */
+ /*char **args_vector =
+ calloc(argcp + 4, sizeof(char *)); */
+ char **args_vector = calloc(argcp + 1, sizeof(char *));
+ if (args_vector == NULL) {
+ ERR("Out of memory");
+ exit(1);
+ }
+ /*args_vector[0] = strdup(backend_cmd);
+ args_vector[1] = strdup(item->req_id);
+ args_vector[2] = strdup(item->pkgid); */
+ int arg_idx;
+ for (arg_idx = 0; arg_idx < argcp; arg_idx++) {
+ /* args_vector[arg_idx+3] = argvp[arg_idx]; */
+ args_vector[arg_idx] = argvp[arg_idx];
+ }
- /* queue is empty and backend process is not running */
- if ( (item == NULL) || (item->req_type == -1) ) {
- if(item)
- free(item);
- DBG("the queue is empty");
- return FALSE;
+ /* dbg */
+ /*for(arg_idx = 0; arg_idx < argcp+3; arg_idx++) { */
+ for (arg_idx = 0; arg_idx < argcp + 1; arg_idx++) {
+ DBG(">>>>>> args_vector[%d]=%s",
+ arg_idx, args_vector[arg_idx]);
}
- __set_backend_busy((pos + num_of_backends - 1) % num_of_backends);
- __set_recovery_mode(item->pkgid, item->pkg_type);
-
- switch (item->req_type) {
- case COMM_REQ_TO_INSTALLER:
- DBG("installer start");
- _save_queue_status(item, "processing");
- DBG("saved queue status. Now try fork()");
- /*save pkg type and pkg name for future*/
- x = (pos + num_of_backends - 1) % num_of_backends;
- strncpy((ptr + x)->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
- strncpy((ptr + x)->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy((ptr + x)->args, item->args, MAX_PKG_ARGS_LEN-1);
- (ptr + x)->pid = fork();
- DBG("child forked [%d]\n", (ptr + x)->pid);
-
- switch ((ptr + x)->pid) {
- case 0: /* child */
- DBG("before run _get_backend_cmd()");
- user_ctx* user_context;
- /*Check for efl-tpk app*/
- backend_cmd = _get_backend_cmd(item->pkg_type);
- if (strcmp(item->pkg_type, "tpk") == 0) {
- ret = __is_efl_tpk_app(item->pkgid);
- if (ret == 1) {
- if (backend_cmd)
- free(backend_cmd);
- backend_cmd = _get_backend_cmd("efltpk");
- }
- }
+ return args_vector;
+}
- if (NULL == backend_cmd)
- break;
+static void __exec_with_arg_vector(const char *cmd, char **argv, uid_t uid)
+{
+ user_ctx* user_context = get_user_context(uid);
+ if(!user_context) {
+ DBG("Failed to getenv for the user : %d", uid);
+ exit(1);
+ }
+ if(set_environement(user_context)){
+ DBG("Failed to set env for the user : %d", uid);
+ exit(1);
+ }
+ free_user_context(user_context);
- DBG("Try to exec [%s][%s]", item->pkg_type,
- backend_cmd);
- fprintf(stdout, "Try to exec [%s][%s]\n",
- item->pkg_type, backend_cmd);
-
- /* Create args vector
- * req_id + pkgid + args
- *
- * vector size = # of args +
- *(req_id + pkgid + NULL termination = 3)
- * Last value must be NULL for execv.
- */
- gboolean ret_parse;
- gint argcp;
- gchar **argvp;
- GError *gerr = NULL;
- ret_parse = g_shell_parse_argv(item->args,
- &argcp, &argvp, &gerr);
- if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", item->args);
- DBG("messsage: %s", gerr->message);
- exit(1);
- }
+ /* Execute backend !!! */
+ int ret = execv(cmd, argv);
- /* Setup argument !!! */
- /*char **args_vector =
- calloc(argcp + 4, sizeof(char *)); */
- char **args_vector = calloc(argcp + 1, sizeof(char *));
- /*args_vector[0] = strdup(backend_cmd);
- args_vector[1] = strdup(item->req_id);
- args_vector[2] = strdup(item->pkgid); */
- int arg_idx;
- for (arg_idx = 0; arg_idx < argcp; arg_idx++) {
- /* args_vector[arg_idx+3] = argvp[arg_idx]; */
- args_vector[arg_idx] = argvp[arg_idx];
- }
+ /* Code below: exec failure. Should not be happened! */
+ DBG(">>>>>> OOPS 2!!!");
- /* dbg */
- /*for(arg_idx = 0; arg_idx < argcp+3; arg_idx++) { */
- for (arg_idx = 0; arg_idx < argcp + 1; arg_idx++) {
- DBG(">>>>>> args_vector[%d]=%s",
- arg_idx, args_vector[arg_idx]);
- }
+ /* g_strfreev(args_vector); *//* FIXME: causes error */
- /* Execute backend !!! */
- user_context = get_user_context(item->uid);
- if(user_context) {
- setgid(user_context->gid);
- setuid(item->uid);
- ret = execve(backend_cmd, args_vector,user_context->env);
- } else {
- ret = -1;
- perror("fail to retreive user context");
- exit(1);
- }
- /* Code below: exec failure. Should not be happened! */
- DBG(">>>>>> OOPS 2!!!");
+ if (ret == -1) {
+ perror("fail to exec");
+ exit(1);
+ }
+}
- /* g_strfreev(args_vector); *//* FIXME: causes error */
+gboolean queue_job(void *data)
+{
+ pm_dbus_msg *item = NULL;
+ backend_info *ptr;
+ int x;
+ int ret;
+ char *backend_cmd = NULL;
- if (ret == -1) {
- perror("fail to exec");
- exit(1);
- }
- _save_queue_status(item, "done");
- if (NULL != backend_cmd)
- free(backend_cmd);
- exit(0); /* exit */
- break;
+ /* Pop a job from queue */
+ for (x = 0, ptr = begin; x < num_of_backends; x++, ptr++) {
+ if (__is_backend_busy(x))
+ continue;
- case -1: /* error */
- fprintf(stderr, "Fail to execute fork()\n");
- exit(1);
+ item = _pm_queue_pop(x);
+ if (item && item->req_type != -1)
break;
+ free(item);
+ }
+
+ /* all backend messages queue are empty or busy */
+ if (x == num_of_backends)
+ return FALSE;
+
+ __set_backend_busy(x);
+ __set_recovery_mode(item->uid, item->pkgid, item->pkg_type);
+
+ /* fork */
+ _save_queue_status(item, "processing");
+ DBG("saved queue status. Now try fork()");
+ /*save pkg type and pkg name for future*/
+ strncpy(ptr->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
+ strncpy(ptr->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
+ strncpy(ptr->args, item->args, MAX_PKG_ARGS_LEN-1);
+ ptr->uid = item->uid;
+ ptr->pid = fork();
+ DBG("child forked [%d] for request type [%d]", ptr->pid, item->req_type);
+
+ switch (ptr->pid) {
+ case 0: /* child */
+ switch (item->req_type) {
+ case COMM_REQ_TO_INSTALLER:
+ DBG("before run _get_backend_cmd()");
+ /*Check for efl-tpk app*/
+ backend_cmd = _get_backend_cmd(item->pkg_type);
+ if (backend_cmd == NULL)
+ break;
+
+ DBG("Try to exec [%s][%s]", item->pkg_type, backend_cmd);
+ fprintf(stdout, "Try to exec [%s][%s]\n", item->pkg_type, backend_cmd);
- default: /* parent */
- DBG("parent \n");
- _wait_backend((ptr + x)->pid);
- _save_queue_status(item, "done");
+ char **args_vector = __generate_argv(item->args);
+ args_vector[0] = backend_cmd;
+
+ /* Execute backend !!! */
+ __exec_with_arg_vector(backend_cmd, args_vector, item->uid);
+ free(backend_cmd);
break;
- }
- break;
- case COMM_REQ_TO_ACTIVATOR:
- DBG("activator start");
- int val = 0;
- _save_queue_status(item, "processing");
- DBG("saved queue status. Now try fork()");
- /*save pkg type and pkg name for future*/
- x = (pos + num_of_backends - 1) % num_of_backends;
- strncpy((ptr + x)->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
- strncpy((ptr + x)->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy((ptr + x)->args, item->args, MAX_PKG_ARGS_LEN-1);
- (ptr + x)->pid = fork();
- DBG("child forked [%d]\n", (ptr + x)->pid);
-
- switch ((ptr + x)->pid) {
- case 0: /* child */
+ case COMM_REQ_TO_ACTIVATOR:
+ DBG("activator start");
+ int val = 0;
if (item->args[0] == '1') /* activate */
val = 1;
else if (item->args[0] == '0') /* deactivate */
perror("fail to activate/deactivte package");
exit(1);
}
-
- ret = ail_desktop_appinfo_modify_usr_str(item->pkgid,
- item->uid,
- AIL_PROP_NAME_STR,
- label, FALSE);
- if (ret != AIL_ERROR_OK) {
- perror("fail to activate/deactivte package");
- exit(1);
- }
free(label);
}
-
- ret = ail_desktop_appinfo_modify_usr_bool(item->pkgid,
- item->uid,
- AIL_PROP_X_SLP_ENABLED_BOOL,
- val, TRUE);
- if (ret != AIL_ERROR_OK) {
- perror("fail to activate/deactivte package");
- exit(1);
- }
} else { /* in case of package */
ERR("(De)activate PKG[pkgid=%s, val=%d]", item->pkgid, val);
char *manifest = NULL;
if (ret < 0) {
ERR("insert in db failed\n");
}
-
- ret = ail_usr_desktop_add(item->pkgid, item->uid);
- if (ret != AIL_ERROR_OK) {
- ERR("fail to ail_desktop_add");
- }
} else {
pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
}
perror("fail to activate/deactivte package");
exit(1);
}
-
- ret = ail_desktop_appinfo_modify_usr_bool(item->pkgid,
- item->uid,
- AIL_PROP_X_SLP_ENABLED_BOOL,
- val, TRUE);
- if (ret != AIL_ERROR_OK) {
- perror("fail to ail_desktop_appinfo");
- exit(1);
- }
}
else
ret = pkgmgr_parser_parse_usr_manifest_for_uninstallation(manifest, item->uid, NULL);
exit(1);
}
}
-
- _save_queue_status(item, "done");
- exit(0);
break;
-
- case -1: /* error */
- fprintf(stderr, "Fail to execute fork()\n");
- exit(1);
- break;
-
- default: /* parent */
- DBG("parent exit\n");
- _wait_backend((ptr + x)->pid);
- _save_queue_status(item, "done");
- break;
- }
- break;
- case COMM_REQ_TO_MOVER:
- case COMM_REQ_TO_CLEARER:
- DBG("cleaner start");
- _save_queue_status(item, "processing");
- DBG("saved queue status. Now try fork()");
- /*save pkg type and pkg name for future*/
- x = (pos + num_of_backends - 1) % num_of_backends;
- strncpy((ptr + x)->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
- strncpy((ptr + x)->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy((ptr + x)->args, item->args, MAX_PKG_ARGS_LEN-1);
- (ptr + x)->pid = fork();
- DBG("child forked [%d]\n", (ptr + x)->pid);
-
- switch ((ptr + x)->pid) {
- case 0: /* child */
+ case COMM_REQ_TO_MOVER:
+ case COMM_REQ_TO_CLEARER:
+ DBG("cleaner start");
DBG("before run _get_backend_cmd()");
backend_cmd = _get_backend_cmd(item->pkg_type);
if (NULL == backend_cmd)
break;
- DBG("Try to exec [%s][%s]", item->pkg_type,
- backend_cmd);
- fprintf(stdout, "Try to exec [%s][%s]\n",
- item->pkg_type, backend_cmd);
-
- /* Create args vector
- * req_id + pkgid + args
- *
- * vector size = # of args +
- *(req_id + pkgid + NULL termination = 3)
- * Last value must be NULL for execv.
- */
- gboolean ret_parse;
- gint argcp;
- gchar **argvp;
- GError *gerr = NULL;
- user_ctx* user_context = get_user_context(item->uid);
- if(!user_context) {
- DBG("Failed to getenv for the user : %d", item->uid);
- exit(1);
- }
- if(set_environement(user_context)){
- DBG("Failed to set env for the user : %d", item->uid);
- exit(1);
- }
- free_user_context(user_context);
-
- ret_parse = g_shell_parse_argv(item->args,
- &argcp, &argvp, &gerr);
- if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", item->args);
- DBG("messsage: %s", gerr->message);
- exit(1);
- }
-
- /* Setup argument !!! */
- /*char **args_vector =
- calloc(argcp + 4, sizeof(char *)); */
- char **args_vector = calloc(argcp + 1, sizeof(char *));
- /*args_vector[0] = strdup(backend_cmd);
- args_vector[1] = strdup(item->req_id);
- args_vector[2] = strdup(item->pkgid); */
- int arg_idx;
- for (arg_idx = 0; arg_idx < argcp; arg_idx++) {
- /* args_vector[arg_idx+3] = argvp[arg_idx]; */
- args_vector[arg_idx] = argvp[arg_idx];
- }
+ DBG("Try to exec [%s][%s]", item->pkg_type, backend_cmd);
+ fprintf(stdout, "Try to exec [%s][%s]\n", item->pkg_type, backend_cmd);
- /* dbg */
- /*for(arg_idx = 0; arg_idx < argcp+3; arg_idx++) { */
- for (arg_idx = 0; arg_idx < argcp + 1; arg_idx++) {
- DBG(">>>>>> args_vector[%d]=%s",
- arg_idx, args_vector[arg_idx]);
- }
+ char **args_vectors = __generate_argv(item->args);
+ args_vectors[0] = backend_cmd;
/* Execute backend !!! */
- ret = execv(backend_cmd, args_vector);
-
- /* Code below: exec failure. Should not be happened! */
- DBG(">>>>>> OOPS 2!!!");
-
- /* g_strfreev(args_vector); *//* FIXME: causes error */
-
- if (ret == -1) {
- perror("fail to exec");
- exit(1);
- }
- _save_queue_status(item, "done");
- if (NULL != backend_cmd)
- free(backend_cmd);
- exit(0);
- break;
-
- case -1: /* error */
- fprintf(stderr, "Fail to execute fork()\n");
- exit(1);
- break;
-
- default: /* parent */
- DBG("parent \n");
- _wait_backend((ptr + x)->pid);
- _save_queue_status(item, "done");
+ __exec_with_arg_vector(backend_cmd, args_vectors, item->uid);
+ free(backend_cmd);
break;
- }
- break;
-
- case COMM_REQ_GET_SIZE:
- DBG("COMM_REQ_GET_SIZE pkgid = %s\n", item->pkgid);
- _save_queue_status(item, "processing");
- DBG("saved queue status. Now try fork()");
- /*save pkg type and pkg name for future*/
- x = (pos + num_of_backends - 1) % num_of_backends;
- strncpy((ptr + x)->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
- strncpy((ptr + x)->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy((ptr + x)->args, item->args, MAX_PKG_ARGS_LEN-1);
- (ptr + x)->pid = fork();
- DBG("child forked [%d]\n", (ptr + x)->pid);
-
- switch ((ptr + x)->pid) {
- case 0: /* child */
+ case COMM_REQ_GET_SIZE:
DBG("before run _get_backend_cmd()");
- backend_cmd = strdup("/usr/bin/pkg_getsize");
- if (NULL == backend_cmd)
- break;
-
- DBG("Try to exec [%s][%s]", item->pkg_type,
- backend_cmd);
- fprintf(stdout, "Try to exec [%s][%s]\n",
- item->pkg_type, backend_cmd);
-
- /* Create args vector
- * req_id + pkgid + args
- *
- * vector size = # of args +
- *(req_id + pkgid + NULL termination = 3)
- * Last value must be NULL for execv.
- */
- gboolean ret_parse;
- gint argcp;
- gchar **argvp;
- GError *gerr = NULL;
- user_ctx* user_context = get_user_context(item->uid);
- if(!user_context) {
- DBG("Failed to getenv for the user : %d", item->uid);
- exit(1);
- }
- if(set_environement(user_context)){
- DBG("Failed to set env for the user : %d", item->uid);
- exit(1);
- }
- free_user_context(user_context);
-
- ret_parse = g_shell_parse_argv(item->args,
- &argcp, &argvp, &gerr);
- if (FALSE == ret_parse) {
- DBG("Failed to split args: %s", item->args);
- DBG("messsage: %s", gerr->message);
- exit(1);
- }
-
- /* Setup argument !!! */
- /*char **args_vector =
- calloc(argcp + 4, sizeof(char *)); */
- char **args_vector = calloc(argcp + 1, sizeof(char *));
- /*args_vector[0] = strdup(backend_cmd);
- args_vector[1] = strdup(item->req_id);
- args_vector[2] = strdup(item->pkgid); */
- int arg_idx;
- for (arg_idx = 0; arg_idx < argcp; arg_idx++) {
- /* args_vector[arg_idx+3] = argvp[arg_idx]; */
- args_vector[arg_idx] = argvp[arg_idx];
- }
-
- /* dbg */
- /*for(arg_idx = 0; arg_idx < argcp+3; arg_idx++) { */
- for (arg_idx = 0; arg_idx < argcp + 1; arg_idx++) {
- DBG(">>>>>> args_vector[%d]=%s",
- arg_idx, args_vector[arg_idx]);
- }
-
- /* Execute backend !!! */
- ret = execv(backend_cmd, args_vector);
-
- /* Code below: exec failure. Should not be happened! */
- DBG(">>>>>> OOPS 2!!!");
-
- /* g_strfreev(args_vector); *//* FIXME: causes error */
-
- if (ret == -1) {
- perror("fail to exec");
- exit(1);
- }
- _save_queue_status(item, "done");
- if (NULL != backend_cmd)
- free(backend_cmd);
- exit(0);
- break;
-
- case -1: /* error */
- fprintf(stderr, "Fail to execute fork()\n");
- exit(1);
- break;
-
- default: /* parent */
- DBG("parent \n");
- _wait_backend((ptr + x)->pid);
- _save_queue_status(item, "done");
+ __exec_with_arg_vector("/usr/bin/pkg_getsize", __generate_argv(item->args), item->uid);
break;
- }
- break;
-
- case COMM_REQ_KILL_APP:
- case COMM_REQ_CHECK_APP:
- DBG("COMM_REQ_CHECK_APP start");
- _save_queue_status(item, "processing");
- DBG("saved queue status. Now try fork()");
- /*save pkg type and pkg name for future*/
- x = (pos + num_of_backends - 1) % num_of_backends;
- strncpy((ptr + x)->pkgtype, item->pkg_type, MAX_PKG_TYPE_LEN-1);
- strncpy((ptr + x)->pkgid, item->pkgid, MAX_PKG_NAME_LEN-1);
- strncpy((ptr + x)->args, item->args, MAX_PKG_ARGS_LEN-1);
- (ptr + x)->pid = fork();
- DBG("child forked [%d]\n", (ptr + x)->pid);
-
- switch ((ptr + x)->pid) {
- case 0: /* child */
- DBG("child run parse argv()");
-
+ case COMM_REQ_KILL_APP:
+ case COMM_REQ_CHECK_APP:
+ DBG("COMM_REQ_CHECK_APP start");
pkgmgrinfo_pkginfo_h handle;
ret = pkgmgrinfo_pkginfo_get_usr_pkginfo(item->pkgid, item->uid, &handle);
if (ret < 0) {
}
if (item->req_type == COMM_REQ_KILL_APP) {
- ret = pkgmgrinfo_appinfo_get_usr_list(handle, PMSVC_UI_APP, __pkgcmd_app_cb, "kill", item->uid);
+ ret = pkgmgrinfo_appinfo_get_usr_list(handle, PMINFO_ALL_APP, __pkgcmd_app_cb, "kill", item->uid);
if (ret < 0) {
DBG("pkgmgrinfo_appinfo_get_list() failed\n");
pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
exit(1);
}
} else if (item->req_type == COMM_REQ_CHECK_APP) {
- ret = pkgmgrinfo_appinfo_get_usr_list(handle, PMSVC_UI_APP, __pkgcmd_app_cb, "check", item->uid);
+ ret = pkgmgrinfo_appinfo_get_usr_list(handle, PMINFO_ALL_APP, __pkgcmd_app_cb, "check", item->uid);
if (ret < 0) {
DBG("pkgmgrinfo_appinfo_get_list() failed\n");
pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
exit(1);
}
}
-
pkgmgrinfo_pkginfo_destroy_pkginfo(handle);
-
- _save_queue_status(item, "done");
- exit(0);
- break;
-
- case -1: /* error */
- fprintf(stderr, "Fail to execute fork()\n");
- exit(1);
break;
-
- default: /* parent */
- DBG("parent exit\n");
- _wait_backend((ptr + x)->pid);
- _save_queue_status(item, "done");
+ case COMM_REQ_CLEAR_CACHE_DIR:
+ __exec_with_arg_vector("/usr/bin/pkg_clearcache", __generate_argv(item->args), item->uid);
break;
}
+ /* exit child */
+ _save_queue_status(item, "done");
+ exit(0);
break;
- default:
+ case -1:
+ fprintf(stderr, "Fail to execute_fork()\n");
+ exit(1);
+
+ default: /* parent */
+ DBG("parent exit\n");
+ _save_queue_status(item, "done");
break;
}
pid_t pid;
char *backend_cmd = NULL;
char *backend_name = NULL;
- backend_info *ptr = NULL;
int r;
DBG("server start");
- if (argv[1]) {
- if (strcmp(argv[1], "init") == 0) {
- /* if current status is "processing",
- execute related backend with '-r' option */
- if (!(fp_status = fopen(STATUS_FILE, "r")))
- return 0; /*if file is not exist, terminated. */
-
- fgets(buf, 32, fp_status);
- /* if processing <-- unintended termination */
- if (strcmp(buf, "processing") == 0) {
- pid = fork();
-
- if (pid == 0) { /* child */
- fgets(buf, 32, fp_status);
+ if (argv[1] && (strcmp(argv[1], "init") == 0)) {
+ /* if current status is "processing",
+ execute related backend with '-r' option */
+ if (!(fp_status = fopen(STATUS_FILE, "r")))
+ return 0; /*if file is not exist, terminated. */
+ /* if processing <-- unintended termination */
+ if (fgets(buf, 32, fp_status) &&
+ strcmp(buf, "processing") == 0) {
+ pid = fork();
+ if (pid == 0) { /* child */
+ if (fgets(buf, 32, fp_status))
backend_cmd = _get_backend_cmd(buf);
- if (!backend_cmd) { /* if NULL, */
- DBG("fail to get"
- " backend command");
- goto err;
- }
- backend_name =
- strrchr(backend_cmd, '/');
-
- execl(backend_cmd, backend_name, "-r",
- NULL);
- if (backend_cmd)
- free(backend_cmd);
- fprintf(fp_status, " ");
- err:
- fclose(fp_status);
- exit(13);
- } else if (pid < 0) { /* error */
- DBG("fork fail");
- fclose(fp_status);
- return 0;
- } else { /* parent */
-
- DBG("parent end\n");
- fprintf(fp_status, " ");
- fclose(fp_status);
- return 0;
+ if (!backend_cmd) { /* if NULL, */
+ DBG("fail to get"
+ " backend command");
+ goto err;
}
+ backend_name =
+ strrchr(backend_cmd, '/');
+
+ execl(backend_cmd, backend_name, "-r",
+ NULL);
+ if (backend_cmd)
+ free(backend_cmd);
+ fprintf(fp_status, " ");
+err:
+ fclose(fp_status);
+ exit(13);
+ } else if (pid < 0) { /* error */
+ DBG("fork fail");
+ fclose(fp_status);
+ return 0;
+ } else { /* parent */
+
+ DBG("parent end\n");
+ fprintf(fp_status, " ");
+ fclose(fp_status);
+ return 0;
}
}
}
return -1;
}
- /*Allocate memory for holding pid, pkgtype and pkgid*/
- ptr = (backend_info*)calloc(num_of_backends, sizeof(backend_info));
- if (ptr == NULL) {
- DBG("Malloc Failed\n");
+ r = __init_backend_info();
+ if (r) {
+ DBG("backend info init failed");
+ return -1;
+ }
+
+ r = __init_request_handler();
+ if (r) {
+ ERR("dbus init failed");
+ return -1;
+ }
+
+ if (__register_signal_handler()) {
+ ERR("failed to register signal handler");
return -1;
}
- memset(ptr, '\0', num_of_backends * sizeof(backend_info));
- begin = ptr;
+#if !GLIB_CHECK_VERSION(2,35,0)
g_type_init();
+#endif
mainloop = g_main_loop_new(NULL, FALSE);
if (!mainloop) {
ERR("g_main_loop_new failed");
return -1;
}
- struct appdata ad;
-
DBG("Main loop is created.");
- PkgMgrObject *pkg_mgr;
- pkg_mgr = g_object_new(PKG_MGR_TYPE_OBJECT, NULL);
- pkg_mgr_set_request_callback(pkg_mgr, req_cb, &ad);
- DBG("pkg_mgr object is created, and request callback is registered.");
-
g_main_loop_run(mainloop);
-
DBG("Quit main loop.");
+ __fini_request_handler();
+ __fini_backend_info();
_pm_queue_final();
- /*Free backend info */
- if (begin) {
- free(begin);
- begin = NULL;
- }
DBG("package manager server terminated.");
projects / platform / core / appfw / slp-pkgmgr.git / blobdiff