diff --git a/src/include/xce/types.h b/src/include/xce/types.h index 12fbe34b..fa5663e8 100644 --- a/src/include/xce/types.h +++ b/src/include/xce/types.h @@ -8,9 +8,9 @@ #include #include +#include "netio.h" #include "xlist.h" #include "zarray.h" -#include "netio.h" #define XCE_VAL_STRING (0) #define XCE_VAL_NUMERIC (1) @@ -277,7 +277,6 @@ typedef struct { zarray_t usages; } worker_t; - typedef struct { char* host; int nallocs; @@ -446,7 +445,6 @@ typedef struct { xce_job_t job; } job_t; - typedef struct { int count; xce_job_t** data; diff --git a/src/scheduler/src/decision.c b/src/scheduler/src/decision.c index cb49eead..5af397f8 100644 --- a/src/scheduler/src/decision.c +++ b/src/scheduler/src/decision.c @@ -2,4 +2,3 @@ #include #include "decision.h" - diff --git a/src/scheduler/src/main.c b/src/scheduler/src/main.c index e6f63b5c..a494df09 100644 --- a/src/scheduler/src/main.c +++ b/src/scheduler/src/main.c @@ -66,8 +66,8 @@ static xce_scheduler_t sched; static void stop_scheduler(xce_scheduler_t* sched) { - xce_decision_t *decision = NULL; - + xce_decision_t* decision = NULL; + INFO("stop to scheduling jobs..."); sched->stop = 1; diff --git a/src/scheduler/src/scheduler.c b/src/scheduler/src/scheduler.c index 535bb30a..93ff8e7b 100644 --- a/src/scheduler/src/scheduler.c +++ b/src/scheduler/src/scheduler.c @@ -186,7 +186,7 @@ void sched_fini(xce_scheduler_t* sched) dataq_fini(sched->pend_updates[0]); dataq_fini(sched->pend_updates[1]); - + mylock_fini(&(sched->lock)); return; @@ -249,7 +249,7 @@ int sched_update(xce_scheduler_t* sched) } sched_pend_update_killer(it); - + if (rc < 0) { /* something wrong? */ }