}
-//Test method
-/*
-static void
-bndl_iterator_test(const char* pKey, const char* pVal, void* pData)
-{
- LOG_LOGD("SyncJobQueue sync extra key %s val %s", pKey, pVal);
-}
-*/
-
-
+/* LCOV_EXCL_START */
void
RepositoryEngine::CheckSyncJobsData(void) {
LOG_LOGD("Verifying Sync jobs");
doc = xmlParseFile(pDocName);
if (doc == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Failed to parse syncjobs.xml");
doc = xmlParseFile(pDocName);
- /* LCOV_EXCL_STOP */
}
cur = xmlDocGetRootElement(doc);
if (cur == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncjobs.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
}
/* Parse sync jobs */
if (xmlStrcmp(cur->name, XML_NODE_JOBS)) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncjobs.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
} else {
xmlChar* pTotalJobsCount = xmlGetProp(cur, XML_ATTR_JOBS_COUNT);
int totalcount = (pTotalJobsCount == NULL) ? 0 : atoi((char*)pTotalJobsCount);
}
}
}
+/* LCOV_EXCL_STOP */
bool
}
+/* LCOV_EXCL_START */
static void
RemoveLegacySyncData(const char *pCommandLine) {
char cmd[128];
else
LOG_LOGD("rm %s : failed", cmd);
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
void
RepositoryEngine::ReadSyncJobsData(void) {
LOG_LOGD("Reading Sync jobs");
doc = xmlParseFile(pDocName);
if (doc == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Failed to parse syncjobs.xml");
doc = xmlParseFile(pDocName);
- /* LCOV_EXCL_STOP */
}
cur = xmlDocGetRootElement(doc);
if (cur == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncjobs.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
}
/* Parse sync jobs */
if (xmlStrcmp(cur->name, XML_NODE_JOBS)) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncjobs.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
} else {
xmlChar* pTotalJobsCount = xmlGetProp(cur, XML_ATTR_JOBS_COUNT);
int totalcount = (pTotalJobsCount == NULL) ? 0 : atoi((char*)pTotalJobsCount);
cur = cur->xmlChildrenNode;
while (cur != NULL) {
- /* LCOV_EXCL_START */
if (!xmlStrcmp(cur->name, XML_NODE_PACKAGE)) {
xmlChar* pPackageId;
xmlChar* pJobsCount;
}
}
cur = cur->next;
- /* LCOV_EXCL_STOP */
}
}
RemoveLegacySyncData(PATH_SYNCJOBS);
RemoveLegacySyncData(PATH_SYNCDIR);
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
void
RepositoryEngine::ReadSyncAdapters(void) {
LOG_LOGD("Reading sync adapters");
doc = xmlParseFile(pDocName);
if (doc == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Failed to parse syncadapters.xml");
doc = xmlParseFile(pDocName);
- /* LCOV_EXCL_STOP */
}
cur = xmlDocGetRootElement(doc);
if (cur == NULL) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncadapters.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
}
/* Parse sync jobs */
if (xmlStrcmp(cur->name, XML_NODE_SYNCADAPTERS)) {
- /* LCOV_EXCL_START */
LOG_LOGD("Found empty document while parsing syncadapters.xml");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
} else {
xmlChar* pSACount;
pSACount = xmlGetProp(cur, XML_ATTR_COUNT);
int ret = xmlSaveFormatFileEnc(PATH_SYNCADAPTERS, doc, "UTF-8", 1);
if (ret < 0)
- LOG_LOGD("Failed to write sync adapter data, error [%d]", ret); /* LCOV_EXCL_LINE */
+ LOG_LOGD("Failed to write sync adapter data, error [%d]", ret);
xmlFreeDoc(doc);
xmlCleanupParser();
RemoveLegacySyncData(PATH_SYNCADAPTERS);
}
+/* LCOV_EXCL_STOP */
/* LCOV_EXCL_START */
/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
void
RepositoryEngine::WriteSyncJobsData(void) {
LOG_LOGD("Writing sync jobs");
map<string, SyncJobsInfo*>::iterator itr = syncJobs.begin();
while (itr != syncJobs.end()) {
- /* LCOV_EXCL_START */
string package = itr->first;
SyncJobsInfo* pJobsInfo = itr->second;
}
}
itr++;
- /* LCOV_EXCL_STOP */
}
int ret = xmlSaveFormatFileEnc(PATH_SYNCJOBS, doc, "UTF-8" , 1);
if (ret < 0) {
- LOG_LOGD("Failed to write account data, error [%d], errno [%d]", ret, errno); /* LCOV_EXCL_LINE */
+ LOG_LOGD("Failed to write account data, error [%d], errno [%d]", ret, errno);
}
xmlFreeDoc(doc);
xmlCleanupParser();
LOG_LOGD("Ends");
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
void
RepositoryEngine::WriteSyncAdapters(void) {
LOG_LOGD("Writing sync adapters");
SyncAdapterAggregator* pAggregator = SyncManager::GetInstance()->GetSyncAdapterAggregator();
if (!pAggregator) {
- /* LCOV_EXCL_START */
LOG_LOGD("Failed to get sync adapter aggregator, skip writing to file");
xmlFreeDoc(doc);
return;
- /* LCOV_EXCL_STOP */
}
ss << pAggregator->__syncAdapterList.size();
int ret = xmlSaveFormatFileEnc(PATH_SYNCADAPTERS, doc, "UTF-8", 1);
if (ret < 0) {
- LOG_LOGD("Failed to write sync adapter data, error [%d]", ret); /* LCOV_EXCL_LINE */
+ LOG_LOGD("Failed to write sync adapter data, error [%d]", ret);
}
xmlFreeDoc(doc);
xmlCleanupParser();
LOG_LOGD("Ends");
}
+/* LCOV_EXCL_STOP */
/* LCOV_EXCL_START */
bundle_add_str(pExtra, (const char*)pKey, (const char*)pVal);
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
void
RepositoryEngine::ParseSyncJobsN(xmlNodePtr cur, xmlChar* pPackage) {
xmlChar* pAppId = xmlGetProp(cur, XML_ATTR_JOB_APP_ID);
}
+/* LCOV_EXCL_START */
static void create_db_schema(void) {
sqlite3 *db;
db = db_open();
db_close(db);
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
static void create_db_file(void) {
sqlite3 *db;
db = db_open();
create_db_schema();
}
+/* LCOV_EXCL_STOP */
static int check_db_file(void) {
sqlite3 *db = NULL;
db = db_open();
if (!db) {
+ /* LCOV_EXCL_START */
LOG_LOGD("DB open error : couldn't get information for DoA");
return isApp;
+ /* LCOV_EXCL_STOP */
}
char *search_query = NULL;
int ret = sqlite3_prepare_v2(db, search_query, strlen(search_query), &stmt, NULL);
if (ret != SQLITE_OK) {
+ /* LCOV_EXCL_START */
LOG_LOGD("prepare : search query[%s] ret[%d] err_msg[%s]", search_query, ret, sqlite3_errmsg(db));
sqlite3_finalize(stmt);
sqlite3_free(search_query);
db_close(db);
LOG_LOGD("sync-manager DB close : couldn't get information for DoA");
return isApp;
+ /* LCOV_EXCL_STOP */
}
ret = sqlite3_step(stmt);
}
+/* LCOV_EXCL_START */
int
RepositoryEngine::ReadSyncAdaptersFromDB(void) {
sqlite3 *db = NULL;
return 1;
}
+/* LCOV_EXCL_STOP */
int
}
+/* LCOV_EXCL_START */
int
RepositoryEngine::UpdateSyncAdapterToDB(const char *SvcAppId, int UserId, const char *AppStatus, int ProcId) {
sqlite3 *db = NULL;
return 0;
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
int
RepositoryEngine::UpdateSyncAdapterToDB(const char *SvcAppId, int UserId, const char *AppStatus) {
sqlite3 *db = NULL;
return 0;
}
+/* LCOV_EXCL_STOP */
int
sqlite3 *db = NULL;
db = db_open();
if (!db) {
+ /* LCOV_EXCL_START */
LOG_LOGD("DB open error");
return;
+ /* LCOV_EXCL_STOP */
}
LOG_LOGD("sync-manager DB open");
ret = sqlite3_prepare_v2(db, search_query, strlen(search_query), &stmt, NULL);
if (ret != SQLITE_OK) {
+ /* LCOV_EXCL_START */
LOG_LOGD("prepare : search query[%s] ret[%d] err_msg[%s]", search_query, ret, sqlite3_errmsg(db));
sqlite3_finalize(stmt);
sqlite3_free(search_query);
db_close(db);
LOG_LOGD("sync-manager DB close");
return;
+ /* LCOV_EXCL_STOP */
}
ret = sqlite3_step(stmt);
int ret = sqlite3_prepare_v2(db, search_query, strlen(search_query), &stmt, NULL);
if (ret != SQLITE_OK) {
+ /* LCOV_EXCL_START */
LOG_LOGD("prepare : search query[%s] ret[%d] err_msg[%s]", search_query, ret, sqlite3_errmsg(db));
sqlite3_finalize(stmt);
sqlite3_free(search_query);
db_close(db);
LOG_LOGD("sync-manager DB close");
return 0;
+ /* LCOV_EXCL_STOP */
}
ret = sqlite3_step(stmt);
}
+/* LCOV_EXCL_START */
int
RepositoryEngine::UpdateAppStatusToDB(const char *SvcAppId, const char *PkgName, int UserId, const char *AppStatus) {
sqlite3 *db = NULL;
return 0;
}
+/* LCOV_EXCL_STOP */
int
int ret = SQLITE_OK;
ret = sqlite3_prepare_v2(db, update_query, strlen(update_query), &stmt, NULL);
if (ret != SQLITE_OK) {
+ /* LCOV_EXCL_START */
LOG_LOGD("prepare : update query[%s] ret[%d] err_msg[%s]", update_query, ret, sqlite3_errmsg(db));
sqlite3_finalize(stmt);
sqlite3_free(update_query);
db_close(db);
LOG_LOGD("sync-manager DB close");
return -1;
+ /* LCOV_EXCL_STOP */
}
ret = sqlite3_step(stmt);
if (ret != SQLITE_OK && ret != SQLITE_DONE) {
+ /* LCOV_EXCL_START */
LOG_LOGD("DB error [%d : %s] for [%s]", ret, sqlite3_errmsg(db), update_query);
sqlite3_reset(stmt);
sqlite3_finalize(stmt);
db_close(db);
LOG_LOGD("sync-manager DB close");
return -1;
+ /* LCOV_EXCL_STOP */
}
LOG_LOGD("result : Update sync job to DB complete [%s]", update_query);
if (PkgName && strlen(PkgName) > 0) {
delete_query = sqlite3_mprintf("DELETE FROM %Q WHERE PkgName=%Q AND UserId=%Q AND SyncJobId=%Q", SYNC_JOB_TABLE, PkgName, uid, jobId);
} else {
+ /* LCOV_EXCL_START */
LOG_LOGD("Delete sync job fail : invalid package-name");
db_close(db);
LOG_LOGD("sync-manager DB close");
return -1;
+ /* LCOV_EXCL_STOP */
}
sqlite3_stmt *stmt = NULL;
ret = sqlite3_prepare_v2(db, delete_query, strlen(delete_query), &stmt, NULL);
if (ret != SQLITE_OK) {
+ /* LCOV_EXCL_START */
LOG_LOGD("prepare : delete query[%s] ret[%d] err_msg[%s]", delete_query, ret, sqlite3_errmsg(db));
sqlite3_finalize(stmt);
sqlite3_free(delete_query);
db_close(db);
LOG_LOGD("sync-manager DB close");
return -1;
+ /* LCOV_EXCL_STOP */
}
ret = sqlite3_step(stmt);
}
+/* LCOV_EXCL_START */
int
RepositoryEngine::DeleteAllSyncJobsFromDB(const char *PkgName, int UserId) {
sqlite3 *db = NULL;
return 0;
}
+/* LCOV_EXCL_STOP */
//}//_SyncManager
+