cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-08-04 01:36:23 -04:00
Code Issues Packages Projects Releases Wiki Activity

call setsockopt correctly on connecting() IOCP-bufferevents so shutdown() will work

Browse Source
This commit is contained in:
Nick Mathewson 2011-04-22 10:54:02 -04:00
parent b4f89f00c6
commit 52f9baeee2
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
bufferevent_async.c
View File

@ -63,6 +63,11 @@
#include "util-internal.h" #include "util-internal.h"
#include "iocp-internal.h" #include "iocp-internal.h"
#ifndef SO_UPDATE_CONNECT_CONTEXT
/* Mingw is sometimes missing this */
#define SO_UPDATE_CONNECT_CONTEXT 0x7010
#endif
/* prototypes */ /* prototypes */
static int be_async_enable(struct bufferevent *, short); static int be_async_enable(struct bufferevent *, short);
static int be_async_disable(struct bufferevent *, short); static int be_async_disable(struct bufferevent *, short);
@ -403,11 +408,15 @@ connect_complete(struct event_overlapped *eo, ev_uintptr_t key,
{ {
struct bufferevent_async *bev_a = upcast_connect(eo); struct bufferevent_async *bev_a = upcast_connect(eo);
struct bufferevent *bev = &bev_a->bev.bev; struct bufferevent *bev = &bev_a->bev.bev;
evutil_socket_t sock;
BEV_LOCK(bev); BEV_LOCK(bev);
EVUTIL_ASSERT(bev_a->bev.connecting); EVUTIL_ASSERT(bev_a->bev.connecting);
bev_a->bev.connecting = 0; bev_a->bev.connecting = 0;
sock = _evbuffer_overlapped_get_fd(bev_a->bev.bev.input);
/* XXXX Handle error? */
setsockopt(sock, SOL_SOCKET, SO_UPDATE_CONNECT_CONTEXT, NULL, 0);
if (ok) if (ok)
bufferevent_async_set_connected(bev); bufferevent_async_set_connected(bev);