青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

   C++ 技術中心

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

公告

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

留言簿(27)

搜索

  •  

最新隨筆

最新評論

評論排行榜

在linux網絡編程中,很長時間使用select做事件觸發。select會隨著監聽fd的數目的增長而降低效率,因為在實現中,它是采用輪詢的方式處理的,輪詢的fd數目越多,自然耗時就越多。對于IM服務器要支持上萬個鏈接,就顯得力不從心了。而且fd支持數目是有限的,在linux/posix/_types.h頭文件中,有這樣的聲明:#defind __FD_SETSIZE 1024.

  epoll則沒有這樣的限制,epoll支持的最大鏈接數是最大可打開的文件的數目。epoll只對活躍的socket進行操作——這是因為epoll是根據每個fd上面的callback函數實現的。那么,只有活躍的socket才會主動地調用callback函數。在一個高速的LAN環境,如果幾乎所有的socket都是活躍的,epoll的效率比select會稍微有下降。

  使用mmap加速內核與用戶空間的消息傳遞。無論select,poll都需要內核把FD消息通知給用戶空間,如何避免不必要的內存拷貝,在這點上epoll通過內核與用戶空間mmap同一塊內存空間實現的。

  epoll有兩種工作方式LT(level triggered)和ET(edge triggered)。

  LT(level triggered)是缺省的工作方式,支持block和non-block socket。在這種模式下,內核告訴你一個文件描述符已經就緒了,然后對這個描述符進行io操作。如果你不作任何操作,內核還會繼續通知你的。所以,這種模式編程出錯可能性要小一點。傳統的select/poll都是這種模型的代表。

  ET(edge triggered)高速工作方式,只支持no-block描述符。在這種模式下,當描述符由未就緒變為就緒時,內核通過epoll告訴你。然后它假設你知道文件描述符已經就緒,并且不再為那個描述符發送更多的就緒通知,直到你做了某些操作導致描述符不再是就緒狀態了(比如,你在發送、接收或者接收請求、或者發送接收的數據少于一定量時導致了一個EWOULDBLOCK錯誤)。但是請注意,如果一直不對這個fd作io操作(從而導致它再次變成未就緒),內核不會發送更多的通知(only once),不過在TCP協議中,ET模式的加速效果仍需要更多benchmark確認。

epoll接口

int epoll_create(int size)

創建一個epoll句柄,size告訴內核這個監聽的數目一共有多大。這個參數不同于select的第一個參數,給出最大的fd+1值。需要注意的是,當創建好epoll句柄后,它就會占用一個fd值,在linux下如果查看/proc/prodid/fd/能夠看到這個fd的,所以使用完epoll后,必須調用close關閉。

int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)

epoll事件注冊函數,它不同于select是在監聽事件時告訴內核要監聽什么類型的事件,而是在這里先注冊要監聽的事件類型。

epfd:epoll描述符

op:EPOLL_CTL_ADD 注冊新的fd

EPOLL_CTL_MOD 修改已注冊的fd的監聽事件

EPOLL_CTL_DEL 從epfd中刪除一個fd

struct epoll_event {

__uint32_t event; /* EPOLLIN 可以讀(包括對端socket正常關閉)

EPOLLOUT 可以寫

EPOLLPRI 有緊急數據可讀(這里應該表示有帶外數據到來)

EPOLLERR 對應文件描述符發生錯誤

EPOLLHUP 對應的文件描述符被掛斷

EPOLLET ET工作模式

EPOLLONESHOT 只監聽一次事件,當監聽完這次事件后,還需要繼續監聽的話,需要再次把fd加入到監聽隊列里。

epoll_data_t data; /* user data */

};

typedef union epoll_data {
void ptr;
int fd;
__uint32_t u32;
__uint64_t u64;
} epoll_data_t;

int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout)

等待事件的產生,類似于select。

events,從內核得到事件的總和

maxevents,告訴內核這個events有多大,不能大于epoll_create size 值

timeout,超時時間(毫秒)。0:立即返回,-1 不確定或永久阻塞

返回,0:超時;否則 事件個數

假如有這樣一個例子:
1. 我們已經把一個用來從管道中讀取數據的文件句柄(RFD)添加到epoll描述符
2. 這個時候從管道的另一端被寫入了2KB的數據
3. 調用epoll_wait(2),并且它會返回RFD,說明它已經準備好讀取操作
4. 然后我們讀取了1KB的數據
5. 調用epoll_wait(2)......

