summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_poll.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2017-02-01 19:20:07 +0300
committerIgor Sysoev <igor@sysoev.ru>2017-02-01 19:20:07 +0300
commit6e67bee0f4f96ad0a7d1a231dfdae8431714c66a (patch)
treec422698ab3b7828f7346ca18e1f5a1b8305ed769 /src/nxt_poll.c
parent8942550b13515e54aff9d682bec3da45ade26e18 (diff)
downloadunit-6e67bee0f4f96ad0a7d1a231dfdae8431714c66a.tar.gz
unit-6e67bee0f4f96ad0a7d1a231dfdae8431714c66a.tar.bz2
nxt_str_t changes.
Diffstat (limited to '')
-rw-r--r--src/nxt_poll.c18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/nxt_poll.c b/src/nxt_poll.c
index 6f6299b0..fd195261 100644
--- a/src/nxt_poll.c
+++ b/src/nxt_poll.c
@@ -454,8 +454,8 @@ nxt_poll_set_add(nxt_thread_t *thr, nxt_poll_event_set_t *ps,
lhq.key_hash = nxt_murmur_hash2(&ch->fd, sizeof(nxt_fd_t));
lhq.replace = 0;
- lhq.key.len = sizeof(nxt_fd_t);
- lhq.key.data = (u_char *) &ch->fd;
+ lhq.key.length = sizeof(nxt_fd_t);
+ lhq.key.start = (u_char *) &ch->fd;
lhq.value = phe;
lhq.proto = &nxt_poll_fd_hash_proto;
lhq.data = ps->poll_set;
@@ -501,8 +501,8 @@ nxt_poll_set_delete(nxt_thread_t *thr, nxt_poll_event_set_t *ps,
nxt_log_debug(thr->log, "poll delete event: fd:%d", ch->fd);
lhq.key_hash = nxt_murmur_hash2(&ch->fd, sizeof(nxt_fd_t));
- lhq.key.len = sizeof(nxt_fd_t);
- lhq.key.data = (u_char *) &ch->fd;
+ lhq.key.length = sizeof(nxt_fd_t);
+ lhq.key.start = (u_char *) &ch->fd;
lhq.proto = &nxt_poll_fd_hash_proto;
lhq.data = ps->poll_set;
@@ -682,8 +682,8 @@ nxt_poll_fd_hash_get(nxt_poll_event_set_t *ps, nxt_fd_t fd)
nxt_poll_hash_entry_t *phe;
lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t));
- lhq.key.len = sizeof(nxt_fd_t);
- lhq.key.data = (u_char *) &fd;
+ lhq.key.length = sizeof(nxt_fd_t);
+ lhq.key.start = (u_char *) &fd;
lhq.proto = &nxt_poll_fd_hash_proto;
lhq.data = ps->poll_set;
@@ -706,7 +706,7 @@ nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data)
phe = data;
- if (*(nxt_fd_t *) lhq->key.data == phe->fd) {
+ if (*(nxt_fd_t *) lhq->key.start == phe->fd) {
poll_set = lhq->data;
if (nxt_fast_path(phe->fd == poll_set[phe->index].fd)) {
@@ -740,8 +740,8 @@ nxt_poll_fd_hash_destroy(nxt_lvlhsh_t *lh)
}
lhq.key_hash = nxt_murmur_hash2(&phe->fd, sizeof(nxt_fd_t));
- lhq.key.len = sizeof(nxt_fd_t);
- lhq.key.data = (u_char *) &phe->fd;
+ lhq.key.length = sizeof(nxt_fd_t);
+ lhq.key.start = (u_char *) &phe->fd;
if (nxt_lvlhsh_delete(lh, &lhq) != NXT_OK) {
nxt_thread_log_alert("event fd %d not found in hash", phe->fd);