fanasina/y_project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

y_worker,y_task: remove some debug printf

Browse Source
This commit is contained in:
fanasina
2025-10-18 10:26:23 +02:00
parent 6c643f0792
commit 14552f5248
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
y_worker_t/src/y_worker_t/y_task_t.c
+7 -7
View File
@@ -26,22 +26,22 @@ void free_y_tasQ(struct y_tasQ * tasQ){
} }
void push_tasQ(struct y_tasQ *tasQ, struct y_task_t task){ void push_tasQ(struct y_tasQ *tasQ, struct y_task_t task){
printf("debug: push_tasQ debut\n"); ///printf("debug: push_tasQ debut\n");
pthread_mutex_lock(tasQ->mut_tasQ); pthread_mutex_lock(tasQ->mut_tasQ);
push_back_list_y_TASK_T(tasQ->list_tasQ, task); push_back_list_y_TASK_T(tasQ->list_tasQ, task);
pthread_mutex_unlock(tasQ->mut_tasQ); pthread_mutex_unlock(tasQ->mut_tasQ);
pthread_cond_signal(tasQ->cond_tasQ); pthread_cond_signal(tasQ->cond_tasQ);
printf("debug: push_tasQ fin\n"); ///printf("debug: push_tasQ fin\n");
} }
struct list_y_TASK_T* pull_tasQ(struct y_tasQ *tasQ){ struct list_y_TASK_T* pull_tasQ(struct y_tasQ *tasQ){
printf("debug: pull_tasQ debut id_th:%ld\n",pthread_self()); ///printf("debug: pull_tasQ debut id_th:%ld\n",pthread_self());
struct list_y_TASK_T *valueRet = NULL; struct list_y_TASK_T *valueRet = NULL;
pthread_mutex_lock(tasQ->mut_tasQ); pthread_mutex_lock(tasQ->mut_tasQ);
while(tasQ->list_tasQ->end_list == NULL){ while(tasQ->list_tasQ->end_list == NULL){
pthread_cond_wait(tasQ->cond_tasQ, tasQ->mut_tasQ); pthread_cond_wait(tasQ->cond_tasQ, tasQ->mut_tasQ);
} }
valueRet = pull_begin_from_list_y_TASK_T(tasQ->list_tasQ); valueRet = pull_begin_from_list_y_TASK_T(tasQ->list_tasQ);
printf("debug: call pull_begin_from_list_y_TASK_T debut\n"); ///printf("debug: call pull_begin_from_list_y_TASK_T debut\n");
// valueRet = pull_end_from_list_y_TASK_T(tasQ->list_tasQ); // valueRet = pull_end_from_list_y_TASK_T(tasQ->list_tasQ);
//printf("debug: call pull_begin_from_list_y_TASK_T fin, is tasQ NULL? : %d\nis tasQ->list_tasQ NULL?:%d\n", tasQ==NULL, tasQ->list_tasQ == NULL); //printf("debug: call pull_begin_from_list_y_TASK_T fin, is tasQ NULL? : %d\nis tasQ->list_tasQ NULL?:%d\n", tasQ==NULL, tasQ->list_tasQ == NULL);
pthread_mutex_unlock(tasQ->mut_tasQ); pthread_mutex_unlock(tasQ->mut_tasQ);
@@ -78,10 +78,10 @@ void * execute_task(void *arg){
struct y_tasQ *historytasQ = argx->historytasQ; struct y_tasQ *historytasQ = argx->historytasQ;
struct list_y_TASK_T *l_task=NULL; struct list_y_TASK_T *l_task=NULL;
while(check_go_on_tasQ(argx)){ while(check_go_on_tasQ(argx)){
printf("\n\ndebug: -------------------> task begin\n\n \n"); ///printf("\n\ndebug: -------------------> task begin\n\n \n");
l_task = pull_tasQ(tasQ); l_task = pull_tasQ(tasQ);
printf("debug: is l_task NULL? = %d\n", l_task==NULL); ///printf("debug: is l_task NULL? = %d\n", l_task==NULL);
if(l_task){ if(l_task){
if((l_task->value.status != TASK_DONE) && (l_task->value.func!=NULL)) if((l_task->value.status != TASK_DONE) && (l_task->value.func!=NULL))
l_task->value.ret = l_task->value.func(l_task->value.arg); l_task->value.ret = l_task->value.func(l_task->value.arg);
@@ -92,7 +92,7 @@ void * execute_task(void *arg){
if(l_task) append_list_y_TASK_T(historytasQ->list_tasQ, l_task); if(l_task) append_list_y_TASK_T(historytasQ->list_tasQ, l_task);
pthread_mutex_unlock(historytasQ->mut_tasQ); pthread_mutex_unlock(historytasQ->mut_tasQ);
printf("\n\ndebug: -------------------> task done\n\n \n"); ///printf("\n\ndebug: -------------------> task done\n\n \n");
} }
//printf("debug: -------------------> exit task exec \n"); //printf("debug: -------------------> exit task exec \n");
y_worker_t/src/y_worker_t/y_worker_t.c
+1 -1
View File
@@ -112,7 +112,7 @@ void* execute_work(void* arg){
}; };
printf("debug: execute_task end, worker exec=%d id:%ld self:%ld \n",exec,pworker->id, pworker->id_thread); //printf("debug: execute_task end, worker exec=%d id:%ld self:%ld \n",exec,pworker->id, pworker->id_thread);
pthread_mutex_lock(pworker->mut_worker); pthread_mutex_lock(pworker->mut_worker);
pworker->status=WORKER_OFF; pworker->status=WORKER_OFF;