X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fstorage-inhouse.c;h=b6513af91d40f3efa796418f4f9dd6e005fc94a0;hb=refs%2Ftags%2Faccepted%2Ftizen%2Funified%2F20230831.081041;hp=d3e30d3e88ba5a3e9bb985ca8a3f6b29faa67687;hpb=93e5212a3c6ab4877f57b92a2e71dad432644b2d;p=platform%2Fcore%2Fsystem%2Flibstorage.git diff --git a/src/storage-inhouse.c b/src/storage-inhouse.c index d3e30d3..b6513af 100755 --- a/src/storage-inhouse.c +++ b/src/storage-inhouse.c @@ -15,17 +15,26 @@ */ +#include +#include #include #include #include #include +#include +#include +#include +#include #include "common.h" -#include "list.h" #include "log.h" #include "storage-internal.h" #include "storage-external-dbus.h" +#define FORMAT_TIMEOUT (120*1000) +#define USER_PARTITION "user" +#define CONTAINER_USER_PARTITION "contain-user" + /* Get compat path from origin Multi-user path from TZ_USER_CONTENT/.. to /opt/usr/media/.. @@ -57,6 +66,14 @@ API int storage_get_compat_internal_path(const char* origin, int len, char* comp return -1; } + if (getuid() <= USER_UID_START) { + //LCOV_EXCL_START System Error + _E("Only apps and user session daemons are allowed " + "to use storage_get_compat_internal_path()"); + return -1; + //LCOV_EXCL_STOP + } + // this API works on place where compat path is bind-mounted if (!is_compat_bind_mount()) { //LCOV_EXCL_START System Error @@ -65,7 +82,7 @@ API int storage_get_compat_internal_path(const char* origin, int len, char* comp //LCOV_EXCL_STOP } - str = tzplatform_getenv(TZ_USER_CONTENT); + str = tzplatform_uid_getenv(getuid(), TZ_USER_CONTENT); str_len = strlen(str); if (strncmp(origin, str, str_len) != 0) { _E("Failed to match TZ_USER_CONTENT"); @@ -113,6 +130,14 @@ API int storage_get_origin_internal_path(const char* compat, int len, char* orig return -1; } + if (getuid() <= USER_UID_START) { + //LCOV_EXCL_START System Error + _E("Only apps and user session daemons are allowed " + "to use storage_get_origin_internal_path()"); + return -1; + //LCOV_EXCL_STOP + } + // this API works on place where compat path is bind-mounted if (!is_compat_bind_mount()) { //LCOV_EXCL_START System Error @@ -127,7 +152,7 @@ API int storage_get_origin_internal_path(const char* compat, int len, char* orig return -1; } - r = snprintf(origin, len, "%s%s", tzplatform_getenv(TZ_USER_CONTENT), compat + compat_len); + r = snprintf(origin, len, "%s%s", tzplatform_uid_getenv(getuid(), TZ_USER_CONTENT), compat + compat_len); if (r < 0) { //LCOV_EXCL_START System Error _E("failed to create new path"); @@ -140,61 +165,383 @@ API int storage_get_origin_internal_path(const char* compat, int len, char* orig API int storage_get_primary_sdcard(int *storage_id, char **path) { - GVariant *result; - storage_ext_device info; + GVariant *reply; + int ret, ret_dbus; + char *reply_mount_point = NULL; + int reply_id; if (!storage_id || !path) return STORAGE_ERROR_INVALID_PARAMETER; - result = dbus_method_call_sync(STORAGE_EXT_BUS_NAME, + if (!storage_ext_is_supported()) + return STORAGE_ERROR_NOT_SUPPORTED; + + dbus_handle_h dbus_handle = gdbus_get_connection(G_BUS_TYPE_SYSTEM, true); + if (dbus_handle == NULL) { + //LCOV_EXCL_START Dbus error + _E("Failed to get dbus connection"); + return STORAGE_ERROR_OPERATION_FAILED; + //LCOV_EXCL_STOP + } + + ret_dbus = gdbus_priv_call_sync_with_reply(dbus_handle, + STORAGE_EXT_BUS_NAME, STORAGE_EXT_PATH_MANAGER, STORAGE_EXT_IFACE_MANAGER, "GetMmcPrimary", - NULL); - if (!result) { + NULL, + &reply); + + gdbus_free_connection(dbus_handle); + + if (ret_dbus < 0) { //LCOV_EXCL_START System Error _E("Failed to get primary sdcard partition"); //LCOV_EXCL_LINE return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE //LCOV_EXCL_STOP } - g_variant_get(result, "(issssssisibii)", - &info.type, &info.devnode, &info.syspath, - &info.fs_usage, &info.fs_type, - &info.fs_version, &info.fs_uuid, - &info.readonly, &info.mount_point, - &info.state, &info.primary, - &info.flags, &info.storage_id); + if (!g_variant_get_safe(reply, "(issssssisibii)", + NULL, NULL, NULL, + NULL, NULL, + NULL, NULL, + NULL, &reply_mount_point, + NULL, NULL, + NULL, &reply_id)) { + //LCOV_EXCL_START Dbus error + g_variant_unref(reply); + return STORAGE_ERROR_OPERATION_FAILED; + //LCOV_EXCL_STOP + } + + g_variant_unref(reply); + + if (reply_id < 0) { + ret = STORAGE_ERROR_NO_DEVICE; + goto out; + } + + *path = strdup(reply_mount_point); + if (*path == NULL) { + ret = STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE System Error + goto out; //LCOV_EXCL_LINE System Error + } + + *storage_id = reply_id; + + ret = STORAGE_ERROR_NONE; +out: + g_free(reply_mount_point); - g_variant_unref(result); + return ret; +} + +//LCOV_EXCL_START Internal API +API int storage_get_storage_level(const char *path, char **level) +{ + int ret_level; - if (info.storage_id < 0) - return STORAGE_ERROR_NO_DEVICE; + if (!level || !path) + return STORAGE_ERROR_INVALID_PARAMETER; - *path = strdup(info.mount_point); - if (*path == NULL) + ret_level = storage_ext_get_storage_level(path, level); + if (ret_level == -ENOMEM) return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE System Error + else if (ret_level == -EINVAL) + return STORAGE_ERROR_INVALID_PARAMETER; + else if (ret_level < 0) + return STORAGE_ERROR_OPERATION_FAILED; + + return STORAGE_ERROR_NONE; +} +//LCOV_EXCL_STOP Internal API + +//LCOV_EXCL_START Not called callback +static void mount_mmc_cb(GVariant *var, void *user_data, GError *err) +{ + struct mmc_contents *mmc_data = (struct mmc_contents*)user_data; + int mmc_ret = -1; + + _D("mount_mmc_cb called"); + + if (!var) { + _E("no message [%s]", err->message); + mmc_ret = -EBADMSG; + goto exit; + } + + g_variant_get(var, "(i)", &mmc_ret); + + _I("Mount State : %d", mmc_ret); + +exit: + if (var) + g_variant_unref(var); + (mmc_data->mmc_cb)(mmc_ret, mmc_data->user_data); +} +//LCOV_EXCL_STOP + +//LCOV_EXCL_START Internal API +API int storage_request_mount_mmc(struct mmc_contents *mmc_data) +{ + void (*mount_cb)(GVariant *, void *, GError *) = NULL; + void *data = NULL; + char *path; + int ret_val; + int id; + + if (mmc_data && mmc_data->mmc_cb) { + _I("Mount callback exists"); + mount_cb = mount_mmc_cb; + data = mmc_data; + } + + ret_val = storage_get_primary_sdcard(&id, &path); + if (ret_val != STORAGE_ERROR_NONE) + return ret_val; + if (path) + free(path); + + ret_val = gdbus_call_async_with_reply(STORAGE_EXT_BUS_NAME, + STORAGE_EXT_PATH_MANAGER, + STORAGE_EXT_IFACE_MANAGER, + "Mount", + g_variant_new("(is)", id, ""), + mount_cb, + -1, + data); - *storage_id = info.storage_id; + _I("Mount Request %s", ret_val == 0 ? "Success" : "Failed"); + + if (ret_val == -ENOMEM) + return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE System Error + if (ret_val < 0) + return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE return STORAGE_ERROR_NONE; } +//LCOV_EXCL_STOP Internal API + +//LCOV_EXCL_START Not called callback +static void unmount_mmc_cb(GVariant *var, void *user_data, GError *err) +{ + struct mmc_contents *mmc_data = (struct mmc_contents*)user_data; + int mmc_ret; + + _D("unmount_mmc_cb called"); + + if (!var) { + _E("no message [%s]", err->message); + mmc_ret = -EBADMSG; + goto exit; + } + + g_variant_get(var, "(i)", &mmc_ret); + + _I("Unmount State : %d", mmc_ret); + +exit: + if (var) + g_variant_unref(var); + (mmc_data->mmc_cb)(mmc_ret, mmc_data->user_data); +} +//LCOV_EXCL_STOP -API int storage_get_storage_level(enum tzplatform_variable id, char **level) +//LCOV_EXCL_START Internal API +API int storage_request_unmount_mmc(struct mmc_contents *mmc_data, int option) { - int ret; + void (*unmount_cb)(GVariant *, void *, GError *) = NULL; + void *data = NULL; + char *path; + int ret_val; + int id; - if (!level) + if (option < 0 || option > 1) return STORAGE_ERROR_INVALID_PARAMETER; - if (id != TZ_SYS_USER || id != TZ_SYS_TMP || id != TZ_SYS_OPT) + if (mmc_data && mmc_data->mmc_cb) { + _I("Unmount callback exists"); + unmount_cb = unmount_mmc_cb; + data = mmc_data; + } + + ret_val = storage_get_primary_sdcard(&id, &path); + if (ret_val != STORAGE_ERROR_NONE) + return ret_val; + if (path) + free(path); + + ret_val = gdbus_call_async_with_reply(STORAGE_EXT_BUS_NAME, + STORAGE_EXT_PATH_MANAGER, + STORAGE_EXT_IFACE_MANAGER, + "Unmount", + g_variant_new("(ii)", id, option), + unmount_cb, + -1, + data); + + _I("Unmount Request %s", ret_val == 0 ? "Success" : "Failed"); + + if (ret_val == -ENOMEM) + return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE System Error + if (ret_val < 0) + return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE + + return STORAGE_ERROR_NONE; +} +//LCOV_EXCL_STOP + +//LCOV_EXCL_START Not called callback +static void format_mmc_cb(GVariant *var, void *user_data, GError *err) +{ + struct mmc_contents *mmc_data = (struct mmc_contents*)user_data; + int mmc_ret; + + _D("format_mmc_cb called"); + + if (!var) { + _E("no message [%s]", err->message); + mmc_ret = -EBADMSG; + goto exit; + } + + g_variant_get(var, "(i)", &mmc_ret); + + _I("Format State : %d", mmc_ret); + +exit: + if (var) + g_variant_unref(var); + (mmc_data->mmc_cb)(mmc_ret, mmc_data->user_data); +} +//LCOV_EXCL_STOP + +//LCOV_EXCL_START Internal API +API int storage_request_format_mmc(struct mmc_contents *mmc_data) +{ + return storage_format_mmc(mmc_data, 1); +} +//LCOV_EXCL_STOP + +//LCOV_EXCL_START Internal API +API int storage_format_mmc(struct mmc_contents *mmc_data, int option) +{ + void (*format_cb)(GVariant *, void *, GError *) = NULL; + void *data = NULL; + char *path; + int ret_val; + int id; + + if (option < 0 || option > 1) return STORAGE_ERROR_INVALID_PARAMETER; - ret = storage_ext_get_storage_level(id, level); - if (ret == -ENOMEM) + if (mmc_data && mmc_data->mmc_cb) { + _I("Format callback exists"); + format_cb = format_mmc_cb; + data = mmc_data; + } + + ret_val = storage_get_primary_sdcard(&id, &path); + if (ret_val != STORAGE_ERROR_NONE) + return ret_val; + if (path) + free(path); + + ret_val = gdbus_call_async_with_reply(STORAGE_EXT_BUS_NAME, + STORAGE_EXT_PATH_MANAGER, + STORAGE_EXT_IFACE_MANAGER, + "Format", + g_variant_new("(ii)", id, option), + format_cb, + FORMAT_TIMEOUT, + data); + + _I("Format Request %s", ret_val == 0 ? "Success" : "Failed"); + + if (ret_val == -ENOMEM) return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE System Error - else if (ret < 0) - return STORAGE_ERROR_OPERATION_FAILED; + if (ret_val < 0) + return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE + + return STORAGE_ERROR_NONE; +} +//LCOV_EXCL_STOP + +//LCOV_EXCL_START Internal API +API int storage_is_mounted_opt_usr(storage_part_mount_e *mounted) +{ + blkid_cache cache = NULL; + blkid_dev_iterate iter; + blkid_dev dev; + int ret_val; + bool found = false; + char *user_label = syscommon_is_container()? CONTAINER_USER_PARTITION: USER_PARTITION; + + if (!mounted) + return STORAGE_ERROR_INVALID_PARAMETER; + + _D("Find user partition label: %s", user_label); + ret_val = blkid_get_cache(&cache, NULL); + if (ret_val < 0) { + _E("Failed to get cache"); //LCOV_EXCL_LINE + *mounted = STORAGE_PART_ERROR; //LCOV_EXCL_LINE + return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE + } + + ret_val = blkid_probe_all(cache); + if (ret_val < 0) { + _E("Failed to probe all block devices"); //LCOV_EXCL_LINE + *mounted = STORAGE_PART_ERROR; //LCOV_EXCL_LINE + return STORAGE_ERROR_OPERATION_FAILED; //LCOV_EXCL_LINE + } + + iter = blkid_dev_iterate_begin(cache); + if (!iter) { + _E("Failed to get iterate"); //LCOV_EXCL_LINE + *mounted = STORAGE_PART_ERROR; //LCOV_EXCL_LINE + return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE + } + + ret_val = blkid_dev_set_search(iter, "LABEL", user_label); + if (blkid_dev_next(iter, &dev) == 0) { + dev = blkid_verify(cache, dev); + if (dev) { + found = true; + _D("Partition for user data is found(LABEL=%s)", user_label); + } + } + blkid_dev_iterate_end(iter); + + if (!found) { + iter = blkid_dev_iterate_begin(cache); + if (!iter) { + _E("Failed to get iterate"); //LCOV_EXCL_LINE + *mounted = STORAGE_PART_ERROR; //LCOV_EXCL_LINE + return STORAGE_ERROR_OUT_OF_MEMORY; //LCOV_EXCL_LINE + } + + ret_val = blkid_dev_set_search(iter, "PARTLABEL", user_label); + if (blkid_dev_next(iter, &dev) == 0) { + dev = blkid_verify(cache, dev); + if (dev) { + found = true; + _D("Partition for user data is found(PARTLABEL=%s)", user_label); + } + } + blkid_dev_iterate_end(iter); + } + + blkid_put_cache(cache); + + if (found) { + ret_val = mount_check(tzplatform_getenv(TZ_SYS_USER)); + if (ret_val) + *mounted = STORAGE_PART_MOUNTED; + else + *mounted = STORAGE_PART_NOT_MOUNTED; + } else + *mounted = STORAGE_PART_NOT_SUPPORTED; return STORAGE_ERROR_NONE; } +//LCOV_EXCL_STOP