FreeCalypso > hg > fc-magnetite
view src/cs/riviera/rvf/rvf_msg.c @ 468:79bc5876eb98
romvecs-patch: actual patch for xxd created
author | Mychaela Falconia <falcon@freecalypso.org> |
---|---|
date | Sun, 25 Mar 2018 01:28:30 +0000 |
parents | 945cf7f506b2 |
children |
line wrap: on
line source
/****************************************************************************/ /* */ /* 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); }