--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/cs/riviera/rvf/rvf_msg.c	Sun Sep 25 22:50:11 2016 +0000
@@ -0,0 +1,194 @@
+/****************************************************************************/
+/*                                                                          */
+/*  Name        rvf_msg.c                                                */
+/*                                                                          */
+/*  Function    this file contains rvf message handling functions            */
+/*                                                                          */
+/*  Version		0.1															*/
+/*																			*/
+/* 	Date       	Modification												*/
+/*  ------------------------------------									*/
+/*  18-March-2002															*/
+/*																			*/
+/* (C) Copyright 2002 by Texas Instruments Incorporated, All Rights Reserved*/
+/****************************************************************************/
+
+#include "rvf/rvf_api.h"
+#include "rvf/rvf_i.h"
+#include "rvm/rvm_use_id_list.h"
+#include "rvm/rvm_api.h"	// RVM_TMS_MSG & RVM_MSG_OFFSET
+
+// PRIVATE
+static const UINT8	BOUNDBUFVAL=20; 
+T_RVF_RET _send_msg (T_RVF_G_ADDR_ID addr_id, void *msg, UINT8 mbox, UINT8 bindbuf);
+
+/*******************************************************************************
+**
+** Function         rvf_get_msg_buf
+**
+** Description      Request for a message buffer.  
+**					Automatically update the message id of the buffer
+**
+**
+** Returns          T_RVF_MB_STATUS:	RVF_GREEN if everything is ok,
+**										RVF_YELLOW if watermark limit has been reached,
+**										RVF_RED if max size has been reached (does not return a buffer)
+**
+*******************************************************************************/
+T_RVF_MB_STATUS rvf_get_msg_buf(T_RVF_MB_ID mb_id,
+								UINT32 message_size,
+								T_RVF_MSG_ID msg_id,
+								T_RVF_MSG ** pp_msg)
+{
+
+	T_RVF_MB_STATUS mb_status;
+
+
+	mb_status = rvf_get_buf(mb_id,message_size,(T_RVF_BUFFER**) pp_msg);
+
+	if (mb_status != RVF_RED)
+	{
+		(*pp_msg)->msg_id = msg_id;
+	}
+
+	return mb_status;
+}
+
+
+
+/*******************************************************************************
+**
+** Function         rvf_fre_msg
+**
+** Description      Deallocate a message buffer
+**
+**
+** Returns          T_RVF_RET:	T_RVF_OK if succesful,...
+**
+*******************************************************************************/
+T_RVF_RET rvf_free_msg(T_RVF_MSG *p_msg)
+{
+	return rvf_free_buf( (T_RVF_BUFFER *)  p_msg);
+}
+
+T_RVF_RET rvf_free_timer_msg(T_RVF_MSG *p_msg)
+{
+	return rvf_free_buf( (T_RVF_BUFFER *)  p_msg);
+}
+
+
+/*******************************************************************************
+**
+** Function         rvf_send_msg
+**
+** Description      Called by applications to send a buffer to a SWE.
+**
+** Returns			RVF_OK if successful, else an error code.
+**
+** Comments			Priority is defined the inverse of NU. for legacy reasons
+*******************************************************************************/
+T_RVF_RET rvf_send_msg (T_RVF_G_ADDR_ID addr_id, void *msg) {
+	return _send_msg ( addr_id, msg, 0, FALSE);
+}
+
+T_RVF_RET rvf_send_priority_msg (T_RVF_G_ADDR_ID addr_id, void *msg) {
+	return _send_msg ( addr_id, msg, 1, TRUE);
+}
+
+T_RVF_RET _send_msg (T_RVF_G_ADDR_ID addr_id, void *msg, UINT8 mbox, UINT8 bindbuf) {
+    T_RVF_INTERNAL_BUF    *p_hdr;
+	T_RVF_INTERNAL_BUF*	cur=NULL;
+	UINT8 i=0;   
+	T_RVF_G_ADDR_ID tid=RVF_INVALID_ADDR_ID;
+
+    /* If task non-existant or not started, drop buffer */
+    if ((addr_id >= MAX_RVF_G_ADDR_ID)) {
+        rvf_send_trace( "RVF: rvf_send_msg(): invalid taskid", 35, NULL_PARAM, RV_TRACE_LEVEL_ERROR, RVM_USE_ID );
+        rvf_free_buf (msg);
+        return RVF_INVALID_PARAMETER;
+    }
+	if((tid=resolveHostAddrId(addr_id))==RVF_INVALID_ADDR_ID) {
+		rvf_free_buf (msg);
+		return RVF_INTERNAL_ERR;
+	}
+	if(!pRtAddrIdTable[tid]) {
+		rvf_free_buf (msg);
+		return RVF_INTERNAL_ERR;
+	}
+
+	// Reject all msg or only continuous tm msg if bound buf limit
+	if(bindbuf) {
+		for(i=0, cur=pRtAddrIdTable[tid]->OSTaskQFirst[mbox];
+				 cur && cur->p_next; cur=cur->p_next, i++) ;
+		if(((T_RV_HDR*)msg)->msg_id==RVM_TMS_MSG) {
+			if(i>=BOUNDBUFVAL && ((T_RVF_TMS_MSG*)msg)->cont) {
+				rvf_free_buf(msg);
+				return RVF_MEMORY_ERR;
+			}
+		} else {
+			if(i>=BOUNDBUFVAL) {
+				rvf_free_buf(msg);
+				return RVF_MEMORY_ERR;
+			}
+		}
+	}
+
+#if RVF_ENABLE_BUF_CORRUPTION_CHECK	
+	/* check for buffer corruption */
+	if (_rvf_chk_buf_damage(msg) == TRUE)
+    {	rvf_send_trace( "RVF: rvf_send_msg(): buffer corrupted", 37, NULL_PARAM, RV_TRACE_LEVEL_ERROR, RVM_USE_ID );
+	}
+#endif
+
+	/* update the addr_id field of the message */
+	((T_RV_HDR *)msg)->dest_addr_id = addr_id;
+	p_hdr = USER2MEM(msg);
+
+#if RVF_ENABLE_BUF_LINKAGE_CHECK
+    /* check if the buffer has been already enqueued */
+	if ( RVF_BUF_IS_LINKED( p_hdr) )
+	{
+		rvf_send_trace( "RVF: rvf_send_msg(): buffer already enqueued", 44, NULL_PARAM, RV_TRACE_LEVEL_ERROR, RVM_USE_ID );
+        return RVF_MEMORY_ERR;
+    }
+#endif
+
+    rvf_disable(8);		/* enter critical section */
+
+	/* chained the buffer in the mailbox list */
+    /*if (OSTaskQFirst[task_id][mbox])	{
+		OSTaskQLast[task_id][mbox]->p_next = p_hdr;
+	} else {
+		OSTaskQFirst[task_id][mbox] = p_hdr;
+	}
+    OSTaskQLast[task_id][mbox] = p_hdr;
+	p_hdr->p_next = NULL;*/
+
+	if (pRtAddrIdTable[tid]->OSTaskQFirst[mbox]) {
+		pRtAddrIdTable[tid]->OSTaskQLast[mbox]->p_next = p_hdr;
+	} else	{	
+		pRtAddrIdTable[tid]->OSTaskQFirst[mbox] = p_hdr;
+	}
+    pRtAddrIdTable[tid]->OSTaskQLast[mbox] = p_hdr;
+
+	p_hdr->p_next = NULL;
+
+#if RVF_ENABLE_BUF_LINKAGE_CHECK
+	RVF_SET_BUF_LINKED(p_hdr);	/* change buffer status */
+#endif
+
+    rvf_enable(); 
+
+	/* send a rvf event  */
+    rvf_send_event(tid, (UINT16) (EVENT_MASK(mbox)) );
+
+	return RVF_OK;
+}
+
+// Poss. Deprecate ! [Only used by: rvf.Buffer::_rvf_send_msg_to_mbox() ]
+// May conflict with "msg::rvf_send_priority_msg()"
+T_RVF_RET rvf_adapt_send_msg (T_RVF_G_ADDR_ID addr_id, void *msg, UINT8 mbox) {
+	return _send_msg ( addr_id, msg, mbox, FALSE); 
+}
+
+