Deleted
Added
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 --- |