自学教程：C++ CHECK_DISPATCH函数代码示例

ERslp_tsk(void){	WINFO	winfo;	ER		ercd;	LOG_SLP_TSK_ENTER();	CHECK_DISPATCH();	t_lock_cpu();	if (p_runtsk->wupque) {		p_runtsk->wupque = false;		ercd = E_OK;	}	else {		p_runtsk->tstat = (TS_WAITING | TS_WAIT_SLP);		make_wait(&winfo);		LOG_TSKSTAT(p_runtsk);		dispatch();		ercd = winfo.wercd;	}	t_unlock_cpu();  error_exit:	LOG_SLP_TSK_LEAVE(ercd);	return(ercd);}

JSP_L1_CODESYSCALL ERtwai_sem(ID semid, TMO tmout){	SEMCB	*semcb;	WINFO_WOBJ winfo;	TMEVTB	tmevtb;	ER	ercd;	LOG_TWAI_SEM_ENTER(semid, tmout);	CHECK_DISPATCH();	CHECK_SEMID(semid);	CHECK_TMOUT(tmout);	semcb = get_semcb(semid);	t_lock_cpu();	if (semcb->semcnt >= 1) {		semcb->semcnt -= 1;		ercd = E_OK;	}	else if (tmout == TMO_POL) {		ercd = E_TMOUT;	}	else {		wobj_make_wait_tmout((WOBJCB *) semcb, &winfo, &tmevtb, tmout);		dispatch();		ercd = winfo.winfo.wercd;	}	t_unlock_cpu();    exit:	LOG_TWAI_SEM_LEAVE(ercd);	return(ercd);}

ERtslp_tsk(TMO tmout){	WINFO	winfo;	TMEVTB	tmevtb;	ER		ercd;	LOG_TSLP_TSK_ENTER(tmout);	CHECK_DISPATCH();	CHECK_TMOUT(tmout);	t_lock_cpu();	if (p_runtsk->wupque) {		p_runtsk->wupque = false;		ercd = E_OK;	}	else if (tmout == TMO_POL) {		ercd = E_TMOUT;	}	else {		p_runtsk->tstat = (TS_WAITING | TS_WAIT_SLP);		make_wait_tmout(&winfo, &tmevtb, tmout);		LOG_TSKSTAT(p_runtsk);		dispatch();		ercd = winfo.wercd;	}	t_unlock_cpu();  error_exit:	LOG_TSLP_TSK_LEAVE(ercd);	return(ercd);}

ERdly_tsk(RELTIM dlytim){	WINFO	winfo;	TMEVTB	tmevtb;	ER		ercd;	LOG_DLY_TSK_ENTER(dlytim);	CHECK_DISPATCH();	CHECK_PAR(dlytim <= TMAX_RELTIM);	t_lock_cpu();	p_runtsk->tstat = (TS_WAITING | TS_WAIT_DLY);	(void) make_non_runnable(p_runtsk);	p_runtsk->p_winfo = &winfo;	winfo.p_tmevtb = &tmevtb;	tmevtb_enqueue(&tmevtb, dlytim, (CBACK) wait_tmout_ok, (void *) p_runtsk);	LOG_TSKSTAT(p_runtsk);	dispatch();	ercd = winfo.wercd;	t_unlock_cpu();  error_exit:	LOG_DLY_TSK_LEAVE(ercd);	return(ercd);}

SYSCALL ERi_vtrcv_tmb(T_MSG **ppk_msg, TMO tmout)	{	ER	ercd = E_OK;    	CHECK_TMOUT(tmout);	CHECK_DISPATCH();	BEGIN_CRITICAL_SECTION;	if ( ctxtsk->tmq_head ) 		{		*ppk_msg = ctxtsk->tmq_head;		ctxtsk->tmq_head = nextmsg(*ppk_msg);		}	else 		{		ercd = E_TMOUT;		if ( tmout != TMO_POL ) 			{			ctxtsk->wspec = &wspec_tmb_tfifo;			ctxtsk->wgcb = (GCB *) 0;			ctxtsk->wercd = &ercd;			ctxtsk->winfo.tmb.ppk_msg = ppk_msg;			make_wait(tmout);			queue_initialize(&(ctxtsk->tskque));			}		}	END_CRITICAL_SECTION;	return(ercd);	}

JSP_L1_CODESYSCALL ERwai_sem(ID semid){	SEMCB	*semcb;	WINFO_WOBJ winfo;	ER	ercd;	LOG_WAI_SEM_ENTER(semid);	CHECK_DISPATCH();	CHECK_SEMID(semid);	semcb = get_semcb(semid);	t_lock_cpu();	if (semcb->semcnt >= 1) {		semcb->semcnt -= 1;		ercd = E_OK;	}	else {		wobj_make_wait((WOBJCB *) semcb, &winfo);		dispatch();		ercd = winfo.winfo.wercd;	}	t_unlock_cpu();    exit:	LOG_WAI_SEM_LEAVE(ercd);	return(ercd);}

SYSCALL ERrcv_mbx(ID mbxid, T_MSG **ppk_msg){	MBXCB	*mbxcb;	WINFO_MBX winfo;	ER	ercd;    	LOG_RCV_MBX_ENTER(mbxid, ppk_msg);	CHECK_DISPATCH();	CHECK_MBXID(mbxid);	mbxcb = get_mbxcb(mbxid);    	t_lock_cpu();	if (mbxcb->head != NULL) {		*ppk_msg = mbxcb->head;		mbxcb->head = (*ppk_msg)->next;		ercd = E_OK;	}	else {		wobj_make_wait((WOBJCB *) mbxcb, (WINFO_WOBJ *) &winfo);		dispatch();		ercd = winfo.winfo.wercd;		if (ercd == E_OK) {			*ppk_msg = winfo.pk_msg;		}	}	t_unlock_cpu();    exit:	LOG_RCV_MBX_LEAVE(ercd, *ppk_msg);	return(ercd);}