Edge Triggered 工作模式:
如果我們在第1步將RFD添加到epoll描述符的時候使用了EPOLLET標志,那么在第5步調用epoll_wait(2)之后將有可能會掛起,因為剩余的數據還存在于文件的輸入緩沖區內,而且數據發出端還在等待一個針對已經發出數據的反饋信息。只有在監視的文件句柄上發生了某個事件的時候 ET 工作模式才會匯報事件。因此在第5步的時候,調用者可能會放棄等待仍在存在于文件輸入緩沖區內的剩余數據。在上面的例子中,會有一個事件產生在RFD句柄上,因為在第2步執行了一個寫操作,然后,事件將會在第3步被銷毀。因為第4步的讀取操作沒有讀空文件輸入緩沖區內的數據,因此我們在第5步調用 epoll_wait(2)完成后,是否掛起是不確定的。epoll工作在ET模式的時候,必須使用非阻塞套接口,以避免由于一個文件句柄的阻塞讀/阻塞寫操作把處理多個文件描述符的任務餓死。最好以下面的方式調用ET模式的epoll接口,在后面會介紹避免可能的缺陷。
i 基于非阻塞文件句柄
ii 只有當read(2)或者write(2)返回EAGAIN時才需要掛起,等待。但這并不是說每次read()時都需要循環讀,直到讀到產生一個EAGAIN才認為此次事件處理完成,當read()返回的讀到的數據長度小于請求的數據長度時,就可以確定此時緩沖中已沒有數據了,也就可以認為此事讀事件已處理完成。

