Browse Source

Use a unique event structure for each client added to the epoll list

master
Con Kolivas 10 years ago
parent
commit
8f1336986f
  1. 10
      src/connector.c

10
src/connector.c

@ -30,6 +30,7 @@ struct client_instance {
UT_hash_handle hh; UT_hash_handle hh;
int64_t id; int64_t id;
int fd; int fd;
struct epoll_event event;
/* Reference count for when this instance is used outside of the /* Reference count for when this instance is used outside of the
* connector_data lock */ * connector_data lock */
@ -167,7 +168,6 @@ static int accept_client(cdata_t *cdata, const int epfd, const uint64_t server)
int fd, port, no_clients, sockd; int fd, port, no_clients, sockd;
ckpool_t *ckp = cdata->ckp; ckpool_t *ckp = cdata->ckp;
client_instance_t *client; client_instance_t *client;
struct epoll_event event;
socklen_t address_len; socklen_t address_len;
ck_rlock(&cdata->lock); ck_rlock(&cdata->lock);
@ -230,9 +230,9 @@ static int accept_client(cdata_t *cdata, const int epfd, const uint64_t server)
ck_wunlock(&cdata->lock); ck_wunlock(&cdata->lock);
client->fd = fd; client->fd = fd;
event.data.u64 = client->id; client->event.data.u64 = client->id;
event.events = EPOLLIN | EPOLLRDHUP; client->event.events = EPOLLIN | EPOLLRDHUP;
if (unlikely(epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &event) < 0)) { if (unlikely(epoll_ctl(epfd, EPOLL_CTL_ADD, fd, &client->event) < 0)) {
LOGERR("Failed to epoll_ctl add in accept_client"); LOGERR("Failed to epoll_ctl add in accept_client");
return 0; return 0;
} }
@ -256,7 +256,7 @@ static int drop_client(cdata_t *cdata, client_instance_t *client)
if (fd != -1) { if (fd != -1) {
client_id = client->id; client_id = client->id;
epoll_ctl(cdata->epfd, EPOLL_CTL_DEL, fd, NULL); epoll_ctl(cdata->epfd, EPOLL_CTL_DEL, fd, &client->event);
nolinger_socket(fd); nolinger_socket(fd);
Close(client->fd); Close(client->fd);
HASH_DEL(cdata->clients, client); HASH_DEL(cdata->clients, client);

Loading…
Cancel
Save