acl/lib_acl/include/msg/acl_msgio.h

75 lines
2.3 KiB
C
Raw Normal View History

2014-11-19 00:25:21 +08:00
#ifndef ACL_MSGIO_INCLUDE_H
#define ACL_MSGIO_INCLUDE_H
#ifdef __cplusplus
extern "C" {
#endif
2017-06-02 14:47:24 +08:00
#include "../stdlib/acl_define.h"
#include "../stdlib/acl_vstring.h"
#include "../stdlib/acl_ring.h"
#include "../aio/acl_aio.h"
2014-11-19 00:25:21 +08:00
typedef struct ACL_MSGIO ACL_MSGIO;
typedef struct ACL_MSGIO_INFO ACL_MSGIO_INFO;
typedef int (*ACL_MSGIO_NOTIFY_FN)(int msg_type, ACL_MSGIO *peer,
const ACL_MSGIO_INFO *info, void *arg);
/**
* <EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD>Ͷ<EFBFBD><EFBFBD><EFBFBD>
*/
#define ACL_MSGIO_OK 0
#define ACL_MSGIO_TIMEOUT 1 /* <20><>ʱ<EFBFBD><CAB1>Ϣ */
#define ACL_MSGIO_EXCEPT 2 /* <20><EFBFBD><ECB3A3>Ϣ */
#define ACL_MSGIO_CONNECT 3 /* <20><><EFBFBD>ӳɹ<D3B3><C9B9><EFBFBD>Ϣ */
#define ACL_MSGIO_CONNECT_TIMEOUT 4 /* <20><><EFBFBD>ӳ<EFBFBD>ʱ<EFBFBD><CAB1>Ϣ */
#define ACL_MSGIO_QUIT 5 /* <20>˳<EFBFBD><CBB3><EFBFBD>Ϣ */
#define ACL_MSGIO_OPEN 6 /* <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ */
#define ACL_MSGIO_USER 1000
struct ACL_MSGIO_INFO {
struct {
int type;
int dlen;
} hdr;
struct {
ACL_VSTRING *buf;
} body;
};
ACL_API void acl_msgio_init(void);
ACL_API void acl_msgio_close(ACL_MSGIO *mio);
ACL_API void acl_msgio_reg(ACL_MSGIO *mio, int id,
ACL_MSGIO_NOTIFY_FN callback, void *arg);
ACL_API void acl_msgio_listen_reg(ACL_MSGIO *mio, int id,
ACL_MSGIO_NOTIFY_FN callback, void *arg, int inherit);
ACL_API void acl_msgio_unreg(ACL_MSGIO *mio, int id, ACL_MSGIO_NOTIFY_FN callback);
ACL_API void acl_msgio_unreg_id(ACL_MSGIO *mio, int id);
ACL_API void acl_msgio_unreg_all(ACL_MSGIO *mio);
ACL_API int acl_msgio_wait(ACL_MSGIO *mio);
ACL_API ACL_MSGIO *acl_msgio_listen(ACL_AIO *aio, const char *addr);
ACL_API ACL_MSGIO *acl_msgio_accept(ACL_MSGIO *listener);
ACL_API ACL_MSGIO *acl_msgio_connect(ACL_AIO *aio, const char *addr, int timeout);
ACL_API void acl_msgio_set_noblock(ACL_AIO *aio, ACL_MSGIO *mio);
ACL_API int acl_msgio_send(ACL_MSGIO *mio, int type, void *data, int dlen);
/* void acl_msgio_timer(ACL_MSGIO *mio, ACL_MSGIO_NOTIFY_FN callback, void *arg); */
ACL_API void acl_msgio_addr(const ACL_MSGIO *mio, char *buf, size_t size);
ACL_API ACL_AIO *acl_msgio_aio(ACL_MSGIO *mio);
ACL_API ACL_VSTREAM *acl_msgio_vstream(ACL_MSGIO *mio);
ACL_API ACL_ASTREAM *acl_msgio_astream(ACL_MSGIO *mio);
#define ACL_MSGIO_ON_MSG(id, callback, arg) do { \
acl_msgio_reg(NULL, id, callback, arg); \
} while(0)
#ifdef __cplusplus
}
#endif
#endif