基于消息机制的异步架构之回调函数注册

/*

* akg.h

*

业务逻辑注册

*

*/

#ifndef AKG_H_

#define AKG_H_

#include "conn.h"

#include "msgqueue.h"

#define MAX_PKG_TYPE (0xffff)

extern const uint16 g_akg_connected_id;

extern const uint16 g_akg_timeout_id;

extern const uint16 g_akg_closed_id;

extern const uint16 g_akg_error_id;

typedef int (*FUNC_PTR)(MSG* msg);//用户自定义相关函数

extern FUNC_PTR AKG_FUNC[MAX_PKG_TYPE];

typedef int (*FUNC_PTR_C)(CONN* c);//客户端连接相关函数

extern FUNC_PTR_C CLIENT_AKG_FUNC[MAX_PKG_TYPE];

#endif /* AKG_H_ */

/*

*

* akg.c

* 业务逻辑注册

*/

#include "akg.h"

const uint16 g_akg_connected_id = 0xfffc;//65532

const uint16 g_akg_timeout_id = 0xfffd;

const uint16 g_akg_closed_id = 0xfffe;

const uint16 g_akg_error_id = 0xffff;

FUNC_PTR AKG_FUNC[MAX_PKG_TYPE];

FUNC_PTR_C CLIENT_AKG_FUNC[MAX_PKG_TYPE];