px_ls_module_rs.h

MMORPG游戏服务器端架构及函数

#pragma	  once

/* must been first include begin */
#include "..\ProjectX_Common\ProjectX_Copyright.h"
#include "..\ProjectX_Common\ProjectX_Common.h"
/* must been first include end */

/* std and common include */
#include <windows.h>
#include <stdio.h>
#include <stdlib.h>


typedef struct tagPx_LS_RS {
	CRITICAL_SECTION *	cts_state;
	CRITICAL_SECTION *	cts_recv;
	CRITICAL_SECTION *	cts_send;
	int					size_recv_append;
	int					size_send_append;
	int					last_handled_frame;
	byte				send_sign;
	char			*	recv_buf;
	char			*	precv_start;
	char			*	precv_end;
	char			*	precv_append;
	char			*	send_buf;
	char			*	psend_start;
	char			*	psend_end;
	char			*	psend_append; 
}PX_LS_RS, * LPPX_LS_RS;

typedef struct tagPx_LS_RS_Per_Data {
	PX_LS_RS * pmodule_rs;
}PX_LS_RS_PER_DATA, * LPPX_LS_RS_PER_DATA;

typedef struct tagPx_LS_RS_Io_Data {
	OVERLAPPED	overlapped;
	char *		buf;
	int			size;
	byte		io_type;
	WSABUF		wsabuf;
}PX_LS_RS_IO_DATA, * LPPX_LS_RS_IO_DATA;

void init_module_rs(void);
void set_module_rs_state(byte state);
BOOL valid_module_rs_state(byte state);
void set_module_rs_send_state(byte state);
void close_module_rs(void);
void free_module_rs_resource(void);

void add_buf_to_module_rs_recv_buf(int size,char * packet);
void update_module_rs_send_buf(int size);
int get_module_rs_send_buf(char * packet);
void tidy_module_rs_recv_buf(void);
void tidy_module_rs_send_buf(void);

void handle_module_rs_recv_buf(void);

void handle_module_rs_status_refresh(void);
void handle_module_rs_heartbreak(void);

void tell_module_rs_close_all_client();
void tell_module_rs_ls_need_close();

void module_rs_packet(WORD mc,int size,char * packet);
void messagecode_module_rs_ack_request_connect(int size, char * packet);
void messagecode_module_rs_need_version(int size, char * packet);
void messagecode_module_rs_ack_version_check(int size, char * packet);
void messagecode_module_rs_need_md5_code(int size, char * packet);
void messagecode_module_rs_ack_md5_code_check(int size, char * packet);
void messagecode_module_rs_need_special_code(int size, char * packet);
void messagecode_module_rs_ack_special_code_check(int size, char * packet);
void messagecode_module_rs_request_status(int size, char * packet);
void messagecode_module_rs_send_heartbreak(int size, char * packet);
void messagecode_module_rs_request_close(int size, char * packet);
void messagecode_module_rs_request_close_now(int size, char * packet);
void messagecode_module_rs_newclient_connect(int size, char * packet);
void messagecode_module_rs_client_disconnect(int size, char * packet);
void messagecode_module_rs_client_packet(int size, char * packet);
void messagecode_module_rs_info_from_broadcast(int size, char * packet);
void messagecode_module_rs_info_from_third_ls(int size, char * packet);
void messagecode_module_rs_doubt_client_ah(int size, char * packet);

DWORD WINAPI module_rs_connect_thread(PVOID paparm);
DWORD WINAPI module_rs_iocp_thread(PVOID paparm);