SYSCALL INT _tk_rcv_mbf_u( ID mbfid, void *msg, TMO_U tmout ){	MBFCB	*mbfcb;	TCB	*tcb;	INT	rcvsz;	ER	ercd = E_OK;	CHECK_MBFID(mbfid);	CHECK_TMOUT(tmout);	CHECK_DISPATCH();	mbfcb = get_mbfcb(mbfid);	BEGIN_CRITICAL_SECTION;	if (mbfcb->mbfid == 0) {		ercd = E_NOEXS;		goto error_exit;	}	/* Check receive wait disable */	if ( is_diswai((GCB*)mbfcb, ctxtsk, TTW_RMBF) ) {		ercd = E_DISWAI;		goto error_exit;	}	if ( !mbf_empty(mbfcb) ) {		/* Read from message buffer */		rcvsz = mbf_to_msg(mbfcb, msg);		/* Accept message from sending task(s) */		mbf_wakeup(mbfcb);	} else if ( !isQueEmpty(&mbfcb->send_queue) ) {		/* Receive directly from send wait task */		tcb = (TCB*)mbfcb->send_queue.next;		rcvsz = tcb->winfo.smbf.msgsz;		memcpy(msg, tcb->winfo.smbf.msg, (UINT)rcvsz);		wait_release_ok(tcb);		mbf_wakeup(mbfcb);	} else {		ercd = E_TMOUT;		if ( tmout != TMO_POL ) {			/* Ready for receive wait */			ctxtsk->wspec = &wspec_rmbf;			ctxtsk->wid = mbfid;			ctxtsk->wercd = &ercd;			ctxtsk->winfo.rmbf.msg = msg;			ctxtsk->winfo.rmbf.p_msgsz = &rcvsz;			make_wait(tmout, mbfcb->mbfatr);			QueInsert(&ctxtsk->tskque, &mbfcb->recv_queue);		}	}    error_exit:	END_CRITICAL_SECTION;	return ( ercd < E_OK )? ercd: rcvsz;}

ERtrcv_pdq(ID pdqid, intptr_t *p_data, PRI *p_datapri, TMO tmout){	PDQCB	*p_pdqcb;	WINFO_PDQ winfo_pdq;	TMEVTB	tmevtb;	bool_t	dspreq;	ER		ercd;	LOG_TRCV_PDQ_ENTER(pdqid, p_data, p_datapri, tmout);	CHECK_DISPATCH();	CHECK_PDQID(pdqid);	CHECK_MACV_WRITE(p_data, intptr_t);	CHECK_MACV_WRITE(p_datapri, PRI);	CHECK_TMOUT(tmout);	p_pdqcb = get_pdqcb(pdqid);	t_lock_cpu();	if (p_pdqcb->p_pdqinib->pdqatr == TA_NOEXS) {		ercd = E_NOEXS;	}	else if (VIOLATE_ACPTN(p_pdqcb->p_pdqinib->acvct.acptn2)) {		ercd = E_OACV;	}	else if (receive_pridata(p_pdqcb, p_data, p_datapri, &dspreq)) {		if (dspreq) {			dispatch();		}		ercd = E_OK;	}	else if (tmout == TMO_POL) {		ercd = E_TMOUT;	}	else if (p_runtsk->waifbd) {		ercd = E_RLWAI;	}	else {		p_runtsk->tstat = (TS_WAITING | TS_WAIT_RPDQ);		make_wait_tmout(&(winfo_pdq.winfo), &tmevtb, tmout);		queue_insert_prev(&(p_pdqcb->rwait_queue), &(p_runtsk->task_queue));		winfo_pdq.p_pdqcb = p_pdqcb;		LOG_TSKSTAT(p_runtsk);		dispatch();		ercd = winfo_pdq.winfo.wercd;		if (ercd == E_OK) {			*p_data = winfo_pdq.data;			*p_datapri = winfo_pdq.datapri;		}	}	t_unlock_cpu();  error_exit:	LOG_TRCV_PDQ_LEAVE(ercd, *p_data, *p_datapri);	return(ercd);}

ERloc_mtx(ID mtxid){	MTXCB		*p_mtxcb;	WINFO_MTX	winfo_mtx;	ER			ercd;	LOG_LOC_MTX_ENTER(mtxid);	CHECK_DISPATCH();	CHECK_ID(VALID_MTXID(mtxid));	p_mtxcb = get_mtxcb(mtxid);	lock_cpu_dsp();	if (p_mtxcb->p_mtxinib->mtxatr == TA_NOEXS) {		ercd = E_NOEXS;	}	else if (VIOLATE_ACPTN(p_mtxcb->p_mtxinib->acvct.acptn1)) {		ercd = E_OACV;	}	else if (MTX_CEILING(p_mtxcb)			&& p_mtxcb->p_mtxinib->ceilpri < p_runtsk->p_dominib->minpriority			&& VIOLATE_ACPTN(p_runtsk->p_dominib->acvct.acptn2)) {		ercd = E_OACV;									/*［NGKI5124］*/	}	else if (p_runtsk->raster) {		ercd = E_RASTER;	}	else if (MTX_CEILING(p_mtxcb)				&& p_runtsk->bpriority < p_mtxcb->p_mtxinib->ceilpri) {		ercd = E_ILUSE;	}	else if (p_mtxcb->p_loctsk == NULL) {		mutex_acquire(p_runtsk, p_mtxcb);		/*		 *  
C++ CHECK_DISPLAY函数代码示例
C++ CHECK_CONTEXT函数代码示例