Add retry logic to all DB query execsubmit/tizen_2.1/20130516.133656accepted/tizen_2.1/20130520.093228tizen_2.1

Change-Id: I450aa2f1e5b368da634753ca046a542f13c4e884

1 files changed, 66 insertions, 7 deletions

diff --git a/native/ctsvc_sqlite.c b/native/ctsvc_sqlite.c
index e511911..fc912f8 100755
--- a/native/ctsvc_sqlite.c
+++ b/native/ctsvc_sqlite.c
@@ -38,6 +38,8 @@
 #include "ctsvc_phonelog.h"
 #include "ctsvc_person.h"
 
+#define CTSVC_QUERY_RETRY_TIME	2
+
 static __thread sqlite3 *ctsvc_db = NULL;
 
 static inline int __ctsvc_db_busyhandler(void *pData, int count)
@@ -135,14 +137,52 @@ int cts_db_get_next_id(const char *table) {
 
 int ctsvc_query_get_first_int_result(const char *query, int *result) {
 	int ret;
+	struct timeval from, now, diff;
+	bool retry = false;
 	cts_stmt stmt = NULL;
 	RETVM_IF(NULL == ctsvc_db, CONTACTS_ERROR_DB /*CTS_ERR_DB_NOT_OPENED*/, "DB error : Database is not opended");
 
-	ret = sqlite3_prepare_v2(ctsvc_db, query, strlen(query), &stmt, NULL);
-	RETVM_IF(SQLITE_OK != ret, CONTACTS_ERROR_DB,
-			"DB error : sqlite3_prepare_v2(%s) Failed(%s)", query, sqlite3_errmsg(ctsvc_db));
+	gettimeofday(&from, NULL);
+	do {
+		ret = sqlite3_prepare_v2(ctsvc_db, query, strlen(query), &stmt, NULL);
+
+		if (ret != SQLITE_OK)
+			CTS_ERR("DB error : sqlite3_prepare_v2() Failed(%d, %s)", ret, sqlite3_errmsg(ctsvc_db));
+
+		if (ret == SQLITE_BUSY || ret == SQLITE_LOCKED) {
+			gettimeofday(&now, NULL);
+			timersub(&now, &from, &diff);
+			retry = (diff.tv_sec < CTSVC_QUERY_RETRY_TIME)? true:false;
+			if (retry)
+				usleep(50*1000); // 50 ms
+		} else
+			retry = false;
+	}while(retry);
+
+	if (SQLITE_OK != ret) {
+		CTS_ERR("DB error : sqlite3_prepare_v2(%s) Failed(%s)", query, sqlite3_errmsg(ctsvc_db));
+		return CONTACTS_ERROR_DB;
+	}
+
+	retry = false;
+	gettimeofday(&from, NULL);
+	do {
+		ret = sqlite3_step(stmt);
+
+		if (ret != SQLITE_ROW)
+			CTS_ERR("DB error : sqlite3_step() Failed(%d, %s)", ret, sqlite3_errmsg(ctsvc_db));
+
+		if (ret == SQLITE_BUSY || ret == SQLITE_LOCKED) {
+			gettimeofday(&now, NULL);
+			timersub(&now, &from, &diff);
+			retry = (diff.tv_sec < CTSVC_QUERY_RETRY_TIME)? true:false;
+			if (retry)
+				usleep(50*1000); // 50 ms
+		}
+		else
+			retry = false;
+	}while(retry);
 
-	ret = sqlite3_step(stmt);
 	if (SQLITE_ROW != ret) {
 		sqlite3_finalize(stmt);
 		CTS_DBG("query : %s", query);
@@ -163,12 +203,31 @@ int ctsvc_query_get_first_int_result(const char *query, int *result) {
 
 int ctsvc_query_exec(const char *query) {
 	int ret;
+	struct timeval from, now, diff;
+	bool retry = false;
 	char *err_msg = NULL;
 
 	RETVM_IF(NULL == ctsvc_db, CONTACTS_ERROR_DB /*CTS_ERR_DB_NOT_OPENED*/, "DB error : Database is not opended");
 	CTS_DBG("query : %s", query);
 
-	ret = sqlite3_exec(ctsvc_db, query, NULL, NULL, &err_msg);
+	gettimeofday(&from, NULL);
+	do {
+		ret = sqlite3_exec(ctsvc_db, query, NULL, NULL, &err_msg);
+
+		if (ret != SQLITE_OK)
+			CTS_ERR("DB error : sqlite3_exec() Failed(%d, %s)", ret, sqlite3_errmsg(ctsvc_db));
+
+		if (ret == SQLITE_BUSY || ret == SQLITE_LOCKED) {
+			gettimeofday(&now, NULL);
+			timersub(&now, &from, &diff);
+			retry = (diff.tv_sec < CTSVC_QUERY_RETRY_TIME)? true:false;
+			if (retry)
+				usleep(50*1000); // 50 ms
+		}
+		else
+			retry = false;
+	} while(retry);
+
 	if (SQLITE_OK != ret) {
 		CTS_ERR("sqlite3_exec(%s) Failed(%d, %s)", query, ret, err_msg);
 		sqlite3_free(err_msg);
@@ -207,7 +266,7 @@ cts_stmt cts_query_prepare(char *query) {
 		if (ret == SQLITE_BUSY || ret == SQLITE_LOCKED) {
 			gettimeofday(&now, NULL);
 			timersub(&now, &from, &diff);
-			retry = (diff.tv_sec < 2)? true:false; // retry it during 2 second
+			retry = (diff.tv_sec < CTSVC_QUERY_RETRY_TIME)? true:false;
 			if (retry)
 				usleep(50*1000); // 50 ms
 		} else
@@ -251,7 +310,7 @@ int cts_stmt_step(cts_stmt stmt) {
 		if (ret == SQLITE_BUSY || ret == SQLITE_LOCKED) {
 			gettimeofday(&now, NULL);
 			timersub(&now, &from, &diff);
-			retry = (diff.tv_sec < 1)? true:false; // retry it during 1 second
+			retry = (diff.tv_sec < CTSVC_QUERY_RETRY_TIME)? true:false;
 			if (retry)
 				usleep(50*1000); // 50 ms
 		}