que_pub.h

abstract rtos

#ifdef __cplusplus
extern "C"{
#endif 

#ifndef __INC_QUE_PUB_H__
#define __INC_QUE_PUB_H__






#define QUE_MOD_INIT_FAIL        AOS_MAKE_ERRNO(MPE_QUE, 1)
#define QUE_INVALID_POINTER_PARA AOS_MAKE_ERRNO(MPE_QUE, 2)
#define QUE_SYS_CREATE_FAIL      AOS_MAKE_ERRNO(MPE_QUE, 3)
#define QUE_SYS_CANCEL_FAIL      AOS_MAKE_ERRNO(MPE_QUE, 4)
#define QUE_INVALID_QUE_ID       AOS_MAKE_ERRNO(MPE_QUE, 5)
#define QUE_UNAVAILABLE          AOS_MAKE_ERRNO(MPE_QUE, 6)
#define QUE_TIMEOUT              AOS_MAKE_ERRNO(MPE_QUE, 7)
#define QUE_SYS_CALL_FAIL        AOS_MAKE_ERRNO(MPE_QUE, 8)
#define QUE_CREATE_NOMEM         AOS_MAKE_ERRNO(MPE_QUE, 9)





U32 m_mque_init();
U32 aos_mq_create( S8 name[AOS_NAME_LEN+1], U32 flags, U32 ulMaxMsg, U32 ulMsgSize, U32*pulMqId );
U32 aos_mq_cancel( U32 ulMqId );
U32 aos_mq_send( U32 ulMqId, U8 *pMsgPtr, U32 ulMsgLen, U32 ulTimeOut );
U32 aos_mq_receive( U32 ulMqId , U8 *pMsgPtr, U32 ulMsgLen, U32 ulTimeOut );
U32 aos_mq_trysend( U32 ulMqId, U8 *pMsgPtr, U32 ulMsgLen );
U32 aos_mq_tryreceive( U32 ulMqId , U8 *pMsgPtr, U32 ulMsgLen );
U32 aos_mq_curmsgs( U32 ulMqId );
U32 aos_mq_info( U32 ulMqId, U32 *pFlags, U32 *pulMaxMsg, U32 *pulMsgSize);

#endif


#ifdef __cplusplus
}
#endif