Function handle_io

timer.c:756–812

inline static int handle_io(struct fd_map* fm, int idx,int event_type)
{
	int n=0;

	pt_become_active();

	pre_run_handle_script_reload(fm->app_flags);

	profiling_proc_start( LEVEL_SIP, 1);

	switch(fm->type){
		case F_TIMER_JOB:
			profiling_proc_enter( LEVEL_FULL, "timer_job", 1 );
			handle_timer_job();
			profiling_proc_exit( LEVEL_FULL, "timer_job", n);
			break;
		case F_SCRIPT_ASYNC:
			profiling_proc_enter( LEVEL_SIP, "async_script", 0 );
			n = async_script_resume_f( fm->fd, fm->data,
				(event_type==IO_WATCH_TIMEOUT)?1:0 );
			profiling_proc_exit( LEVEL_SIP, "async_script", n);
			break;
		case F_FD_ASYNC:
			profiling_proc_enter( LEVEL_SIP, "async_fd", 0 );
			n = async_fd_resume( fm->fd, fm->data);
			profiling_proc_exit( LEVEL_SIP, "async_fd", n);
			break;
		case F_LAUNCH_ASYNC:
			profiling_proc_enter( LEVEL_SIP, "async_launch", 0 );
			n = async_launch_resume( fm->fd, fm->data);
			profiling_proc_exit( LEVEL_SIP, "async_launch", n);
			break;
		case F_IPC:
			profiling_proc_enter( LEVEL_SIP, "ipc_job", 1 );
			ipc_handle_job(fm->fd);
			profiling_proc_exit( LEVEL_SIP, "ipc_job", n);
			break;
		default:
			LM_CRIT("unknown fd type %d in Timer Extra\n", fm->type);
			n = -1;
			break;
	}

	if (reactor_is_empty() && _termination_in_progress==1) {
		LM_WARN("reactor got empty while termination in progress\n");
		ipc_handle_all_pending_jobs(IPC_FD_READ_SELF);
		if (reactor_is_empty())
			dynamic_process_final_exit();
	}

	profiling_proc_end( LEVEL_SIP, n );

	post_run_handle_script_reload();

	pt_become_idle();
	return n;
}