#define MEDIA_SVC_MAX_COMMIT_SIZE 200
-static __thread GList *g_media_svc_item_validity_query_list = NULL;
-static __thread GList *g_media_svc_insert_item_query_list = NULL;
-static __thread GList *g_media_svc_update_item_query_list = NULL;
+static __thread GList *g_media_svc_scanner_query_list = NULL;
static __thread GList *g_media_svc_update_list = NULL;
int _media_svc_count_record_with_path(sqlite3 *handle, const char *path, int *count)
media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "failed to insert item");
} else {
media_svc_sec_debug("Query[%s]", sql);
- _media_svc_sql_query_add(&g_media_svc_insert_item_query_list, &sql);
+ _media_svc_sql_query_add(&g_media_svc_scanner_query_list, &sql);
}
return MS_MEDIA_ERR_NONE;
if (sql != NULL) {
media_svc_debug("query[%s]", sql);
- _media_svc_sql_query_add(&g_media_svc_update_item_query_list, &sql);
+ _media_svc_sql_query_add(&g_media_svc_scanner_query_list, &sql);
} else {
media_svc_error("sqlite3_mprintf failed");
ret = MS_MEDIA_ERR_OUT_OF_MEMORY;
/* Scanner use only batch insert */
if (is_direct) {
media_svc_sec_debug("Query [%s]", sql);
- _media_svc_sql_query_add(&g_media_svc_insert_item_query_list, &sql);
+ _media_svc_sql_query_add(&g_media_svc_scanner_query_list, &sql);
} else {
ret = _media_svc_sql_query(sql, uid);
SQLITE3_SAFE_FREE(sql);
ret = _media_svc_sql_query_direct(sql, uid);
SQLITE3_SAFE_FREE(sql);
} else {
- _media_svc_sql_query_add(&g_media_svc_item_validity_query_list, &sql);
+ _media_svc_sql_query_add(&g_media_svc_scanner_query_list, &sql);
}
return ret;
ret = _media_svc_sql_query_list(&g_media_svc_update_list, uid);
break;
- case MEDIA_SVC_QUERY_SET_ITEM_VALIDITY:
- ret = _media_svc_sql_query_list_direct(&g_media_svc_item_validity_query_list, uid);
- break;
- case MEDIA_SVC_QUERY_INSERT_ITEM:
- ret = _media_svc_sql_query_list_direct(&g_media_svc_insert_item_query_list, uid);
- break;
- case MEDIA_SVC_QUERY_UPDATE_ITEM:
- ret = _media_svc_sql_query_list_direct(&g_media_svc_update_item_query_list, uid);
+ case MEDIA_SVC_QUERY_SCANNER:
+ ret = _media_svc_sql_query_list_direct(&g_media_svc_scanner_query_list, uid);
break;
default:
media_svc_error("Wrong type[%d]", query_type);
#include "media-svc-noti.h"
#include "media-svc-storage.h"
-static __thread int g_media_svc_item_validity_data_cnt = 0;
-static __thread int g_media_svc_item_validity_cur_data_cnt = 0;
-
-static __thread int g_media_svc_insert_item_data_cnt = 0;
-static __thread int g_media_svc_insert_item_cur_data_cnt = 0;
+static __thread int g_media_svc_data_cnt = 0;
+static __thread int g_media_svc_cur_data_cnt = 0;
/* Flag for items to be published by notification */
static __thread bool g_insert_with_noti = false;
{
media_svc_retvm_if(data_cnt < 1, MS_MEDIA_ERR_INVALID_PARAMETER, "data_cnt shuld be bigger than 1");
- g_media_svc_insert_item_data_cnt = data_cnt;
- g_media_svc_insert_item_cur_data_cnt = 0;
+ g_media_svc_data_cnt = data_cnt;
+ g_media_svc_cur_data_cnt = 0;
/* Prepare for making noti item list */
if (with_noti) {
media_svc_debug_fenter();
- if (g_media_svc_insert_item_cur_data_cnt > 0) {
- ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_INSERT_ITEM, uid);
+ if (g_media_svc_cur_data_cnt > 0) {
+ ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SCANNER, uid);
if (g_insert_with_noti) {
media_svc_debug("sending noti list");
_media_svc_publish_noti_list();
}
}
- g_media_svc_insert_item_data_cnt = 0;
- g_media_svc_insert_item_cur_data_cnt = 0;
+ g_media_svc_data_cnt = 0;
+ g_media_svc_cur_data_cnt = 0;
return ret;
}
if (g_insert_with_noti)
_media_svc_insert_item_to_noti_list(&content_info);
- if (++g_media_svc_insert_item_cur_data_cnt == g_media_svc_insert_item_data_cnt) {
- ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_INSERT_ITEM, uid);
+ if (++g_media_svc_cur_data_cnt == g_media_svc_data_cnt) {
+ ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SCANNER, uid);
media_svc_retv_del_if(ret != MS_MEDIA_ERR_NONE, ret, &content_info);
if (g_insert_with_noti) {
_media_svc_initialize_noti_list();
}
- g_media_svc_insert_item_cur_data_cnt = 0;
+ g_media_svc_cur_data_cnt = 0;
}
_media_svc_destroy_content_info(&content_info);
return MS_MEDIA_ERR_NONE;
}
-int media_svc_set_item_validity_begin(int data_cnt)
-{
- media_svc_debug("Transaction data count : [%d]", data_cnt);
-
- media_svc_retvm_if(data_cnt < 1, MS_MEDIA_ERR_INVALID_PARAMETER, "data_cnt shuld be bigger than 1");
-
- g_media_svc_item_validity_data_cnt = data_cnt;
- g_media_svc_item_validity_cur_data_cnt = 0;
-
- return MS_MEDIA_ERR_NONE;
-}
-
-int media_svc_set_item_validity_end(uid_t uid)
-{
- int ret = MS_MEDIA_ERR_NONE;
-
- media_svc_debug_fenter();
-
- if (g_media_svc_item_validity_cur_data_cnt > 0)
- ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SET_ITEM_VALIDITY, uid);
-
- g_media_svc_item_validity_data_cnt = 0;
- g_media_svc_item_validity_cur_data_cnt = 0;
-
- return ret;
-}
-
int media_svc_set_item_validity(const char *path, int validity, uid_t uid)
{
int ret = MS_MEDIA_ERR_NONE;
ret = _media_svc_update_item_validity(path, validity, true, uid);
media_svc_retv_if(ret != MS_MEDIA_ERR_NONE, ret);
- if (++g_media_svc_item_validity_cur_data_cnt == g_media_svc_item_validity_data_cnt) {
- ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SET_ITEM_VALIDITY, uid);
+ if (++g_media_svc_cur_data_cnt == g_media_svc_data_cnt) {
+ ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SCANNER, uid);
media_svc_retv_if(ret != MS_MEDIA_ERR_NONE, ret);
- g_media_svc_item_validity_cur_data_cnt = 0;
+ g_media_svc_cur_data_cnt = 0;
}
return ret;
g_ptr_array_free(path_list, TRUE);
- ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_UPDATE_ITEM, uid);
+ ret = _media_svc_list_query_do(MEDIA_SVC_QUERY_SCANNER, uid);
media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "_media_svc_list_query_do failed");
/* Noti for this */