/* DMW_MsgQue.h */ #ifndef __DMW_MSGQUE_H__ #define __DMW_MSGQUE_H__ typedef struct { UINT8 *MsgBuf; int nMsgSize; // Msg 한개의 크기. 사용자 정의 type의 sizeof() 크기라고 보면 된다. int nMaxQueSize; int nNumberMsg; DHL_OS_SEMA_ID Mutex; DHL_OS_SEMA_ID Sema4; // counting sema4 char *(*pfnMsgName)(void *pMsg); } DMW_MSGQUE; typedef char *(*DMW_FN_MSG_NAME)(void *msg); typedef BOOL (*DMW_FN_MSG_CHECK)(void *msg, UINT32 param); typedef void (*DMW_FN_MSG_DELETE)(void *msg); STATUS DMW_SYS_InitMsgQue(DMW_MSGQUE *hMsgQue, int nMsgSize, int nInitialQueSize, DMW_FN_MSG_NAME pfnName); // MsgQue를 초기화 한다. // nMsgSize는 사용자 메시지 하나의 byte 크기이다. // pfnName은 디버깅 용도로 사용되며, 각 메시지에 이름을 부여하여 consol에 출려할 때 사용. // 사용하지 않으려면 NULL을 지정한다. STATUS DMW_SYS_AddUserMsg(DMW_MSGQUE *hMsgQue, void *pMsg); STATUS DMW_SYS_GetUserMsg(DMW_MSGQUE *hMsgQue, void *pMsg, UINT32 uTimeoutTicks); // timeout 은 MsgQue에 메시지가 없는 경우 기다리게 될 시간이다. // 0 이면 기다리지 않음. 메시지가 없으면 바로 에러를 리턴한다. // (UINT32)-1 이면 timeout 없이 무한정 기다린다. // timeout 값은 OS tick 단위임. BOOL DMW_SYS_UserMsgExist(DMW_MSGQUE *hMsgQue); // 메시지가 하나라도 존재하면 true를 리턴. BOOL DMW_SYS_CheckSpecificMsgExist(DMW_MSGQUE *hMsgQue, DMW_FN_MSG_CHECK pfnCheck, UINT32 param); // 특정 메시지가 존재하는지 체크할 때 사용. // 메시지 비교 (comparion check) 함수 포인터를 인자로 제공해야 한다. STATUS DMW_SYS_DeleteMsgConditionally(DMW_MSGQUE *hMsgQue, DMW_FN_MSG_CHECK fnCondition, UINT32 param, DMW_FN_MSG_DELETE fnDelete); // 특정 조건에 맞는 메시지를 Queue에서 삭제. // void DMW_SYS_PrintUserMsgs(DMW_MSGQUE *hMsgQue, DMW_FN_MSG_NAME fnName2); // 메시지 큐의 내용을 consol에 표시. // 메시지는 그냥 void * 로 간주되어 저장되었기 때문에 // 어떤 메시지인지를 알려주는 naming function을 제공해야 각 메시지를 구별해 볼수 있다. // 여기서 인자로 지정한 naming function이 MsgQue를 처음 생성할 때 // 지정했던 naming function 보다 우선한다. // 즉 fnName2가 NULL이면 pfnName을 사용함. #endif // __DMW_MSGQUE_H__