Attachment #4915 for ticket #3977

View | Details | Raw Unified | Return to ticket 3977
Collapse All | Expand All




static int  _add_starting_step(uint16_t type, void *req);
static int  _remove_starting_step(uint16_t type, void *req);
static int  _compare_starting_steps(void *s0, void *s1);
static int  _compare_starting_steps2(void *s0, void *s1);
static int  _wait_for_starting_step(uint32_t job_id, uint32_t step_id);
static bool _step_is_starting(uint32_t job_id, uint32_t step_id);


	}

	if (!list_delete_all(conf->starting_steps,
			     _compare_starting_steps2,
			     &starting_step)) {
		error("%s: step %u.%u not found", __func__,
		      starting_step.job_id,

		return (step0->job_id  == step1->job_id);
}

static int _compare_starting_steps2(void *listentry, void *key)
{
	starting_step_t *step0 = (starting_step_t *)listentry;
	starting_step_t *step1 = (starting_step_t *)key;

	return (step0->job_id  == step1->job_id &&
		step0->step_id == step1->step_id);
}


/* Wait for a step to get far enough in the launch process to have
   a socket open, ready to handle RPC calls.  Pass step_id = NO_VAL

Return to ticket 3977

Lines 230-235 static gids_t _gids_cache_lookup(char user, gid_t gid); Link Here

(-)a/src/slurmd/slurmd/req.c (-1 / +11 lines)
230	static int _add_starting_step(uint16_t type, void *req);	230	static int _add_starting_step(uint16_t type, void *req);
231	static int _remove_starting_step(uint16_t type, void *req);	231	static int _remove_starting_step(uint16_t type, void *req);
232	static int _compare_starting_steps(void s0, void s1);	232	static int _compare_starting_steps(void s0, void s1);
		233	static int _compare_starting_steps2(void s0, void s1);
233	static int _wait_for_starting_step(uint32_t job_id, uint32_t step_id);	234	static int _wait_for_starting_step(uint32_t job_id, uint32_t step_id);
234	static bool _step_is_starting(uint32_t job_id, uint32_t step_id);	235	static bool _step_is_starting(uint32_t job_id, uint32_t step_id);
235		236
Lines 6443-6449 _remove_starting_step(uint16_t type, void *req) Link Here
6443	}	6444	}
6444		6445
6445	if (!list_delete_all(conf->starting_steps,	6446	if (!list_delete_all(conf->starting_steps,
6446	_compare_starting_steps,	6447	_compare_starting_steps2,
6447	&starting_step)) {	6448	&starting_step)) {
6448	error("%s: step %u.%u not found", __func__,	6449	error("%s: step %u.%u not found", __func__,
6449	starting_step.job_id,	6450	starting_step.job_id,
Lines 6469-6474 static int _compare_starting_steps(void listentry, void key) Link Here
6469	return (step0->job_id == step1->job_id);	6470	return (step0->job_id == step1->job_id);
6470	}	6471	}
6471		6472
		6473	static int _compare_starting_steps2(void listentry, void key)
		6474	{
		6475	starting_step_t step0 = (starting_step_t )listentry;
		6476	starting_step_t step1 = (starting_step_t )key;
		6477
		6478	return (step0->job_id == step1->job_id &&
		6479	step0->step_id == step1->step_id);
		6480	}
		6481
6472		6482
6473	/* Wait for a step to get far enough in the launch process to have	6483	/* Wait for a step to get far enough in the launch process to have
6474	a socket open, ready to handle RPC calls. Pass step_id = NO_VAL	6484	a socket open, ready to handle RPC calls. Pass step_id = NO_VAL