GetQueuedCompletionStatus

GetQueuedCompletion 然後,當GetQueuedCompletion 對GetQueuedCompletion

GetQueuedCompletionStatus函式有個OVERLAPPED結構,很多資料上都採用不同的結構體來擴展該結構,比如有的資料定義:
typedef struct _OVERLAPPEDPLUS
{
OVERLAPPED ol;
SOCKET s, sclient;
int OpCode;
WSABUF wbuf;
DWORD dwBytes, dwFlags;
}OVERLAPPEDPLUS;
然後,當GetQueuedCompletionStatus(hIOCP, &dwBytesXfered,(PULONG_PTR)&PerHandleKey, &Overlap, INFINITE);函式返回時候,人們常用OverlapPlus = CONTAINING_RECORD(Overlap, OVERLAPPEDPLUS, ol)得到一些信息。比如此時連線埠上完成的是什麼操作,數據是什麼等,還有,系統如何做到自動填充上述的結構的,也就是說,系統怎么知道在Overlap->OpCode存放的應該是操作類型,如讀,寫操作,而在Overlap->wbuf存放的應該是讀寫數據。
Overlap->OpCode,操作類型是在投遞WSASend,WSARecv的時候,由你自己指定填充這個欄位。
因為是非堵塞的,等於投遞到與套接字相關聯的完成連線埠上,系統會把把WSASend對應的緩衝區提交到底層緩衝,也可以把WSARecv投遞的緩衝區,用接收到的數據填充,每一個WSASend,WSARecv,都應有新申請一個overlaspped plus結構提交,以存放本次投遞的IO操作的相關數據,――單IO運算元據所以工作器執行緒中,從完成連線埠佇列中get得到一個完成包的時候,可以根據單句柄數據知道在這個完成連線埠上是哪一個套接字投遞的IO操作完成了,從get到的overlapped中得到相關的已經完成IO數據和信息,並作相應的處理。比如投遞了1M,完成包卻告知只完成512K,那么你就知道要把餘下的512K繼續投遞WSASend,當然上一個WSASend的Overlapped這個時候可以重用到下一個WSASend中,這個是允許的,可以用一個欄位存放全部1M,把餘下未Send成功512k放到wbuf中,繼續投遞或者投遞WSARecv1M數據,卻收到一個512K的完成通知,那么你要繼續投遞WSARecv,當然前一個WSARecv的overlapped也可以重用,不過需要一些處理,把已經接收到的512K保存到某個欄位中,再投遞一個512K的請求去接收完成連線埠內部,對投遞的Overlapped的填充,好像只有WSARecv的時候填充WSABUF,其他都是投遞IO前,代碼中顯式填充,並投遞的。至於完成了多少個位元組,是在lpNumberOfBytes中得到。
對GetQueuedCompletionStatus函式解釋:
實現從指定的IOCP獲取CP。當CP佇列為空時,對此函式的調用將被阻塞,而不是一直等待I/O的完成。當CP佇列不為空時,被阻塞的執行緒將以後進先出(LIFO)順序被釋放。對於IOCP機制,它允許多執行緒並發調用GetQueuedCompletionStatus函式,最大並發數是在調用CreateIoCompletionPort函式時指定的,超出最大並發數的調用執行緒,將被阻塞。函式解釋如下:
聲明:
BOOL GetQueuedCompletionStatus(
HANDLE CompletionPort,
LPDWORD lpNumberOfBytes,
PULONG_PTR lpCompletionKey,
LPOVERLAPPED *lpOverlapped,
DWORD dwMilliseconds);
調用參數:
CompletionPort:指定的IOCP,該值由CreateIoCompletionPort函式創建。
lpnumberofbytes:一次完成後的I/O操作所傳送數據的位元組數。
lpcompletionkey:當檔案I/O操作完成後,用於存放與之關聯的CK。
lpoverlapped:為調用IOCP機制所引用的OVERLAPPED結構。
dwmilliseconds:用於指定調用者等待CP的時間。
返回值:
調用成功,則返回非零數值,相關數據存於lpNumberOfBytes、lpCompletionKey、lpoverlapped變數中。失敗則返回零值。

相關詞條

相關搜尋

熱門詞條

聯絡我們