CIOCP自定义帮助函数

                                                 1 客户链接列表                                                               

m_pConnectionList指向客户链接列表，描述全部链接的CIOCPContext对象组成的表

AddAConnnection函数向列表中加入一个CIOCPContext对象。若是到达最大数量返回FALSE

CloseAConnnection函数关闭指定的客户链接

CloseAllConnection函数遍历整个链接列表，关闭全部的客户套接字

             　　　　　　　　　　2 抛出接收请求的列表　　　　　　　　　　　　　　　　

全部未决的accept请求都在m_pPendingAccepts指向的列表中

InsertPendingAccept函数将一个IO缓冲区对象插入到m_pPendingAccepts表中

RemovePendingAccept函数遍历这个表，从中移除指定的缓冲区对象

　　　　　　　　　　　　　　　　3 序列化读操做　　　　　　　　　　　　　　　　　　　　　　

为保证异步读操做投递顺序完成，为每一个链接投递读请求分配一个序列号。

pOutOfOederReads列表中的元素是按照其序列号从小到大的顺序排列的

GetNextReadBuffer函数:

　　以客户上下文   和   读操做完成缓冲区对象  为参数，以正确的顺序返回这个客户发送的下一个缓冲区对象

主要函数代码：

CIOCPBuffer *CIOCPServer::GetNextReadBuffer(CIOCPContext *pContext,CIOCPBuffer *pBuffer) { if(pBuffer !=NULL) { if(pBuffer->nSequenceNumber == pContext->nCurrentReadSequence) return pBuffer; pBuffer->pNext = NULL; CIOCPBuffer *ptr = pContext->pOutOfOrderReads; CIOCPBuffer *pPre = NULL; while(ptr!=NULL) { if(pBuffer->nSequenceNumber < ptr->nSequenceNumber) break; pPre = ptr; ptr = ptr->pNext; } if(pPre == NULL) { pBuffer->pNext = pContext->pOutOfOrderReads; pContext->pOutOfOrderReads = pBuffer; } else { pBuffer->pNext = pPre->pNext; pPre->pNext = pBuffer; } } CIOCPBuffer *ptr = pContext->pOutOfOrderReads; if(ptr!=NULL &&(ptr->nSequenceNumber == pContext->nCurrentReadSequence)) { pContext->pOutOfOrderReads = ptr->pNext; return ptr; } return NULL }

　　　　　　　　　　　　　　　　4　 投递重叠IO　　　　　　　　　　　　　　　　　　　　　　

PostAccept 　　PostSend 　　PostRecv函数分别用于在套接字上投递AcceptIO　　SendIO 　　RecvIO

PostRecv代码比其余两个多了一个投递序列号..其余的都差很少，代码以下：

BOOL CIOCPServer::PostRecv(CIOCPContext *pContext,CIOCPBuffer *pBuffer) { pBuffer->nOperation = OP_READ; ::EnterCriticalSection(&pContext->Lock); pBuffer->nSequenceNumber = pContext->nSequenceNumber; DWORD dwBytes; DWORD dwFlags= 0; WSABUF buf; buf.buf = pBuffer->buff; buf.len = pBuffer->nLen; if(::WSARecv(pContext->s,&buf,1,&dwBtytes,&dwFlags,&pBuffer->ol,NULL)!=NO_ERROR) { ::LeaveCriticalSection(&pContext->Lock); return FALSE; } pContext->nOutstandingRecv++; pContext->nReadSequence++; ::LeaveCriticalSection(&pContext->Lock); return TRUE; }