另外,當使用epoll的ET模型來工作時,當產生了一個EPOLLIN事件后,
讀數據的時候需要考慮的是當recv()返回的大小如果等于請求的大小,那么很有可能是緩沖區還有數據未讀完,也意味著該次事件還沒有處理完,所以還需要再次讀取
while(rs)
{
buflen = recv(activeevents[i].data.fd, buf, sizeof(buf), 0);
if(buflen < 0)
{
// 由于是非阻塞的模式,所以當errno為EAGAIN時,表示當前緩沖區已無數據可讀
// 在這里就當作是該次事件已處理處.
if(errno == EAGAIN)
break;
else
return;
}
else if(buflen == 0)
{
// 這里表示對端的socket已正常關閉.
}
if(buflen == sizeof(buf)
rs = 1; // 需要再次讀取
else
rs = 0;
}


還有,假如發送端流量大于接收端的流量(意思是epoll所在的程序讀比轉發的socket要快),由于是非阻塞的socket,那么send()函數雖然返回,但實際緩沖區的數據并未真正發給接收端,這樣不斷的讀和發,當緩沖區滿后會產生EAGAIN錯誤(參考man send),同時,不理會這次請求發送的數據.所以,需要封裝socket_send()的函數用來處理這種情況,該函數會盡量將數據寫完再返回,返回-1表示出錯。在socket_send()內部,當寫緩沖已滿(send()返回-1,且errno為EAGAIN),那么會等待后再重試.這種方式并不很完美,在理論上可能會長時間的阻塞在socket_send()內部,但暫沒有更好的辦法.

ssize_t socket_send(int sockfd, const char* buffer, size_t buflen)
{
ssize_t tmp;
size_t total = buflen;
const char *p = buffer;

while(1)
{
tmp = send(sockfd, p, total, 0);
if(tmp < 0)
{
// 當send收到信號時,可以繼續寫,但這里返回-1.
if(errno == EINTR)
return -1;

// 當socket是非阻塞時,如返回此錯誤,表示寫緩沖隊列已滿,
// 在這里做延時后再重試.
if(errno == EAGAIN)
{
usleep(1000);
continue;
}

return -1;
}

if((size_t)tmp == total)
return buflen;

total -= tmp;
p += tmp;
}

return tmp;
}

posted on 2013-07-01 19:13 C++技術中心 閱讀(3237) 評論(1)  編輯 收藏 引用 所屬分類: Linux 編程

Feedback

# re: epoll原理 2013-07-18 11:52 Gezidan Studio
socket_send這個函數毫無價值,實際應用中不會這么寫..  回復  更多評論
  

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            亚洲人成亚洲人成在线观看图片 | 久久全球大尺度高清视频| 免费日韩av片| 久久精品视频免费观看| 亚洲欧美另类国产| 午夜日韩视频| 欧美aa国产视频| 久久精品免费| 久久久久久久久久码影片| 久久精品国产一区二区电影 | 嫩草成人www欧美| 久久九九全国免费精品观看| 欧美大片91| 欧美三区视频| 国产一区日韩欧美| 亚洲激情六月丁香| 亚洲午夜一区| 裸体一区二区三区| 一区二区三区国产| 久久综合狠狠综合久久综合88| 欧美精品一区二区视频| 国产婷婷色综合av蜜臀av| 亚洲黄色尤物视频| 欧美一区二区三区在线| 欧美大片在线观看一区| 亚洲图片在线观看| 久久久福利视频| 99精品福利视频| 久久一区二区视频| 国产精品免费看久久久香蕉| 久久伊人亚洲| 欧美高清视频一区二区| 99re6这里只有精品视频在线观看| 国产精品捆绑调教| 亚洲综合视频一区| 国产区欧美区日韩区| 国产亚洲一区精品| 日韩视频在线观看国产| 久久亚洲二区| 亚洲性线免费观看视频成熟| 欧美激情第二页| 亚洲第一精品在线| 欧美专区在线观看一区| 日韩视频一区| 欧美jizz19性欧美| 很黄很黄激情成人| 在线午夜精品自拍| 亚洲丶国产丶欧美一区二区三区| 午夜免费电影一区在线观看| 国产精品扒开腿做爽爽爽软件| 亚洲美女尤物影院| 国产自产v一区二区三区c| 久久伊伊香蕉| 亚洲激情啪啪| 浪潮色综合久久天堂| 欧美亚洲日本国产| 国产伦精品一区二区三区免费迷| 夜夜爽av福利精品导航| 欧美激情1区2区3区| 久久久久久一区二区三区| 国产一区二区三区无遮挡| 亚洲社区在线观看| 亚洲精品社区| 欧美日韩在线播放三区| 99热这里只有成人精品国产| 亚洲精品欧美精品| 欧美美女喷水视频| 一卡二卡3卡四卡高清精品视频| 亚洲精品乱码久久久久久久久| 欧美二区在线| 亚洲视频综合| 欧美一区二区视频网站| 亚洲第一精品夜夜躁人人躁| 欧美激情视频一区二区三区在线播放 | 亚洲视频精选在线| 99国内精品久久| 国产欧美日韩在线观看| 久久伊伊香蕉| 欧美国产精品一区| 中日韩美女免费视频网址在线观看| 亚洲免费一区二区| 欧美日本一道本| 一区二区视频免费完整版观看| 久久综合国产精品| 欧美激情一区二区三区成人| 国产精品99久久久久久久vr| 午夜精品99久久免费| 精品51国产黑色丝袜高跟鞋| 亚洲电影成人| 欧美精品日韩一本| 国产手机视频一区二区| 亚洲激情国产精品| 国产伦精品一区二区三区视频孕妇 | 欧美日韩亚洲一区二区三区四区 | 国产在线视频欧美| 亚洲国产天堂久久综合网| 国产精品白丝jk黑袜喷水| 久久综合久久综合久久综合| 欧美日韩精品系列| 蜜桃av一区二区在线观看| 老司机精品视频网站| 亚洲欧美在线一区二区| 欧美成人免费全部观看天天性色| 欧美亚洲一区二区在线观看| 欧美好骚综合网| 久久久99爱| 欧美午夜免费电影| 亚洲电影专区| 狠狠综合久久av一区二区老牛| 一本色道久久88亚洲综合88| 亚洲黄色尤物视频| 久久婷婷一区| 久久美女性网| 国产免费成人在线视频| 99re成人精品视频| 日韩视频永久免费| 久久亚洲欧美| 久久这里只有| 国产欧美一区二区色老头| 日韩午夜av在线| 亚洲三级毛片| 乱中年女人伦av一区二区| 久久久久久久综合| 国产欧亚日韩视频| 亚洲欧美日韩精品久久亚洲区| 一区二区三区欧美亚洲| 欧美另类一区| 亚洲国产精品嫩草影院| 在线不卡视频| 久久黄色小说| 裸体素人女欧美日韩| 在线国产精品播放| 久久夜色精品国产欧美乱| 免费在线成人| 91久久在线| 欧美乱人伦中文字幕在线| 亚洲人精品午夜在线观看| 亚洲精一区二区三区| 欧美第一黄色网| 日韩亚洲精品视频| 亚洲精选在线| 亚洲第一在线综合在线| 久久婷婷国产综合精品青草 | 亚洲麻豆一区| 99国产成+人+综合+亚洲欧美| 欧美极品在线视频| 日韩亚洲精品电影| 午夜天堂精品久久久久| 国产亚洲欧美日韩在线一区| 久久国产精品色婷婷| 欧美99久久| 日韩亚洲精品在线| 国产精品v日韩精品| 亚洲欧美一区二区精品久久久| 久久精品一区二区三区四区| 亚洲承认在线| 欧美区二区三区| 亚洲欧美日韩在线高清直播| 久久永久免费| 在线亚洲欧美专区二区| 国产精品无码永久免费888| 欧美在线观看视频在线| 欧美大胆人体视频| 一本色道久久综合狠狠躁篇的优点| 欧美视频官网| 久久久精品一区| 99re视频这里只有精品| 久久九九热免费视频| 亚洲精品乱码久久久久久蜜桃91 | 亚洲精品日韩综合观看成人91| 欧美日韩国产高清| 久久国产99| 99精品国产热久久91蜜凸| 久久国产精品一区二区三区| 一区二区亚洲精品| 国产精品美女在线| 欧美ed2k| 久久九九全国免费精品观看| 日韩视频第一页| 欧美3dxxxxhd| 性欧美1819性猛交| 亚洲日本欧美日韩高观看| 国产精品永久免费视频| 欧美久久久久免费| 久久久亚洲国产美女国产盗摄| 正在播放欧美视频| 欧美国产精品| 久久婷婷综合激情| 午夜日韩视频| 亚洲网站在线看| 亚洲精品一区二区网址| 尤物视频一区二区| 国产一区二区三区无遮挡| 国产精品高潮视频| 欧美日韩国产在线观看| 另类图片国产| 久久免费视频在线观看| 亚洲一区二区三区在线| 亚洲激情二区| 91久久精品一区二区别|