external
/
uhub
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Work in progress on the kqueue backend.

This commit is contained in:
Jan Vidar Krey 2010-01-27 00:43:10 +01:00
parent 31a69b1f3f
commit ac48ad01fb
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/network/kqueue.c
View File

@ -115,18 +115,21 @@ void net_con_destroy(struct net_connection* con)
void net_con_initialize(struct net_connection* con_, int sd, net_connection_cb callback, const void* ptr, int events) void net_con_initialize(struct net_connection* con_, int sd, net_connection_cb callback, const void* ptr, int events)
{ {
short filter = 0;
struct net_connection_kqueue* con = (struct net_connection_kqueue*) con_; struct net_connection_kqueue* con = (struct net_connection_kqueue*) con_;
con->sd = sd; con->sd = sd;
con->flags = 0; con->flags = 0;
con->callback = callback; con->callback = callback;
con->ev.events = 0; con->ev.events = 0;
con->ptr = (void*) ptr; con->ptr = (void*) ptr;
con->ev.data.ptr = (void*) con;
net_set_nonblocking(con->sd, 1); net_set_nonblocking(con->sd, 1);
net_set_nosigpipe(con->sd, 1); net_set_nosigpipe(con->sd, 1);
/* FIXME */ if (events & NET_EVENT_READ) filter |= EVFILT_READ;
if (events & NET_EVENT_WRITE) filter |= EVFILT_READ;
EV_SET(&con->ev, sd, filter, EV_ADD, 0, 0, con);
g_backend->conns[sd] = con; g_backend->conns[sd] = con;
g_backend->num++; g_backend->num++;
@ -141,8 +144,16 @@ void net_con_reinitialize(struct net_connection* con, net_connection_cb callback
void net_con_update(struct net_connection* con_, int events) void net_con_update(struct net_connection* con_, int events)
{ {
short filter = 0;
struct net_connection_kqueue* con = (struct net_connection_kqueue*) con_; struct net_connection_kqueue* con = (struct net_connection_kqueue*) con_;
/* FIXME */
if (events & NET_EVENT_READ) filter |= EVFILT_READ;
if (events & NET_EVENT_WRITE) filter |= EVFILT_READ;
if (filter == con->ev.filter)
return;
EV_SET(&con->ev, sd, filter, EV_ADD, 0, 0, con);
} }
void net_con_close(struct net_connection* con_) void net_con_close(struct net_connection* con_)
@ -159,12 +170,11 @@ void net_con_close(struct net_connection* con_)
net_con_clear_timeout(con_); net_con_clear_timeout(con_);
/* FIXME */ EV_SET(&con->ev, sd, 0, EV_DELETE, 0, 0, 0);
net_close(con->sd); net_close(con->sd);
con->sd = -1; con->sd = -1;
net_con_print("DEL", con);
net_cleanup_delayed_free(g_backend->cleaner, con_); net_cleanup_delayed_free(g_backend->cleaner, con_);
} }