diff --git a/src/common/qsw.c b/src/common/qsw.c index 182be03c3f03f48c56a7267574f9eb02e6d23930..038dc807bf1552a24fec377e769b23c7468ab58b 100644 --- a/src/common/qsw.c +++ b/src/common/qsw.c @@ -25,9 +25,13 @@ \*****************************************************************************/ #if HAVE_CONFIG_H -#include "config.h" +# include "config.h" #endif +#ifdef WITH_PTHREADS +# include <pthread.h> +#endif /* WITH_PTHREADS */ + #include <sys/param.h> #include <sys/types.h> #include <sys/wait.h> @@ -41,17 +45,16 @@ #include <stdlib.h> #include <unistd.h> #include <limits.h> /* INT_MAX */ -#include <pthread.h> #include <stdio.h> #include <elan3/elan3.h> #include <elan3/elanvp.h> #include <rms/rmscall.h> -#include <src/common/bitstring.h> -#include <src/common/log.h> -#include <src/common/pack.h> -#include <src/common/qsw.h> -#include <src/common/slurm_errno.h> +#include "src/common/bitstring.h" +#include "src/common/log.h" +#include "src/common/pack.h" +#include "src/common/qsw.h" +#include "src/common/slurm_errno.h" /* * Definitions local to this module. @@ -416,7 +419,8 @@ _generate_hwcontext(int num) _unlock_qsw(); } else { _srand_if_needed(); - new = lrand48() % (QSW_CTX_END - (QSW_CTX_START + num - 1) - 1); + new = lrand48() % + (QSW_CTX_END - (QSW_CTX_START + num - 1) - 1); new += QSW_CTX_START; } return new; @@ -494,8 +498,10 @@ _init_elan_capability(ELAN_CAPABILITY *cap, int nprocs, int nnodes, else task_cnt = min_procs_per_node; for (j = 0; j < task_cnt; j++) { - proc0 = (i - cap->LowNode) * max_procs_per_node; - assert((proc0 + j) < (sizeof(cap->Bitmap) * 8)); + proc0 = (i - cap->LowNode) * + max_procs_per_node; + assert((proc0 + j) < + (sizeof(cap->Bitmap) * 8)); BT_SET(cap->Bitmap, (proc0 + j)); } } @@ -525,7 +531,8 @@ qsw_setup_jobinfo(qsw_jobinfo_t j, int nprocs, bitstr_t *nodeset, /* initialize jobinfo */ j->j_prognum = _generate_prognum(); j->j_ctx = NULL; - _init_elan_capability(&j->j_cap, nprocs, nnodes, nodeset, cyclic_alloc); + _init_elan_capability(&j->j_cap, nprocs, nnodes, nodeset, + cyclic_alloc); return 0; } diff --git a/src/common/qsw.h b/src/common/qsw.h index 0183a85617818a5198670d64dbdcf5eeee00b6c7..fb177db2390b73bbdef8a4eaf075aeb952711e50 100644 --- a/src/common/qsw.h +++ b/src/common/qsw.h @@ -29,8 +29,8 @@ #include <elan3/elan3.h> #include <elan3/elanvp.h> -#include <src/common/bitstring.h> -#include <src/common/pack.h> +#include "src/common/bitstring.h" +#include "src/common/pack.h" #ifndef _QSW_INCLUDED #define _QSW_INCLUDED @@ -70,9 +70,11 @@ void qsw_prog_fini(qsw_jobinfo_t jobinfo); int qsw_prgdestroy(qsw_jobinfo_t jobinfo); /* was qsw_prog_reap */ -int qsw_setcap(qsw_jobinfo_t jobinfo, int procnum); /* was qsw_attach */ +int qsw_setcap(qsw_jobinfo_t jobinfo, int procnum); + /* was qsw_attach */ -int qsw_prgsignal(qsw_jobinfo_t jobinfo, int signum); /* was qsw_signal_job */ +int qsw_prgsignal(qsw_jobinfo_t jobinfo, int signum); + /* was qsw_signal_job */ int qsw_getnodeid(void); int qsw_getnodeid_byhost(char *host);