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

   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++技術中心 閱讀(3249) 評論(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>
            在线免费一区三区| 久久精品一区二区三区四区| 日韩视频中文| 99在线精品免费视频九九视| 久久九九国产精品怡红院| 99精品国产在热久久下载| 久久久久国产成人精品亚洲午夜| 91久久香蕉国产日韩欧美9色| 亚洲免费一在线| 欧美日韩免费一区| 日韩午夜中文字幕| 欧美国产精品日韩| 噜噜噜91成人网| 亚洲美女黄网| 国产精品伊人日日| 国产一二精品视频| 性欧美8khd高清极品| 欧美一区二区黄色| 一本久久精品一区二区| 国产视频一区三区| 亚洲区中文字幕| 伊人精品在线| 亚洲女性喷水在线观看一区| 亚洲精品影院在线观看| 久久一区二区三区av| 久久亚洲私人国产精品va| 久久精视频免费在线久久完整在线看 | 国产主播一区二区三区| 久久精品国亚洲| 久久综合色8888| 久久激情综合网| 亚洲国产精品一区二区第一页| 亚洲综合久久久久| 国产午夜精品久久久久久免费视| 老司机一区二区| 欧美精品免费在线| 亚洲小说春色综合另类电影| 亚洲欧美网站| 亚洲成人资源网| 亚洲精品中文字幕在线观看| 国产精品久久久爽爽爽麻豆色哟哟| 欧美在线免费一级片| 久久这里有精品15一区二区三区| 99国产精品久久久久久久久久| 久久久久五月天| 欧美激情片在线观看| 国产一区999| 亚洲日本免费电影| 欧美精品一区二区三区一线天视频| 久久精品国产99国产精品澳门| 欧美日韩亚洲一区在线观看| 亚洲图片你懂的| 欧美电影免费观看高清| 欧美xxx在线观看| 宅男精品视频| 国产亚洲毛片| 欧美视频一区二区| 欧美成人69av| 亚洲成人直播| 国产日韩精品一区二区浪潮av| 久久免费视频这里只有精品| 亚洲天堂av电影| 国产三区精品| 亚洲国产欧美日韩精品| 亚洲欧美另类在线| 老鸭窝毛片一区二区三区| 妖精成人www高清在线观看| 国产精品婷婷午夜在线观看| 老司机精品视频网站| 一区二区三区精品国产| 亚洲欧美国产精品va在线观看| 欧美一区二区三区播放老司机 | 欧美在线免费观看视频| 欧美在线视频不卡| 亚洲视频免费看| 亚洲精品视频在线| 在线精品视频在线观看高清| 国产精品久久久久久久一区探花| 欧美福利在线| 欧美极品在线播放| 欧美日韩亚洲高清| 欧美午夜在线观看| 国产精品热久久久久夜色精品三区| 亚洲国产欧美精品| 欧美亚洲色图校园春色| 久久综合色一综合色88| 亚洲一级在线观看| 欧美日韩蜜桃| 亚洲精品女av网站| 亚洲娇小video精品| 韩日欧美一区| 影音先锋久久资源网| 国产精品久久久久三级| 久久激情五月婷婷| 欧美日韩不卡合集视频| 亚洲国产日日夜夜| 欧美sm视频| 亚洲人永久免费| 久久久久久亚洲综合影院红桃| 亚洲欧美日韩中文在线制服| 欧美日韩在线视频首页| 99精品欧美一区二区三区| 日韩一级在线| 欧美日韩久久| 一个色综合导航| 亚洲欧美日韩精品一区二区| 国产精品入口66mio| 亚洲图片欧美一区| 国产日韩欧美| 久久久999精品免费| 另类人畜视频在线| 亚洲欧洲一区二区在线播放| 欧美国产第一页| 美女网站在线免费欧美精品| 欧美日韩亚洲一区| 欧美日韩精品综合在线| 欧美日本一区| 一本到高清视频免费精品| 欧美韩日一区二区| 久久久一本精品99久久精品66| 国产日韩一区欧美| 久久久久国产成人精品亚洲午夜| 亚洲一区二区视频| 国产日韩欧美精品综合| 久久尤物视频| 欧美激情一区二区三区成人| 欧美在线视频网站| 国产无遮挡一区二区三区毛片日本| 久久精品一区二区三区不卡| 国产精品久久久一区麻豆最新章节| 欧美成人一区二区| 国产伦精品一区二区三区视频孕妇| 极品日韩久久| 欧美亚洲日本一区| 夜夜嗨一区二区| 国产日韩欧美91| 在线观看视频一区二区欧美日韩 | 国产精品国码视频| 久久精品视频导航| 一本色道久久综合亚洲二区三区| 久久久久九九视频| 亚洲麻豆国产自偷在线| 国产伦精品免费视频 | 一区二区在线视频播放| 欧美日韩国产综合久久| 久久gogo国模啪啪人体图| 亚洲精品国产视频| 久久中文字幕一区| 欧美一级片在线播放| 亚洲欧美视频一区| 亚洲精品一区二区三区在线观看| 久久精品亚洲一区二区三区浴池| 日韩图片一区| 久久久久www| 国产日韩一区| 久久激情五月激情| 中日韩美女免费视频网站在线观看| 久久夜色精品一区| 欧美午夜在线观看| 在线中文字幕一区| 在线中文字幕一区| 欧美日韩免费一区二区三区| 亚洲美女在线观看| 亚洲日本欧美天堂| 久久在线免费| 亚洲福利一区| 日韩写真在线| 久久综合一区二区三区| 久久久精品2019中文字幕神马| 国产精品成人aaaaa网站| 亚洲精品一区二区三区婷婷月 | 国产精品福利在线观看| 另类尿喷潮videofree| 国产日韩在线一区| 欧美一级视频免费在线观看| 一区二区三区成人| 国产日韩欧美一区二区三区在线观看| 亚洲精品影院| 亚洲欧美资源在线| 国产精品网站在线播放| 亚洲欧美卡通另类91av| 欧美一区二区在线免费播放| 国产午夜久久| 欧美日韩一区二区在线观看视频 | 久久免费视频在线观看| 1000部精品久久久久久久久| 欧美国产日韩一区二区三区| 亚洲国产精品久久人人爱蜜臀 | 99精品视频免费观看视频| 欧美日韩国产限制| 午夜精品久久99蜜桃的功能介绍| 久久精品视频免费| 一本久道综合久久精品| 亚洲高清电影| 亚洲美女尤物影院| 国产日韩欧美一区二区| 欧美成年人网站| 欧美中文字幕视频| 日韩视频在线你懂得| 久久漫画官网|