cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-09-08 03:44:22 -04:00
Code Issues Packages Projects Releases Wiki Activity

IOCP: don't launch reads or writes on an unconnected socket

Browse Source
This commit is contained in:
Nick Mathewson 2011-08-18 11:41:55 -04:00
parent 643922e907
commit 495c227f59
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
bufferevent_async.c
View File

@ -188,7 +188,7 @@ bev_async_consider_writing(struct bufferevent_async *beva)
/* Don't write if there's a write in progress, or we do not
* want to write, or when there's nothing left to write. */
if (beva->write_in_progress)
if (beva->write_in_progress || beva->bev.connecting)
return;
if (!beva->ok || !(bev->enabled&EV_WRITE) ||
!evbuffer_get_length(bev->output)) {
@ -234,7 +234,7 @@ bev_async_consider_reading(struct bufferevent_async *beva)
/* Don't read if there is a read in progress, or we do not
* want to read. */
if (beva->read_in_progress)
if (beva->read_in_progress || beva->bev.connecting)
return;
if (!beva->ok || !(bev->enabled&EV_READ)) {
bev_async_del_read(beva);
@ -324,7 +324,11 @@ be_async_enable(struct bufferevent *buf, short what)
if (!bev_async->ok)
return -1;
/* NOTE: This interferes with non-blocking connect */
if (bev_async->bev.connecting) {
/* Don't launch anything during connection attempts. */
return 0;
}
if (what & EV_READ)
BEV_RESET_GENERIC_READ_TIMEOUT(buf);
if (what & EV_WRITE)