📄 socket.h
字号:
#ifndef PHCLIENT_SOCKET_H
#define PHCLIENT_SOCKET_H
#include "MyOs.h"
#include "Constdef.h"
#define SOCKET_BUFFSIZE 8192 //注意, 这里单个包的大小不能超过该设置数值
#define SOCKET_RESULT_SUCCESS 0x00 //函数正常退出
#define SOCKET_RESULT_ECONNECT 0xFF //connect出错
#define SOCKET_RESULT_ECREATE 0xFE //建立Socket时出错.
#define SOCKET_RESULT_EOSERROR 0xF7 //操作系统指定的其它错误
#define SOCKET_RESULT_ENOTCONNECTED 0xFD //试图发送或者接收数据时SOCKET未连接
#define SOCKET_RESULT_ECANNOTWRITE 0xFC //试图发送数据时套接字不可写
#define PHLOGIN_SERVER_PORT 6060
#define PHLOGIN_SERVER_ADDR "PH051.ORAY.NET"
#define MAX_IP_LEN 16
typedef void ( *PFNProcessData )( void* pBuffer, int nLen );
int InitSocket( void );
int SendPacket( void* pBuffer, Uint32 Len );
void UninitSocket( void );
struct _PACKETQUEUENODE;
typedef struct
{
MY_CRITICAL cs;
MY_SEM sem;
struct _PACKETQUEUENODE *pFirstNode;
}SocketQueue;
#if 1
typedef struct
{
MY_SOCKET s;
SocketQueue SendQueue;
MY_CRITICAL ReconnectCS;
int bConnected;
MY_THREAD RecvThread;
MY_THREAD SendThread;
char PendingBuffer[ SOCKET_BUFFSIZE ];
int nPendingSize;
}SocketEntry;
typedef struct _PACKETQUEUENODE
{
SocketEntry *pEntry;
void *pBuffer;
int nLen;
struct _PACKETQUEUENODE *pNext;
}PacketQueueNode;
//将pPacket地址开始的缓冲区的nLen个字节数据加入到pQueue队列
void AddPacketToQueue( SocketQueue *pQueue, SocketEntry *pEntry, void* pPacket, int nLen );
//清除队列
void ClearQueue( SocketQueue *pQueue );
//初始化SocketQueue
void InitSocketQueue( SocketQueue *pQueue );
//释放SocketQueue
void UninitSocketQueue( SocketQueue *pQueue );
//取队首元素并删除
PacketQueueNode* GetQueueTopNode( SocketQueue *pQueue );
void Reconnect( SocketEntry *pEntry );
#endif
#endif
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -