nxt_conn_read.c (836:ecd3c5bbf7d8) nxt_conn_read.c (979:7037bef7b9b0)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 31 unchanged lines hidden (view full) ---

40 ssize_t n;
41 nxt_conn_t *c;
42 nxt_event_engine_t *engine;
43 nxt_work_handler_t handler;
44 const nxt_conn_state_t *state;
45
46 c = obj;
47
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 31 unchanged lines hidden (view full) ---

40 ssize_t n;
41 nxt_conn_t *c;
42 nxt_event_engine_t *engine;
43 nxt_work_handler_t handler;
44 const nxt_conn_state_t *state;
45
46 c = obj;
47
48 nxt_debug(task, "conn read fd:%d rdy:%d cl:%d",
49 c->socket.fd, c->socket.read_ready, c->socket.closed);
48 nxt_debug(task, "conn read fd:%d rdy:%d cl:%d er:%d bl:%d",
49 c->socket.fd, c->socket.read_ready, c->socket.closed,
50 c->socket.error, c->block_read);
50
51
51 if (c->socket.error != 0) {
52 if (c->socket.error != 0 || c->block_read) {
52 return;
53 }
54
55 engine = task->thread->engine;
56
57 /*
58 * Here c->io->read() is assigned instead of direct nxt_conn_io_read()
59 * because the function can be called by nxt_kqueue_conn_io_read().

--- 192 unchanged lines hidden ---
53 return;
54 }
55
56 engine = task->thread->engine;
57
58 /*
59 * Here c->io->read() is assigned instead of direct nxt_conn_io_read()
60 * because the function can be called by nxt_kqueue_conn_io_read().

--- 192 unchanged lines hidden ---