186 static void _notify_slurmctld_jobs(agent_info_t *agent_ptr);
187 static void _notify_slurmctld_nodes(agent_info_t *agent_ptr,
585 	agent_info_t *agent_ptr = (agent_info_t *) args;  in _wdog()  local
586 	thd_t *thread_ptr = agent_ptr->thread_struct;  in _wdog()
592 	if ( (agent_ptr->msg_type == SRUN_JOB_COMPLETE)			||  in _wdog()
593 	     (agent_ptr->msg_type == SRUN_REQUEST_SUSPEND)		||  in _wdog()
594 	     (agent_ptr->msg_type == SRUN_STEP_MISSING)			||  in _wdog()
595 	     (agent_ptr->msg_type == SRUN_STEP_SIGNAL)			||  in _wdog()
596 	     (agent_ptr->msg_type == SRUN_EXEC)				||  in _wdog()
597 	     (agent_ptr->msg_type == SRUN_NODE_FAIL)			||  in _wdog()
598 	     (agent_ptr->msg_type == SRUN_PING)				||  in _wdog()
599 	     (agent_ptr->msg_type == SRUN_TIMEOUT)			||  in _wdog()
600 	     (agent_ptr->msg_type == SRUN_USER_MSG)			||  in _wdog()
601 	     (agent_ptr->msg_type == RESPONSE_RESOURCE_ALLOCATION)	||  in _wdog()
602 	     (agent_ptr->msg_type == RESPONSE_HET_JOB_ALLOCATION) )  in _wdog()
617 		slurm_mutex_lock(&agent_ptr->thread_mutex);  in _wdog()
618 		for (i = 0; i < agent_ptr->thread_count; i++) {  in _wdog()
638 		slurm_mutex_unlock(&agent_ptr->thread_mutex);  in _wdog()
642 		_notify_slurmctld_jobs(agent_ptr);  in _wdog()
644 		_notify_slurmctld_nodes(agent_ptr,  in _wdog()
649 	for (i = 0; i < agent_ptr->thread_count; i++) {  in _wdog()
660 	slurm_mutex_unlock(&agent_ptr->thread_mutex);  in _wdog()
664 static void _notify_slurmctld_jobs(agent_info_t *agent_ptr)  in _notify_slurmctld_jobs()  argument
670 	thd_t *thread_ptr = agent_ptr->thread_struct;  in _notify_slurmctld_jobs()
672 	if        (agent_ptr->msg_type == SRUN_PING) {  in _notify_slurmctld_jobs()
673 		srun_ping_msg_t *msg = *agent_ptr->msg_args_pptr;  in _notify_slurmctld_jobs()
676 	} else if (agent_ptr->msg_type == SRUN_TIMEOUT) {  in _notify_slurmctld_jobs()
677 		srun_timeout_msg_t *msg = *agent_ptr->msg_args_pptr;  in _notify_slurmctld_jobs()
680 	} else if (agent_ptr->msg_type == RESPONSE_RESOURCE_ALLOCATION) {  in _notify_slurmctld_jobs()
682 			*agent_ptr->msg_args_pptr;  in _notify_slurmctld_jobs()
685 	} else if (agent_ptr->msg_type == RESPONSE_HET_JOB_ALLOCATION) {  in _notify_slurmctld_jobs()
686 		List het_alloc_list = *agent_ptr->msg_args_pptr;  in _notify_slurmctld_jobs()
693 	} else if ((agent_ptr->msg_type == SRUN_JOB_COMPLETE)		||  in _notify_slurmctld_jobs()
694 		   (agent_ptr->msg_type == SRUN_REQUEST_SUSPEND)	||  in _notify_slurmctld_jobs()
695 		   (agent_ptr->msg_type == SRUN_STEP_MISSING)		||  in _notify_slurmctld_jobs()
696 		   (agent_ptr->msg_type == SRUN_STEP_SIGNAL)		||  in _notify_slurmctld_jobs()
697 		   (agent_ptr->msg_type == SRUN_EXEC)			||  in _notify_slurmctld_jobs()
698 		   (agent_ptr->msg_type == SRUN_USER_MSG)) {  in _notify_slurmctld_jobs()
700 	} else if (agent_ptr->msg_type == SRUN_NODE_FAIL) {  in _notify_slurmctld_jobs()
703 		error("%s: invalid msg_type %u", __func__, agent_ptr->msg_type);  in _notify_slurmctld_jobs()
714 static void _notify_slurmctld_nodes(agent_info_t *agent_ptr,  in _notify_slurmctld_nodes()  argument
724 	thd_t *thread_ptr = agent_ptr->thread_struct;  in _notify_slurmctld_nodes()
730 		if (agent_ptr->msg_type == REQUEST_BATCH_JOB_LAUNCH) {  in _notify_slurmctld_nodes()
733 					*agent_ptr->msg_args_pptr;  in _notify_slurmctld_nodes()
747 	if (retry_cnt && agent_ptr->retry)  in _notify_slurmctld_nodes()
748 		_queue_agent_retry(agent_ptr, retry_cnt);  in _notify_slurmctld_nodes()
752 	for (i = 0; i < agent_ptr->thread_count; i++) {  in _notify_slurmctld_nodes()
826 	if ((agent_ptr->msg_type == REQUEST_PING) ||  in _notify_slurmctld_nodes()
827 	    (agent_ptr->msg_type == REQUEST_HEALTH_CHECK) ||  in _notify_slurmctld_nodes()
828 	    (agent_ptr->msg_type == REQUEST_ACCT_GATHER_UPDATE) ||  in _notify_slurmctld_nodes()
829 	    (agent_ptr->msg_type == REQUEST_NODE_REGISTRATION_STATUS))  in _notify_slurmctld_nodes()