#ifndef __MSG_MGR_DEF_
|
#define __MSG_MGR_DEF_
|
|
#include "shm_allocator.h"
|
|
#define SEM_TYPE_ID 0
|
#define RSV_TYPE_ID 1
|
|
#define MSG_TYPE_SEM 1
|
#define MSG_TYPE_RSV 2
|
|
#define SEM_CREATE 0
|
#define SEM_GET 1
|
#define SEM_POST 2
|
#define SEM_RM 3
|
#define SEM_RESET 4
|
|
#define MSG_PATH "/tmp/msgqueue"
|
#define MSG_RSV_PATH "/tmp/msgqueue_rsv"
|
|
#define QUERY_MUTEX_KEY 0x8700
|
|
#define MAX_LOCK 100
|
#define MAX_LOCK_HOLD 10
|
|
#define SEM_WT_TIMEOUT 60
|
|
typedef struct _msg_info
|
{
|
long mtype;
|
int key;
|
int id;
|
int act;
|
int count;
|
|
} Msg_info;
|
|
int msg_init(void);
|
void msg_distrib(int msg_id, Msg_info *message);
|
int get_msg_info(int msg_id, Msg_info *message);
|
void *sem_msg_handler(void *skptr);
|
void msg_info_set(int index, Msg_info msg_obj);
|
|
typedef std::set<int, std::less<int>, SHM_STL_Allocator<int> > recvbuf_val;
|
typedef std::map<int, recvbuf_val *, std::less<int>, SHM_STL_Allocator<std::pair<int, recvbuf_val *> > > recvbuf_data;
|
|
#endif //end of file
|
