message.c

minitos是一个实时的嵌入式操作系统

/*
	miniTOS V0.1.3  1998-2004 (c) 林良水 (Lin LS)
	miniTOS是一个开放源码的软件，授权LGPL，但开发人员不保证本软件的可靠性，
以及对您的损失负任何责任。
	www.minitos.com

	本文实现miniTOS进程之间消息的传递。

	create by Lin LS ,1998.10
*/
#include <stdio.h>

#include "minitosdef.h"
#include "extdefine.h"

/*********************************************************************************
**Function: 发送Msg 给指定的进程 dest,若发送不成功不挂起本进程。
**Input:
**OutPut:
**Return: 0--SUCC
**********************************************************************************/
int SendMessage(struct ProcTbl * dest,void * Msg)
{
	if(dest==NULL)
		return ERR_DEST;
	if(dest->ptrMsg==NULL)
	{
		dest->ptrMsg=Msg;
		if ( (dest->status)&1==1)	//Is dest Block for waiting Message? 
		{				//yes; unBlock it
			ready(dest);
			sched();	
				//这里的status不需要改变，由Receive来改变。	
		}
		return 0;
	}
	return ERR_MSGFULL;
}
/*********************************************************************************
**Function: 接收一条消息，若没有消息挂起本进程。
**Input: 
**Output: Msg--接收到的消息
**Return: 0--SUCC
**********************************************************************************/
int ReceiveMessageSuspend(void * Msg)
{
	if(ptrCurrProc->ptrMsg!=NULL)
	{	//there is Msg in current process.
		Msg=ptrCurrProc->ptrMsg;	//get  msg
		ptrCurrProc->ptrMsg=NULL;
		return 0;
	}
	// No Msg in,Block current Process.
	ptrCurrProc->status|=0x01;  //set status bit mean blocking for waiting msg
	unready(ptrCurrProc);
	sched();	//等待接收msg
	//---------------------------------------------
	//接收到Msg ,restart this process
	ptrCurrProc->status&=0xFE;	//bit.0 clear to 0
	if(ptrCurrProc->ptrMsg==NULL)
	{
		return ERR_MSGEMPTY;
	}
	Msg=ptrCurrProc->ptrMsg;	//get  msg
	ptrCurrProc->ptrMsg=NULL;
	return 0;
}


/*
使用说明

char MsgBuf[100];
void idle1(void)
{
	CreatMailBox(MAILBOX	* ptrMailBox,void * MailBoxBuf);
	for(;;)
	{
		SendOneChar(1,'1');
		ReceiveMessageSuspend(MsgBuf);  // 1---IPC Message 

	}
}

void idle2(void)
{
	for(;;)

	{
		SendOneChar(1,'2');
		SendMessage(&Proc[0],MsgBuf);	//1--IPC Message,dest = Proc[0]=idle1	
	}
}

*/