|
Lines 179-184
static int max_backfill_jobs_start = 0;
Link Here
|
| 179 |
static bool backfill_continue = false; |
179 |
static bool backfill_continue = false; |
| 180 |
static bool assoc_limit_stop = false; |
180 |
static bool assoc_limit_stop = false; |
| 181 |
static int defer_rpc_cnt = 0; |
181 |
static int defer_rpc_cnt = 0; |
|
|
182 |
static int defer_rpc_cnt_lb = 0; |
| 182 |
static int sched_timeout = SCHED_TIMEOUT; |
183 |
static int sched_timeout = SCHED_TIMEOUT; |
| 183 |
static int yield_sleep = YIELD_SLEEP; |
184 |
static int yield_sleep = YIELD_SLEEP; |
| 184 |
static List pack_job_list = NULL; |
185 |
static List pack_job_list = NULL; |
|
Lines 802-807
static void _load_config(void)
Link Here
|
| 802 |
defer_rpc_cnt); |
803 |
defer_rpc_cnt); |
| 803 |
defer_rpc_cnt = 0; |
804 |
defer_rpc_cnt = 0; |
| 804 |
} |
805 |
} |
|
|
806 |
if (sched_params && (tmp_ptr = strstr(sched_params, "max_rpc_cnt_lb="))) |
| 807 |
defer_rpc_cnt_lb = atoi(tmp_ptr + 15); |
| 808 |
else if (sched_params && |
| 809 |
(tmp_ptr = strstr(sched_params, "max_rpc_count_lb="))) |
| 810 |
defer_rpc_cnt_lb = atoi(tmp_ptr + 17); |
| 811 |
else |
| 812 |
defer_rpc_cnt_lb = 0; |
| 813 |
if (defer_rpc_cnt_lb < 0) { |
| 814 |
error("Invalid SchedulerParameters max_rpc_cnt_lb: %d", |
| 815 |
defer_rpc_cnt_lb); |
| 816 |
defer_rpc_cnt_lb = 0; |
| 817 |
} |
| 805 |
|
818 |
|
| 806 |
xfree(sched_params); |
819 |
xfree(sched_params); |
| 807 |
} |
820 |
} |
|
Lines 935-940
static int _yield_locks(int usec)
Link Here
|
| 935 |
int max_rpc_cnt; |
948 |
int max_rpc_cnt; |
| 936 |
|
949 |
|
| 937 |
max_rpc_cnt = MAX((defer_rpc_cnt / 10), 20); |
950 |
max_rpc_cnt = MAX((defer_rpc_cnt / 10), 20); |
|
|
951 |
max_rpc_cnt = MAX(max_rpc_cnt, defer_rpc_cnt_lb); |
| 938 |
job_update = last_job_update; |
952 |
job_update = last_job_update; |
| 939 |
node_update = last_node_update; |
953 |
node_update = last_node_update; |
| 940 |
part_update = last_part_update; |
954 |
part_update = last_part_update; |
