lei.chen/myxce
1
0
Fork 1
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

format code

Browse source
This commit is contained in:
Rongsong Shen 2025-12-18 17:39:09 +08:00
parent 8d78f0cbeb
commit 2b190bdb1d
4 changed files with 5 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/include/xce/types.h
View file

@ -8,9 +8,9 @@
#include <sys/resource.h> #include <sys/resource.h>
#include <time.h> #include <time.h>
#include "netio.h"
#include "xlist.h" #include "xlist.h"
#include "zarray.h" #include "zarray.h"
#include "netio.h"
#define XCE_VAL_STRING (0) #define XCE_VAL_STRING (0)
#define XCE_VAL_NUMERIC (1) #define XCE_VAL_NUMERIC (1)
@ -277,7 +277,6 @@ typedef struct {
zarray_t usages; zarray_t usages;
} worker_t; } worker_t;
typedef struct { typedef struct {
char* host; char* host;
int nallocs; int nallocs;
@ -446,7 +445,6 @@ typedef struct {
xce_job_t job; xce_job_t job;
} job_t; } job_t;
typedef struct { typedef struct {
int count; int count;
xce_job_t** data; xce_job_t** data;

1
src/scheduler/src/decision.c
View file

@ -2,4 +2,3 @@
#include <stdlib.h> #include <stdlib.h>
#include "decision.h" #include "decision.h"

4
src/scheduler/src/main.c
View file

@ -66,8 +66,8 @@ static xce_scheduler_t sched;
static void stop_scheduler(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..."); INFO("stop to scheduling jobs...");
sched->stop = 1; sched->stop = 1;

4
src/scheduler/src/scheduler.c
View file

@ -186,7 +186,7 @@ void sched_fini(xce_scheduler_t* sched)
dataq_fini(sched->pend_updates[0]); dataq_fini(sched->pend_updates[0]);
dataq_fini(sched->pend_updates[1]); dataq_fini(sched->pend_updates[1]);
mylock_fini(&(sched->lock)); mylock_fini(&(sched->lock));
return; return;
@ -249,7 +249,7 @@ int sched_update(xce_scheduler_t* sched)
} }
sched_pend_update_killer(it); sched_pend_update_killer(it);
if (rc < 0) { if (rc < 0) {
/* something wrong? */ /* something wrong? */
} }