@@ -186,11 +186,12 @@ void dt_control_job_set_state_callback(_dt_job_t *job, dt_job_state_change_callb
186186 job -> state_changed_cb = cb ;
187187}
188188
189-
190- static void dt_control_job_print (_dt_job_t * job )
189+ // We don't want to log dt_get_wtime() as we already show the stamp
190+ static void _control_job_print (_dt_job_t * job , const char * info , const char * err , int32_t res )
191191{
192192 if (!job ) return ;
193- dt_print (DT_DEBUG_CONTROL , "%s | queue: %d | priority: %d" , job -> description , job -> queue , job -> priority );
193+ dt_print (DT_DEBUG_CONTROL , "[%s]\t%02d %s %s | queue: %d | priority: %d" ,
194+ info , res , err , job -> description , job -> queue , job -> priority );
194195}
195196
196197void dt_control_job_cancel (_dt_job_t * job )
@@ -213,7 +214,7 @@ void dt_control_job_wait(_dt_job_t *job)
213214 g_usleep (100000 ); // wait 0.1 seconds
214215 state = dt_control_job_get_state (job );
215216 }
216-
217+
217218 /* if job execution is not finished let's wait for it */
218219 if (state == DT_JOB_STATE_RUNNING || state == DT_JOB_STATE_CANCELLED )
219220 {
@@ -246,19 +247,15 @@ static gboolean _control_run_job_res(dt_control_t *control, int32_t res)
246247 dt_pthread_mutex_lock (& job -> wait_mutex );
247248 if (dt_control_job_get_state (job ) == DT_JOB_STATE_QUEUED )
248249 {
249- dt_print (DT_DEBUG_CONTROL , "[run_job+] %02d %f " , res , dt_get_wtime ());
250- dt_control_job_print (job );
251- dt_print (DT_DEBUG_CONTROL , "\n" );
250+ _control_job_print (job , "run_job+" , "" , res );
252251
253252 _control_job_set_state (job , DT_JOB_STATE_RUNNING );
254253
255254 /* execute job */
256255 job -> result = job -> execute (job );
257256
258257 _control_job_set_state (job , DT_JOB_STATE_FINISHED );
259- dt_print (DT_DEBUG_CONTROL , "[run_job-] %02d %f " , res , dt_get_wtime ());
260- dt_control_job_print (job );
261- dt_print (DT_DEBUG_CONTROL , "\n" );
258+ _control_job_print (job , "run_job-" , "" , res );
262259 }
263260 dt_pthread_mutex_unlock (& job -> wait_mutex );
264261 dt_control_job_dispose (job );
@@ -330,22 +327,15 @@ static _dt_job_t *_control_schedule_job(dt_control_t *control)
330327
331328static void _control_job_execute (_dt_job_t * job )
332329{
333- dt_print (DT_DEBUG_CONTROL , "[run_job+] %02d %f " , DT_CTL_WORKER_RESERVED + dt_control_get_threadid (),
334- dt_get_wtime ());
335- dt_control_job_print (job );
336- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
330+ _control_job_print (job , "run_job+" , "" , DT_CTL_WORKER_RESERVED + dt_control_get_threadid ());
337331
338332 _control_job_set_state (job , DT_JOB_STATE_RUNNING );
339333
340334 /* execute job */
341335 job -> result = job -> execute (job );
342336
343337 _control_job_set_state (job , DT_JOB_STATE_FINISHED );
344-
345- dt_print (DT_DEBUG_CONTROL , "[run_job-] %02d %f " , DT_CTL_WORKER_RESERVED + dt_control_get_threadid (),
346- dt_get_wtime ());
347- dt_control_job_print (job );
348- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
338+ _control_job_print (job , "run_job-" , "" , DT_CTL_WORKER_RESERVED + dt_control_get_threadid ());
349339}
350340
351341static gboolean _control_run_job (dt_control_t * control )
@@ -394,8 +384,7 @@ gboolean dt_control_add_job_res(dt_control_t *control,
394384 }
395385
396386 dt_print (DT_DEBUG_CONTROL , "[add_job_res] %d | " , res );
397- dt_control_job_print (job );
398- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
387+ _control_job_print (job , "add_job_res" , "" , res );
399388
400389 _control_job_set_state (job , DT_JOB_STATE_QUEUED );
401390 control -> job_res [res ] = job ;
@@ -441,9 +430,7 @@ gboolean dt_control_add_job(dt_control_t *control,
441430 GList * * queue = & control -> queues [queue_id ];
442431 size_t length = control -> queue_length [queue_id ];
443432
444- dt_print (DT_DEBUG_CONTROL , "[add_job] %zu | " , length );
445- dt_control_job_print (job );
446- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
433+ _control_job_print (job , "add_job" , "" , (int32_t )length );
447434
448435 if (queue_id == DT_JOB_QUEUE_SYSTEM_FG )
449436 {
@@ -456,9 +443,7 @@ gboolean dt_control_add_job(dt_control_t *control,
456443 _dt_job_t * other_job = (_dt_job_t * )control -> job [k ];
457444 if (_control_job_equal (job , other_job ))
458445 {
459- dt_print (DT_DEBUG_CONTROL , "[add_job] found job already in scheduled: " );
460- dt_control_job_print (other_job );
461- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
446+ _control_job_print (other_job , "add_job" , "found job already in scheduled:" , -1 );
462447
463448 dt_pthread_mutex_unlock (& control -> queue_mutex );
464449
@@ -475,9 +460,7 @@ gboolean dt_control_add_job(dt_control_t *control,
475460 _dt_job_t * other_job = (_dt_job_t * )iter -> data ;
476461 if (_control_job_equal (job , other_job ))
477462 {
478- dt_print (DT_DEBUG_CONTROL , "[add_job] found job already in queue: " );
479- dt_control_job_print (other_job );
480- dt_print_nts (DT_DEBUG_CONTROL , "\n" );
463+ _control_job_print (other_job , "add_job" , "found job already in queue" , -1 );
481464
482465 * queue = g_list_delete_link (* queue , iter );
483466 length -- ;
0 commit comments