sys_que.h

abstract rtos

#ifdef __cplusplus
#if __cplusplus
extern "C"{
#endif 
#endif 

#ifndef __INC_SYS_QUE_H__
#define __INC_SYS_QUE_H__








typedef struct mq_des
{
    U32 magic_num;                   
    S8   name[AOS_NAME_LEN]; 
    SYS_SEM_T sm_read;            
    SYS_SEM_T sm_write;           
    
    U32 mq_flags;                      
    U32 mq_maxmsg;                
    U32 mq_msgsize;                
    S32 mq_curmsgs;               
    
    U32 read_idx;                    
    U32 write_idx;                   

    U8   msg[4];                      
}*SYS_MQD_T;




U32 sys_mq_create( S8 name[AOS_NAME_LEN+1], U32 flags, U32 maxmsg, U32 msgsize, SYS_MQD_T*mqp );
U32 sys_mq_cancel( SYS_MQD_T mqdes );
U32 sys_mq_send( SYS_MQD_T mqdes, U8 *ptr, U32 length, U32 timeout );
U32 sys_mq_receive( SYS_MQD_T mqdes , U8 *ptr, U32 length, U32 timeout );
U32 sys_mq_trysend( SYS_MQD_T mqdes, U8 *ptr, U32 length );
U32 sys_mq_tryreceive( SYS_MQD_T mqdes , U8 *ptr, U32 length );
U32 sys_mq_curmsgs( SYS_MQD_T mqdes );
U32 sys_mq_info( SYS_MQD_T mqdes, U32 *pFlags, U32 *pulMaxMsg, U32 *pulMsgSize);

#endif

#ifdef __cplusplus
#if __cplusplus
}
#endif 
#endif