X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fmedia_content.c;h=24907483f591a5504348e49180b7c7d68a88fac6;hb=refs%2Fchanges%2F30%2F304030%2F2;hp=bc96f35a1a48c654904296bc5bb59fce3edc2968;hpb=4930f2cdfd845fc59941eb475b031c829bce73bd;p=platform%2Fcore%2Fapi%2Fmedia-content.git diff --git a/src/media_content.c b/src/media_content.c index bc96f35..2490748 100644 --- a/src/media_content.c +++ b/src/media_content.c @@ -14,9 +14,10 @@ * limitations under the License. */ - #include #include +#include +#include static sqlite3 *db_handle = NULL; static int ref_count = 0; @@ -41,7 +42,7 @@ int _content_query_prepare(const char *select_query, const char *condition_query int ret = MEDIA_CONTENT_ERROR_NONE; char *query = NULL; - content_retvm_if(!STRING_VALID(select_query), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "invalid select_query"); + content_retip_if_fail(select_query); /* If 'option_query' is NULL, 'condition_query' is also NULL. */ if (option_query) { @@ -64,8 +65,8 @@ int _content_get_result(char *query, sqlite3_stmt **stmt) { int err = MEDIA_CONTENT_ERROR_NONE; - content_retvm_if(_content_get_db_handle() == NULL, MEDIA_CONTENT_ERROR_DB_FAILED, "database is not connected"); - content_retvm_if(!STRING_VALID(query), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "invalid query"); + content_retip_if_fail(_content_get_db_handle()); + content_retip_if_fail(query); content_sec_debug("Query[%s]", query); @@ -83,62 +84,6 @@ int _content_get_result(char *query, sqlite3_stmt **stmt) return MEDIA_CONTENT_ERROR_NONE; } -#ifdef _USE_SENIOR_MODE -int _content_query_prepare_by_union_select(sqlite3_stmt **stmt, char *select_query1, char *condition_query1, char *option_query1, char *select_query2, char *condition_query2, char *option_query2) -{ - int len = 0; - int err = MEDIA_CONTENT_ERROR_NONE; - char query[MAX_QUERY_SIZE] = {0, }; - - content_retvm_if(_content_get_db_handle() == NULL, MEDIA_CONTENT_ERROR_DB_FAILED, "database is not connected"); - content_retvm_if(!STRING_VALID(select_query1), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "invalid select_query1"); - content_retvm_if(!STRING_VALID(select_query2), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "invalid select_query2"); - - if (!STRING_VALID(condition_query1)) - condition_query1 = (char *)" "; - - if (!STRING_VALID(option_query1)) - option_query1 = (char *)" "; - - if (!STRING_VALID(condition_query2)) - condition_query2 = (char *)" "; - - if (!STRING_VALID(option_query2)) - option_query2 = (char *)" "; - - len = snprintf(query, sizeof(query), "SELECT * FROM (%s %s %s) as table1 UNION ALL SELECT * FROM (%s %s %s) as table2", - select_query1, condition_query1, option_query1, select_query2, condition_query2, option_query2); - if (len > 0 && len < sizeof(query)) { - query[len] = '\0'; - } else if (len >= sizeof(query)) { - query[MAX_QUERY_SIZE -1] = '\0'; - } else { - content_error("snprintf failed"); - return MEDIA_CONTENT_ERROR_INVALID_PARAMETER; - } - - content_sec_debug("Query : [%s]", query); - - err = sqlite3_prepare_v2(_content_get_db_handle(), query, strlen(query), stmt, NULL); - if (err != SQLITE_OK) { - content_error("DB_FAILED(0x%08x) fail to sqlite3_prepare(), %s", MEDIA_CONTENT_ERROR_DB_FAILED, sqlite3_errmsg(_content_get_db_handle())); - - if (err == SQLITE_BUSY) { - content_error(" BUSY ERROR"); - return MEDIA_CONTENT_ERROR_DB_BUSY; - } else if (err == SQLITE_PERM) { - content_error("PERMISSION EROR"); - return MEDIA_CONTENT_ERROR_PERMISSION_DENIED; - } else { - content_error("OTHER ERROR"); - return MEDIA_CONTENT_ERROR_DB_FAILED; - } - } - - return MEDIA_CONTENT_ERROR_NONE; -} -#endif - int _content_error_capi(int internal_error) { if (internal_error == MS_MEDIA_ERR_NONE) @@ -164,7 +109,6 @@ int _content_error_capi(int internal_error) return MEDIA_CONTENT_ERROR_NETWORK; case MS_MEDIA_ERR_PERMISSION_DENIED: return MEDIA_CONTENT_ERROR_PERMISSION_DENIED; - case MS_MEDIA_ERR_THUMB_TOO_BIG: case MS_MEDIA_ERR_THUMB_UNSUPPORTED: return MEDIA_CONTENT_ERROR_UNSUPPORTED_CONTENT; default: @@ -251,47 +195,45 @@ int media_content_scan_file(const char *path) char *folder_path = NULL; int check_file = MEDIA_CONTENT_ERROR_NONE; char storage_id[MEDIA_CONTENT_UUID_SIZE+1] = {0,}; - char repl_path[MAX_PATH_LEN] = {0,}; - content_retvm_if(!STRING_VALID(path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "invalid path"); + content_retip_if_fail(STRING_VALID(path)); content_sec_debug("Path : %s", path); - ret = _media_content_replace_path(path, repl_path); - content_retvm_if(!STRING_VALID(repl_path), MEDIA_CONTENT_ERROR_INVALID_OPERATION, "path replacement failed"); + content_retvm_if(_media_util_is_ignorable_file(path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid path"); - content_retvm_if(_media_util_is_ignorable_file(repl_path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid path"); - - ret = media_svc_get_storage_id(_content_get_db_handle(), repl_path, storage_id, _content_get_uid()); + ret = media_svc_get_storage_id(_content_get_db_handle(), path, storage_id, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { content_error("media_svc_get_storage_id failed : %d", ret); return _content_error_capi(ret); } - check_file = _media_util_check_file_exist(repl_path); + check_file = _media_util_check_file_exist(path); if (check_file == MEDIA_CONTENT_ERROR_NONE) { /* This means this path has to be inserted or refreshed */ - folder_path = g_path_get_dirname(repl_path); + folder_path = g_path_get_dirname(path); if (_media_util_is_ignorable_dir(folder_path)) { g_free(folder_path); return MEDIA_CONTENT_ERROR_INVALID_PARAMETER; } + g_free(folder_path); + /* check feature */ - content_retvm_if(!_media_util_check_support_media_type(repl_path), MEDIA_CONTENT_ERROR_NOT_SUPPORTED, "Unsupported media type"); + content_retvm_if(!_media_util_check_support_media_type(path), MEDIA_CONTENT_ERROR_NOT_SUPPORTED, "Unsupported media type"); ms_user_storage_type_e storage_type; - ret = ms_user_get_storage_type(_content_get_uid(), repl_path, &storage_type); + ret = ms_user_get_storage_type(_content_get_uid(), path, &storage_type); if (ret != MS_MEDIA_ERR_NONE) { - content_sec_error("ms_user_get_storage_type failed : %d (%s)", ret, repl_path); + content_sec_error("ms_user_get_storage_type failed : %d (%s)", ret, path); return _content_error_capi(ret); } - ret = media_svc_check_item_exist_by_path(_content_get_db_handle(), storage_id, repl_path); + ret = media_svc_check_item_exist_by_path(_content_get_db_handle(), storage_id, path); if (ret == MS_MEDIA_ERR_NONE) { /* Refresh */ - ret = media_svc_refresh_item(_content_get_db_handle(), false, storage_id, storage_type, repl_path, _content_get_uid()); + ret = media_svc_refresh_item(_content_get_db_handle(), false, storage_id, storage_type, path, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { content_error("media_svc_refresh_item failed : %d", ret); return _content_error_capi(ret); @@ -299,13 +241,13 @@ int media_content_scan_file(const char *path) } else if (ret == MS_MEDIA_ERR_DB_NO_RECORD) { /* Insert */ - ret = media_svc_insert_item_immediately(_content_get_db_handle(), storage_id, storage_type, repl_path, _content_get_uid()); + ret = media_svc_insert_item_immediately(_content_get_db_handle(), storage_id, storage_type, path, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { if (ret == MS_MEDIA_ERR_DB_CONSTRAINT_FAIL) { - content_sec_error("This item is already inserted. This may be normal operation because other process already did this (%s)", repl_path); + content_sec_error("This item is already inserted. This may be normal operation because other process already did this (%s)", path); ret = MEDIA_CONTENT_ERROR_NONE; } else { - content_sec_error("media_svc_insert_item_immediately failed : %d (%s)", ret, repl_path); + content_sec_error("media_svc_insert_item_immediately failed : %d (%s)", ret, path); } return _content_error_capi(ret); @@ -320,7 +262,7 @@ int media_content_scan_file(const char *path) } else { /* This means this path has to be deleted */ content_debug("This path doesn't exists in file system... So now start to delete it from DB"); - ret = media_svc_delete_item_by_path(_content_get_db_handle(), storage_id, repl_path, _content_get_uid()); + ret = media_svc_delete_item_by_path(_content_get_db_handle(), storage_id, path, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { if (ret == MS_MEDIA_ERR_DB_NO_RECORD) { content_error("Does not exist in media DB also... So, this is an invalid parameter"); @@ -403,34 +345,30 @@ int media_content_scan_folder(const char *path, bool is_recursive, media_scan_co { int ret = MEDIA_CONTENT_ERROR_NONE; char storage_id[MEDIA_CONTENT_UUID_SIZE+1] = {0, }; - char repl_path[MAX_PATH_LEN] = {0, }; ms_user_storage_type_e storage_type = MS_USER_STORAGE_INTERNAL; content_retip_if_fail(STRING_VALID(path)); content_retip_if_fail(callback); - ret = _media_content_replace_path(path, repl_path); - content_retvm_if(!STRING_VALID(repl_path), MEDIA_CONTENT_ERROR_INVALID_OPERATION, "path replacement failed"); - - ret = _media_content_check_dir(repl_path); + ret = _media_content_check_dir(path); content_retvm_if(ret == MEDIA_CONTENT_ERROR_PERMISSION_DENIED, ret, "Permission Denied"); if (ret == MEDIA_CONTENT_ERROR_NONE) { /* If directory exist check that's ignore directory or not*/ - content_retvm_if(_media_util_is_ignorable_dir(repl_path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid folder path"); + content_retvm_if(_media_util_is_ignorable_dir(path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid folder path"); } else { /* This means this folder has to be deleted */ /* Or, it is real invalid path.. check storage type */ - ret = ms_user_get_storage_type(_content_get_uid(), repl_path, &storage_type); + ret = ms_user_get_storage_type(_content_get_uid(), path, &storage_type); if (ret != MS_MEDIA_ERR_NONE) { - content_sec_error("ms_user_get_storage_type failed : %d (%s)", ret, repl_path); + content_sec_error("ms_user_get_storage_type failed : %d (%s)", ret, path); return _content_error_capi(ret); } content_debug("This path doesn't exists in file system... So will be deleted it from DB"); } - ret = media_svc_get_storage_id(_content_get_db_handle(), repl_path, storage_id, _content_get_uid()); + ret = media_svc_get_storage_id(_content_get_db_handle(), path, storage_id, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { content_error("media_svc_get_storage_id failed : %d", ret); return _content_error_capi(ret); @@ -442,7 +380,7 @@ int media_content_scan_folder(const char *path, bool is_recursive, media_scan_co cb_data->callback = callback; cb_data->user_data = user_data; - ret = media_directory_scanning_async(repl_path, storage_id, is_recursive, _media_content_scan_cb, cb_data, _content_get_uid()); + ret = media_directory_scanning_async(path, storage_id, is_recursive, _media_content_scan_cb, cb_data, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) { content_error("media_directory_scanning_async failed : %d", ret); g_free(cb_data); @@ -452,6 +390,42 @@ int media_content_scan_folder(const char *path, bool is_recursive, media_scan_co } #ifdef _USE_TVPD_MODE +bool _is_mounted(const char *dir_path) +{ + bool ret = false; + char mount_path[MAX_PATH_LEN] = {0,}; + char root_path[MAX_PATH_LEN] = {0,}; + struct mntent *mnt; + const char *table = "/etc/mtab"; + FILE *fp; + + snprintf(root_path, MAX_PATH_LEN, "%s%s", tzplatform_getenv(TZ_SYS_STORAGE), "/USBDrive"); + if (!g_str_has_prefix(dir_path, root_path)) + return true; + + char *p = strstr(dir_path + strlen(root_path), "/"); + if(p && p - dir_path < MAX_PATH_LEN) + strncpy(mount_path, dir_path, p - dir_path); + else + snprintf(mount_path, MAX_PATH_LEN, "%s", dir_path); + + fp = setmntent(table, "r"); + if (!fp) { + content_error("open /etc/mtab failed"); + return false; + } + while ((mnt = getmntent(fp))) { + if (!strncmp(mnt->mnt_dir, mount_path, strlen(mount_path))) { + ret = true; + break; + } + } + endmntent(fp); + + content_error("[NO ERROR] dir_path[%s] mount_path[%s] ret[%d]", dir_path, mount_path, ret); + return ret; +} + int media_content_scan_folder_v2(const char *path, bool is_recursive, media_scan_completed_cb_v2 callback, void *user_data) { int ret = MEDIA_CONTENT_ERROR_NONE; @@ -460,6 +434,7 @@ int media_content_scan_folder_v2(const char *path, bool is_recursive, media_scan content_retip_if_fail(STRING_VALID(path)); content_retip_if_fail(callback); + content_retvm_if(!_is_mounted(path), MEDIA_CONTENT_ERROR_PERMISSION_DENIED, "path is not mounted"); content_retvm_if(_media_util_is_ignorable_dir(path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid folder path"); ret = _media_content_check_dir(path); @@ -486,14 +461,10 @@ int media_content_scan_folder_v2(const char *path, bool is_recursive, media_scan int media_content_cancel_scan_folder(const char *path) { int ret = MEDIA_CONTENT_ERROR_NONE; - char repl_path[MAX_PATH_LEN] = {0, }; - - content_retvm_if(!STRING_VALID(path), MEDIA_CONTENT_ERROR_INVALID_PARAMETER, "Invalid path"); - ret = _media_content_replace_path(path, repl_path); - content_retvm_if(!STRING_VALID(repl_path), MEDIA_CONTENT_ERROR_INVALID_OPERATION, "path replacement failed"); + content_retip_if_fail(STRING_VALID(path)); - ret = media_directory_scanning_cancel(repl_path, _content_get_uid()); + ret = media_directory_scanning_cancel(path, _content_get_uid()); if (ret != MS_MEDIA_ERR_NONE) content_error("media_directory_scanning_async failed : %d", ret); @@ -545,15 +516,6 @@ int media_content_add_db_updated_cb(media_content_db_update_cb callback, void *u return _content_error_capi(ret); } -#ifdef TIZEN_FEATURE_COMPATIBILITY -int media_content_set_db_updated_cb(media_content_db_update_cb callback, void *user_data) -{ - content_warn("DEPRECATION WARNING: media_content_set_db_updated_cb() is removed from 5.0."); - - return MEDIA_CONTENT_ERROR_NONE; -} -#endif - int media_content_remove_db_updated_cb(media_content_noti_h noti_handle) { int ret = MEDIA_CONTENT_ERROR_NONE;