• <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>

               C++ 技術中心

               :: 首頁 :: 聯系 ::  :: 管理
              160 Posts :: 0 Stories :: 87 Comments :: 0 Trackbacks

            公告

            鄭重聲明:本BLOG所發表的原創文章,作者保留一切權利。必須經過作者本人同意后方可轉載,并注名作者(天空)和出處(CppBlog.com)。作者Email:coder@luckcoder.com

            留言簿(27)

            搜索

            •  

            最新隨筆

            最新評論

            評論排行榜

            在Linux中使用非阻塞的socket的情形下。

            (一)發送時

              當客戶通過Socket提供的send函數發送大的數據包時,就可能返回一個EAGAIN的錯誤。該錯誤產生的原因是由于send 函數中的size變量大小超過了tcp_sendspace的值。tcp_sendspace定義了應用在調用send之前能夠在kernel中緩存的數據量。當應用程序在socket中設置了O_NDELAY或者O_NONBLOCK屬性后,如果發送緩存被占滿,send就會返回EAGAIN的錯誤。

              為了消除該錯誤,有三種方法可以選擇:
              1.調大tcp_sendspace,使之大于send中的size參數
              ---no -p -o tcp_sendspace=65536

              2.在調用send前,在setsockopt函數中為SNDBUF設置更大的值

              3.使用write替代send,因為write沒有設置O_NDELAY或者O_NONBLOCK

            (二)接收時

            接收數據時常遇到Resource temporarily unavailable的提示,errno代碼為11(EAGAIN)。這表明你在非阻塞模式下調用了阻塞操作,在該操作沒有完成就返回這個錯誤,這個錯誤不會破壞socket的同步,不用管它,下次循環接著recv就可以。對非阻塞socket而言,EAGAIN不是一種錯誤。在VxWorks和Windows上,EAGAIN的名字叫做EWOULDBLOCK。其實這算不上錯誤,只是一種異常而已。

              另外,如果出現EINTR即errno為4,錯誤描述Interrupted system call,操作也應該繼續。

              最后,如果recv的返回值為0,那表明對方已將連接斷開,我們的接收操作也應該結束。

            (三)以下是另一種解釋

            假如發送端流量大于接收端的流量(意思是epoll所在的程序讀比轉發的socket要快),由于是非阻塞的socket,那么send()函數雖然返回,但實際緩沖區的數據并未真正發給接收端,這樣不斷的讀和發,當緩沖區滿后會產生EAGAIN錯誤(參考man send),同時,不理會這次請求發送的數據.所以,

            需要封裝socket_send()的函數用來處理這種情況,該函數會盡量將數據寫完再返回,返回-1表示出錯。在socket_send()內部,當寫緩沖已滿(send()返回-1,且errno為EAGAIN),那么會等待后再重試.這種方式并不很完美,在理論上可能會長時間的阻塞在socket_send()內部,但暫沒有更好的辦法.
            這種方法類似于readn和writen的封裝(自己寫過,在《UNIX環境高級編程》中也有介紹)

            1. size_t socket_send(int sockfd, const char* buffer, size_t buflen)
            2. {
            3. size_t tmp;
            4. size_t total = buflen;
            5. const char *p = buffer;
            6. while(1)
            7. {
            8. tmp = send(sockfd, p, total, 0);
            9. if(tmp < 0)
            10. {
            11. // 當send收到信號時,可以繼續寫,但這里返回-1.
            12. if(errno == EINTR)
            13. {
            14. return -1;
            15. }
            16. // 當socket是非阻塞時,如返回此錯誤,表示寫緩沖隊列已滿,
            17. // 在這里做延時后再重試.
            18. if(errno == EAGAIN)
            19. {
            20. usleep(1000);
            21. continue;
            22. }
            23. return -1;
            24. }
            25. if((size_t)tmp == total)
            26. {
            27. return buflen;
            28. }
            29. total -= tmp;
            30. p += tmp;
            31. }
            32. return tmp;
            33. }

            posted on 2013-07-01 18:53 C++技術中心 閱讀(12594) 評論(0)  編輯 收藏 引用 所屬分類: Linux 編程
            国产精品99久久99久久久| 精品久久久无码中文字幕天天| 天天爽天天爽天天片a久久网| 少妇人妻综合久久中文字幕 | 91久久精品无码一区二区毛片| 香蕉久久夜色精品升级完成| 精品久久久久久久国产潘金莲| 欧美性大战久久久久久| 久久久WWW成人免费精品| 久久男人AV资源网站| 久久久久九国产精品| 精品久久综合1区2区3区激情| 久久久中文字幕日本| 狠狠色丁香婷婷久久综合| 国内精品久久久久影院薰衣草 | 久久99久久无码毛片一区二区| 国内精品久久久久久野外| 久久综合综合久久狠狠狠97色88 | 久久精品国产亚洲精品| 国内精品久久久久久久涩爱| 久久久久亚洲?V成人无码| 伊人久久大香线蕉综合热线| 久久九九兔免费精品6| 久久精品国产亚洲av日韩| 国内精品久久久久影院免费| 久久精品国产一区二区电影| 亚洲Av无码国产情品久久| 久久99精品久久久大学生| 久久婷婷久久一区二区三区| 欧美午夜A∨大片久久| 午夜久久久久久禁播电影| 国产三级精品久久| 久久精品成人欧美大片| 国产巨作麻豆欧美亚洲综合久久 | 久久精品亚洲AV久久久无码| 精品熟女少妇a∨免费久久| 久久激情五月丁香伊人| 久久精品亚洲日本波多野结衣 | 婷婷综合久久中文字幕| 亚洲精品无码久久久久AV麻豆| 久久青青草原精品国产|