#define MS_STRING_VALID(str) ((str != NULL && strlen(str) > 0) ? true : false)
#define SAFE_STRLCPY(dst, src, n) g_strlcpy(dst, src, n);
-int media_db_update_db(sqlite3 *handle, const char *query_str);
-
#endif /*_MEDIA_UTIL_INTERNAL_H_*/
return ret;
}
-int media_db_update_db(sqlite3 *handle, const char *query_str)
-{
- MSAPI_RETVM_IF(handle == NULL, MS_MEDIA_ERR_INVALID_PARAMETER, "Handle is NULL");
- MSAPI_RETVM_IF(!MS_STRING_VALID(query_str), MS_MEDIA_ERR_INVALID_PARAMETER, "Invalid Query");
-
- return __media_db_update_directly(handle, query_str);
-}
-
static int __media_db_request_recovery(uid_t uid)
{
int ret = MS_MEDIA_ERR_NONE;
GSource *source = NULL;
GIOChannel *channel = NULL;
GMainContext *context = NULL;
- sqlite3 *db_handle = NULL;
/* Create TCP Socket*/
ret = ms_ipc_create_server_socket(MS_DB_UPDATE_PORT, &sockfd);
g_io_channel_unref(channel);
/* Set callback to be called when socket is readable */
- g_source_set_callback(source, (GSourceFunc)ms_read_db_tcp_socket, db_handle, NULL);
+ g_source_set_callback(source, (GSourceFunc)ms_read_db_tcp_socket, NULL, NULL);
g_db_source_id = g_source_attach(source, context);
g_source_unref(source);
int client_sock = -1;
ms_comm_msg_s recv_msg;
int ret = MS_MEDIA_ERR_NONE;
- sqlite3 *db_handle = (sqlite3 *)data;
ms_peer_credentials creds;
MS_DBG_RETVM_IF(power_off, G_SOURCE_CONTINUE, "POWER OFF");
goto ERROR;
}
- ret = media_db_connect(&db_handle, recv_msg.uid, true);
- if (ret != MS_MEDIA_ERR_NONE) {
- MS_DBG_ERR("Failed to connect DB");
- goto ERROR;
- }
-
- if (MS_STRING_VALID(recv_msg.msg)) {
- ret = media_db_update_db(db_handle, recv_msg.msg);
- if (ret != MS_MEDIA_ERR_NONE)
- MS_DBG_ERR("media_db_update_db error : %d", ret);
- } else {
- ret = MS_MEDIA_ERR_INVALID_PARAMETER;
- }
-
- media_db_disconnect(db_handle);
+ ret = media_db_update_db_direct(recv_msg.msg, recv_msg.uid);
ERROR:
if (write(client_sock, &ret, sizeof(ret)) != sizeof(ret))