#include <sys/types.h>
#include <signal.h>
#include <grp.h>
+#include <fcntl.h>
#include <glib.h>
#include <gio/gio.h>
#define EXT_STORAGE_APPDATA_GROUP 10002
#define MEDIA_STORAGE_GROUP 10502
#define ARRAY_SIZE(array) (sizeof(array) / sizeof(array[0]))
+#define MAX_LONGLONG_LENGTH 32
typedef struct {
char **env;
static GIOChannel *pipe_io;
static guint pipe_wid;
static GHashTable *backend_info_table;
-static GMainLoop *mainloop = NULL;
+static GMainLoop *mainloop;
static int __check_backend_status_for_exit(void);
static int __check_queue_status_for_exit(void);
backend_busy = backend_busy & ~(1 << position);
}
+static gboolean getsize_io_handler(GIOChannel *io, GIOCondition cond,
+ gpointer data)
+{
+ GError *err = NULL;
+ GIOStatus s;
+ gsize len;
+ char buf[MAX_LONGLONG_LENGTH];
+ long long result = 0;
+ struct backend_job *job = (struct backend_job *)data;
+
+ s = g_io_channel_read_chars(io, (gchar *)buf, sizeof(buf), &len, &err);
+ if (s != G_IO_STATUS_NORMAL) {
+ ERR("getsize fd read failed: %s", err->message);
+ g_error_free(err);
+ result = -1;
+ } else {
+ if (strlen(buf) == 0) {
+ ERR("empty result");
+ result = -1;
+ } else {
+ result = atoll(buf);
+ }
+ }
+
+ _return_value_to_caller(job->req_id, g_variant_new("(ix)",
+ (result < 0) ? PKGMGR_R_ERROR : PKGMGR_R_OK, result));
+
+ unlink(job->extra->getsize_fifo);
+ free(job->extra->getsize_fifo);
+ job->extra->getsize_fifo = NULL;
+
+ return FALSE;
+}
+
+static int __setup_size_info_io(struct backend_job *job)
+{
+ guint getsize_wid;
+
+ job->extra->getsize_fd = open(job->extra->getsize_fifo,
+ O_RDONLY | O_NONBLOCK);
+ if (job->extra->getsize_fd < 0) {
+ ERR("failed to open the fifo(%s), errno(%d)",
+ job->extra->getsize_fifo, errno);
+ return -1;
+ }
+
+ job->extra->getsize_io = g_io_channel_unix_new(job->extra->getsize_fd);
+ if (!job->extra->getsize_io)
+ return -1;
+ g_io_channel_set_encoding(job->extra->getsize_io, NULL, NULL);
+ g_io_channel_set_buffered(job->extra->getsize_io, FALSE);
+ getsize_wid = g_io_add_watch(job->extra->getsize_io,
+ G_IO_IN, getsize_io_handler, job);
+ if (!getsize_wid) {
+ ERR("failed to add io watch");
+ return -1;
+ }
+
+ return 0;
+}
+
static gboolean pipe_io_handler(GIOChannel *io, GIOCondition cond,
gpointer data)
{
DBG("backend[%s] exit", job->backend_type);
}
+ if (job->extra) {
+ if (job->extra->getsize_fifo) {
+ ERR("invalid backend close");
+ _return_value_to_caller(job->req_id,
+ g_variant_new("(ix)", PKGMGR_R_ERROR, -1));
+ }
+ }
+
g_hash_table_remove(backend_info_table, (gconstpointer)info.pid);
g_idle_add(queue_job, NULL);
return 0;
}
-void free_user_context(user_ctx* ctx)
+void free_user_context(user_ctx *ctx)
{
char **env = NULL;
int i = 0;
static int __fork_and_exec_with_args(char **argv, uid_t uid)
{
- user_ctx* user_context;
+ user_ctx *user_context;
GError *error = NULL;
gboolean ret;
int pid;
if (ret != TRUE) {
ERR("Failed to excute backend: %s", error->message);
g_error_free(error);
+ free_user_context(user_context);
+ return -1;
}
free_user_context(user_context);
if (ret != PMINFO_R_OK)
goto catch;
- if ((job->req_type == REQUEST_TYPE_DISABLE_APP ||
- job->req_type == REQUEST_TYPE_ENABLE_APP) &&
- *is_global) {
- ret = PMINFO_R_ERROR;
- goto catch;
- } else if ((job->req_type == REQUEST_TYPE_DISABLE_GLOBAL_APP_FOR_UID ||
- job->req_type ==
- REQUEST_TYPE_ENABLE_GLOBAL_APP_FOR_UID) &&
+ if ((job->req_type == REQUEST_TYPE_DISABLE_GLOBAL_APP_FOR_UID ||
+ job->req_type ==
+ REQUEST_TYPE_ENABLE_GLOBAL_APP_FOR_UID) &&
!*is_global) {
ret = PMINFO_R_ERROR;
goto catch;
char *backend_cmd;
char **argv;
char args[MAX_PKG_ARGS_LEN];
+ gchar *req_id;
+ gchar *pkgid;
int pid;
backend_cmd = job->backend_path;
if (backend_cmd == NULL)
return -1;
+ req_id = g_shell_quote(job->req_id);
+ pkgid = g_shell_quote(job->pkgid);
+ if (!req_id || !pkgid)
+ return -1;
+
snprintf(args, sizeof(args), "%s -k %s -i %s -u %d %s", backend_cmd,
- job->req_id, job->pkgid, (int)job->target_uid, job->args);
+ req_id, pkgid, (int)job->target_uid, job->args);
argv = __generate_argv(args);
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
+ g_free(req_id);
+ g_free(pkgid);
return pid;
}
char *backend_cmd;
char **argv;
char args[MAX_PKG_ARGS_LEN];
+ gchar *req_id;
+ gchar *pkgid;
int pid;
backend_cmd = job->backend_path;
if (backend_cmd == NULL)
return -1;
+ req_id = g_shell_quote(job->req_id);
+ pkgid = g_shell_quote(job->pkgid);
+ if (!req_id || !pkgid)
+ return -1;
+
snprintf(args, sizeof(args), "%s -k %s -w %s -u %d %s", backend_cmd,
- job->req_id, job->pkgid, (int)job->target_uid, job->args);
+ req_id, pkgid, (int)job->target_uid, job->args);
argv = __generate_argv(args);
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
+ g_free(req_id);
+ g_free(pkgid);
return pid;
}
char *backend_cmd;
char **argv;
char args[MAX_PKG_ARGS_LEN];
+ gchar *req_id;
+ gchar *pkgid;
int pid;
backend_cmd = job->backend_path;
if (backend_cmd == NULL)
return -1;
+ req_id = g_shell_quote(job->req_id);
+ pkgid = g_shell_quote(job->pkgid);
+ if (!req_id || !pkgid)
+ return -1;
+
snprintf(args, sizeof(args), "%s -k %s -r %s -u %d", backend_cmd,
- job->req_id, job->pkgid, (int)job->target_uid);
+ req_id, pkgid, (int)job->target_uid);
argv = __generate_argv(args);
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
+ g_free(req_id);
+ g_free(pkgid);
return pid;
}
char *backend_cmd;
char **argv;
char args[MAX_PKG_ARGS_LEN];
+ pkgmgrinfo_pkginfo_h pkginfo_h;
+ bool is_readonly;
+ bool is_global;
+ int ret;
int pid;
backend_cmd = job->backend_path;
if (backend_cmd == NULL)
return -1;
- snprintf(args, sizeof(args), "%s -k %s -u %d -A %s", backend_cmd,
- job->req_id, (int)job->target_uid, job->pkgid);
- argv = __generate_argv(args);
+ ret = pkgmgrinfo_pkginfo_get_usr_disabled_pkginfo(
+ job->pkgid, job->target_uid, &pkginfo_h);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get appinfo");
+ return -1;
+ }
+
+ ret = pkgmgrinfo_pkginfo_is_global(pkginfo_h, &is_global);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get global value");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+
+ if ((is_global && job->target_uid != GLOBAL_USER) ||
+ (!is_global && job->target_uid == GLOBAL_USER)) {
+ ERR("Invalid attempt to enable pkg");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+ ret = pkgmgrinfo_pkginfo_is_readonly(pkginfo_h, &is_readonly);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get readonly value");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+
+ snprintf(args, sizeof(args), "%s -k %s -u %d -A %s %s",
+ backend_cmd, job->req_id, (int)job->target_uid,
+ job->pkgid, (is_readonly) ? "--preload" : "");
+ argv = __generate_argv(args);
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
return pid;
}
char *backend_cmd;
char **argv;
char args[MAX_PKG_ARGS_LEN];
+ pkgmgrinfo_pkginfo_h pkginfo_h;
+ bool is_readonly;
+ bool is_global;
+ int ret;
int pid;
backend_cmd = job->backend_path;
if (backend_cmd == NULL)
return -1;
- snprintf(args, sizeof(args), "%s -k %s -u %d -D %s", backend_cmd,
- job->req_id, (int)job->target_uid, job->pkgid);
+ ret = pkgmgrinfo_pkginfo_get_usr_pkginfo(
+ job->pkgid, job->target_uid, &pkginfo_h);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get appinfo");
+ return -1;
+ }
+
+ ret = pkgmgrinfo_pkginfo_is_global(pkginfo_h, &is_global);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get global value");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+
+ if ((is_global && job->target_uid != GLOBAL_USER) ||
+ (!is_global && job->target_uid == GLOBAL_USER)) {
+ ERR("Invalid attempt to disable pkg");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+
+ ret = pkgmgrinfo_pkginfo_is_readonly(pkginfo_h, &is_readonly);
+ if (ret != PMINFO_R_OK) {
+ ERR("Failed to get readonly value");
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
+ return -1;
+ }
+
+ snprintf(args, sizeof(args), "%s -k %s -u %d -D %s %s",
+ backend_cmd, job->req_id, (int)job->target_uid,
+ job->pkgid, (is_readonly) ? "--preload" : "");
argv = __generate_argv(args);
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
+ pkgmgrinfo_pkginfo_destroy_pkginfo(pkginfo_h);
return pid;
}
if (ret != PMINFO_R_OK || strlen(job->appid) == 0) {
_send_app_signal(job->target_uid, job->req_id, job->pkgid, job->pkgid,
PKGMGR_INSTALLER_START_KEY_STR,
- PKGMGR_INSTALLER_GLOBAL_APP_ENABLE_FOR_UID,
+ PKGMGR_INSTALLER_APP_ENABLE_EVENT_STR,
job->req_type);
_send_app_signal(job->target_uid, job->req_id, job->pkgid, job->pkgid,
PKGMGR_INSTALLER_END_KEY_STR,
_send_app_signal(job->target_uid, job->req_id, job->pkgid, job->appid,
PKGMGR_INSTALLER_START_KEY_STR,
- PKGMGR_INSTALLER_GLOBAL_APP_ENABLE_FOR_UID,
+ PKGMGR_INSTALLER_APP_ENABLE_EVENT_STR,
job->req_type);
ret = pkgmgr_parser_update_global_app_disable_for_uid_info_in_db(
_send_app_signal(job->target_uid, job->req_id,
job->pkgid, job->pkgid,
PKGMGR_INSTALLER_START_KEY_STR,
- PKGMGR_INSTALLER_GLOBAL_APP_DISABLE_FOR_UID,
+ PKGMGR_INSTALLER_APP_DISABLE_EVENT_STR,
job->req_type);
_send_app_signal(job->target_uid, job->req_id, job->pkgid, job->pkgid,
PKGMGR_INSTALLER_END_KEY_STR,
_send_app_signal(job->target_uid, job->req_id,
job->pkgid, job->appid,
PKGMGR_INSTALLER_START_KEY_STR,
- PKGMGR_INSTALLER_GLOBAL_APP_DISABLE_FOR_UID,
+ PKGMGR_INSTALLER_APP_DISABLE_EVENT_STR,
job->req_type);
ret = __kill_app(job->appid, job->target_uid);
return pid;
}
+static int __process_getsize_sync(struct backend_job *job)
+{
+ static const char backend_cmd[] = "/usr/bin/pkg_getsize";
+ char **argv;
+ char args[MAX_PKG_ARGS_LEN];
+ char fifo_path[PATH_MAX];
+ int pid;
+
+ snprintf(fifo_path, sizeof(fifo_path), "/tmp/pkgmgr/%s",
+ job->req_id);
+
+ job->extra = calloc(1, sizeof(struct job_extra_info));
+ if (!job->extra) {
+ ERR("memory alloc failed");
+ goto error;
+ }
+
+ job->extra->getsize_fifo = strdup(fifo_path);
+ if (!job->extra->getsize_fifo) {
+ ERR("out of memory");
+ goto error;
+ }
+
+ if (mkfifo(job->extra->getsize_fifo, 0600) < 0) {
+ ERR("failed to mkfifo");
+ goto error;
+ }
+
+ snprintf(args, sizeof(args), "%s %s %s %d -k %s -u %d --sync",
+ backend_cmd, job->pkgid, job->args, job->caller_uid,
+ job->req_id, job->target_uid);
+ argv = __generate_argv(args);
+ pid = __fork_and_exec_with_args(argv, APPFW_UID);
+
+ g_strfreev(argv);
+
+ if (pid < 0) {
+ ERR("failed to execute backend");
+ goto error;
+ }
+ if (__setup_size_info_io(job) < 0) {
+ ERR("failed to setup io handler");
+ goto error;
+ }
+
+ return pid;
+
+error:
+ _return_value_to_caller(job->req_id,
+ g_variant_new("(ix)", PKGMGR_R_ERROR, -1));
+ return -1;
+}
+
static int __process_cleardata(struct backend_job *job)
{
- char *backend_cmd;
+ static const char *backend_cmd = "/usr/bin/pkg_cleardata";
char **argv;
char args[MAX_PKG_ARGS_LEN];
int pid;
- backend_cmd = job->backend_path;
- if (backend_cmd == NULL)
+ if ((int)job->target_uid < REGULAR_USER)
return -1;
- /* TODO: set movetype */
- snprintf(args, sizeof(args), "%s -k %s -c %s -u %d", backend_cmd,
- job->req_id, job->pkgid, (int)job->target_uid);
+ snprintf(args, sizeof(args), "%s -d -n %s -u %d",
+ backend_cmd, job->pkgid, job->target_uid);
argv = __generate_argv(args);
-
pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
-
return pid;
}
static int __process_clearcache(struct backend_job *job)
{
- static const char *backend_cmd = "/usr/bin/pkg_clearcache";
+ static const char *backend_cmd = "/usr/bin/pkg_cleardata";
char **argv;
char args[MAX_PKG_ARGS_LEN];
int pid;
- snprintf(args, sizeof(args), "%s %s", backend_cmd, job->pkgid);
+ if ((int)job->target_uid < REGULAR_USER)
+ return -1;
+
+ snprintf(args, sizeof(args), "%s -c -n %s -u %d",
+ backend_cmd, job->pkgid, job->target_uid);
argv = __generate_argv(args);
- pid = __fork_and_exec_with_args(argv, job->target_uid);
+ pid = __fork_and_exec_with_args(argv, APPFW_UID);
g_strfreev(argv);
-
return pid;
}
static int __process_set_app_label(struct backend_job *job)
{
int ret;
- int mode = -1;
- ret = pkgmgr_parser_update_app_label_info_in_usr_db(job->pkgid, job->appid,
- job->args);
+ ret = pkgmgr_parser_update_app_label_info_in_usr_db(job->pkgid,
+ job->target_uid, job->args);
_return_value_to_caller(job->req_id, g_variant_new("(i)", ret));
return ret;
}
+static int __process_migrate_external_image(struct backend_job *job)
+{
+ char *backend_cmd;
+ char **argv;
+ char args[MAX_PKG_ARGS_LEN];
+ int pid;
+
+ backend_cmd = job->backend_path;
+ if (backend_cmd == NULL)
+ return -1;
+
+ snprintf(args, sizeof(args), "%s -k %s --migrate-extimg %s -u %d %s",
+ backend_cmd, job->req_id, job->pkgid,
+ (int)job->target_uid, job->args);
+
+ argv = __generate_argv(args);
+
+ pid = __fork_and_exec_with_args(argv, APPFW_UID);
+ g_strfreev(argv);
+
+ return pid;
+}
+
+static int __post_process(int ret, int x, struct backend_job *job)
+{
+ if (ret < 0) {
+ __set_backend_free(x);
+ _free_backend_job(job);
+ } else {
+ g_hash_table_insert(backend_info_table, (gpointer)ret,
+ (gpointer)job);
+ }
+ return 0;
+}
+
gboolean queue_job(void *data)
{
struct backend_job *job = NULL;
/* all backend messages queue are empty or busy */
if (x == num_of_backends || job == NULL) {
- DBG("no job left");
+ DBG("no job available");
return FALSE;
}
ret = -1;
_send_fail_signal(job);
_free_backend_job(job);
- return FALSE;
+ return TRUE;
}
}
#endif
case REQUEST_TYPE_INSTALL:
__set_backend_busy(x);
ret = __process_install(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_MOUNT_INSTALL:
__set_backend_busy(x);
ret = __process_mount_install(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_REINSTALL:
__set_backend_busy(x);
ret = __process_reinstall(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_UNINSTALL:
__set_backend_busy(x);
ret = __process_uninstall(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_MOVE:
__set_backend_busy(x);
ret = __process_move(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_ENABLE_PKG:
__set_backend_busy(x);
ret = __process_enable_pkg(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ if (ret < 0)
+ _send_fail_signal(job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_DISABLE_PKG:
__set_backend_busy(x);
ret = __process_disable_pkg(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ if (ret < 0)
+ _send_fail_signal(job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_ENABLE_APP:
ret = __process_enable_app(job);
case REQUEST_TYPE_GETSIZE:
__set_backend_busy(x);
ret = __process_getsize(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
+ break;
+ case REQUEST_TYPE_GETSIZE_SYNC:
+ __set_backend_busy(x);
+ ret = __process_getsize_sync(job);
+ if (ret < 0)
+ __free_extra_info(job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_CLEARDATA:
__set_backend_busy(x);
ret = __process_cleardata(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_CLEARCACHE:
__set_backend_busy(x);
ret = __process_clearcache(job);
- g_hash_table_insert(backend_info_table, (gpointer)ret,
- (gpointer)job);
+ __post_process(ret, x, job);
break;
case REQUEST_TYPE_ENABLE_GLOBAL_APP_FOR_UID:
ret = __process_enable_global_app_for_uid(job);
case REQUEST_TYPE_SET_APP_LABEL:
ret = __process_set_app_label(job);
_free_backend_job(job);
+ break;
+ case REQUEST_TYPE_MIGRATE_EXTERNAL_IMAGE:
+ __set_backend_busy(x);
+ ret = __process_migrate_external_image(job);
+ __post_process(ret, x, job);
+ break;
default:
ret = -1;
break;
}
- return FALSE;
+ return TRUE;
}
int main(int argc, char *argv[])
projects / platform / core / appfw / pkgmgr-server.git / blobdiff