• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            twzheng's cppblog

            『站在風口浪尖緊握住鼠標旋轉(zhuǎn)!』 http://www.cnblogs.com/twzheng

              C++博客 :: 首頁 :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理 ::
              136 隨筆 :: 78 文章 :: 353 評論 :: 0 Trackbacks

            GetQueuedCompletionStatus函數(shù)有個OVERLAPPED結(jié)構(gòu),很多資料上都采用不同的結(jié)構(gòu)體來擴展該結(jié)構(gòu),比如有的資料定義:
            typedef struct _OVERLAPPEDPLUS
            {
            OVERLAPPED ol;
            SOCKET s, sclient;
            int OpCode;
            WSABUF wbuf;
            DWORD dwBytes, dwFlags;
            }OVERLAPPEDPLUS;

            然后,當GetQueuedCompletionStatus(hIocp, &dwBytesXfered,(PULONG_PTR)&PerHandleKey, &Overlap, INFINITE);函數(shù)返回時候,人們常用OverlapPlus = CONTAINING_RECORD(Overlap, OVERLAPPEDPLUS, ol)得到一些信息。比如此時端口上完成的是什么操作,數(shù)據(jù)是什么等,還有,系統(tǒng)如何做到自動填充上述的結(jié)構(gòu)的,也就是說,系統(tǒng)怎么知道在Overlap->OpCode存放的應(yīng)該是操作類型,如讀,寫操作,而在Overlap->wbuf存放的應(yīng)該是讀寫數(shù)據(jù)。


            Overlap->OpCode,操作類型是在投遞WSASend,WSARecv的時候,由你自己指定填充這個字段。

            因為是非堵塞的,等于投遞到與套接字相關(guān)聯(lián)的完成端口上,系統(tǒng)會把把WSASend對應(yīng)的緩沖區(qū)提交到底層緩沖,也可以把WSARecv投遞的緩沖區(qū),用接收到的數(shù)據(jù)填充,每一個WSASend,WSARecv,都應(yīng)有新申請一個overlaspped plus結(jié)構(gòu)提交,以存放本次投遞的IO操作的相關(guān)數(shù)據(jù),——單IO操作數(shù)據(jù)所以工作器線程中,從完成端口隊列中g(shù)et得到一個完成包的時候,可以根據(jù)單句柄數(shù)據(jù)知道在這個完成端口上是哪一個套接字投遞的IO操作完成了,從get到的overlapped中得到相關(guān)的已經(jīng)完成IO數(shù)據(jù)和信息,并作相應(yīng)的處理。比如投遞了1M,完成包卻告知只完成512K,那么你就知道要把余下的512K繼續(xù)投遞WSASend,當然上一個WSASend的Overlapped這個時候可以重用到下一個WSASend中,這個是允許的,可以用一個字段存放全部1M,把余下未Send成功512k放到wbuf中,繼續(xù)投遞或者投遞WSARecv1M數(shù)據(jù),卻收到一個512K的完成通知,那么你要繼續(xù)投遞WSARecv,當然前一個WSARecv的overlapped也可以重用,不過需要一些處理,把已經(jīng)接收到的512K保存到某個字段中,再投遞一個512K的請求去接收完成端口內(nèi)部,對投遞的Overlapped的填充,好像只有WSARecv的時候填充WSABUF,其他都是投遞IO前,代碼中顯式填充,并投遞的。至于完成了多少個字節(jié),是在lpNumberOfBytes中得到。

            對GetQueuedCompletionStatus函數(shù)解釋:
            實現(xiàn)從指定的IOCP獲取CP。當CP隊列為空時,對此函數(shù)的調(diào)用將被阻塞,而不是一直等待I/O的完成。當CP隊列不為空時,被阻塞的線程將以后進先出(LIFO)順序被釋放。對于IOCP機制,它允許多線程并發(fā)調(diào)用GetQueuedCompletionStatus函數(shù),最大并發(fā)數(shù)是在調(diào)用CreateIoCompletionPort函數(shù)時指定的,超出最大并發(fā)數(shù)的調(diào)用線程,將被阻塞。函數(shù)解釋如下:  
              聲明:  
              BOOL   GetQueuedCompletionStatus(  
                      HANDLE   CompletionPort,    
                      LPDWORD   lpNumberOfBytes,    
                      PULONG_PTR   lpCompletionKey,    
                      LPOVERLAPPED   *lpOverlapped,    
                      DWORD   dwMilliseconds);  
              調(diào)用參數(shù):  
              CompletionPort:指定的IOCP,該值由CreateIoCompletionPort函數(shù)創(chuàng)建。  
              lpnumberofbytes:一次完成后的I/O操作所傳送數(shù)據(jù)的字節(jié)數(shù)。  
              lpcompletionkey:當文件I/O操作完成后,用于存放與之關(guān)聯(lián)的CK。  
              lpoverlapped:為調(diào)用IOCP機制所引用的OVERLAPPED結(jié)構(gòu)。  
              dwmilliseconds:用于指定調(diào)用者等待CP的時間。  
              返回值:  
              調(diào)用成功,則返回非零數(shù)值,相關(guān)數(shù)據(jù)存于lpNumberOfBytes、lpCompletionKey、lpCompletionKey變量中。失敗則返回零值。

            posted on 2007-04-16 00:55 譚文政 閱讀(12853) 評論(0)  編輯 收藏 引用 所屬分類: 網(wǎng)絡(luò)編程

            評論

            # re: GetQueuedCompletionStatus函數(shù) 2008-11-27 22:47 王博煒
            不錯  回復(fù)  更多評論
              

            99精品国产在热久久无毒不卡| 97精品国产97久久久久久免费 | 亚洲国产精品久久久久久| 国产精品岛国久久久久| 久久精品亚洲福利| 久久精品国产99久久无毒不卡| 97超级碰碰碰碰久久久久| 国产成人精品综合久久久| 久久久久久狠狠丁香| 久久亚洲AV无码精品色午夜麻豆| 久久精品国产第一区二区三区| 亚洲国产精品综合久久一线 | 国产精品久久亚洲不卡动漫| 久久婷婷是五月综合色狠狠| 精品久久久无码中文字幕| 欧美噜噜久久久XXX| 久久这里只有精品首页| 国内精品欧美久久精品| 久久免费视频观看| 精品久久久久久国产潘金莲| 久久综合亚洲色一区二区三区| 国产巨作麻豆欧美亚洲综合久久| 综合人妻久久一区二区精品| 深夜久久AAAAA级毛片免费看 | 99久久精品免费看国产一区二区三区 | 国产成人精品白浆久久69| 综合网日日天干夜夜久久| 久久国产欧美日韩精品免费| 久久影院午夜理论片无码| 久久av高潮av无码av喷吹| 免费国产99久久久香蕉| 久久99精品久久久久久动态图| 久久亚洲精品成人AV| 久久综合88熟人妻| 久久天天躁狠狠躁夜夜avapp| 色欲久久久天天天综合网精品| 国内精品久久久久久久久电影网| 老男人久久青草av高清| 色婷婷综合久久久久中文一区二区| 久久久www免费人成精品| 久久婷婷五月综合97色一本一本 |