Skip to content

Topic/t2 debug1 #298

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
dharshini555 wants to merge 8 commits into from
Closed

Topic/t2 debug1 #298

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
73f7796
Add debug logs in dca.c
dharshini555 Mar 14, 2026
ac066d7
Add the debug print for haystack
dharshini555 Mar 16, 2026
43c586d
Add debug logs for telemetry2_0
dharshini555 Mar 23, 2026
5fe0aca
Add set log demand true in reboot sequence
dharshini555 Mar 23, 2026
7b27131
Modify islogdemand as true
dharshini555 Mar 23, 2026
02457c7
Merge branch 'develop' into topic/t2_debug1
dharshini555 Mar 24, 2026
02b6c62
Add print for haystack
dharshini555 Mar 24, 2026
44dbe9b
Update dca.c
dharshini555 Mar 24, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 16 additions & 16 deletions source/bulkdata/datamodel.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,15 +51,15 @@ static void *process_rp_thread(void *data)
(void) data;//To fix compiler warning
cJSON *reportProfiles = NULL;

T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);

while(!stopProcessing)
{
pthread_mutex_lock(&rpMutex);
T2Info("%s: Waiting for event from tr-181 \n", __FUNCTION__);
pthread_cond_wait(&rpCond, &rpMutex);

T2Debug("%s: Received wake up signal \n", __FUNCTION__);
T2Info("%s: Received wake up signal \n", __FUNCTION__);
if(t2_queue_count(rpQueue) > 0)
{
reportProfiles = (cJSON *)t2_queue_pop(rpQueue);
Expand All @@ -72,7 +72,7 @@ static void *process_rp_thread(void *data)
}
pthread_mutex_unlock(&rpMutex);
}
T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
return NULL;
}

Expand All @@ -81,15 +81,15 @@ static void *process_tmprp_thread(void *data)
(void) data;//To fix compiler warning
cJSON *tmpReportProfiles = NULL;

T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);

while(!stopProcessing)
{
pthread_mutex_lock(&tmpRpMutex);
T2Info("%s: Waiting for event from tr-181 \n", __FUNCTION__);
pthread_cond_wait(&tmpRpCond, &tmpRpMutex);

T2Debug("%s: Received wake up signal \n", __FUNCTION__);
T2Info("%s: Received wake up signal \n", __FUNCTION__);
if(t2_queue_count(tmpRpQueue) > 0)
{
tmpReportProfiles = (cJSON *)t2_queue_pop(tmpRpQueue);
Expand All @@ -102,7 +102,7 @@ static void *process_tmprp_thread(void *data)
}
pthread_mutex_unlock(&tmpRpMutex);
}
T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
return NULL;
}

Expand Down Expand Up @@ -182,7 +182,7 @@ T2ERROR datamodel_processProfile(char *JsonBlob, bool rprofiletypes)
*/
void datamodel_getSavedJsonProfilesasString(char** SavedProfiles)
{
T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);
size_t configIndex = 0;
Vector *configList = NULL;
Config *config = NULL;
Expand All @@ -196,7 +196,7 @@ void datamodel_getSavedJsonProfilesasString(char** SavedProfiles)
for(; configIndex < Vector_Size(configList); configIndex++)
{
config = Vector_At(configList, configIndex);
T2Debug("Processing config with name : %s\n", config->name);
T2Info("Processing config with name : %s\n", config->name);
cJSON *temparrayItem = cJSON_CreateObject();
cJSON_AddStringToObject(temparrayItem, "name", config->name);
cJSON *tempObject = cJSON_Parse(config->configData);
Expand All @@ -210,15 +210,15 @@ void datamodel_getSavedJsonProfilesasString(char** SavedProfiles)
cJSON_Delete(jsonObj);
}
Vector_Destroy(configList, free);
T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
}

/**
* Caller is responsible for freeing the allocated memory in passed reference
*/
int datamodel_getSavedMsgpackProfilesasString(char** SavedProfiles)
{
T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);
//#if defined(FEATURE_SUPPORT_WEBCONFIG) get should work without the restriction of webconfig
char filePath[REPORTPROFILES_FILE_PATH_SIZE] = {'\0'};
snprintf(filePath, sizeof(filePath), "%s%s", REPORTPROFILES_PERSISTENCE_PATH, MSGPACK_REPORTPROFILES_PERSISTENT_FILE);
Expand Down Expand Up @@ -253,12 +253,12 @@ int datamodel_getSavedMsgpackProfilesasString(char** SavedProfiles)
return 0;
}
fclose (fp);
T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
*SavedProfiles = msgpack.msgpack_blob;
return msgpack.msgpack_blob_size;
}
//#endif
T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
return 0;
}

Expand Down Expand Up @@ -298,7 +298,7 @@ T2ERROR datamodel_MsgpackProcessProfile(char *str, int strSize)

T2ERROR datamodel_init(void)
{
T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);
rpQueue = t2_queue_create();
if (rpQueue == NULL)
{
Expand Down Expand Up @@ -332,13 +332,13 @@ T2ERROR datamodel_init(void)
pthread_create(&rpMsgThread, NULL, process_msg_thread, (void *)NULL);
pthread_create(&tmpRpThread, NULL, process_tmprp_thread, (void *)NULL);

T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
return T2ERROR_SUCCESS;
}

void datamodel_unInit(void)
{
T2Debug("%s ++in\n", __FUNCTION__);
T2Info("%s ++in\n", __FUNCTION__);

pthread_mutex_lock(&rpMutex);
stopProcessing = true;
Expand All @@ -357,5 +357,5 @@ void datamodel_unInit(void)
pthread_mutex_destroy(&tmpRpMutex);
pthread_cond_destroy(&tmpRpCond);

T2Debug("%s --out\n", __FUNCTION__);
T2Info("%s --out\n", __FUNCTION__);
}
Loading
Loading