socket.h

来自「可以在linux下使用的ddns的测试程式」· C头文件 代码 · 共 80 行

#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