c 635 core/ngx_connection.c ngx_connection_t *c; c 647 core/ngx_connection.c c = ls[i].connection; c 649 core/ngx_connection.c if (c) { c 650 core/ngx_connection.c if (c->read->active) { c 652 core/ngx_connection.c ngx_del_conn(c, NGX_CLOSE_EVENT); c 662 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, 0); c 665 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); c 669 core/ngx_connection.c ngx_free_connection(c); c 671 core/ngx_connection.c c->fd = (ngx_socket_t) -1; c 708 core/ngx_connection.c ngx_connection_t *c; c 722 core/ngx_connection.c c = ngx_cycle->free_connections; c 724 core/ngx_connection.c if (c == NULL) { c 726 core/ngx_connection.c c = ngx_cycle->free_connections; c 729 core/ngx_connection.c if (c == NULL) { c 739 core/ngx_connection.c ngx_cycle->free_connections = c->data; c 745 core/ngx_connection.c ngx_cycle->files[s] = c; c 748 core/ngx_connection.c rev = c->read; c 749 core/ngx_connection.c wev = c->write; c 751 core/ngx_connection.c ngx_memzero(c, sizeof(ngx_connection_t)); c 753 core/ngx_connection.c c->read = rev; c 754 core/ngx_connection.c c->write = wev; c 755 core/ngx_connection.c c->fd = s; c 756 core/ngx_connection.c c->log = log; c 769 core/ngx_connection.c rev->data = c; c 770 core/ngx_connection.c wev->data = c; c 774 core/ngx_connection.c return c; c 779 core/ngx_connection.c ngx_free_connection(ngx_connection_t *c) c 783 core/ngx_connection.c c->data = ngx_cycle->free_connections; c 784 core/ngx_connection.c ngx_cycle->free_connections = c; c 790 core/ngx_connection.c ngx_cycle->files[c->fd] = NULL; c 796 core/ngx_connection.c ngx_close_connection(ngx_connection_t *c) c 802 core/ngx_connection.c if (c->fd == -1) { c 803 core/ngx_connection.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed"); c 807 core/ngx_connection.c if (c->read->timer_set) { c 808 core/ngx_connection.c ngx_del_timer(c->read); c 811 core/ngx_connection.c if (c->write->timer_set) { c 812 core/ngx_connection.c ngx_del_timer(c->write); c 816 core/ngx_connection.c ngx_del_conn(c, NGX_CLOSE_EVENT); c 819 core/ngx_connection.c if (c->read->active || c->read->disabled) { c 820 core/ngx_connection.c ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); c 823 core/ngx_connection.c if (c->write->active || c->write->disabled) { c 824 core/ngx_connection.c ngx_del_event(c->write, NGX_WRITE_EVENT, NGX_CLOSE_EVENT); c 838 core/ngx_connection.c if (c->read->prev) { c 839 core/ngx_connection.c ngx_delete_posted_event(c->read); c 842 core/ngx_connection.c if (c->write->prev) { c 843 core/ngx_connection.c ngx_delete_posted_event(c->write); c 846 core/ngx_connection.c c->read->closed = 1; c 847 core/ngx_connection.c c->write->closed = 1; c 849 core/ngx_connection.c if (c->single_connection) { c 850 core/ngx_connection.c ngx_unlock(&c->lock); c 851 core/ngx_connection.c c->read->locked = 0; c 852 core/ngx_connection.c c->write->locked = 0; c 859 core/ngx_connection.c if (c->read->prev) { c 860 core/ngx_connection.c ngx_delete_posted_event(c->read); c 863 core/ngx_connection.c if (c->write->prev) { c 864 core/ngx_connection.c ngx_delete_posted_event(c->write); c 867 core/ngx_connection.c c->read->closed = 1; c 868 core/ngx_connection.c c->write->closed = 1; c 872 core/ngx_connection.c ngx_reusable_connection(c, 0); c 874 core/ngx_connection.c log_error = c->log_error; c 876 core/ngx_connection.c ngx_free_connection(c); c 878 core/ngx_connection.c fd = c->fd; c 879 core/ngx_connection.c c->fd = (ngx_socket_t) -1; c 914 core/ngx_connection.c ngx_reusable_connection(ngx_connection_t *c, ngx_uint_t reusable) c 916 core/ngx_connection.c ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0, c 919 core/ngx_connection.c if (c->reusable) { c 920 core/ngx_connection.c ngx_queue_remove(&c->queue); c 923 core/ngx_connection.c c->reusable = reusable; c 929 core/ngx_connection.c (ngx_queue_t *) &ngx_cycle->reusable_connections_queue, &c->queue); c 939 core/ngx_connection.c ngx_connection_t *c; c 947 core/ngx_connection.c c = ngx_queue_data(q, ngx_connection_t, queue); c 949 core/ngx_connection.c ngx_log_debug0(NGX_LOG_DEBUG_CORE, c->log, 0, c 952 core/ngx_connection.c c->close = 1; c 953 core/ngx_connection.c c->read->handler(c->read); c 959 core/ngx_connection.c ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s, c 971 core/ngx_connection.c switch (c->local_sockaddr->sa_family) { c 975 core/ngx_connection.c sin6 = (struct sockaddr_in6 *) c->local_sockaddr; c 985 core/ngx_connection.c sin = (struct sockaddr_in *) c->local_sockaddr; c 994 core/ngx_connection.c if (getsockname(c->fd, (struct sockaddr *) &sa, &len) == -1) { c 995 core/ngx_connection.c ngx_connection_error(c, ngx_socket_errno, "getsockname() failed"); c 999 core/ngx_connection.c c->local_sockaddr = ngx_palloc(c->pool, len); c 1000 core/ngx_connection.c if (c->local_sockaddr == NULL) { c 1004 core/ngx_connection.c ngx_memcpy(c->local_sockaddr, &sa, len); c 1011 core/ngx_connection.c s->len = ngx_sock_ntop(c->local_sockaddr, s->data, s->len, port); c 1018 core/ngx_connection.c ngx_connection_error(ngx_connection_t *c, ngx_err_t err, char *text) c 1028 core/ngx_connection.c ) && c->log_error == NGX_ERROR_IGNORE_ECONNRESET) c 1034 core/ngx_connection.c if (err == NGX_EINVAL && c->log_error == NGX_ERROR_IGNORE_EINVAL) { c 1054 core/ngx_connection.c switch (c->log_error) { c 1070 core/ngx_connection.c ngx_log_error(level, c->log, err, text); c 184 core/ngx_connection.h void ngx_close_connection(ngx_connection_t *c); c 185 core/ngx_connection.h ngx_int_t ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s, c 187 core/ngx_connection.h ngx_int_t ngx_connection_error(ngx_connection_t *c, ngx_err_t err, char *text); c 190 core/ngx_connection.h void ngx_free_connection(ngx_connection_t *c); c 192 core/ngx_connection.h void ngx_reusable_connection(ngx_connection_t *c, ngx_uint_t reusable); c 26 core/ngx_core.h typedef void (*ngx_connection_handler_pt)(ngx_connection_t *c); c 22 core/ngx_crc32.h u_char c; c 28 core/ngx_crc32.h c = *p++; c 29 core/ngx_crc32.h crc = ngx_crc32_table_short[(crc ^ (c & 0xf)) & 0xf] ^ (crc >> 4); c 30 core/ngx_crc32.h crc = ngx_crc32_table_short[(crc ^ (c >> 4)) & 0xf] ^ (crc >> 4); c 59 core/ngx_crc32.h uint32_t c; c 61 core/ngx_crc32.h c = *crc; c 64 core/ngx_crc32.h c = ngx_crc32_table256[(c ^ *p++) & 0xff] ^ (c >> 8); c 67 core/ngx_crc32.h *crc = c; c 110 core/ngx_hash.h #define ngx_hash(key, c) ((ngx_uint_t) key * 31 + c) c 19 core/ngx_inet.c u_char *p, c; c 29 core/ngx_inet.c c = *p; c 31 core/ngx_inet.c if (c >= '0' && c <= '9') { c 32 core/ngx_inet.c octet = octet * 10 + (c - '0'); c 36 core/ngx_inet.c if (c == '.' && octet < 256) { c 64 core/ngx_inet.c u_char c, *zero, *digit, *s, *d; c 85 core/ngx_inet.c c = *p++; c 87 core/ngx_inet.c if (c == ':') { c 112 core/ngx_inet.c if (c == '.' && nibbles) { c 133 core/ngx_inet.c if (c >= '0' && c <= '9') { c 134 core/ngx_inet.c word = word * 16 + (c - '0'); c 138 core/ngx_inet.c c |= 0x20; c 140 core/ngx_inet.c if (c >= 'a' && c <= 'f') { c 141 core/ngx_inet.c word = word * 16 + (c - 'a') + 10; c 648 core/ngx_open_file_cache.c ngx_open_file_cache_cleanup_t *c = data; c 650 core/ngx_open_file_cache.c c->file->count--; c 652 core/ngx_open_file_cache.c ngx_close_cached_file(c->cache, c->file, c->min_uses, c->log); c 655 core/ngx_open_file_cache.c ngx_expire_old_cached_files(c->cache, 1, c->log); c 606 core/ngx_output_chain.c ngx_connection_t *c; c 608 core/ngx_output_chain.c c = ctx->connection; c 620 core/ngx_output_chain.c ngx_log_debug2(NGX_LOG_DEBUG_CORE, c->log, 0, c 635 core/ngx_output_chain.c ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0, c 650 core/ngx_output_chain.c if (size == 0 && !c->buffered) { c 654 core/ngx_output_chain.c ctx->out = c->send_chain(c, ctx->out, ctx->limit); c 656 core/ngx_output_chain.c ngx_log_debug1(NGX_LOG_DEBUG_CORE, c->log, 0, c 666 core/ngx_output_chain.c if (!c->buffered) { c 48 core/ngx_palloc.c ngx_pool_cleanup_t *c; c 50 core/ngx_palloc.c for (c = pool->cleanup; c; c = c->next) { c 51 core/ngx_palloc.c if (c->handler) { c 53 core/ngx_palloc.c "run cleanup: %p", c); c 54 core/ngx_palloc.c c->handler(c->data); c 316 core/ngx_palloc.c ngx_pool_cleanup_t *c; c 318 core/ngx_palloc.c c = ngx_palloc(p, sizeof(ngx_pool_cleanup_t)); c 319 core/ngx_palloc.c if (c == NULL) { c 324 core/ngx_palloc.c c->data = ngx_palloc(p, size); c 325 core/ngx_palloc.c if (c->data == NULL) { c 330 core/ngx_palloc.c c->data = NULL; c 333 core/ngx_palloc.c c->handler = NULL; c 334 core/ngx_palloc.c c->next = p->cleanup; c 336 core/ngx_palloc.c p->cleanup = c; c 338 core/ngx_palloc.c ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, p->log, 0, "add cleanup: %p", c); c 340 core/ngx_palloc.c return c; c 347 core/ngx_palloc.c ngx_pool_cleanup_t *c; c 350 core/ngx_palloc.c for (c = p->cleanup; c; c = c->next) { c 351 core/ngx_palloc.c if (c->handler == ngx_pool_cleanup_file) { c 353 core/ngx_palloc.c cf = c->data; c 356 core/ngx_palloc.c c->handler(cf); c 357 core/ngx_palloc.c c->handler = NULL; c 368 core/ngx_palloc.c ngx_pool_cleanup_file_t *c = data; c 370 core/ngx_palloc.c ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, c->log, 0, "file cleanup: fd:%d", c 371 core/ngx_palloc.c c->fd); c 373 core/ngx_palloc.c if (ngx_close_file(c->fd) == NGX_FILE_ERROR) { c 374 core/ngx_palloc.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 375 core/ngx_palloc.c ngx_close_file_n " \"%s\" failed", c->name); c 383 core/ngx_palloc.c ngx_pool_cleanup_file_t *c = data; c 387 core/ngx_palloc.c ngx_log_debug2(NGX_LOG_DEBUG_ALLOC, c->log, 0, "file cleanup: fd:%d %s", c 388 core/ngx_palloc.c c->fd, c->name); c 390 core/ngx_palloc.c if (ngx_delete_file(c->name) == NGX_FILE_ERROR) { c 394 core/ngx_palloc.c ngx_log_error(NGX_LOG_CRIT, c->log, err, c 395 core/ngx_palloc.c ngx_delete_file_n " \"%s\" failed", c->name); c 399 core/ngx_palloc.c if (ngx_close_file(c->fd) == NGX_FILE_ERROR) { c 400 core/ngx_palloc.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 401 core/ngx_palloc.c ngx_close_file_n " \"%s\" failed", c->name); c 946 core/ngx_resolver.c ngx_connection_t *c; c 949 core/ngx_resolver.c c = rev->data; c 952 core/ngx_resolver.c n = ngx_udp_recv(c, buf, NGX_RESOLVER_UDP_SIZE); c 958 core/ngx_resolver.c ngx_resolver_process_response(c->data, buf, n); c 2109 core/ngx_resolver.c ngx_connection_t *c; c 2121 core/ngx_resolver.c c = ngx_get_connection(s, &uc->log); c 2123 core/ngx_resolver.c if (c == NULL) { c 2136 core/ngx_resolver.c ngx_free_connection(c); c 2146 core/ngx_resolver.c rev = c->read; c 2147 core/ngx_resolver.c wev = c->write; c 2152 core/ngx_resolver.c uc->connection = c; c 2154 core/ngx_resolver.c c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1); c 2160 core/ngx_resolver.c rev->lock = &c->lock; c 2161 core/ngx_resolver.c wev->lock = &c->lock; c 2162 core/ngx_resolver.c rev->own_lock = &c->lock; c 2163 core/ngx_resolver.c wev->own_lock = &c->lock; c 2168 core/ngx_resolver.c "connect to %V, fd:%d #%d", &uc->server, s, c->number); c 2198 core/ngx_resolver.c if (ngx_add_conn(c) == NGX_ERROR) { c 1008 core/ngx_string.c u_char c, ch; c 1023 core/ngx_string.c c = (u_char) (ch | 0x20); c 1025 core/ngx_string.c if (c >= 'a' && c <= 'f') { c 1026 core/ngx_string.c value = value * 16 + (c - 'a' + 10); c 1266 core/ngx_string.c u_char c, *last; c 1273 core/ngx_string.c c = *p; c 1275 core/ngx_string.c if (c < 0x80) { c 1293 core/ngx_string.c u_char c, *next; c 1301 core/ngx_string.c c = *src; c 1302 core/ngx_string.c *dst = c; c 1304 core/ngx_string.c if (c < 0x80) { c 1306 core/ngx_string.c if (c != '\0') { c 1488 core/ngx_string.c u_char *d, *s, ch, c, decoded; c 1530 core/ngx_string.c c = (u_char) (ch | 0x20); c 1531 core/ngx_string.c if (c >= 'a' && c <= 'f') { c 1532 core/ngx_string.c decoded = (u_char) (c - 'a' + 10); c 1568 core/ngx_string.c c = (u_char) (ch | 0x20); c 1569 core/ngx_string.c if (c >= 'a' && c <= 'f') { c 1570 core/ngx_string.c ch = (u_char) ((decoded << 4) + c - 'a' + 10); c 46 core/ngx_string.h #define ngx_tolower(c) (u_char) ((c >= 'A' && c <= 'Z') ? (c | 0x20) : c) c 47 core/ngx_string.h #define ngx_toupper(c) (u_char) ((c >= 'a' && c <= 'z') ? (c & ~0x20) : c) c 62 core/ngx_string.h #define ngx_strchr(s1, c) strchr((const char *) s1, (int) c) c 65 core/ngx_string.h ngx_strlchr(u_char *p, u_char *last, u_char c) c 69 core/ngx_string.h if (*p == c) { c 86 core/ngx_string.h #define ngx_memset(buf, c, n) (void) memset(buf, c, n) c 21 event/modules/ngx_aio_module.c static ngx_int_t ngx_aio_del_connection(ngx_connection_t *c, ngx_uint_t flags); c 117 event/modules/ngx_aio_module.c ngx_aio_del_connection(ngx_connection_t *c, ngx_uint_t flags) c 121 event/modules/ngx_aio_module.c if (c->read->active == 0 && c->write->active == 0) { c 129 event/modules/ngx_aio_module.c rc = aio_cancel(c->fd, NULL); c 131 event/modules/ngx_aio_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_cancel: %d", rc); c 134 event/modules/ngx_aio_module.c c->read->active = 0; c 135 event/modules/ngx_aio_module.c c->write->active = 0; c 140 event/modules/ngx_aio_module.c c->read->active = 0; c 141 event/modules/ngx_aio_module.c c->write->active = 0; c 142 event/modules/ngx_aio_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 148 event/modules/ngx_aio_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 154 event/modules/ngx_aio_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 218 event/modules/ngx_devpoll_module.c ngx_connection_t *c; c 226 event/modules/ngx_devpoll_module.c c = ev->data; c 228 event/modules/ngx_devpoll_module.c "devpoll add event: fd:%d ev:%04Xi", c->fd, event); c 241 event/modules/ngx_devpoll_module.c ngx_connection_t *c; c 243 event/modules/ngx_devpoll_module.c c = ev->data; c 250 event/modules/ngx_devpoll_module.c "devpoll del event: fd:%d ev:%04Xi", c->fd, event); c 259 event/modules/ngx_devpoll_module.c e = (event == POLLIN) ? c->write : c->read; c 271 event/modules/ngx_devpoll_module.c e = c->write; c 275 event/modules/ngx_devpoll_module.c e = c->read; c 291 event/modules/ngx_devpoll_module.c ngx_connection_t *c; c 293 event/modules/ngx_devpoll_module.c c = ev->data; c 296 event/modules/ngx_devpoll_module.c "devpoll fd:%d ev:%04Xi fl:%04Xi", c->fd, event, flags); c 312 event/modules/ngx_devpoll_module.c change_list[nchanges].fd = c->fd; c 347 event/modules/ngx_devpoll_module.c ngx_connection_t *c; c 413 event/modules/ngx_devpoll_module.c c = ngx_cycle->files[fd]; c 415 event/modules/ngx_devpoll_module.c if (c == NULL || c->fd == -1) { c 494 event/modules/ngx_devpoll_module.c rev = c->read; c 516 event/modules/ngx_devpoll_module.c wev = c->write; c 98 event/modules/ngx_epoll_module.c static ngx_int_t ngx_epoll_add_connection(ngx_connection_t *c); c 99 event/modules/ngx_epoll_module.c static ngx_int_t ngx_epoll_del_connection(ngx_connection_t *c, c 341 event/modules/ngx_epoll_module.c ngx_connection_t *c; c 344 event/modules/ngx_epoll_module.c c = ev->data; c 349 event/modules/ngx_epoll_module.c e = c->write; c 356 event/modules/ngx_epoll_module.c e = c->read; c 372 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | ev->instance); c 376 event/modules/ngx_epoll_module.c c->fd, op, ee.events); c 378 event/modules/ngx_epoll_module.c if (epoll_ctl(ep, op, c->fd, &ee) == -1) { c 380 event/modules/ngx_epoll_module.c "epoll_ctl(%d, %d) failed", op, c->fd); c 399 event/modules/ngx_epoll_module.c ngx_connection_t *c; c 413 event/modules/ngx_epoll_module.c c = ev->data; c 416 event/modules/ngx_epoll_module.c e = c->write; c 420 event/modules/ngx_epoll_module.c e = c->read; c 427 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | ev->instance); c 437 event/modules/ngx_epoll_module.c c->fd, op, ee.events); c 439 event/modules/ngx_epoll_module.c if (epoll_ctl(ep, op, c->fd, &ee) == -1) { c 441 event/modules/ngx_epoll_module.c "epoll_ctl(%d, %d) failed", op, c->fd); c 452 event/modules/ngx_epoll_module.c ngx_epoll_add_connection(ngx_connection_t *c) c 457 event/modules/ngx_epoll_module.c ee.data.ptr = (void *) ((uintptr_t) c | c->read->instance); c 459 event/modules/ngx_epoll_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 460 event/modules/ngx_epoll_module.c "epoll add connection: fd:%d ev:%08XD", c->fd, ee.events); c 462 event/modules/ngx_epoll_module.c if (epoll_ctl(ep, EPOLL_CTL_ADD, c->fd, &ee) == -1) { c 463 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 464 event/modules/ngx_epoll_module.c "epoll_ctl(EPOLL_CTL_ADD, %d) failed", c->fd); c 468 event/modules/ngx_epoll_module.c c->read->active = 1; c 469 event/modules/ngx_epoll_module.c c->write->active = 1; c 476 event/modules/ngx_epoll_module.c ngx_epoll_del_connection(ngx_connection_t *c, ngx_uint_t flags) c 488 event/modules/ngx_epoll_module.c c->read->active = 0; c 489 event/modules/ngx_epoll_module.c c->write->active = 0; c 493 event/modules/ngx_epoll_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 494 event/modules/ngx_epoll_module.c "epoll del connection: fd:%d", c->fd); c 500 event/modules/ngx_epoll_module.c if (epoll_ctl(ep, op, c->fd, &ee) == -1) { c 501 event/modules/ngx_epoll_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 502 event/modules/ngx_epoll_module.c "epoll_ctl(%d, %d) failed", op, c->fd); c 506 event/modules/ngx_epoll_module.c c->read->active = 0; c 507 event/modules/ngx_epoll_module.c c->write->active = 0; c 523 event/modules/ngx_epoll_module.c ngx_connection_t *c; c 571 event/modules/ngx_epoll_module.c c = event_list[i].data.ptr; c 573 event/modules/ngx_epoll_module.c instance = (uintptr_t) c & 1; c 574 event/modules/ngx_epoll_module.c c = (ngx_connection_t *) ((uintptr_t) c & (uintptr_t) ~1); c 576 event/modules/ngx_epoll_module.c rev = c->read; c 578 event/modules/ngx_epoll_module.c if (c->fd == -1 || rev->instance != instance) { c 586 event/modules/ngx_epoll_module.c "epoll: stale event %p", c); c 591 event/modules/ngx_epoll_module.c log = c->log ? c->log : cycle->log; c 598 event/modules/ngx_epoll_module.c c->fd, revents, event_list[i].data.ptr); c 603 event/modules/ngx_epoll_module.c c->fd, revents); c 610 event/modules/ngx_epoll_module.c c->fd, revents); c 646 event/modules/ngx_epoll_module.c wev = c->write; c 272 event/modules/ngx_eventport_module.c ngx_connection_t *c; c 274 event/modules/ngx_eventport_module.c c = ev->data; c 279 event/modules/ngx_eventport_module.c e = c->write; c 286 event/modules/ngx_eventport_module.c e = c->read; c 298 event/modules/ngx_eventport_module.c "eventport add event: fd:%d ev:%04Xi", c->fd, events); c 300 event/modules/ngx_eventport_module.c if (port_associate(ep, PORT_SOURCE_FD, c->fd, events, c 320 event/modules/ngx_eventport_module.c ngx_connection_t *c; c 334 event/modules/ngx_eventport_module.c c = ev->data; c 337 event/modules/ngx_eventport_module.c e = c->write; c 341 event/modules/ngx_eventport_module.c e = c->read; c 347 event/modules/ngx_eventport_module.c "eventport change event: fd:%d ev:%04Xi", c->fd, event); c 349 event/modules/ngx_eventport_module.c if (port_associate(ep, PORT_SOURCE_FD, c->fd, event, c 360 event/modules/ngx_eventport_module.c "eventport del event: fd:%d", c->fd); c 362 event/modules/ngx_eventport_module.c if (port_dissociate(ep, PORT_SOURCE_FD, c->fd) == -1) { c 386 event/modules/ngx_eventport_module.c ngx_connection_t *c; c 497 event/modules/ngx_eventport_module.c c = ev->data; c 498 event/modules/ngx_eventport_module.c rev = c->read; c 499 event/modules/ngx_eventport_module.c wev = c->write; c 533 event/modules/ngx_eventport_module.c if (port_associate(ep, PORT_SOURCE_FD, c->fd, POLLIN, c 284 event/modules/ngx_kqueue_module.c ngx_connection_t *c; c 322 event/modules/ngx_kqueue_module.c c = ev->data; c 325 event/modules/ngx_kqueue_module.c "previous event on #%d were not passed in kernel", c->fd); c 408 event/modules/ngx_kqueue_module.c ngx_connection_t *c; c 410 event/modules/ngx_kqueue_module.c c = ev->data; c 414 event/modules/ngx_kqueue_module.c c->fd, filter, flags); c 435 event/modules/ngx_kqueue_module.c kev->ident = c->fd; c 116 event/modules/ngx_poll_module.c ngx_connection_t *c; c 118 event/modules/ngx_poll_module.c c = ev->data; c 124 event/modules/ngx_poll_module.c "poll event fd:%d ev:%i is already set", c->fd, event); c 129 event/modules/ngx_poll_module.c e = c->write; c 135 event/modules/ngx_poll_module.c e = c->read; c 142 event/modules/ngx_poll_module.c "poll add event: fd:%d ev:%i", c->fd, event); c 145 event/modules/ngx_poll_module.c event_list[nevents].fd = c->fd; c 168 event/modules/ngx_poll_module.c ngx_connection_t *c; c 170 event/modules/ngx_poll_module.c c = ev->data; c 177 event/modules/ngx_poll_module.c c->fd, event); c 182 event/modules/ngx_poll_module.c e = c->write; c 188 event/modules/ngx_poll_module.c e = c->read; c 195 event/modules/ngx_poll_module.c "poll del event: fd:%d ev:%i", c->fd, event); c 207 event/modules/ngx_poll_module.c c = ngx_cycle->files[event_list[nevents].fd]; c 209 event/modules/ngx_poll_module.c if (c->fd == -1) { c 214 event/modules/ngx_poll_module.c if (c->read->index == (ngx_uint_t) nevents) { c 215 event/modules/ngx_poll_module.c c->read->index = ev->index; c 218 event/modules/ngx_poll_module.c if (c->write->index == (ngx_uint_t) nevents) { c 219 event/modules/ngx_poll_module.c c->write->index = ev->index; c 245 event/modules/ngx_poll_module.c ngx_connection_t *c; c 340 event/modules/ngx_poll_module.c c = ngx_cycle->files[event_list[i].fd]; c 342 event/modules/ngx_poll_module.c if (c->fd == -1) { c 376 event/modules/ngx_poll_module.c ev = c->read; c 392 event/modules/ngx_poll_module.c ev = c->write; c 48 event/modules/ngx_rtsig_module.c static ngx_int_t ngx_rtsig_add_connection(ngx_connection_t *c); c 49 event/modules/ngx_rtsig_module.c static ngx_int_t ngx_rtsig_del_connection(ngx_connection_t *c, c 195 event/modules/ngx_rtsig_module.c ngx_rtsig_add_connection(ngx_connection_t *c) c 200 event/modules/ngx_rtsig_module.c if (c->read->accept && c->read->disabled) { c 202 event/modules/ngx_rtsig_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 203 event/modules/ngx_rtsig_module.c "rtsig enable connection: fd:%d", c->fd); c 205 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETOWN, ngx_pid) == -1) { c 206 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 211 event/modules/ngx_rtsig_module.c c->read->active = 1; c 212 event/modules/ngx_rtsig_module.c c->read->disabled = 0; c 217 event/modules/ngx_rtsig_module.c signo = rtscf->signo + c->read->instance; c 219 event/modules/ngx_rtsig_module.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 220 event/modules/ngx_rtsig_module.c "rtsig add connection: fd:%d signo:%ui", c->fd, signo); c 222 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETFL, O_RDWR|O_NONBLOCK|O_ASYNC) == -1) { c 223 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 228 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETSIG, (int) signo) == -1) { c 229 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 234 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETOWN, ngx_pid) == -1) { c 235 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 241 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETAUXFL, O_ONESIGFD) == -1) { c 242 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 248 event/modules/ngx_rtsig_module.c c->read->active = 1; c 249 event/modules/ngx_rtsig_module.c c->write->active = 1; c 256 event/modules/ngx_rtsig_module.c ngx_rtsig_del_connection(ngx_connection_t *c, ngx_uint_t flags) c 258 event/modules/ngx_rtsig_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 259 event/modules/ngx_rtsig_module.c "rtsig del connection: fd:%d", c->fd); c 261 event/modules/ngx_rtsig_module.c if ((flags & NGX_DISABLE_EVENT) && c->read->accept) { c 263 event/modules/ngx_rtsig_module.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 264 event/modules/ngx_rtsig_module.c "rtsig disable connection: fd:%d", c->fd); c 266 event/modules/ngx_rtsig_module.c c->read->active = 0; c 267 event/modules/ngx_rtsig_module.c c->read->disabled = 1; c 272 event/modules/ngx_rtsig_module.c c->read->active = 0; c 273 event/modules/ngx_rtsig_module.c c->write->active = 0; c 277 event/modules/ngx_rtsig_module.c if (fcntl(c->fd, F_SETFL, O_RDWR|O_NONBLOCK) == -1) { c 278 event/modules/ngx_rtsig_module.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 283 event/modules/ngx_rtsig_module.c c->read->active = 0; c 284 event/modules/ngx_rtsig_module.c c->write->active = 0; c 300 event/modules/ngx_rtsig_module.c ngx_connection_t *c; c 363 event/modules/ngx_rtsig_module.c c = ngx_cycle->files[si.si_fd]; c 365 event/modules/ngx_rtsig_module.c if (c == NULL) { c 374 event/modules/ngx_rtsig_module.c rev = c->read; c 384 event/modules/ngx_rtsig_module.c "rtsig: stale event %p", c); c 404 event/modules/ngx_rtsig_module.c wev = c->write; c 471 event/modules/ngx_rtsig_module.c ngx_connection_t *c; c 490 event/modules/ngx_rtsig_module.c c = cycle->files[overflow_current++]; c 492 event/modules/ngx_rtsig_module.c if (c == NULL || c->fd == -1) { c 498 event/modules/ngx_rtsig_module.c if (c->read->active && c->read->handler) { c 502 event/modules/ngx_rtsig_module.c if (c->write->active && c->write->handler) { c 510 event/modules/ngx_rtsig_module.c overflow_list[n].fd = c->fd; c 547 event/modules/ngx_rtsig_module.c c = cycle->files[overflow_list[i].fd]; c 549 event/modules/ngx_rtsig_module.c if (c == NULL) { c 553 event/modules/ngx_rtsig_module.c rev = c->read; c 581 event/modules/ngx_rtsig_module.c wev = c->write; c 126 event/modules/ngx_select_module.c ngx_connection_t *c; c 128 event/modules/ngx_select_module.c c = ev->data; c 131 event/modules/ngx_select_module.c "select add event fd:%d ev:%i", c->fd, event); c 135 event/modules/ngx_select_module.c "select event fd:%d ev:%i is already set", c->fd, event); c 144 event/modules/ngx_select_module.c ev->write ? "write" : "read", c->fd, event); c 149 event/modules/ngx_select_module.c FD_SET(c->fd, &master_read_fd_set); c 152 event/modules/ngx_select_module.c FD_SET(c->fd, &master_write_fd_set); c 155 event/modules/ngx_select_module.c if (max_fd != -1 && max_fd < c->fd) { c 156 event/modules/ngx_select_module.c max_fd = c->fd; c 173 event/modules/ngx_select_module.c ngx_connection_t *c; c 175 event/modules/ngx_select_module.c c = ev->data; c 184 event/modules/ngx_select_module.c "select del event fd:%d ev:%i", c->fd, event); c 187 event/modules/ngx_select_module.c FD_CLR(c->fd, &master_read_fd_set); c 190 event/modules/ngx_select_module.c FD_CLR(c->fd, &master_write_fd_set); c 193 event/modules/ngx_select_module.c if (max_fd == c->fd) { c 218 event/modules/ngx_select_module.c ngx_connection_t *c; c 222 event/modules/ngx_select_module.c c = event_index[i]->data; c 223 event/modules/ngx_select_module.c if (max_fd < c->fd) { c 224 event/modules/ngx_select_module.c max_fd = c->fd; c 236 event/modules/ngx_select_module.c c = ev->data; c 238 event/modules/ngx_select_module.c "select event: fd:%d wr:%d", c->fd, ev->write); c 313 event/modules/ngx_select_module.c c = ev->data; c 317 event/modules/ngx_select_module.c if (FD_ISSET(c->fd, &work_write_fd_set)) { c 320 event/modules/ngx_select_module.c "select write %d", c->fd); c 324 event/modules/ngx_select_module.c if (FD_ISSET(c->fd, &work_read_fd_set)) { c 327 event/modules/ngx_select_module.c "select read %d", c->fd); c 128 event/modules/ngx_win32_select_module.c ngx_connection_t *c; c 130 event/modules/ngx_win32_select_module.c c = ev->data; c 133 event/modules/ngx_win32_select_module.c "select add event fd:%d ev:%i", c->fd, event); c 137 event/modules/ngx_win32_select_module.c "select event fd:%d ev:%i is already set", c->fd, event); c 146 event/modules/ngx_win32_select_module.c ev->write ? "write" : "read", c->fd, event); c 160 event/modules/ngx_win32_select_module.c FD_SET(c->fd, &master_read_fd_set); c 164 event/modules/ngx_win32_select_module.c FD_SET(c->fd, &master_write_fd_set); c 182 event/modules/ngx_win32_select_module.c ngx_connection_t *c; c 184 event/modules/ngx_win32_select_module.c c = ev->data; c 193 event/modules/ngx_win32_select_module.c "select del event fd:%d ev:%i", c->fd, event); c 196 event/modules/ngx_win32_select_module.c FD_CLR(c->fd, &master_read_fd_set); c 200 event/modules/ngx_win32_select_module.c FD_CLR(c->fd, &master_write_fd_set); c 225 event/modules/ngx_win32_select_module.c ngx_connection_t *c; c 231 event/modules/ngx_win32_select_module.c c = ev->data; c 233 event/modules/ngx_win32_select_module.c "select event: fd:%d wr:%d", c->fd, ev->write); c 304 event/modules/ngx_win32_select_module.c c = ev->data; c 308 event/modules/ngx_win32_select_module.c if (FD_ISSET(c->fd, &work_write_fd_set)) { c 311 event/modules/ngx_win32_select_module.c "select write %d", c->fd); c 315 event/modules/ngx_win32_select_module.c if (FD_ISSET(c->fd, &work_read_fd_set)) { c 318 event/modules/ngx_win32_select_module.c "select read %d", c->fd); c 349 event/ngx_event.c ngx_connection_t *c; c 352 event/ngx_event.c c = wev->data; c 354 event/ngx_event.c if (ngx_send_lowat(c, lowat) == NGX_ERROR) { c 579 event/ngx_event.c ngx_connection_t *c, *next, *old; c 679 event/ngx_event.c c = cycle->connections; c 692 event/ngx_event.c rev[i].lock = &c[i].lock; c 693 event/ngx_event.c rev[i].own_lock = &c[i].lock; c 707 event/ngx_event.c wev[i].lock = &c[i].lock; c 708 event/ngx_event.c wev[i].own_lock = &c[i].lock; c 718 event/ngx_event.c c[i].data = next; c 719 event/ngx_event.c c[i].read = &cycle->read_events[i]; c 720 event/ngx_event.c c[i].write = &cycle->write_events[i]; c 721 event/ngx_event.c c[i].fd = (ngx_socket_t) -1; c 723 event/ngx_event.c next = &c[i]; c 726 event/ngx_event.c c[i].lock = 0; c 738 event/ngx_event.c c = ngx_get_connection(ls[i].fd, cycle->log); c 740 event/ngx_event.c if (c == NULL) { c 744 event/ngx_event.c c->log = &ls[i].log; c 746 event/ngx_event.c c->listening = &ls[i]; c 747 event/ngx_event.c ls[i].connection = c; c 749 event/ngx_event.c rev = c->read; c 751 event/ngx_event.c rev->log = c->log; c 823 event/ngx_event.c if (ngx_add_conn(c) == NGX_ERROR) { c 842 event/ngx_event.c ngx_send_lowat(ngx_connection_t *c, size_t lowat) c 849 event/ngx_event.c c->write->available = lowat; c 855 event/ngx_event.c if (lowat == 0 || c->sndlowat) { c 861 event/ngx_event.c if (setsockopt(c->fd, SOL_SOCKET, SO_SNDLOWAT, c 865 event/ngx_event.c ngx_connection_error(c, ngx_socket_errno, c 870 event/ngx_event.c c->sndlowat = 1; c 236 event/ngx_event.h ngx_int_t (*add_conn)(ngx_connection_t *c); c 237 event/ngx_event.h ngx_int_t (*del_conn)(ngx_connection_t *c, ngx_uint_t flags); c 556 event/ngx_event.h ngx_int_t ngx_send_lowat(ngx_connection_t *c, size_t lowat); c 14 event/ngx_event_accept.c static void ngx_close_accepted_connection(ngx_connection_t *c); c 26 event/ngx_event_accept.c ngx_connection_t *c, *lc; c 109 event/ngx_event_accept.c c = ngx_get_connection(s, ev->log); c 111 event/ngx_event_accept.c if (c == NULL) { c 124 event/ngx_event_accept.c c->pool = ngx_create_pool(ls->pool_size, ev->log); c 125 event/ngx_event_accept.c if (c->pool == NULL) { c 126 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 130 event/ngx_event_accept.c c->sockaddr = ngx_palloc(c->pool, socklen); c 131 event/ngx_event_accept.c if (c->sockaddr == NULL) { c 132 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 136 event/ngx_event_accept.c ngx_memcpy(c->sockaddr, sa, socklen); c 138 event/ngx_event_accept.c log = ngx_palloc(c->pool, sizeof(ngx_log_t)); c 140 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 151 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 161 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 169 event/ngx_event_accept.c c->recv = ngx_recv; c 170 event/ngx_event_accept.c c->send = ngx_send; c 171 event/ngx_event_accept.c c->recv_chain = ngx_recv_chain; c 172 event/ngx_event_accept.c c->send_chain = ngx_send_chain; c 174 event/ngx_event_accept.c c->log = log; c 175 event/ngx_event_accept.c c->pool->log = log; c 177 event/ngx_event_accept.c c->socklen = socklen; c 178 event/ngx_event_accept.c c->listening = ls; c 179 event/ngx_event_accept.c c->local_sockaddr = ls->sockaddr; c 181 event/ngx_event_accept.c c->unexpected_eof = 1; c 184 event/ngx_event_accept.c if (c->sockaddr->sa_family == AF_UNIX) { c 185 event/ngx_event_accept.c c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED; c 186 event/ngx_event_accept.c c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED; c 189 event/ngx_event_accept.c c->sendfile = 0; c 194 event/ngx_event_accept.c rev = c->read; c 195 event/ngx_event_accept.c wev = c->write; c 223 event/ngx_event_accept.c c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1); c 230 event/ngx_event_accept.c rev->lock = &c->lock; c 231 event/ngx_event_accept.c wev->lock = &c->lock; c 232 event/ngx_event_accept.c rev->own_lock = &c->lock; c 233 event/ngx_event_accept.c wev->own_lock = &c->lock; c 237 event/ngx_event_accept.c c->addr_text.data = ngx_pnalloc(c->pool, ls->addr_text_max_len); c 238 event/ngx_event_accept.c if (c->addr_text.data == NULL) { c 239 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 243 event/ngx_event_accept.c c->addr_text.len = ngx_sock_ntop(c->sockaddr, c->addr_text.data, c 245 event/ngx_event_accept.c if (c->addr_text.len == 0) { c 246 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 271 event/ngx_event_accept.c "*%d accept: %V fd:%d", c->number, &c->addr_text, s); c 274 event/ngx_event_accept.c if (ngx_add_conn(c) == NGX_ERROR) { c 275 event/ngx_event_accept.c ngx_close_accepted_connection(c); c 283 event/ngx_event_accept.c ls->handler(c); c 339 event/ngx_event_accept.c ngx_connection_t *c; c 344 event/ngx_event_accept.c c = ls[i].connection; c 348 event/ngx_event_accept.c if (ngx_add_conn(c) == NGX_ERROR) { c 353 event/ngx_event_accept.c if (ngx_add_event(c->read, NGX_READ_EVENT, 0) == NGX_ERROR) { c 368 event/ngx_event_accept.c ngx_connection_t *c; c 373 event/ngx_event_accept.c c = ls[i].connection; c 375 event/ngx_event_accept.c if (!c->read->active) { c 380 event/ngx_event_accept.c if (ngx_del_conn(c, NGX_DISABLE_EVENT) == NGX_ERROR) { c 385 event/ngx_event_accept.c if (ngx_del_event(c->read, NGX_READ_EVENT, NGX_DISABLE_EVENT) c 398 event/ngx_event_accept.c ngx_close_accepted_connection(ngx_connection_t *c) c 402 event/ngx_event_accept.c ngx_free_connection(c); c 404 event/ngx_event_accept.c fd = c->fd; c 405 event/ngx_event_accept.c c->fd = (ngx_socket_t) -1; c 408 event/ngx_event_accept.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_socket_errno, c 412 event/ngx_event_accept.c if (c->pool) { c 413 event/ngx_event_accept.c ngx_destroy_pool(c->pool); c 179 event/ngx_event_busy_lock.c ngx_event_busy_lock_ctx_t *c, *p; c 190 event/ngx_event_busy_lock.c for (c = bl->events->next; c; c = c->next) { c 191 event/ngx_event_busy_lock.c if (c == ctx) { c 195 event/ngx_event_busy_lock.c p = c; c 22 event/ngx_event_connect.c ngx_connection_t *c; c 40 event/ngx_event_connect.c c = ngx_get_connection(s, pc->log); c 42 event/ngx_event_connect.c if (c == NULL) { c 77 event/ngx_event_connect.c c->recv = ngx_recv; c 78 event/ngx_event_connect.c c->send = ngx_send; c 79 event/ngx_event_connect.c c->recv_chain = ngx_recv_chain; c 80 event/ngx_event_connect.c c->send_chain = ngx_send_chain; c 82 event/ngx_event_connect.c c->sendfile = 1; c 84 event/ngx_event_connect.c c->log_error = pc->log_error; c 87 event/ngx_event_connect.c c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED; c 88 event/ngx_event_connect.c c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED; c 92 event/ngx_event_connect.c c->sendfile = 0; c 96 event/ngx_event_connect.c rev = c->read; c 97 event/ngx_event_connect.c wev = c->write; c 102 event/ngx_event_connect.c pc->connection = c; c 104 event/ngx_event_connect.c c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1); c 112 event/ngx_event_connect.c rev->own_lock = &c->lock; c 113 event/ngx_event_connect.c wev->own_lock = &c->lock; c 118 event/ngx_event_connect.c if (ngx_add_conn(c) == NGX_ERROR) { c 124 event/ngx_event_connect.c "connect to %V, fd:%d #%d", pc->name, s, c->number); c 159 event/ngx_event_connect.c ngx_log_error(level, c->log, err, "connect() to %V failed", c 243 event/ngx_event_connect.c ngx_free_connection(c); c 21 event/ngx_event_openssl.c static ngx_int_t ngx_ssl_handle_recv(ngx_connection_t *c, int n); c 25 event/ngx_event_openssl.c static void ngx_ssl_connection_error(ngx_connection_t *c, int sslerr, c 322 event/ngx_event_openssl.c ngx_connection_t *c; c 328 event/ngx_event_openssl.c c = ngx_ssl_get_connection(ssl_conn); c 340 event/ngx_event_openssl.c ngx_log_debug5(NGX_LOG_DEBUG_EVENT, c->log, 0, c 361 event/ngx_event_openssl.c ngx_connection_t *c; c 364 event/ngx_event_openssl.c c = ngx_ssl_get_connection((ngx_ssl_conn_t *) ssl_conn); c 366 event/ngx_event_openssl.c if (c->ssl->handshaked) { c 367 event/ngx_event_openssl.c c->ssl->renegotiation = 1; c 368 event/ngx_event_openssl.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL renegotiation"); c 483 event/ngx_event_openssl.c ngx_ssl_create_connection(ngx_ssl_t *ssl, ngx_connection_t *c, ngx_uint_t flags) c 487 event/ngx_event_openssl.c sc = ngx_pcalloc(c->pool, sizeof(ngx_ssl_connection_t)); c 497 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "SSL_new() failed"); c 501 event/ngx_event_openssl.c if (SSL_set_fd(sc->connection, c->fd) == 0) { c 502 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "SSL_set_fd() failed"); c 513 event/ngx_event_openssl.c if (SSL_set_ex_data(sc->connection, ngx_ssl_connection_index, c) == 0) { c 514 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "SSL_set_ex_data() failed"); c 518 event/ngx_event_openssl.c c->ssl = sc; c 525 event/ngx_event_openssl.c ngx_ssl_set_session(ngx_connection_t *c, ngx_ssl_session_t *session) c 528 event/ngx_event_openssl.c if (SSL_set_session(c->ssl->connection, session) == 0) { c 529 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "SSL_set_session() failed"); c 539 event/ngx_event_openssl.c ngx_ssl_handshake(ngx_connection_t *c) c 544 event/ngx_event_openssl.c ngx_ssl_clear_error(c->log); c 546 event/ngx_event_openssl.c n = SSL_do_handshake(c->ssl->connection); c 548 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_do_handshake: %d", n); c 552 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 556 event/ngx_event_openssl.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 568 event/ngx_event_openssl.c cipher = SSL_get_current_cipher(c->ssl->connection); c 591 event/ngx_event_openssl.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 593 event/ngx_event_openssl.c SSL_get_version(c->ssl->connection), &buf[1]); c 595 event/ngx_event_openssl.c if (SSL_session_reused(c->ssl->connection)) { c 596 event/ngx_event_openssl.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, c 601 event/ngx_event_openssl.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, c 607 event/ngx_event_openssl.c c->ssl->handshaked = 1; c 609 event/ngx_event_openssl.c c->recv = ngx_ssl_recv; c 610 event/ngx_event_openssl.c c->send = ngx_ssl_write; c 611 event/ngx_event_openssl.c c->recv_chain = ngx_ssl_recv_chain; c 612 event/ngx_event_openssl.c c->send_chain = ngx_ssl_send_chain; c 615 event/ngx_event_openssl.c if (c->ssl->connection->s3) { c 616 event/ngx_event_openssl.c c->ssl->connection->s3->flags |= SSL3_FLAGS_NO_RENEGOTIATE_CIPHERS; c 622 event/ngx_event_openssl.c sslerr = SSL_get_error(c->ssl->connection, n); c 624 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_get_error: %d", sslerr); c 627 event/ngx_event_openssl.c c->read->ready = 0; c 628 event/ngx_event_openssl.c c->read->handler = ngx_ssl_handshake_handler; c 629 event/ngx_event_openssl.c c->write->handler = ngx_ssl_handshake_handler; c 631 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 639 event/ngx_event_openssl.c c->write->ready = 0; c 640 event/ngx_event_openssl.c c->read->handler = ngx_ssl_handshake_handler; c 641 event/ngx_event_openssl.c c->write->handler = ngx_ssl_handshake_handler; c 643 event/ngx_event_openssl.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 652 event/ngx_event_openssl.c c->ssl->no_wait_shutdown = 1; c 653 event/ngx_event_openssl.c c->ssl->no_send_shutdown = 1; c 654 event/ngx_event_openssl.c c->read->eof = 1; c 657 event/ngx_event_openssl.c ngx_log_error(NGX_LOG_INFO, c->log, err, c 663 event/ngx_event_openssl.c c->read->error = 1; c 665 event/ngx_event_openssl.c ngx_ssl_connection_error(c, sslerr, err, "SSL_do_handshake() failed"); c 674 event/ngx_event_openssl.c ngx_connection_t *c; c 676 event/ngx_event_openssl.c c = ev->data; c 678 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 682 event/ngx_event_openssl.c c->ssl->handler(c); c 686 event/ngx_event_openssl.c if (ngx_ssl_handshake(c) == NGX_AGAIN) { c 690 event/ngx_event_openssl.c c->ssl->handler(c); c 695 event/ngx_event_openssl.c ngx_ssl_recv_chain(ngx_connection_t *c, ngx_chain_t *cl) c 708 event/ngx_event_openssl.c n = ngx_ssl_recv(c, last, b->end - last); c 731 event/ngx_event_openssl.c c->read->ready = 1; c 743 event/ngx_event_openssl.c ngx_ssl_recv(ngx_connection_t *c, u_char *buf, size_t size) c 747 event/ngx_event_openssl.c if (c->ssl->last == NGX_ERROR) { c 748 event/ngx_event_openssl.c c->read->error = 1; c 752 event/ngx_event_openssl.c if (c->ssl->last == NGX_DONE) { c 753 event/ngx_event_openssl.c c->read->ready = 0; c 754 event/ngx_event_openssl.c c->read->eof = 1; c 760 event/ngx_event_openssl.c ngx_ssl_clear_error(c->log); c 769 event/ngx_event_openssl.c n = SSL_read(c->ssl->connection, buf, size); c 771 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_read: %d", n); c 777 event/ngx_event_openssl.c c->ssl->last = ngx_ssl_handle_recv(c, n); c 779 event/ngx_event_openssl.c if (c->ssl->last == NGX_OK) { c 796 event/ngx_event_openssl.c switch (c->ssl->last) { c 799 event/ngx_event_openssl.c c->read->ready = 0; c 800 event/ngx_event_openssl.c c->read->eof = 1; c 804 event/ngx_event_openssl.c c->read->error = 1; c 809 event/ngx_event_openssl.c return c->ssl->last; c 816 event/ngx_event_openssl.c ngx_ssl_handle_recv(ngx_connection_t *c, int n) c 821 event/ngx_event_openssl.c if (c->ssl->renegotiation) { c 828 event/ngx_event_openssl.c ngx_log_error(NGX_LOG_NOTICE, c->log, 0, "SSL renegotiation disabled"); c 830 event/ngx_event_openssl.c c->ssl->no_wait_shutdown = 1; c 831 event/ngx_event_openssl.c c->ssl->no_send_shutdown = 1; c 838 event/ngx_event_openssl.c if (c->ssl->saved_write_handler) { c 840 event/ngx_event_openssl.c c->write->handler = c->ssl->saved_write_handler; c 841 event/ngx_event_openssl.c c->ssl->saved_write_handler = NULL; c 842 event/ngx_event_openssl.c c->write->ready = 1; c 844 event/ngx_event_openssl.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 848 event/ngx_event_openssl.c ngx_post_event(c->write, &ngx_posted_events); c 854 event/ngx_event_openssl.c sslerr = SSL_get_error(c->ssl->connection, n); c 858 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_get_error: %d", sslerr); c 861 event/ngx_event_openssl.c c->read->ready = 0; c 867 event/ngx_event_openssl.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 870 event/ngx_event_openssl.c c->write->ready = 0; c 872 event/ngx_event_openssl.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 880 event/ngx_event_openssl.c if (c->ssl->saved_write_handler == NULL) { c 881 event/ngx_event_openssl.c c->ssl->saved_write_handler = c->write->handler; c 882 event/ngx_event_openssl.c c->write->handler = ngx_ssl_write_handler; c 888 event/ngx_event_openssl.c c->ssl->no_wait_shutdown = 1; c 889 event/ngx_event_openssl.c c->ssl->no_send_shutdown = 1; c 892 event/ngx_event_openssl.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, c 897 event/ngx_event_openssl.c ngx_ssl_connection_error(c, sslerr, err, "SSL_read() failed"); c 906 event/ngx_event_openssl.c ngx_connection_t *c; c 908 event/ngx_event_openssl.c c = wev->data; c 910 event/ngx_event_openssl.c c->read->handler(c->read); c 923 event/ngx_event_openssl.c ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 930 event/ngx_event_openssl.c if (!c->ssl->buffer) { c 938 event/ngx_event_openssl.c n = ngx_ssl_write(c, in->buf->pos, in->buf->last - in->buf->pos); c 945 event/ngx_event_openssl.c c->buffered |= NGX_SSL_BUFFERED; c 966 event/ngx_event_openssl.c buf = c->ssl->buf; c 969 event/ngx_event_openssl.c buf = ngx_create_temp_buf(c->pool, NGX_SSL_BUFSIZE); c 974 event/ngx_event_openssl.c c->ssl->buf = buf; c 978 event/ngx_event_openssl.c buf->start = ngx_palloc(c->pool, NGX_SSL_BUFSIZE); c 1014 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 1030 event/ngx_event_openssl.c if (!flush && buf->last < buf->end && c->ssl->buffer) { c 1034 event/ngx_event_openssl.c n = ngx_ssl_write(c, buf->pos, size); c 1041 event/ngx_event_openssl.c c->buffered |= NGX_SSL_BUFFERED; c 1046 event/ngx_event_openssl.c c->sent += n; c 1063 event/ngx_event_openssl.c c->buffered |= NGX_SSL_BUFFERED; c 1066 event/ngx_event_openssl.c c->buffered &= ~NGX_SSL_BUFFERED; c 1074 event/ngx_event_openssl.c ngx_ssl_write(ngx_connection_t *c, u_char *data, size_t size) c 1079 event/ngx_event_openssl.c ngx_ssl_clear_error(c->log); c 1081 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL to write: %d", size); c 1083 event/ngx_event_openssl.c n = SSL_write(c->ssl->connection, data, size); c 1085 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_write: %d", n); c 1089 event/ngx_event_openssl.c if (c->ssl->saved_read_handler) { c 1091 event/ngx_event_openssl.c c->read->handler = c->ssl->saved_read_handler; c 1092 event/ngx_event_openssl.c c->ssl->saved_read_handler = NULL; c 1093 event/ngx_event_openssl.c c->read->ready = 1; c 1095 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 1099 event/ngx_event_openssl.c ngx_post_event(c->read, &ngx_posted_events); c 1105 event/ngx_event_openssl.c sslerr = SSL_get_error(c->ssl->connection, n); c 1109 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_get_error: %d", sslerr); c 1112 event/ngx_event_openssl.c c->write->ready = 0; c 1118 event/ngx_event_openssl.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1121 event/ngx_event_openssl.c c->read->ready = 0; c 1123 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 1132 event/ngx_event_openssl.c if (c->ssl->saved_read_handler == NULL) { c 1133 event/ngx_event_openssl.c c->ssl->saved_read_handler = c->read->handler; c 1134 event/ngx_event_openssl.c c->read->handler = ngx_ssl_read_handler; c 1140 event/ngx_event_openssl.c c->ssl->no_wait_shutdown = 1; c 1141 event/ngx_event_openssl.c c->ssl->no_send_shutdown = 1; c 1142 event/ngx_event_openssl.c c->write->error = 1; c 1144 event/ngx_event_openssl.c ngx_ssl_connection_error(c, sslerr, err, "SSL_write() failed"); c 1153 event/ngx_event_openssl.c ngx_connection_t *c; c 1155 event/ngx_event_openssl.c c = rev->data; c 1157 event/ngx_event_openssl.c c->write->handler(c->write); c 1162 event/ngx_event_openssl.c ngx_ssl_free_buffer(ngx_connection_t *c) c 1164 event/ngx_event_openssl.c if (c->ssl->buf && c->ssl->buf->start) { c 1165 event/ngx_event_openssl.c if (ngx_pfree(c->pool, c->ssl->buf->start) == NGX_OK) { c 1166 event/ngx_event_openssl.c c->ssl->buf->start = NULL; c 1173 event/ngx_event_openssl.c ngx_ssl_shutdown(ngx_connection_t *c) c 1178 event/ngx_event_openssl.c if (c->timedout) { c 1182 event/ngx_event_openssl.c mode = SSL_get_shutdown(c->ssl->connection); c 1184 event/ngx_event_openssl.c if (c->ssl->no_wait_shutdown) { c 1188 event/ngx_event_openssl.c if (c->ssl->no_send_shutdown) { c 1193 event/ngx_event_openssl.c SSL_set_shutdown(c->ssl->connection, mode); c 1195 event/ngx_event_openssl.c ngx_ssl_clear_error(c->log); c 1197 event/ngx_event_openssl.c n = SSL_shutdown(c->ssl->connection); c 1199 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "SSL_shutdown: %d", n); c 1206 event/ngx_event_openssl.c sslerr = SSL_get_error(c->ssl->connection, n); c 1208 event/ngx_event_openssl.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 1213 event/ngx_event_openssl.c SSL_free(c->ssl->connection); c 1214 event/ngx_event_openssl.c c->ssl = NULL; c 1220 event/ngx_event_openssl.c c->read->handler = ngx_ssl_shutdown_handler; c 1221 event/ngx_event_openssl.c c->write->handler = ngx_ssl_shutdown_handler; c 1223 event/ngx_event_openssl.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 1227 event/ngx_event_openssl.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 1232 event/ngx_event_openssl.c ngx_add_timer(c->read, 30000); c 1240 event/ngx_event_openssl.c ngx_ssl_connection_error(c, sslerr, err, "SSL_shutdown() failed"); c 1242 event/ngx_event_openssl.c SSL_free(c->ssl->connection); c 1243 event/ngx_event_openssl.c c->ssl = NULL; c 1252 event/ngx_event_openssl.c ngx_connection_t *c; c 1255 event/ngx_event_openssl.c c = ev->data; c 1256 event/ngx_event_openssl.c handler = c->ssl->handler; c 1259 event/ngx_event_openssl.c c->timedout = 1; c 1264 event/ngx_event_openssl.c if (ngx_ssl_shutdown(c) == NGX_AGAIN) { c 1268 event/ngx_event_openssl.c handler(c); c 1273 event/ngx_event_openssl.c ngx_ssl_connection_error(ngx_connection_t *c, int sslerr, ngx_err_t err, c 1293 event/ngx_event_openssl.c switch (c->log_error) { c 1352 event/ngx_event_openssl.c switch (c->log_error) { c 1369 event/ngx_event_openssl.c ngx_ssl_error(level, c->log, err, text); c 1569 event/ngx_event_openssl.c ngx_connection_t *c; c 1586 event/ngx_event_openssl.c c = ngx_ssl_get_connection(ssl_conn); c 1639 event/ngx_event_openssl.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 1671 event/ngx_event_openssl.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 1690 event/ngx_event_openssl.c ngx_connection_t *c; c 1697 event/ngx_event_openssl.c c = ngx_ssl_get_connection(ssl_conn); c 1702 event/ngx_event_openssl.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 1965 event/ngx_event_openssl.c ngx_ssl_get_protocol(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 1967 event/ngx_event_openssl.c s->data = (u_char *) SSL_get_version(c->ssl->connection); c 1973 event/ngx_event_openssl.c ngx_ssl_get_cipher_name(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 1975 event/ngx_event_openssl.c s->data = (u_char *) SSL_get_cipher_name(c->ssl->connection); c 1981 event/ngx_event_openssl.c ngx_ssl_get_session_id(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 1987 event/ngx_event_openssl.c sess = SSL_get0_session(c->ssl->connection); c 1991 event/ngx_event_openssl.c buf = ngx_alloc(len, c->log); c 2015 event/ngx_event_openssl.c ngx_ssl_get_raw_certificate(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2023 event/ngx_event_openssl.c cert = SSL_get_peer_certificate(c->ssl->connection); c 2030 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "BIO_new() failed"); c 2036 event/ngx_event_openssl.c ngx_ssl_error(NGX_LOG_ALERT, c->log, 0, "PEM_write_bio_X509() failed"); c 2065 event/ngx_event_openssl.c ngx_ssl_get_certificate(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2072 event/ngx_event_openssl.c if (ngx_ssl_get_raw_certificate(c, pool, &cert) != NGX_OK) { c 2109 event/ngx_event_openssl.c ngx_ssl_get_subject_dn(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2118 event/ngx_event_openssl.c cert = SSL_get_peer_certificate(c->ssl->connection); c 2151 event/ngx_event_openssl.c ngx_ssl_get_issuer_dn(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2160 event/ngx_event_openssl.c cert = SSL_get_peer_certificate(c->ssl->connection); c 2193 event/ngx_event_openssl.c ngx_ssl_get_serial_number(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2201 event/ngx_event_openssl.c cert = SSL_get_peer_certificate(c->ssl->connection); c 2232 event/ngx_event_openssl.c ngx_ssl_get_client_verify(ngx_connection_t *c, ngx_pool_t *pool, ngx_str_t *s) c 2236 event/ngx_event_openssl.c if (SSL_get_verify_result(c->ssl->connection) != X509_V_OK) { c 2241 event/ngx_event_openssl.c cert = SSL_get_peer_certificate(c->ssl->connection); c 106 event/ngx_event_openssl.h ngx_int_t ngx_ssl_create_connection(ngx_ssl_t *ssl, ngx_connection_t *c, c 110 event/ngx_event_openssl.h ngx_int_t ngx_ssl_set_session(ngx_connection_t *c, ngx_ssl_session_t *session); c 111 event/ngx_event_openssl.h #define ngx_ssl_get_session(c) SSL_get1_session(c->ssl->connection) c 119 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_protocol(ngx_connection_t *c, ngx_pool_t *pool, c 121 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_cipher_name(ngx_connection_t *c, ngx_pool_t *pool, c 123 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_session_id(ngx_connection_t *c, ngx_pool_t *pool, c 125 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_raw_certificate(ngx_connection_t *c, ngx_pool_t *pool, c 127 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_certificate(ngx_connection_t *c, ngx_pool_t *pool, c 129 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_subject_dn(ngx_connection_t *c, ngx_pool_t *pool, c 131 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_issuer_dn(ngx_connection_t *c, ngx_pool_t *pool, c 133 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_serial_number(ngx_connection_t *c, ngx_pool_t *pool, c 135 event/ngx_event_openssl.h ngx_int_t ngx_ssl_get_client_verify(ngx_connection_t *c, ngx_pool_t *pool, c 139 event/ngx_event_openssl.h ngx_int_t ngx_ssl_handshake(ngx_connection_t *c); c 140 event/ngx_event_openssl.h ssize_t ngx_ssl_recv(ngx_connection_t *c, u_char *buf, size_t size); c 141 event/ngx_event_openssl.h ssize_t ngx_ssl_write(ngx_connection_t *c, u_char *data, size_t size); c 142 event/ngx_event_openssl.h ssize_t ngx_ssl_recv_chain(ngx_connection_t *c, ngx_chain_t *cl); c 143 event/ngx_event_openssl.h ngx_chain_t *ngx_ssl_send_chain(ngx_connection_t *c, ngx_chain_t *in, c 145 event/ngx_event_openssl.h void ngx_ssl_free_buffer(ngx_connection_t *c); c 146 event/ngx_event_openssl.h ngx_int_t ngx_ssl_shutdown(ngx_connection_t *c); c 260 http/modules/ngx_http_browser_module.c u_char *name, *ua, *last, c; c 311 http/modules/ngx_http_browser_module.c c = *name++; c 313 http/modules/ngx_http_browser_module.c if (c >= '0' && c <= '9') { c 314 http/modules/ngx_http_browser_module.c ver = ver * 10 + (c - '0'); c 318 http/modules/ngx_http_browser_module.c if (c == '.') { c 542 http/modules/ngx_http_browser_module.c u_char c; c 601 http/modules/ngx_http_browser_module.c c = value[2].data[i]; c 603 http/modules/ngx_http_browser_module.c if (c >= '0' && c <= '9') { c 604 http/modules/ngx_http_browser_module.c ver = ver * 10 + (c - '0'); c 608 http/modules/ngx_http_browser_module.c if (c == '.') { c 684 http/modules/ngx_http_charset_filter_module.c u_char c, *p, *src, *dst, *saved, **table; c 794 http/modules/ngx_http_charset_filter_module.c c = '\0'; c 801 http/modules/ngx_http_charset_filter_module.c c = p[n & 0xff]; c 844 http/modules/ngx_http_charset_filter_module.c if (c) { c 845 http/modules/ngx_http_charset_filter_module.c *dst++ = c; c 907 http/modules/ngx_http_charset_filter_module.c c = p[n & 0xff]; c 909 http/modules/ngx_http_charset_filter_module.c if (c) { c 910 http/modules/ngx_http_charset_filter_module.c *dst++ = c; c 1447 http/modules/ngx_http_charset_filter_module.c ngx_http_charset_t *c; c 1449 http/modules/ngx_http_charset_filter_module.c c = charsets->elts; c 1451 http/modules/ngx_http_charset_filter_module.c if (name->len != c[i].name.len) { c 1455 http/modules/ngx_http_charset_filter_module.c if (ngx_strcasecmp(name->data, c[i].name.data) == 0) { c 1464 http/modules/ngx_http_charset_filter_module.c c = ngx_array_push(charsets); c 1465 http/modules/ngx_http_charset_filter_module.c if (c == NULL) { c 1469 http/modules/ngx_http_charset_filter_module.c c->tables = NULL; c 1470 http/modules/ngx_http_charset_filter_module.c c->name = *name; c 1471 http/modules/ngx_http_charset_filter_module.c c->length = 0; c 1474 http/modules/ngx_http_charset_filter_module.c c->utf8 = 1; c 1477 http/modules/ngx_http_charset_filter_module.c c->utf8 = 0; c 1606 http/modules/ngx_http_charset_filter_module.c ngx_int_t c; c 1622 http/modules/ngx_http_charset_filter_module.c c = recode[i].src; c 1626 http/modules/ngx_http_charset_filter_module.c if (c == tables[t].src && recode[i].dst == tables[t].dst) { c 1630 http/modules/ngx_http_charset_filter_module.c if (c == tables[t].dst && recode[i].dst == tables[t].src) { c 1637 http/modules/ngx_http_charset_filter_module.c &charset[c].name, &charset[recode[i].dst].name); c 1030 http/modules/ngx_http_geo_module.c ngx_in_cidr_t *c; c 1039 http/modules/ngx_http_geo_module.c c = ngx_array_push(ctx->proxies); c 1040 http/modules/ngx_http_geo_module.c if (c == NULL) { c 1044 http/modules/ngx_http_geo_module.c c->addr = cidr->u.in.addr; c 1045 http/modules/ngx_http_geo_module.c c->mask = cidr->u.in.mask; c 275 http/modules/ngx_http_index_module.c u_char c; c 279 http/modules/ngx_http_index_module.c c = *last; c 280 http/modules/ngx_http_index_module.c if (c != '/' || path == last) { c 282 http/modules/ngx_http_index_module.c c = *(++last); c 305 http/modules/ngx_http_index_module.c *last = c; c 311 http/modules/ngx_http_index_module.c *last = c; c 329 http/modules/ngx_http_index_module.c *last = c; c 116 http/modules/ngx_http_realip_module.c ngx_connection_t *c; c 208 http/modules/ngx_http_realip_module.c c = r->connection; c 210 http/modules/ngx_http_realip_module.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "realip: \"%s\"", ip); c 214 http/modules/ngx_http_realip_module.c if (c->sockaddr->sa_family == AF_INET) { c 215 http/modules/ngx_http_realip_module.c sin = (struct sockaddr_in *) c->sockaddr; c 220 http/modules/ngx_http_realip_module.c ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, c 232 http/modules/ngx_http_realip_module.c if (c->sockaddr->sa_family == AF_UNIX && rlcf->unixsock) { c 248 http/modules/ngx_http_realip_module.c ngx_connection_t *c; c 260 http/modules/ngx_http_realip_module.c c = r->connection; c 262 http/modules/ngx_http_realip_module.c rc = ngx_parse_addr(c->pool, &addr, ip, len); c 273 http/modules/ngx_http_realip_module.c p = ngx_pnalloc(c->pool, len); c 282 http/modules/ngx_http_realip_module.c ctx->connection = c; c 283 http/modules/ngx_http_realip_module.c ctx->sockaddr = c->sockaddr; c 284 http/modules/ngx_http_realip_module.c ctx->socklen = c->socklen; c 285 http/modules/ngx_http_realip_module.c ctx->addr_text = c->addr_text; c 287 http/modules/ngx_http_realip_module.c c->sockaddr = addr.sockaddr; c 288 http/modules/ngx_http_realip_module.c c->socklen = addr.socklen; c 289 http/modules/ngx_http_realip_module.c c->addr_text.len = len; c 290 http/modules/ngx_http_realip_module.c c->addr_text.data = p; c 301 http/modules/ngx_http_realip_module.c ngx_connection_t *c; c 303 http/modules/ngx_http_realip_module.c c = ctx->connection; c 305 http/modules/ngx_http_realip_module.c c->sockaddr = ctx->sockaddr; c 306 http/modules/ngx_http_realip_module.c c->socklen = ctx->socklen; c 307 http/modules/ngx_http_realip_module.c c->addr_text = ctx->addr_text; c 12 http/modules/ngx_http_ssl_module.c typedef ngx_int_t (*ngx_ssl_variable_handler_pt)(ngx_connection_t *c, c 455 http/modules/ngx_http_userid_filter_module.c ngx_connection_t *c; c 503 http/modules/ngx_http_userid_filter_module.c c = r->connection; c 505 http/modules/ngx_http_userid_filter_module.c if (ngx_connection_local_sockaddr(c, NULL, 0) != NGX_OK) { c 509 http/modules/ngx_http_userid_filter_module.c switch (c->local_sockaddr->sa_family) { c 513 http/modules/ngx_http_userid_filter_module.c sin6 = (struct sockaddr_in6 *) c->local_sockaddr; c 525 http/modules/ngx_http_userid_filter_module.c sin = (struct sockaddr_in *) c->local_sockaddr; c 677 http/modules/perl/ngx_http_perl_module.c ngx_connection_t *c; c 701 http/modules/perl/ngx_http_perl_module.c c = r->connection; c 711 http/modules/perl/ngx_http_perl_module.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 739 http/modules/perl/ngx_http_perl_module.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 750 http/modules/perl/ngx_http_perl_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 63 http/ngx_http.h #define ngx_http_set_ctx(r, c, module) r->ctx[module.ctx_index] = c; c 72 http/ngx_http.h void ngx_http_init_connection(ngx_connection_t *c); c 98 http/ngx_http.h void ngx_http_run_posted_requests(ngx_connection_t *c); c 134 http/ngx_http_cache.h void ngx_http_file_cache_free(ngx_http_cache_t *c, ngx_temp_file_t *tf); c 83 http/ngx_http_copy_filter_module.c ngx_connection_t *c; c 88 http/ngx_http_copy_filter_module.c c = r->connection; c 90 http/ngx_http_copy_filter_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 106 http/ngx_http_copy_filter_module.c ctx->sendfile = c->sendfile; c 126 http/ngx_http_copy_filter_module.c c->aio_sendfile = (clcf->aio == NGX_HTTP_AIO_SENDFILE); c 150 http/ngx_http_copy_filter_module.c ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, c 155 http/ngx_http_copy_filter_module.c if (c->busy_sendfile) { c 161 http/ngx_http_copy_filter_module.c file = c->busy_sendfile->file; c 162 http/ngx_http_copy_filter_module.c offset = c->busy_sendfile->file_pos; c 165 http/ngx_http_copy_filter_module.c c->aio_sendfile = (offset != file->aio->last_offset); c 168 http/ngx_http_copy_filter_module.c if (c->aio_sendfile == 0) { c 169 http/ngx_http_copy_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 175 http/ngx_http_copy_filter_module.c c->busy_sendfile = NULL; c 1635 http/ngx_http_core_module.c u_char c, *lowcase; c 1661 http/ngx_http_core_module.c c = ngx_tolower(r->headers_out.content_type.data[i]); c 1662 http/ngx_http_core_module.c hash = ngx_hash(hash, c); c 1663 http/ngx_http_core_module.c lowcase[i] = c; c 1677 http/ngx_http_core_module.c u_char c, *exten; c 1693 http/ngx_http_core_module.c c = r->exten.data[i]; c 1695 http/ngx_http_core_module.c if (c >= 'A' && c <= 'Z') { c 1709 http/ngx_http_core_module.c hash = ngx_hash(hash, c); c 1844 http/ngx_http_core_module.c ngx_connection_t *c; c 1846 http/ngx_http_core_module.c c = r->connection; c 1848 http/ngx_http_core_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1855 http/ngx_http_core_module.c c->error = 1; c 2171 http/ngx_http_core_module.c ngx_connection_t *c; c 2192 http/ngx_http_core_module.c c = r->connection; c 2193 http/ngx_http_core_module.c sr->connection = c; c 2232 http/ngx_http_core_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2250 http/ngx_http_core_module.c if (c->data == r && r->postponed == NULL) { c 2251 http/ngx_http_core_module.c c->data = sr; c 14 http/ngx_http_file_cache.c ngx_http_cache_t *c); c 16 http/ngx_http_file_cache.c ngx_http_cache_t *c); c 21 http/ngx_http_file_cache.c ngx_http_cache_t *c); c 42 http/ngx_http_file_cache.c ngx_http_cache_t *c); c 151 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 153 http/ngx_http_file_cache.c c = ngx_pcalloc(r->pool, sizeof(ngx_http_cache_t)); c 154 http/ngx_http_file_cache.c if (c == NULL) { c 158 http/ngx_http_file_cache.c if (ngx_array_init(&c->keys, r->pool, 4, sizeof(ngx_str_t)) != NGX_OK) { c 162 http/ngx_http_file_cache.c r->cache = c; c 163 http/ngx_http_file_cache.c c->file.log = r->connection->log; c 164 http/ngx_http_file_cache.c c->file.fd = NGX_INVALID_FILE; c 173 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 179 http/ngx_http_file_cache.c c = r->cache; c 180 http/ngx_http_file_cache.c cache = c->file_cache; c 187 http/ngx_http_file_cache.c if (ngx_http_file_cache_exists(cache, c) == NGX_ERROR) { c 192 http/ngx_http_file_cache.c cln->data = c; c 209 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 211 http/ngx_http_file_cache.c c = r->cache; c 215 http/ngx_http_file_cache.c ngx_crc32_init(c->crc32); c 218 http/ngx_http_file_cache.c key = c->keys.elts; c 219 http/ngx_http_file_cache.c for (i = 0; i < c->keys.nelts; i++) { c 225 http/ngx_http_file_cache.c ngx_crc32_update(&c->crc32, key[i].data, key[i].len); c 229 http/ngx_http_file_cache.c c->header_start = sizeof(ngx_http_file_cache_header_t) c 232 http/ngx_http_file_cache.c ngx_crc32_final(c->crc32); c 233 http/ngx_http_file_cache.c ngx_md5_final(c->key, &md5); c 242 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 248 http/ngx_http_file_cache.c c = r->cache; c 250 http/ngx_http_file_cache.c if (c->buf) { c 251 http/ngx_http_file_cache.c return ngx_http_file_cache_read(r, c); c 254 http/ngx_http_file_cache.c cache = c->file_cache; c 261 http/ngx_http_file_cache.c rc = ngx_http_file_cache_exists(cache, c); c 264 http/ngx_http_file_cache.c "http file cache exists: %i e:%d", rc, c->exists); c 271 http/ngx_http_file_cache.c cln->data = c; c 281 http/ngx_http_file_cache.c if (c->error) { c 282 http/ngx_http_file_cache.c return c->error; c 285 http/ngx_http_file_cache.c c->temp_file = 1; c 286 http/ngx_http_file_cache.c test = c->exists ? 1 : 0; c 291 http/ngx_http_file_cache.c if (c->min_uses > 1) { c 301 http/ngx_http_file_cache.c c->temp_file = 1; c 319 http/ngx_http_file_cache.c of.uniq = c->uniq; c 326 http/ngx_http_file_cache.c if (ngx_open_cached_file(clcf->open_file_cache, &c->file.name, &of, r->pool) c 340 http/ngx_http_file_cache.c ngx_open_file_n " \"%s\" failed", c->file.name.data); c 348 http/ngx_http_file_cache.c c->file.fd = of.fd; c 349 http/ngx_http_file_cache.c c->file.log = r->connection->log; c 350 http/ngx_http_file_cache.c c->uniq = of.uniq; c 351 http/ngx_http_file_cache.c c->length = of.size; c 353 http/ngx_http_file_cache.c c->buf = ngx_create_temp_buf(r->pool, c->body_start); c 354 http/ngx_http_file_cache.c if (c->buf == NULL) { c 358 http/ngx_http_file_cache.c return ngx_http_file_cache_read(r, c); c 363 http/ngx_http_file_cache.c ngx_http_file_cache_read(ngx_http_request_t *r, ngx_http_cache_t *c) c 371 http/ngx_http_file_cache.c n = ngx_http_file_cache_aio_read(r, c); c 377 http/ngx_http_file_cache.c if ((size_t) n < c->header_start) { c 379 http/ngx_http_file_cache.c "cache file \"%s\" is too small", c->file.name.data); c 383 http/ngx_http_file_cache.c h = (ngx_http_file_cache_header_t *) c->buf->pos; c 385 http/ngx_http_file_cache.c if (h->crc32 != c->crc32) { c 387 http/ngx_http_file_cache.c "cache file \"%s\" has md5 collision", c->file.name.data); c 391 http/ngx_http_file_cache.c c->buf->last += n; c 393 http/ngx_http_file_cache.c c->valid_sec = h->valid_sec; c 394 http/ngx_http_file_cache.c c->last_modified = h->last_modified; c 395 http/ngx_http_file_cache.c c->date = h->date; c 396 http/ngx_http_file_cache.c c->valid_msec = h->valid_msec; c 397 http/ngx_http_file_cache.c c->header_start = h->header_start; c 398 http/ngx_http_file_cache.c c->body_start = h->body_start; c 402 http/ngx_http_file_cache.c cache = c->file_cache; c 408 http/ngx_http_file_cache.c if (!c->node->exists) { c 409 http/ngx_http_file_cache.c c->node->uses = 1; c 410 http/ngx_http_file_cache.c c->node->body_start = c->body_start; c 411 http/ngx_http_file_cache.c c->node->exists = 1; c 412 http/ngx_http_file_cache.c c->node->uniq = c->uniq; c 414 http/ngx_http_file_cache.c cache->sh->size += (c->length + cache->bsize - 1) / cache->bsize; c 422 http/ngx_http_file_cache.c if (c->valid_sec < now) { c 426 http/ngx_http_file_cache.c if (c->node->updating) { c 430 http/ngx_http_file_cache.c c->node->updating = 1; c 431 http/ngx_http_file_cache.c c->updating = 1; c 439 http/ngx_http_file_cache.c rc, c->valid_sec, now); c 449 http/ngx_http_file_cache.c ngx_http_file_cache_aio_read(ngx_http_request_t *r, ngx_http_cache_t *c) c 465 http/ngx_http_file_cache.c n = ngx_file_aio_read(&c->file, c->buf->pos, c->body_start, 0, r->pool); c 471 http/ngx_http_file_cache.c c->file.aio->data = r; c 472 http/ngx_http_file_cache.c c->file.aio->handler = ngx_http_cache_aio_event_handler; c 483 http/ngx_http_file_cache.c return ngx_read_file(&c->file, c->buf->pos, c->body_start, 0); c 508 http/ngx_http_file_cache.c ngx_http_file_cache_exists(ngx_http_file_cache_t *cache, ngx_http_cache_t *c) c 515 http/ngx_http_file_cache.c fcn = ngx_http_file_cache_lookup(cache, c->key); c 536 http/ngx_http_file_cache.c c->exists = fcn->exists; c 537 http/ngx_http_file_cache.c c->body_start = fcn->body_start; c 544 http/ngx_http_file_cache.c if (fcn->uses >= c->min_uses) { c 546 http/ngx_http_file_cache.c c->exists = fcn->exists; c 547 http/ngx_http_file_cache.c c->body_start = fcn->body_start; c 575 http/ngx_http_file_cache.c ngx_memcpy((u_char *) &fcn->node.key, c->key, sizeof(ngx_rbtree_key_t)); c 577 http/ngx_http_file_cache.c ngx_memcpy(fcn->key, &c->key[sizeof(ngx_rbtree_key_t)], c 605 http/ngx_http_file_cache.c c->uniq = fcn->uniq; c 606 http/ngx_http_file_cache.c c->error = fcn->error; c 607 http/ngx_http_file_cache.c c->node = fcn; c 621 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 623 http/ngx_http_file_cache.c c = r->cache; c 625 http/ngx_http_file_cache.c c->file.name.len = path->name.len + 1 + path->len c 628 http/ngx_http_file_cache.c c->file.name.data = ngx_pnalloc(r->pool, c->file.name.len + 1); c 629 http/ngx_http_file_cache.c if (c->file.name.data == NULL) { c 633 http/ngx_http_file_cache.c ngx_memcpy(c->file.name.data, path->name.data, path->name.len); c 635 http/ngx_http_file_cache.c p = c->file.name.data + path->name.len + 1 + path->len; c 636 http/ngx_http_file_cache.c p = ngx_hex_dump(p, c->key, NGX_HTTP_CACHE_KEY_LEN); c 639 http/ngx_http_file_cache.c ngx_create_hashed_filename(path, c->file.name.data, c->file.name.len); c 642 http/ngx_http_file_cache.c "cache file: \"%s\"", c->file.name.data); c 749 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 754 http/ngx_http_file_cache.c c = r->cache; c 756 http/ngx_http_file_cache.c h->valid_sec = c->valid_sec; c 757 http/ngx_http_file_cache.c h->last_modified = c->last_modified; c 758 http/ngx_http_file_cache.c h->date = c->date; c 759 http/ngx_http_file_cache.c h->crc32 = c->crc32; c 760 http/ngx_http_file_cache.c h->valid_msec = (u_short) c->valid_msec; c 761 http/ngx_http_file_cache.c h->header_start = (u_short) c->header_start; c 762 http/ngx_http_file_cache.c h->body_start = (u_short) c->body_start; c 768 http/ngx_http_file_cache.c key = c->keys.elts; c 769 http/ngx_http_file_cache.c for (i = 0; i < c->keys.nelts; i++) { c 784 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 788 http/ngx_http_file_cache.c c = r->cache; c 790 http/ngx_http_file_cache.c if (c->updated) { c 797 http/ngx_http_file_cache.c c->updated = 1; c 798 http/ngx_http_file_cache.c c->updating = 0; c 800 http/ngx_http_file_cache.c cache = c->file_cache; c 807 http/ngx_http_file_cache.c tf->file.name.data, c->file.name.data); c 816 http/ngx_http_file_cache.c rc = ngx_ext_rename_file(&tf->file.name, &c->file.name, &ext); c 836 http/ngx_http_file_cache.c c->node->count--; c 837 http/ngx_http_file_cache.c c->node->uniq = uniq; c 838 http/ngx_http_file_cache.c c->node->body_start = c->body_start; c 840 http/ngx_http_file_cache.c size = size - (c->node->length + cache->bsize - 1) / cache->bsize; c 842 http/ngx_http_file_cache.c c->node->length = length; c 847 http/ngx_http_file_cache.c c->node->exists = 1; c 850 http/ngx_http_file_cache.c c->node->updating = 0; c 862 http/ngx_http_file_cache.c ngx_http_cache_t *c; c 864 http/ngx_http_file_cache.c c = r->cache; c 867 http/ngx_http_file_cache.c "http file cache send: %s", c->file.name.data); c 881 http/ngx_http_file_cache.c r->header_only = (c->length - c->body_start) == 0; c 889 http/ngx_http_file_cache.c b->file_pos = c->body_start; c 890 http/ngx_http_file_cache.c b->file_last = c->length; c 896 http/ngx_http_file_cache.c b->file->fd = c->file.fd; c 897 http/ngx_http_file_cache.c b->file->name = c->file.name; c 908 http/ngx_http_file_cache.c ngx_http_file_cache_free(ngx_http_cache_t *c, ngx_temp_file_t *tf) c 913 http/ngx_http_file_cache.c if (c->updated) { c 917 http/ngx_http_file_cache.c cache = c->file_cache; c 919 http/ngx_http_file_cache.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->file.log, 0, c 920 http/ngx_http_file_cache.c "http file cache free, fd: %d", c->file.fd); c 924 http/ngx_http_file_cache.c fcn = c->node; c 927 http/ngx_http_file_cache.c if (c->updating) { c 931 http/ngx_http_file_cache.c if (c->error) { c 932 http/ngx_http_file_cache.c fcn->error = c->error; c 934 http/ngx_http_file_cache.c if (c->valid_sec) { c 935 http/ngx_http_file_cache.c fcn->valid_sec = c->valid_sec; c 936 http/ngx_http_file_cache.c fcn->valid_msec = c->valid_msec; c 939 http/ngx_http_file_cache.c } else if (!fcn->exists && fcn->count == 0 && c->min_uses == 1) { c 943 http/ngx_http_file_cache.c c->node = NULL; c 948 http/ngx_http_file_cache.c c->updated = 1; c 949 http/ngx_http_file_cache.c c->updating = 0; c 951 http/ngx_http_file_cache.c if (c->temp_file) { c 953 http/ngx_http_file_cache.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->file.log, 0, c 958 http/ngx_http_file_cache.c ngx_log_error(NGX_LOG_CRIT, c->file.log, ngx_errno, c 970 http/ngx_http_file_cache.c ngx_http_cache_t *c = data; c 972 http/ngx_http_file_cache.c if (c->updated) { c 976 http/ngx_http_file_cache.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->file.log, 0, c 979 http/ngx_http_file_cache.c if (c->updating) { c 980 http/ngx_http_file_cache.c ngx_log_error(NGX_LOG_ALERT, c->file.log, 0, c 981 http/ngx_http_file_cache.c "stalled cache updating, error:%ui", c->error); c 984 http/ngx_http_file_cache.c ngx_http_file_cache_free(c, NULL); c 1340 http/ngx_http_file_cache.c ngx_http_cache_t c; c 1348 http/ngx_http_file_cache.c ngx_memzero(&c, sizeof(ngx_http_cache_t)); c 1358 http/ngx_http_file_cache.c c.file.fd = fd; c 1359 http/ngx_http_file_cache.c c.file.name = *name; c 1360 http/ngx_http_file_cache.c c.file.log = ctx->log; c 1362 http/ngx_http_file_cache.c n = ngx_read_file(&c.file, (u_char *) &h, c 1379 http/ngx_http_file_cache.c c.uniq = ngx_file_uniq(&fi); c 1380 http/ngx_http_file_cache.c c.valid_sec = h.valid_sec; c 1381 http/ngx_http_file_cache.c c.valid_msec = h.valid_msec; c 1382 http/ngx_http_file_cache.c c.body_start = h.body_start; c 1383 http/ngx_http_file_cache.c c.length = ngx_file_size(&fi); c 1391 http/ngx_http_file_cache.c if (c.body_start == 0) { c 1406 http/ngx_http_file_cache.c c.key[i] = (u_char) n; c 1411 http/ngx_http_file_cache.c return ngx_http_file_cache_add(cache, &c); c 1416 http/ngx_http_file_cache.c ngx_http_file_cache_add(ngx_http_file_cache_t *cache, ngx_http_cache_t *c) c 1422 http/ngx_http_file_cache.c fcn = ngx_http_file_cache_lookup(cache, c->key); c 1433 http/ngx_http_file_cache.c ngx_memcpy((u_char *) &fcn->node.key, c->key, sizeof(ngx_rbtree_key_t)); c 1435 http/ngx_http_file_cache.c ngx_memcpy(fcn->key, &c->key[sizeof(ngx_rbtree_key_t)], c 1442 http/ngx_http_file_cache.c fcn->valid_msec = c->valid_msec; c 1447 http/ngx_http_file_cache.c fcn->uniq = c->uniq; c 1448 http/ngx_http_file_cache.c fcn->valid_sec = c->valid_sec; c 1449 http/ngx_http_file_cache.c fcn->body_start = c->body_start; c 1450 http/ngx_http_file_cache.c fcn->length = c->length; c 1452 http/ngx_http_file_cache.c cache->sh->size += (c->length + cache->bsize - 1) / cache->bsize; c 164 http/ngx_http_header_filter_module.c ngx_connection_t *c; c 312 http/ngx_http_header_filter_module.c c = r->connection; c 331 http/ngx_http_header_filter_module.c if (ngx_connection_local_sockaddr(c, &host, 0) != NGX_OK) { c 336 http/ngx_http_header_filter_module.c switch (c->local_sockaddr->sa_family) { c 340 http/ngx_http_header_filter_module.c sin6 = (struct sockaddr_in6 *) c->local_sockaddr; c 350 http/ngx_http_header_filter_module.c sin = (struct sockaddr_in *) c->local_sockaddr; c 362 http/ngx_http_header_filter_module.c if (c->ssl) c 525 http/ngx_http_header_filter_module.c if (c->ssl) { c 601 http/ngx_http_header_filter_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 105 http/ngx_http_parse.c u_char c, ch, *p, *m; c 281 http/ngx_http_parse.c c = (u_char) (ch | 0x20); c 282 http/ngx_http_parse.c if (c >= 'a' && c <= 'z') { c 298 http/ngx_http_parse.c c = (u_char) (ch | 0x20); c 299 http/ngx_http_parse.c if (c >= 'a' && c <= 'z') { c 336 http/ngx_http_parse.c c = (u_char) (ch | 0x20); c 337 http/ngx_http_parse.c if (c >= 'a' && c <= 'z') { c 757 http/ngx_http_parse.c u_char c, ch, *p; c 807 http/ngx_http_parse.c c = lowcase[ch]; c 809 http/ngx_http_parse.c if (c) { c 810 http/ngx_http_parse.c hash = ngx_hash(0, c); c 811 http/ngx_http_parse.c r->lowcase_header[0] = c; c 825 http/ngx_http_parse.c c = lowcase[ch]; c 827 http/ngx_http_parse.c if (c) { c 828 http/ngx_http_parse.c hash = ngx_hash(hash, c); c 829 http/ngx_http_parse.c r->lowcase_header[i++] = c; c 998 http/ngx_http_parse.c u_char c, ch, decoded, *p, *u; c 1230 http/ngx_http_parse.c c = (u_char) (ch | 0x20); c 1231 http/ngx_http_parse.c if (c >= 'a' && c <= 'f') { c 1232 http/ngx_http_parse.c decoded = (u_char) (c - 'a' + 10); c 1258 http/ngx_http_parse.c c = (u_char) (ch | 0x20); c 1259 http/ngx_http_parse.c if (c >= 'a' && c <= 'f') { c 1260 http/ngx_http_parse.c ch = (u_char) ((decoded << 4) + c - 'a' + 10); c 54 http/ngx_http_postpone_filter_module.c ngx_connection_t *c; c 57 http/ngx_http_postpone_filter_module.c c = r->connection; c 59 http/ngx_http_postpone_filter_module.c ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, c 62 http/ngx_http_postpone_filter_module.c if (r != c->data) { c 71 http/ngx_http_postpone_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 81 http/ngx_http_postpone_filter_module.c if (in || c->buffered) { c 97 http/ngx_http_postpone_filter_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 103 http/ngx_http_postpone_filter_module.c c->data = pr->request; c 109 http/ngx_http_postpone_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 114 http/ngx_http_postpone_filter_module.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 55 http/ngx_http_request.c static void ngx_http_close_connection(ngx_connection_t *c); c 63 http/ngx_http_request.c static void ngx_http_ssl_handshake_handler(ngx_connection_t *c); c 182 http/ngx_http_request.c ngx_http_init_connection(ngx_connection_t *c) c 187 http/ngx_http_request.c ctx = ngx_palloc(c->pool, sizeof(ngx_http_log_ctx_t)); c 189 http/ngx_http_request.c ngx_http_close_connection(c); c 193 http/ngx_http_request.c ctx->connection = c; c 197 http/ngx_http_request.c c->log->connection = c->number; c 198 http/ngx_http_request.c c->log->handler = ngx_http_log_error; c 199 http/ngx_http_request.c c->log->data = ctx; c 200 http/ngx_http_request.c c->log->action = "reading client request line"; c 202 http/ngx_http_request.c c->log_error = NGX_ERROR_INFO; c 204 http/ngx_http_request.c rev = c->read; c 206 http/ngx_http_request.c c->write->handler = ngx_http_empty_handler; c 224 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); c 230 http/ngx_http_request.c ngx_http_close_connection(c); c 241 http/ngx_http_request.c ngx_connection_t *c; c 261 http/ngx_http_request.c c = rev->data; c 264 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 266 http/ngx_http_request.c ngx_http_close_connection(c); c 270 http/ngx_http_request.c c->requests++; c 272 http/ngx_http_request.c hc = c->data; c 275 http/ngx_http_request.c hc = ngx_pcalloc(c->pool, sizeof(ngx_http_connection_t)); c 277 http/ngx_http_request.c ngx_http_close_connection(c); c 294 http/ngx_http_request.c r = ngx_pcalloc(c->pool, sizeof(ngx_http_request_t)); c 296 http/ngx_http_request.c ngx_http_close_connection(c); c 303 http/ngx_http_request.c c->data = r; c 306 http/ngx_http_request.c c->sent = 0; c 311 http/ngx_http_request.c port = c->listening->servers; c 313 http/ngx_http_request.c r->connection = c; c 323 http/ngx_http_request.c if (ngx_connection_local_sockaddr(c, NULL, 0) != NGX_OK) { c 324 http/ngx_http_request.c ngx_http_close_connection(c); c 328 http/ngx_http_request.c switch (c->local_sockaddr->sa_family) { c 332 http/ngx_http_request.c sin6 = (struct sockaddr_in6 *) c->local_sockaddr; c 350 http/ngx_http_request.c sin = (struct sockaddr_in *) c->local_sockaddr; c 369 http/ngx_http_request.c switch (c->local_sockaddr->sa_family) { c 405 http/ngx_http_request.c if (c->ssl == NULL) { c 407 http/ngx_http_request.c c->log->action = "SSL handshaking"; c 410 http/ngx_http_request.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 413 http/ngx_http_request.c ngx_http_close_connection(c); c 417 http/ngx_http_request.c if (ngx_ssl_create_connection(&sscf->ssl, c, NGX_SSL_BUFFER) c 420 http/ngx_http_request.c ngx_http_close_connection(c); c 434 http/ngx_http_request.c c->log->file = clcf->error_log->file; c 435 http/ngx_http_request.c if (!(c->log->log_level & NGX_LOG_DEBUG_CONNECTION)) { c 436 http/ngx_http_request.c c->log->log_level = clcf->error_log->log_level; c 439 http/ngx_http_request.c if (c->buffer == NULL) { c 440 http/ngx_http_request.c c->buffer = ngx_create_temp_buf(c->pool, c 442 http/ngx_http_request.c if (c->buffer == NULL) { c 443 http/ngx_http_request.c ngx_http_close_connection(c); c 449 http/ngx_http_request.c r->header_in = c->buffer; c 452 http/ngx_http_request.c r->pool = ngx_create_pool(cscf->request_pool_size, c->log); c 454 http/ngx_http_request.c ngx_http_close_connection(c); c 464 http/ngx_http_request.c ngx_http_close_connection(c); c 471 http/ngx_http_request.c ngx_http_close_connection(c); c 481 http/ngx_http_request.c ngx_http_close_connection(c); c 485 http/ngx_http_request.c c->single_connection = 1; c 486 http/ngx_http_request.c c->destroyed = 0; c 507 http/ngx_http_request.c ctx = c->log->data; c 530 http/ngx_http_request.c ngx_connection_t *c; c 533 http/ngx_http_request.c c = rev->data; c 534 http/ngx_http_request.c r = c->data; c 540 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 541 http/ngx_http_request.c c->timedout = 1; c 546 http/ngx_http_request.c n = recv(c->fd, (char *) buf, 1, MSG_PEEK); c 551 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); c 566 http/ngx_http_request.c rc = ngx_ssl_handshake(c); c 571 http/ngx_http_request.c ngx_add_timer(rev, c->listening->post_accept_timeout); c 574 http/ngx_http_request.c c->ssl->handler = ngx_http_ssl_handshake_handler; c 578 http/ngx_http_request.c ngx_http_ssl_handshake_handler(c); c 590 http/ngx_http_request.c c->log->action = "reading client request line"; c 598 http/ngx_http_request.c ngx_http_ssl_handshake_handler(ngx_connection_t *c) c 602 http/ngx_http_request.c if (c->ssl->handshaked) { c 612 http/ngx_http_request.c c->ssl->no_wait_shutdown = 1; c 614 http/ngx_http_request.c c->read->handler = ngx_http_process_request_line; c 615 http/ngx_http_request.c /* STUB: epoll edge */ c->write->handler = ngx_http_empty_handler; c 617 http/ngx_http_request.c ngx_http_process_request_line(c->read); c 622 http/ngx_http_request.c r = c->data; c 637 http/ngx_http_request.c ngx_connection_t *c; c 647 http/ngx_http_request.c c = ngx_ssl_get_connection(ssl_conn); c 649 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 658 http/ngx_http_request.c r = c->data; c 690 http/ngx_http_request.c ngx_connection_t *c; c 694 http/ngx_http_request.c c = rev->data; c 695 http/ngx_http_request.c r = c->data; c 701 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 702 http/ngx_http_request.c c->timedout = 1; c 749 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 824 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 827 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 830 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 833 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 843 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 890 http/ngx_http_request.c c->log->action = "reading client request headers"; c 902 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 923 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 941 http/ngx_http_request.c ngx_connection_t *c; c 947 http/ngx_http_request.c c = rev->data; c 948 http/ngx_http_request.c r = c->data; c 954 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 955 http/ngx_http_request.c c->timedout = 1; c 984 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 998 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1024 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1107 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1122 http/ngx_http_request.c ngx_connection_t *c; c 1125 http/ngx_http_request.c c = r->connection; c 1126 http/ngx_http_request.c rev = c->read; c 1135 http/ngx_http_request.c n = c->recv(c, r->header_in->last, c 1156 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1161 http/ngx_http_request.c c->error = 1; c 1162 http/ngx_http_request.c c->log->action = "reading client request headers"; c 1457 http/ngx_http_request.c if (c->ssl) { c 1458 http/ngx_http_request.c c->ssl->no_send_shutdown = 1; c 1579 http/ngx_http_request.c ngx_connection_t *c; c 1581 http/ngx_http_request.c c = r->connection; c 1584 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1592 http/ngx_http_request.c if (c->ssl) { c 1600 http/ngx_http_request.c rc = SSL_get_verify_result(c->ssl->connection); c 1603 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1608 http/ngx_http_request.c (SSL_get0_session(c->ssl->connection))); c 1615 http/ngx_http_request.c cert = SSL_get_peer_certificate(c->ssl->connection); c 1618 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 1622 http/ngx_http_request.c (SSL_get0_session(c->ssl->connection))); c 1635 http/ngx_http_request.c if (c->read->timer_set) { c 1636 http/ngx_http_request.c ngx_del_timer(c->read); c 1646 http/ngx_http_request.c c->read->handler = ngx_http_request_handler; c 1647 http/ngx_http_request.c c->write->handler = ngx_http_request_handler; c 1652 http/ngx_http_request.c ngx_http_run_posted_requests(c); c 1783 http/ngx_http_request.c ngx_connection_t *c; c 1787 http/ngx_http_request.c c = ev->data; c 1788 http/ngx_http_request.c r = c->data; c 1790 http/ngx_http_request.c ctx = c->log->data; c 1793 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1803 http/ngx_http_request.c ngx_http_run_posted_requests(c); c 1808 http/ngx_http_request.c ngx_http_run_posted_requests(ngx_connection_t *c) c 1816 http/ngx_http_request.c if (c->destroyed) { c 1820 http/ngx_http_request.c r = c->data; c 1831 http/ngx_http_request.c ctx = c->log->data; c 1834 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1868 http/ngx_http_request.c ngx_connection_t *c; c 1872 http/ngx_http_request.c c = r->connection; c 1874 http/ngx_http_request.c ngx_log_debug5(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1876 http/ngx_http_request.c rc, &r->uri, &r->args, r == c->data, r->main->count); c 1884 http/ngx_http_request.c c->error = 1; c 1902 http/ngx_http_request.c || c->error) c 1926 http/ngx_http_request.c if (c->read->timer_set) { c 1927 http/ngx_http_request.c ngx_del_timer(c->read); c 1930 http/ngx_http_request.c if (c->write->timer_set) { c 1931 http/ngx_http_request.c ngx_del_timer(c->write); c 1935 http/ngx_http_request.c c->read->handler = ngx_http_request_handler; c 1936 http/ngx_http_request.c c->write->handler = ngx_http_request_handler; c 1954 http/ngx_http_request.c if (r != c->data) { c 1955 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1963 http/ngx_http_request.c if (r == c->data) { c 1978 http/ngx_http_request.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 1989 http/ngx_http_request.c c->data = pr; c 2006 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2013 http/ngx_http_request.c if (r->buffered || c->buffered || r->postponed || r->blocked) { c 2022 http/ngx_http_request.c if (r != c->data) { c 2023 http/ngx_http_request.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 2040 http/ngx_http_request.c if (c->read->timer_set) { c 2041 http/ngx_http_request.c ngx_del_timer(c->read); c 2044 http/ngx_http_request.c if (c->write->timer_set) { c 2045 http/ngx_http_request.c c->write->delayed = 0; c 2046 http/ngx_http_request.c ngx_del_timer(c->write); c 2049 http/ngx_http_request.c if (c->read->eof) { c 2196 http/ngx_http_request.c ngx_connection_t *c; c 2199 http/ngx_http_request.c c = r->connection; c 2200 http/ngx_http_request.c wev = c->write; c 2209 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 2211 http/ngx_http_request.c c->timedout = 1; c 2245 http/ngx_http_request.c ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2254 http/ngx_http_request.c if (r->buffered || r->postponed || (r == r->main && c->buffered)) { c 2311 http/ngx_http_request.c ngx_connection_t *c; c 2313 http/ngx_http_request.c c = r->connection; c 2314 http/ngx_http_request.c rev = c->read; c 2316 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http test reading"); c 2327 http/ngx_http_request.c c->error = 1; c 2335 http/ngx_http_request.c n = recv(c->fd, buf, 1, MSG_PEEK); c 2339 http/ngx_http_request.c c->error = 1; c 2349 http/ngx_http_request.c c->error = 1; c 2372 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, err, c 2386 http/ngx_http_request.c ngx_connection_t *c; c 2391 http/ngx_http_request.c c = r->connection; c 2392 http/ngx_http_request.c rev = c->read; c 2396 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "set http keepalive handler"); c 2405 http/ngx_http_request.c c->log->action = "closing request"; c 2414 http/ngx_http_request.c if (b != c->buffer) { c 2427 http/ngx_http_request.c hc->free = ngx_palloc(c->pool, c 2452 http/ngx_http_request.c c->data = hc; c 2457 http/ngx_http_request.c ngx_http_close_connection(c); c 2461 http/ngx_http_request.c wev = c->write; c 2466 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "pipelined request"); c 2473 http/ngx_http_request.c c->log->action = "reading client pipelined request line"; c 2490 http/ngx_http_request.c if (ngx_pfree(c->pool, r) == NGX_OK) { c 2494 http/ngx_http_request.c b = c->buffer; c 2496 http/ngx_http_request.c if (ngx_pfree(c->pool, b->start) == NGX_OK) { c 2510 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, "hc free: %p %d", c 2515 http/ngx_http_request.c ngx_pfree(c->pool, hc->free[i]->start); c 2522 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, "hc busy: %p %d", c 2527 http/ngx_http_request.c ngx_pfree(c->pool, hc->busy[i]->start); c 2535 http/ngx_http_request.c if (c->ssl) { c 2536 http/ngx_http_request.c ngx_ssl_free_buffer(c); c 2544 http/ngx_http_request.c ngx_http_close_connection(c); c 2549 http/ngx_http_request.c c->log->action = "keepalive"; c 2551 http/ngx_http_request.c if (c->tcp_nopush == NGX_TCP_NOPUSH_SET) { c 2552 http/ngx_http_request.c if (ngx_tcp_push(c->fd) == -1) { c 2553 http/ngx_http_request.c ngx_connection_error(c, ngx_socket_errno, ngx_tcp_push_n " failed"); c 2554 http/ngx_http_request.c ngx_http_close_connection(c); c 2558 http/ngx_http_request.c c->tcp_nopush = NGX_TCP_NOPUSH_UNSET; c 2567 http/ngx_http_request.c && c->tcp_nodelay == NGX_TCP_NODELAY_UNSET) c 2569 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "tcp_nodelay"); c 2571 http/ngx_http_request.c if (setsockopt(c->fd, IPPROTO_TCP, TCP_NODELAY, c 2577 http/ngx_http_request.c c->log_error = NGX_ERROR_IGNORE_EINVAL; c 2580 http/ngx_http_request.c ngx_connection_error(c, ngx_socket_errno, c 2583 http/ngx_http_request.c c->log_error = NGX_ERROR_INFO; c 2584 http/ngx_http_request.c ngx_http_close_connection(c); c 2588 http/ngx_http_request.c c->tcp_nodelay = NGX_TCP_NODELAY_SET; c 2596 http/ngx_http_request.c c->idle = 1; c 2597 http/ngx_http_request.c ngx_reusable_connection(c, 1); c 2611 http/ngx_http_request.c ngx_connection_t *c; c 2613 http/ngx_http_request.c c = rev->data; c 2615 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "http keepalive handler"); c 2617 http/ngx_http_request.c if (rev->timedout || c->close) { c 2618 http/ngx_http_request.c ngx_http_close_connection(c); c 2626 http/ngx_http_request.c c->log->handler = NULL; c 2627 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, rev->kq_errno, c 2629 http/ngx_http_request.c "keepalive connection", &c->addr_text); c 2631 http/ngx_http_request.c if (c->ssl) { c 2632 http/ngx_http_request.c c->ssl->no_send_shutdown = 1; c 2635 http/ngx_http_request.c ngx_http_close_connection(c); c 2642 http/ngx_http_request.c b = c->buffer; c 2653 http/ngx_http_request.c b->pos = ngx_palloc(c->pool, size); c 2655 http/ngx_http_request.c ngx_http_close_connection(c); c 2669 http/ngx_http_request.c c->log_error = NGX_ERROR_IGNORE_ECONNRESET; c 2672 http/ngx_http_request.c n = c->recv(c, b->last, size); c 2673 http/ngx_http_request.c c->log_error = NGX_ERROR_INFO; c 2677 http/ngx_http_request.c ngx_http_close_connection(c); c 2684 http/ngx_http_request.c ngx_http_close_connection(c); c 2688 http/ngx_http_request.c c->log->handler = NULL; c 2691 http/ngx_http_request.c ngx_log_error(NGX_LOG_INFO, c->log, ngx_socket_errno, c 2692 http/ngx_http_request.c "client %V closed keepalive connection", &c->addr_text); c 2693 http/ngx_http_request.c ngx_http_close_connection(c); c 2703 http/ngx_http_request.c c->log->handler = ngx_http_log_error; c 2704 http/ngx_http_request.c c->log->action = "reading client request line"; c 2706 http/ngx_http_request.c c->idle = 0; c 2707 http/ngx_http_request.c ngx_reusable_connection(c, 0); c 2717 http/ngx_http_request.c ngx_connection_t *c; c 2720 http/ngx_http_request.c c = r->connection; c 2724 http/ngx_http_request.c rev = c->read; c 2735 http/ngx_http_request.c wev = c->write; c 2745 http/ngx_http_request.c if (ngx_shutdown_socket(c->fd, NGX_WRITE_SHUTDOWN) == -1) { c 2746 http/ngx_http_request.c ngx_connection_error(c, ngx_socket_errno, c 2763 http/ngx_http_request.c ngx_connection_t *c; c 2768 http/ngx_http_request.c c = rev->data; c 2769 http/ngx_http_request.c r = c->data; c 2771 http/ngx_http_request.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2775 http/ngx_http_request.c c->timedout = 1; c 2787 http/ngx_http_request.c n = c->recv(c, buffer, NGX_HTTP_LINGERING_BUFFER_SIZE); c 2789 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, "lingering read: %d", n); c 2903 http/ngx_http_request.c ngx_connection_t *c; c 2906 http/ngx_http_request.c c = r->connection; c 2908 http/ngx_http_request.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2912 http/ngx_http_request.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, "http request count is zero"); c 2922 http/ngx_http_request.c ngx_http_close_connection(c); c 3019 http/ngx_http_request.c ngx_http_close_connection(ngx_connection_t *c) c 3023 http/ngx_http_request.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 3024 http/ngx_http_request.c "close http connection: %d", c->fd); c 3028 http/ngx_http_request.c if (c->ssl) { c 3029 http/ngx_http_request.c if (ngx_ssl_shutdown(c) == NGX_AGAIN) { c 3030 http/ngx_http_request.c c->ssl->handler = ngx_http_close_connection; c 3041 http/ngx_http_request.c c->destroyed = 1; c 3043 http/ngx_http_request.c pool = c->pool; c 3045 http/ngx_http_request.c ngx_close_connection(c); c 265 http/ngx_http_request_body.c ngx_connection_t *c; c 269 http/ngx_http_request_body.c c = r->connection; c 272 http/ngx_http_request_body.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 293 http/ngx_http_request_body.c n = c->recv(c, rb->buf->last, size); c 295 http/ngx_http_request_body.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 303 http/ngx_http_request_body.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 308 http/ngx_http_request_body.c c->error = 1; c 325 http/ngx_http_request_body.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 332 http/ngx_http_request_body.c if (!c->read->ready) { c 334 http/ngx_http_request_body.c ngx_add_timer(c->read, clcf->client_body_timeout); c 336 http/ngx_http_request_body.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 344 http/ngx_http_request_body.c if (c->read->timer_set) { c 345 http/ngx_http_request_body.c ngx_del_timer(c->read); c 496 http/ngx_http_request_body.c ngx_connection_t *c; c 499 http/ngx_http_request_body.c c = r->connection; c 500 http/ngx_http_request_body.c rev = c->read; c 503 http/ngx_http_request_body.c c->timedout = 1; c 504 http/ngx_http_request_body.c c->error = 1; c 535 http/ngx_http_request_body.c c->error = 1; c 41 http/ngx_http_upstream.c static ngx_int_t ngx_http_upstream_test_connect(ngx_connection_t *c); c 134 http/ngx_http_upstream.c ngx_http_upstream_t *u, ngx_connection_t *c); c 135 http/ngx_http_upstream.c static void ngx_http_upstream_ssl_handshake(ngx_connection_t *c); c 406 http/ngx_http_upstream.c ngx_connection_t *c; c 408 http/ngx_http_upstream.c c = r->connection; c 410 http/ngx_http_upstream.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 411 http/ngx_http_upstream.c "http init upstream, client timer: %d", c->read->timer_set); c 413 http/ngx_http_upstream.c if (c->read->timer_set) { c 414 http/ngx_http_upstream.c ngx_del_timer(c->read); c 419 http/ngx_http_upstream.c if (!c->write->active) { c 420 http/ngx_http_upstream.c if (ngx_add_event(c->write, NGX_WRITE_EVENT, NGX_CLEAR_EVENT) c 638 http/ngx_http_upstream.c ngx_http_cache_t *c; c 640 http/ngx_http_upstream.c c = r->cache; c 642 http/ngx_http_upstream.c if (c == NULL) { c 679 http/ngx_http_upstream.c c = r->cache; c 681 http/ngx_http_upstream.c c->min_uses = u->conf->cache_min_uses; c 682 http/ngx_http_upstream.c c->body_start = u->conf->buffer_size; c 683 http/ngx_http_upstream.c c->file_cache = u->conf->cache->data; c 725 http/ngx_http_upstream.c c->valid_sec = 0; c 737 http/ngx_http_upstream.c u->buffer.pos = u->buffer.start + c->header_start; c 776 http/ngx_http_upstream.c ngx_http_cache_t *c; c 779 http/ngx_http_upstream.c c = r->cache; c 781 http/ngx_http_upstream.c if (c->header_start == c->body_start) { c 788 http/ngx_http_upstream.c u->buffer = *c->buf; c 789 http/ngx_http_upstream.c u->buffer.pos += c->header_start; c 882 http/ngx_http_upstream.c ngx_connection_t *c; c 887 http/ngx_http_upstream.c c = ev->data; c 888 http/ngx_http_upstream.c r = c->data; c 891 http/ngx_http_upstream.c c = r->connection; c 893 http/ngx_http_upstream.c ctx = c->log->data; c 896 http/ngx_http_upstream.c ngx_log_debug2(NGX_LOG_DEBUG_HTTP, c->log, 0, c 906 http/ngx_http_upstream.c ngx_http_run_posted_requests(c); c 932 http/ngx_http_upstream.c ngx_connection_t *c; c 939 http/ngx_http_upstream.c c = r->connection; c 942 http/ngx_http_upstream.c if (c->error) { c 971 http/ngx_http_upstream.c c->error = 1; c 1000 http/ngx_http_upstream.c n = recv(c->fd, buf, 1, MSG_PEEK); c 1038 http/ngx_http_upstream.c c->error = 1; c 1064 http/ngx_http_upstream.c ngx_connection_t *c; c 1115 http/ngx_http_upstream.c c = u->peer.connection; c 1117 http/ngx_http_upstream.c c->data = r; c 1119 http/ngx_http_upstream.c c->write->handler = ngx_http_upstream_handler; c 1120 http/ngx_http_upstream.c c->read->handler = ngx_http_upstream_handler; c 1125 http/ngx_http_upstream.c c->sendfile &= r->connection->sendfile; c 1126 http/ngx_http_upstream.c u->output.sendfile = c->sendfile; c 1128 http/ngx_http_upstream.c c->pool = r->pool; c 1129 http/ngx_http_upstream.c c->log = r->connection->log; c 1130 http/ngx_http_upstream.c c->read->log = c->log; c 1131 http/ngx_http_upstream.c c->write->log = c->log; c 1137 http/ngx_http_upstream.c u->writer.connection = c; c 1177 http/ngx_http_upstream.c ngx_add_timer(c->write, u->conf->connect_timeout); c 1183 http/ngx_http_upstream.c if (u->ssl && c->ssl == NULL) { c 1184 http/ngx_http_upstream.c ngx_http_upstream_ssl_init_connection(r, u, c); c 1198 http/ngx_http_upstream.c ngx_http_upstream_t *u, ngx_connection_t *c) c 1202 http/ngx_http_upstream.c if (ngx_ssl_create_connection(u->conf->ssl, c, c 1211 http/ngx_http_upstream.c c->sendfile = 0; c 1224 http/ngx_http_upstream.c rc = ngx_ssl_handshake(c); c 1227 http/ngx_http_upstream.c c->ssl->handler = ngx_http_upstream_ssl_handshake; c 1231 http/ngx_http_upstream.c ngx_http_upstream_ssl_handshake(c); c 1236 http/ngx_http_upstream.c ngx_http_upstream_ssl_handshake(ngx_connection_t *c) c 1241 http/ngx_http_upstream.c r = c->data; c 1244 http/ngx_http_upstream.c if (c->ssl->handshaked) { c 1250 http/ngx_http_upstream.c c->write->handler = ngx_http_upstream_handler; c 1251 http/ngx_http_upstream.c c->read->handler = ngx_http_upstream_handler; c 1333 http/ngx_http_upstream.c ngx_connection_t *c; c 1335 http/ngx_http_upstream.c c = u->peer.connection; c 1337 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1340 http/ngx_http_upstream.c if (!u->request_sent && ngx_http_upstream_test_connect(c) != NGX_OK) { c 1345 http/ngx_http_upstream.c c->log->action = "sending request to upstream"; c 1356 http/ngx_http_upstream.c if (c->write->timer_set) { c 1357 http/ngx_http_upstream.c ngx_del_timer(c->write); c 1361 http/ngx_http_upstream.c ngx_add_timer(c->write, u->conf->send_timeout); c 1363 http/ngx_http_upstream.c if (ngx_handle_write_event(c->write, u->conf->send_lowat) != NGX_OK) { c 1374 http/ngx_http_upstream.c if (c->tcp_nopush == NGX_TCP_NOPUSH_SET) { c 1375 http/ngx_http_upstream.c if (ngx_tcp_push(c->fd) == NGX_ERROR) { c 1376 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_CRIT, c->log, ngx_socket_errno, c 1383 http/ngx_http_upstream.c c->tcp_nopush = NGX_TCP_NOPUSH_UNSET; c 1386 http/ngx_http_upstream.c ngx_add_timer(c->read, u->conf->read_timeout); c 1389 http/ngx_http_upstream.c if (c->read->ready) { c 1407 http/ngx_http_upstream.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 1419 http/ngx_http_upstream.c ngx_connection_t *c; c 1421 http/ngx_http_upstream.c c = u->peer.connection; c 1426 http/ngx_http_upstream.c if (c->write->timedout) { c 1433 http/ngx_http_upstream.c if (u->ssl && c->ssl == NULL) { c 1434 http/ngx_http_upstream.c ngx_http_upstream_ssl_init_connection(r, u, c); c 1443 http/ngx_http_upstream.c (void) ngx_handle_write_event(c->write, 0); c 1457 http/ngx_http_upstream.c ngx_connection_t *c; c 1459 http/ngx_http_upstream.c c = u->peer.connection; c 1461 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1464 http/ngx_http_upstream.c c->log->action = "reading response header from upstream"; c 1466 http/ngx_http_upstream.c if (c->read->timedout) { c 1471 http/ngx_http_upstream.c if (!u->request_sent && ngx_http_upstream_test_connect(c) != NGX_OK) { c 1511 http/ngx_http_upstream.c n = c->recv(c, u->buffer.last, u->buffer.end - u->buffer.last); c 1518 http/ngx_http_upstream.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 1528 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 1550 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 1757 http/ngx_http_upstream.c ngx_http_upstream_test_connect(ngx_connection_t *c) c 1765 http/ngx_http_upstream.c if (c->write->pending_eof) { c 1766 http/ngx_http_upstream.c c->log->action = "connecting to upstream"; c 1767 http/ngx_http_upstream.c (void) ngx_connection_error(c, c->write->kq_errno, c 1783 http/ngx_http_upstream.c if (getsockopt(c->fd, SOL_SOCKET, SO_ERROR, (void *) &err, &len) c 1790 http/ngx_http_upstream.c c->log->action = "connecting to upstream"; c 1791 http/ngx_http_upstream.c (void) ngx_connection_error(c, err, "connect() failed"); c 1937 http/ngx_http_upstream.c ngx_connection_t *c; c 1939 http/ngx_http_upstream.c c = u->peer.connection; c 1940 http/ngx_http_upstream.c rev = c->read; c 1942 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 1946 http/ngx_http_upstream.c ngx_connection_error(c, NGX_ETIMEDOUT, "upstream timed out"); c 1958 http/ngx_http_upstream.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 1964 http/ngx_http_upstream.c n = c->recv(c, b->last, size); c 2008 http/ngx_http_upstream.c ngx_connection_t *c; c 2018 http/ngx_http_upstream.c c = r->connection; c 2024 http/ngx_http_upstream.c if (ngx_shutdown_socket(c->fd, NGX_WRITE_SHUTDOWN) == -1) { c 2025 http/ngx_http_upstream.c ngx_connection_error(c, ngx_socket_errno, c 2031 http/ngx_http_upstream.c c->error = 1; c 2067 http/ngx_http_upstream.c if (clcf->tcp_nodelay && c->tcp_nodelay == NGX_TCP_NODELAY_UNSET) { c 2068 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, "tcp_nodelay"); c 2072 http/ngx_http_upstream.c if (setsockopt(c->fd, IPPROTO_TCP, TCP_NODELAY, c 2075 http/ngx_http_upstream.c ngx_connection_error(c, ngx_socket_errno, c 2081 http/ngx_http_upstream.c c->tcp_nodelay = NGX_TCP_NODELAY_SET; c 2193 http/ngx_http_upstream.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2210 http/ngx_http_upstream.c p->downstream = c; c 2212 http/ngx_http_upstream.c p->log = c->log; c 2223 http/ngx_http_upstream.c p->temp_file->file.log = c->log; c 2287 http/ngx_http_upstream.c c->sendfile = 0; c 2308 http/ngx_http_upstream.c ngx_connection_t *c; c 2311 http/ngx_http_upstream.c c = r->connection; c 2313 http/ngx_http_upstream.c wev = c->write; c 2315 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2318 http/ngx_http_upstream.c c->log->action = "sending to client"; c 2321 http/ngx_http_upstream.c c->timedout = 1; c 2322 http/ngx_http_upstream.c ngx_connection_error(c, NGX_ETIMEDOUT, "client timed out"); c 2335 http/ngx_http_upstream.c ngx_connection_t *c; c 2337 http/ngx_http_upstream.c c = u->peer.connection; c 2339 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2342 http/ngx_http_upstream.c c->log->action = "reading upstream"; c 2344 http/ngx_http_upstream.c if (c->read->timedout) { c 2345 http/ngx_http_upstream.c ngx_connection_error(c, NGX_ETIMEDOUT, "upstream timed out"); c 2521 http/ngx_http_upstream.c ngx_connection_t *c; c 2525 http/ngx_http_upstream.c c = r->connection; c 2528 http/ngx_http_upstream.c wev = c->write; c 2530 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2533 http/ngx_http_upstream.c c->log->action = "sending to client"; c 2559 http/ngx_http_upstream.c c->timedout = 1; c 2560 http/ngx_http_upstream.c ngx_connection_error(c, NGX_ETIMEDOUT, "client timed out"); c 2567 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2591 http/ngx_http_upstream.c ngx_connection_t *c; c 2593 http/ngx_http_upstream.c c = u->peer.connection; c 2595 http/ngx_http_upstream.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 2598 http/ngx_http_upstream.c c->log->action = "reading upstream"; c 2600 http/ngx_http_upstream.c if (c->read->timedout) { c 2602 http/ngx_http_upstream.c ngx_connection_error(c, NGX_ETIMEDOUT, "upstream timed out"); c 365 http/ngx_http_upstream_round_robin.c ngx_connection_t *c; c 380 http/ngx_http_upstream_round_robin.c c = rrp->peers->cached[rrp->peers->last_cached]; c 386 http/ngx_http_upstream_round_robin.c c->read->lock = c->read->own_lock; c 387 http/ngx_http_upstream_round_robin.c c->write->lock = c->write->own_lock; c 390 http/ngx_http_upstream_round_robin.c pc->connection = c; c 53 http/ngx_http_write_filter_module.c ngx_connection_t *c; c 56 http/ngx_http_write_filter_module.c c = r->connection; c 58 http/ngx_http_write_filter_module.c if (c->error) { c 72 http/ngx_http_write_filter_module.c ngx_log_debug7(NGX_LOG_DEBUG_EVENT, c->log, 0, c 83 http/ngx_http_write_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 124 http/ngx_http_write_filter_module.c ngx_log_debug7(NGX_LOG_DEBUG_EVENT, c->log, 0, c 135 http/ngx_http_write_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 166 http/ngx_http_write_filter_module.c ngx_log_debug3(NGX_LOG_DEBUG_HTTP, c->log, 0, c 181 http/ngx_http_write_filter_module.c if (c->write->delayed) { c 182 http/ngx_http_write_filter_module.c c->buffered |= NGX_HTTP_WRITE_BUFFERED; c 186 http/ngx_http_write_filter_module.c if (size == 0 && !(c->buffered & NGX_LOWLEVEL_BUFFERED)) { c 189 http/ngx_http_write_filter_module.c c->buffered &= ~NGX_HTTP_WRITE_BUFFERED; c 199 http/ngx_http_write_filter_module.c c->buffered &= ~NGX_HTTP_WRITE_BUFFERED; c 204 http/ngx_http_write_filter_module.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 214 http/ngx_http_write_filter_module.c - (c->sent - clcf->limit_rate_after); c 217 http/ngx_http_write_filter_module.c c->write->delayed = 1; c 218 http/ngx_http_write_filter_module.c ngx_add_timer(c->write, c 221 http/ngx_http_write_filter_module.c c->buffered |= NGX_HTTP_WRITE_BUFFERED; c 233 http/ngx_http_write_filter_module.c sent = c->sent; c 235 http/ngx_http_write_filter_module.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 238 http/ngx_http_write_filter_module.c chain = c->send_chain(c, r->out, limit); c 240 http/ngx_http_write_filter_module.c ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, c 244 http/ngx_http_write_filter_module.c c->error = 1; c 250 http/ngx_http_write_filter_module.c nsent = c->sent; c 268 http/ngx_http_write_filter_module.c c->write->delayed = 1; c 269 http/ngx_http_write_filter_module.c ngx_add_timer(c->write, delay); c 272 http/ngx_http_write_filter_module.c } else if (c->write->ready c 274 http/ngx_http_write_filter_module.c && (size_t) (c->sent - sent) c 277 http/ngx_http_write_filter_module.c c->write->delayed = 1; c 278 http/ngx_http_write_filter_module.c ngx_add_timer(c->write, 1); c 290 http/ngx_http_write_filter_module.c c->buffered |= NGX_HTTP_WRITE_BUFFERED; c 294 http/ngx_http_write_filter_module.c c->buffered &= ~NGX_HTTP_WRITE_BUFFERED; c 296 http/ngx_http_write_filter_module.c if ((c->buffered & NGX_LOWLEVEL_BUFFERED) && r->postponed == NULL) { c 307 mail/ngx_mail.h ngx_connection_t *c); c 350 mail/ngx_mail.h #define ngx_mail_set_ctx(s, c, module) s->ctx[module.ctx_index] = c; c 366 mail/ngx_mail.h ngx_int_t ngx_mail_starttls_only(ngx_mail_session_t *s, ngx_connection_t *c); c 370 mail/ngx_mail.h void ngx_mail_init_connection(ngx_connection_t *c); c 372 mail/ngx_mail.h ngx_int_t ngx_mail_salt(ngx_mail_session_t *s, ngx_connection_t *c, c 374 mail/ngx_mail.h ngx_int_t ngx_mail_auth_plain(ngx_mail_session_t *s, ngx_connection_t *c, c 377 mail/ngx_mail.h ngx_connection_t *c, ngx_uint_t n); c 379 mail/ngx_mail.h ngx_connection_t *c); c 381 mail/ngx_mail.h ngx_connection_t *c, char *prefix, size_t len); c 382 mail/ngx_mail.h ngx_int_t ngx_mail_auth_cram_md5(ngx_mail_session_t *s, ngx_connection_t *c); c 383 mail/ngx_mail.h ngx_int_t ngx_mail_auth_parse(ngx_mail_session_t *s, ngx_connection_t *c); c 386 mail/ngx_mail.h ngx_int_t ngx_mail_read_command(ngx_mail_session_t *s, ngx_connection_t *c); c 387 mail/ngx_mail.h void ngx_mail_auth(ngx_mail_session_t *s, ngx_connection_t *c); c 388 mail/ngx_mail.h void ngx_mail_close_connection(ngx_connection_t *c); c 229 mail/ngx_mail_auth_http_module.c ngx_connection_t *c; c 234 mail/ngx_mail_auth_http_module.c c = wev->data; c 235 mail/ngx_mail_auth_http_module.c s = c->data; c 245 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 253 mail/ngx_mail_auth_http_module.c n = ngx_send(c, ctx->request->pos, size); c 256 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 273 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 293 mail/ngx_mail_auth_http_module.c ngx_connection_t *c; c 297 mail/ngx_mail_auth_http_module.c c = rev->data; c 298 mail/ngx_mail_auth_http_module.c s = c->data; c 308 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 317 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 326 mail/ngx_mail_auth_http_module.c n = ngx_recv(c, ctx->response->pos, size); c 339 mail/ngx_mail_auth_http_module.c ngx_close_connection(c); c 858 mail/ngx_mail_auth_http_module.c ngx_connection_t *c; c 864 mail/ngx_mail_auth_http_module.c c = rev->data; c 865 mail/ngx_mail_auth_http_module.c s = c->data; c 884 mail/ngx_mail_auth_http_module.c c->log->action = "in auth state"; c 886 mail/ngx_mail_auth_http_module.c ngx_mail_send(c->write); c 888 mail/ngx_mail_auth_http_module.c if (c->destroyed) { c 900 mail/ngx_mail_auth_http_module.c ngx_mail_close_connection(c); c 908 mail/ngx_mail_auth_http_module.c ngx_mail_close_connection(c); c 918 mail/ngx_mail_auth_http_module.c u_char c, ch, *p; c 951 mail/ngx_mail_auth_http_module.c c = (u_char) (ch | 0x20); c 952 mail/ngx_mail_auth_http_module.c if (c >= 'a' && c <= 'z') { c 966 mail/ngx_mail_auth_http_module.c c = (u_char) (ch | 0x20); c 967 mail/ngx_mail_auth_http_module.c if (c >= 'a' && c <= 'z') { c 1100 mail/ngx_mail_auth_http_module.c ngx_connection_t *c; c 1108 mail/ngx_mail_auth_http_module.c c = rev->data; c 1109 mail/ngx_mail_auth_http_module.c s = c->data; c 534 mail/ngx_mail_core_module.c ngx_str_t *c, *value; c 543 mail/ngx_mail_core_module.c c = ngx_array_push(a); c 544 mail/ngx_mail_core_module.c if (c == NULL) { c 548 mail/ngx_mail_core_module.c *c = value[i]; c 13 mail/ngx_mail_handler.c static void ngx_mail_init_session(ngx_connection_t *c); c 16 mail/ngx_mail_handler.c static void ngx_mail_ssl_init_connection(ngx_ssl_t *ssl, ngx_connection_t *c); c 17 mail/ngx_mail_handler.c static void ngx_mail_ssl_handshake_handler(ngx_connection_t *c); c 22 mail/ngx_mail_handler.c ngx_mail_init_connection(ngx_connection_t *c) c 42 mail/ngx_mail_handler.c port = c->listening->servers; c 54 mail/ngx_mail_handler.c if (ngx_connection_local_sockaddr(c, NULL, 0) != NGX_OK) { c 55 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 59 mail/ngx_mail_handler.c sa = c->local_sockaddr; c 101 mail/ngx_mail_handler.c switch (c->local_sockaddr->sa_family) { c 117 mail/ngx_mail_handler.c s = ngx_pcalloc(c->pool, sizeof(ngx_mail_session_t)); c 119 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 128 mail/ngx_mail_handler.c c->data = s; c 129 mail/ngx_mail_handler.c s->connection = c; c 131 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, "*%ui client %V connected to %V", c 132 mail/ngx_mail_handler.c c->number, &c->addr_text, s->addr_text); c 134 mail/ngx_mail_handler.c ctx = ngx_palloc(c->pool, sizeof(ngx_mail_log_ctx_t)); c 136 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 140 mail/ngx_mail_handler.c ctx->client = &c->addr_text; c 143 mail/ngx_mail_handler.c c->log->connection = c->number; c 144 mail/ngx_mail_handler.c c->log->handler = ngx_mail_log_error; c 145 mail/ngx_mail_handler.c c->log->data = ctx; c 146 mail/ngx_mail_handler.c c->log->action = "sending client greeting line"; c 148 mail/ngx_mail_handler.c c->log_error = NGX_ERROR_INFO; c 157 mail/ngx_mail_handler.c c->log->action = "SSL handshaking"; c 159 mail/ngx_mail_handler.c ngx_mail_ssl_init_connection(&sslcf->ssl, c); c 165 mail/ngx_mail_handler.c c->log->action = "SSL handshaking"; c 168 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 171 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 175 mail/ngx_mail_handler.c ngx_mail_ssl_init_connection(&sslcf->ssl, c); c 182 mail/ngx_mail_handler.c ngx_mail_init_session(c); c 191 mail/ngx_mail_handler.c ngx_connection_t *c; c 195 mail/ngx_mail_handler.c c = rev->data; c 196 mail/ngx_mail_handler.c s = c->data; c 199 mail/ngx_mail_handler.c c->log->action = "in starttls state"; c 203 mail/ngx_mail_handler.c ngx_mail_ssl_init_connection(&sslcf->ssl, c); c 208 mail/ngx_mail_handler.c ngx_mail_ssl_init_connection(ngx_ssl_t *ssl, ngx_connection_t *c) c 213 mail/ngx_mail_handler.c if (ngx_ssl_create_connection(ssl, c, 0) == NGX_ERROR) { c 214 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 218 mail/ngx_mail_handler.c if (ngx_ssl_handshake(c) == NGX_AGAIN) { c 220 mail/ngx_mail_handler.c s = c->data; c 224 mail/ngx_mail_handler.c ngx_add_timer(c->read, cscf->timeout); c 226 mail/ngx_mail_handler.c c->ssl->handler = ngx_mail_ssl_handshake_handler; c 231 mail/ngx_mail_handler.c ngx_mail_ssl_handshake_handler(c); c 236 mail/ngx_mail_handler.c ngx_mail_ssl_handshake_handler(ngx_connection_t *c) c 241 mail/ngx_mail_handler.c if (c->ssl->handshaked) { c 243 mail/ngx_mail_handler.c s = c->data; c 248 mail/ngx_mail_handler.c c->read->handler = cscf->protocol->init_protocol; c 249 mail/ngx_mail_handler.c c->write->handler = ngx_mail_send; c 251 mail/ngx_mail_handler.c cscf->protocol->init_protocol(c->read); c 256 mail/ngx_mail_handler.c c->read->ready = 0; c 258 mail/ngx_mail_handler.c ngx_mail_init_session(c); c 262 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 269 mail/ngx_mail_handler.c ngx_mail_init_session(ngx_connection_t *c) c 274 mail/ngx_mail_handler.c s = c->data; c 280 mail/ngx_mail_handler.c s->ctx = ngx_pcalloc(c->pool, sizeof(void *) * ngx_mail_max_module); c 286 mail/ngx_mail_handler.c c->write->handler = ngx_mail_send; c 288 mail/ngx_mail_handler.c cscf->protocol->init_session(s, c); c 293 mail/ngx_mail_handler.c ngx_mail_salt(ngx_mail_session_t *s, ngx_connection_t *c, c 296 mail/ngx_mail_handler.c s->salt.data = ngx_pnalloc(c->pool, c 315 mail/ngx_mail_handler.c ngx_mail_starttls_only(ngx_mail_session_t *s, ngx_connection_t *c) c 319 mail/ngx_mail_handler.c if (c->ssl) { c 336 mail/ngx_mail_handler.c ngx_mail_auth_plain(ngx_mail_session_t *s, ngx_connection_t *c, ngx_uint_t n) c 344 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 348 mail/ngx_mail_handler.c plain.data = ngx_pnalloc(c->pool, ngx_base64_decoded_length(arg[n].len)); c 354 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 365 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 375 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 386 mail/ngx_mail_handler.c ngx_log_debug2(NGX_LOG_DEBUG_MAIL, c->log, 0, c 395 mail/ngx_mail_handler.c ngx_mail_auth_login_username(ngx_mail_session_t *s, ngx_connection_t *c, c 402 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 405 mail/ngx_mail_handler.c s->login.data = ngx_pnalloc(c->pool, ngx_base64_decoded_length(arg[n].len)); c 411 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 416 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 424 mail/ngx_mail_handler.c ngx_mail_auth_login_password(ngx_mail_session_t *s, ngx_connection_t *c) c 431 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 435 mail/ngx_mail_handler.c s->passwd.data = ngx_pnalloc(c->pool, c 442 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 448 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 457 mail/ngx_mail_handler.c ngx_mail_auth_cram_md5_salt(ngx_mail_session_t *s, ngx_connection_t *c, c 464 mail/ngx_mail_handler.c p = ngx_pnalloc(c->pool, len + ngx_base64_encoded_length(s->salt.len) + 2); c 486 mail/ngx_mail_handler.c ngx_mail_auth_cram_md5(ngx_mail_session_t *s, ngx_connection_t *c) c 493 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 496 mail/ngx_mail_handler.c s->login.data = ngx_pnalloc(c->pool, ngx_base64_decoded_length(arg[0].len)); c 502 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 520 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 525 mail/ngx_mail_handler.c ngx_log_debug2(NGX_LOG_DEBUG_MAIL, c->log, 0, c 538 mail/ngx_mail_handler.c ngx_connection_t *c; c 542 mail/ngx_mail_handler.c c = wev->data; c 543 mail/ngx_mail_handler.c s = c->data; c 546 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 547 mail/ngx_mail_handler.c c->timedout = 1; c 548 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 553 mail/ngx_mail_handler.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 554 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 560 mail/ngx_mail_handler.c n = c->send(c, s->out.data, s->out.len); c 570 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 575 mail/ngx_mail_handler.c c->read->handler(c->read); c 582 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 590 mail/ngx_mail_handler.c ngx_add_timer(c->write, cscf->timeout); c 592 mail/ngx_mail_handler.c if (ngx_handle_write_event(c->write, 0) != NGX_OK) { c 593 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 600 mail/ngx_mail_handler.c ngx_mail_read_command(ngx_mail_session_t *s, ngx_connection_t *c) c 607 mail/ngx_mail_handler.c n = c->recv(c, s->buffer->last, s->buffer->end - s->buffer->last); c 610 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 619 mail/ngx_mail_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 640 mail/ngx_mail_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, c 653 mail/ngx_mail_handler.c ngx_mail_close_connection(c); c 662 mail/ngx_mail_handler.c ngx_mail_auth(ngx_mail_session_t *s, ngx_connection_t *c) c 669 mail/ngx_mail_handler.c if (c->read->timer_set) { c 670 mail/ngx_mail_handler.c ngx_del_timer(c->read); c 694 mail/ngx_mail_handler.c ngx_mail_close_connection(ngx_connection_t *c) c 698 mail/ngx_mail_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 699 mail/ngx_mail_handler.c "close mail connection: %d", c->fd); c 703 mail/ngx_mail_handler.c if (c->ssl) { c 704 mail/ngx_mail_handler.c if (ngx_ssl_shutdown(c) == NGX_AGAIN) { c 705 mail/ngx_mail_handler.c c->ssl->handler = ngx_mail_close_connection; c 716 mail/ngx_mail_handler.c c->destroyed = 1; c 718 mail/ngx_mail_handler.c pool = c->pool; c 720 mail/ngx_mail_handler.c ngx_close_connection(c); c 15 mail/ngx_mail_imap_handler.c ngx_connection_t *c); c 17 mail/ngx_mail_imap_handler.c ngx_connection_t *c); c 19 mail/ngx_mail_imap_handler.c ngx_connection_t *c); c 21 mail/ngx_mail_imap_handler.c ngx_connection_t *c); c 36 mail/ngx_mail_imap_handler.c ngx_mail_imap_init_session(ngx_mail_session_t *s, ngx_connection_t *c) c 44 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_imap_init_protocol; c 46 mail/ngx_mail_imap_handler.c ngx_add_timer(c->read, cscf->timeout); c 48 mail/ngx_mail_imap_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 49 mail/ngx_mail_imap_handler.c ngx_mail_close_connection(c); c 52 mail/ngx_mail_imap_handler.c ngx_mail_send(c->write); c 59 mail/ngx_mail_imap_handler.c ngx_connection_t *c; c 63 mail/ngx_mail_imap_handler.c c = rev->data; c 65 mail/ngx_mail_imap_handler.c c->log->action = "in auth state"; c 68 mail/ngx_mail_imap_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 69 mail/ngx_mail_imap_handler.c c->timedout = 1; c 70 mail/ngx_mail_imap_handler.c ngx_mail_close_connection(c); c 74 mail/ngx_mail_imap_handler.c s = c->data; c 77 mail/ngx_mail_imap_handler.c if (ngx_array_init(&s->args, c->pool, 2, sizeof(ngx_str_t)) c 86 mail/ngx_mail_imap_handler.c s->buffer = ngx_create_temp_buf(c->pool, iscf->client_buffer_size); c 94 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_imap_auth_state; c 107 mail/ngx_mail_imap_handler.c ngx_connection_t *c; c 110 mail/ngx_mail_imap_handler.c c = rev->data; c 111 mail/ngx_mail_imap_handler.c s = c->data; c 113 mail/ngx_mail_imap_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "imap auth state"); c 116 mail/ngx_mail_imap_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 117 mail/ngx_mail_imap_handler.c c->timedout = 1; c 118 mail/ngx_mail_imap_handler.c ngx_mail_close_connection(c); c 123 mail/ngx_mail_imap_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "imap send handler busy"); c 130 mail/ngx_mail_imap_handler.c rc = ngx_mail_read_command(s, c); c 142 mail/ngx_mail_imap_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, "imap auth command: %i", c 173 mail/ngx_mail_imap_handler.c rc = ngx_mail_imap_login(s, c); c 177 mail/ngx_mail_imap_handler.c rc = ngx_mail_imap_authenticate(s, c); c 182 mail/ngx_mail_imap_handler.c rc = ngx_mail_imap_capability(s, c); c 194 mail/ngx_mail_imap_handler.c rc = ngx_mail_imap_starttls(s, c); c 205 mail/ngx_mail_imap_handler.c rc = ngx_mail_auth_login_username(s, c, 0); c 214 mail/ngx_mail_imap_handler.c rc = ngx_mail_auth_login_password(s, c); c 218 mail/ngx_mail_imap_handler.c rc = ngx_mail_auth_plain(s, c, 0); c 222 mail/ngx_mail_imap_handler.c rc = ngx_mail_auth_cram_md5(s, c); c 234 mail/ngx_mail_imap_handler.c ngx_mail_auth(s, c); c 255 mail/ngx_mail_imap_handler.c s->tagged_line.data = ngx_pnalloc(c->pool, s->tagged_line.len); c 257 mail/ngx_mail_imap_handler.c ngx_mail_close_connection(c); c 291 mail/ngx_mail_imap_handler.c ngx_mail_send(c->write); c 296 mail/ngx_mail_imap_handler.c ngx_mail_imap_login(ngx_mail_session_t *s, ngx_connection_t *c) c 301 mail/ngx_mail_imap_handler.c if (ngx_mail_starttls_only(s, c)) { c 313 mail/ngx_mail_imap_handler.c s->login.data = ngx_pnalloc(c->pool, s->login.len); c 321 mail/ngx_mail_imap_handler.c s->passwd.data = ngx_pnalloc(c->pool, s->passwd.len); c 329 mail/ngx_mail_imap_handler.c ngx_log_debug2(NGX_LOG_DEBUG_MAIL, c->log, 0, c 333 mail/ngx_mail_imap_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 342 mail/ngx_mail_imap_handler.c ngx_mail_imap_authenticate(ngx_mail_session_t *s, ngx_connection_t *c) c 349 mail/ngx_mail_imap_handler.c if (ngx_mail_starttls_only(s, c)) { c 354 mail/ngx_mail_imap_handler.c rc = ngx_mail_auth_parse(s, c); c 370 mail/ngx_mail_imap_handler.c return ngx_mail_auth_login_username(s, c, 1); c 390 mail/ngx_mail_imap_handler.c if (ngx_mail_salt(s, c, cscf) != NGX_OK) { c 395 mail/ngx_mail_imap_handler.c if (ngx_mail_auth_cram_md5_salt(s, c, "+ ", 2) == NGX_OK) { c 408 mail/ngx_mail_imap_handler.c ngx_mail_imap_capability(ngx_mail_session_t *s, ngx_connection_t *c) c 416 mail/ngx_mail_imap_handler.c if (c->ssl == NULL) { c 440 mail/ngx_mail_imap_handler.c ngx_mail_imap_starttls(ngx_mail_session_t *s, ngx_connection_t *c) c 445 mail/ngx_mail_imap_handler.c if (c->ssl == NULL) { c 448 mail/ngx_mail_imap_handler.c c->read->handler = ngx_mail_starttls_handler; c 142 mail/ngx_mail_imap_module.c ngx_str_t *c, *d; c 162 mail/ngx_mail_imap_module.c c = ngx_array_push(&conf->capabilities); c 163 mail/ngx_mail_imap_module.c if (c == NULL) { c 167 mail/ngx_mail_imap_module.c *c = *d; c 173 mail/ngx_mail_imap_module.c c = conf->capabilities.elts; c 175 mail/ngx_mail_imap_module.c size += 1 + c[i].len; c 199 mail/ngx_mail_imap_module.c p = ngx_cpymem(p, c[i].data, c[i].len); c 29 mail/ngx_mail_imap_module.h void ngx_mail_imap_init_session(ngx_mail_session_t *s, ngx_connection_t *c); c 16 mail/ngx_mail_parse.c u_char ch, *p, *c, c0, c1, c2, c3; c 35 mail/ngx_mail_parse.c c = s->buffer->start; c 37 mail/ngx_mail_parse.c if (p - c == 4) { c 39 mail/ngx_mail_parse.c c0 = ngx_toupper(c[0]); c 40 mail/ngx_mail_parse.c c1 = ngx_toupper(c[1]); c 41 mail/ngx_mail_parse.c c2 = ngx_toupper(c[2]); c 42 mail/ngx_mail_parse.c c3 = ngx_toupper(c[3]); c 214 mail/ngx_mail_parse.c u_char ch, *p, *c; c 275 mail/ngx_mail_parse.c c = s->cmd_start; c 277 mail/ngx_mail_parse.c switch (p - c) { c 280 mail/ngx_mail_parse.c if ((c[0] == 'N' || c[0] == 'n') c 281 mail/ngx_mail_parse.c && (c[1] == 'O'|| c[1] == 'o') c 282 mail/ngx_mail_parse.c && (c[2] == 'O'|| c[2] == 'o') c 283 mail/ngx_mail_parse.c && (c[3] == 'P'|| c[3] == 'p')) c 293 mail/ngx_mail_parse.c if ((c[0] == 'L'|| c[0] == 'l') c 294 mail/ngx_mail_parse.c && (c[1] == 'O'|| c[1] == 'o') c 295 mail/ngx_mail_parse.c && (c[2] == 'G'|| c[2] == 'g') c 296 mail/ngx_mail_parse.c && (c[3] == 'I'|| c[3] == 'i') c 297 mail/ngx_mail_parse.c && (c[4] == 'N'|| c[4] == 'n')) c 307 mail/ngx_mail_parse.c if ((c[0] == 'L'|| c[0] == 'l') c 308 mail/ngx_mail_parse.c && (c[1] == 'O'|| c[1] == 'o') c 309 mail/ngx_mail_parse.c && (c[2] == 'G'|| c[2] == 'g') c 310 mail/ngx_mail_parse.c && (c[3] == 'O'|| c[3] == 'o') c 311 mail/ngx_mail_parse.c && (c[4] == 'U'|| c[4] == 'u') c 312 mail/ngx_mail_parse.c && (c[5] == 'T'|| c[5] == 't')) c 323 mail/ngx_mail_parse.c if ((c[0] == 'S'|| c[0] == 's') c 324 mail/ngx_mail_parse.c && (c[1] == 'T'|| c[1] == 't') c 325 mail/ngx_mail_parse.c && (c[2] == 'A'|| c[2] == 'a') c 326 mail/ngx_mail_parse.c && (c[3] == 'R'|| c[3] == 'r') c 327 mail/ngx_mail_parse.c && (c[4] == 'T'|| c[4] == 't') c 328 mail/ngx_mail_parse.c && (c[5] == 'T'|| c[5] == 't') c 329 mail/ngx_mail_parse.c && (c[6] == 'L'|| c[6] == 'l') c 330 mail/ngx_mail_parse.c && (c[7] == 'S'|| c[7] == 's')) c 341 mail/ngx_mail_parse.c if ((c[0] == 'C'|| c[0] == 'c') c 342 mail/ngx_mail_parse.c && (c[1] == 'A'|| c[1] == 'a') c 343 mail/ngx_mail_parse.c && (c[2] == 'P'|| c[2] == 'p') c 344 mail/ngx_mail_parse.c && (c[3] == 'A'|| c[3] == 'a') c 345 mail/ngx_mail_parse.c && (c[4] == 'B'|| c[4] == 'b') c 346 mail/ngx_mail_parse.c && (c[5] == 'I'|| c[5] == 'i') c 347 mail/ngx_mail_parse.c && (c[6] == 'L'|| c[6] == 'l') c 348 mail/ngx_mail_parse.c && (c[7] == 'I'|| c[7] == 'i') c 349 mail/ngx_mail_parse.c && (c[8] == 'T'|| c[8] == 't') c 350 mail/ngx_mail_parse.c && (c[9] == 'Y'|| c[9] == 'y')) c 360 mail/ngx_mail_parse.c if ((c[0] == 'A'|| c[0] == 'a') c 361 mail/ngx_mail_parse.c && (c[1] == 'U'|| c[1] == 'u') c 362 mail/ngx_mail_parse.c && (c[2] == 'T'|| c[2] == 't') c 363 mail/ngx_mail_parse.c && (c[3] == 'H'|| c[3] == 'h') c 364 mail/ngx_mail_parse.c && (c[4] == 'E'|| c[4] == 'e') c 365 mail/ngx_mail_parse.c && (c[5] == 'N'|| c[5] == 'n') c 366 mail/ngx_mail_parse.c && (c[6] == 'T'|| c[6] == 't') c 367 mail/ngx_mail_parse.c && (c[7] == 'I'|| c[7] == 'i') c 368 mail/ngx_mail_parse.c && (c[8] == 'C'|| c[8] == 'c') c 369 mail/ngx_mail_parse.c && (c[9] == 'A'|| c[9] == 'a') c 370 mail/ngx_mail_parse.c && (c[10] == 'T'|| c[10] == 't') c 371 mail/ngx_mail_parse.c && (c[11] == 'E'|| c[11] == 'e')) c 621 mail/ngx_mail_parse.c u_char ch, *p, *c, c0, c1, c2, c3; c 640 mail/ngx_mail_parse.c c = s->buffer->start; c 642 mail/ngx_mail_parse.c if (p - c == 4) { c 644 mail/ngx_mail_parse.c c0 = ngx_toupper(c[0]); c 645 mail/ngx_mail_parse.c c1 = ngx_toupper(c[1]); c 646 mail/ngx_mail_parse.c c2 = ngx_toupper(c[2]); c 647 mail/ngx_mail_parse.c c3 = ngx_toupper(c[3]); c 697 mail/ngx_mail_parse.c } else if (p - c == 8) { c 699 mail/ngx_mail_parse.c if ((c[0] == 'S'|| c[0] == 's') c 700 mail/ngx_mail_parse.c && (c[1] == 'T'|| c[1] == 't') c 701 mail/ngx_mail_parse.c && (c[2] == 'A'|| c[2] == 'a') c 702 mail/ngx_mail_parse.c && (c[3] == 'R'|| c[3] == 'r') c 703 mail/ngx_mail_parse.c && (c[4] == 'T'|| c[4] == 't') c 704 mail/ngx_mail_parse.c && (c[5] == 'T'|| c[5] == 't') c 705 mail/ngx_mail_parse.c && (c[6] == 'L'|| c[6] == 'l') c 706 mail/ngx_mail_parse.c && (c[7] == 'S'|| c[7] == 's')) c 831 mail/ngx_mail_parse.c ngx_mail_auth_parse(ngx_mail_session_t *s, ngx_connection_t *c) c 836 mail/ngx_mail_parse.c if (ngx_mail_starttls_only(s, c)) { c 865 mail/ngx_mail_parse.c return ngx_mail_auth_plain(s, c, 1); c 14 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_user(ngx_mail_session_t *s, ngx_connection_t *c); c 15 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_pass(ngx_mail_session_t *s, ngx_connection_t *c); c 16 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_capa(ngx_mail_session_t *s, ngx_connection_t *c, c 18 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_stls(ngx_mail_session_t *s, ngx_connection_t *c); c 19 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_apop(ngx_mail_session_t *s, ngx_connection_t *c); c 20 mail/ngx_mail_pop3_handler.c static ngx_int_t ngx_mail_pop3_auth(ngx_mail_session_t *s, ngx_connection_t *c); c 32 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_init_session(ngx_mail_session_t *s, ngx_connection_t *c) c 44 mail/ngx_mail_pop3_handler.c if (ngx_mail_salt(s, c, cscf) != NGX_OK) { c 49 mail/ngx_mail_pop3_handler.c s->out.data = ngx_pnalloc(c->pool, sizeof(pop3_greeting) + s->salt.len); c 65 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_pop3_init_protocol; c 67 mail/ngx_mail_pop3_handler.c ngx_add_timer(c->read, cscf->timeout); c 69 mail/ngx_mail_pop3_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 70 mail/ngx_mail_pop3_handler.c ngx_mail_close_connection(c); c 73 mail/ngx_mail_pop3_handler.c ngx_mail_send(c->write); c 80 mail/ngx_mail_pop3_handler.c ngx_connection_t *c; c 83 mail/ngx_mail_pop3_handler.c c = rev->data; c 85 mail/ngx_mail_pop3_handler.c c->log->action = "in auth state"; c 88 mail/ngx_mail_pop3_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 89 mail/ngx_mail_pop3_handler.c c->timedout = 1; c 90 mail/ngx_mail_pop3_handler.c ngx_mail_close_connection(c); c 94 mail/ngx_mail_pop3_handler.c s = c->data; c 97 mail/ngx_mail_pop3_handler.c if (ngx_array_init(&s->args, c->pool, 2, sizeof(ngx_str_t)) c 104 mail/ngx_mail_pop3_handler.c s->buffer = ngx_create_temp_buf(c->pool, 128); c 112 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_pop3_auth_state; c 122 mail/ngx_mail_pop3_handler.c ngx_connection_t *c; c 125 mail/ngx_mail_pop3_handler.c c = rev->data; c 126 mail/ngx_mail_pop3_handler.c s = c->data; c 128 mail/ngx_mail_pop3_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "pop3 auth state"); c 131 mail/ngx_mail_pop3_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 132 mail/ngx_mail_pop3_handler.c c->timedout = 1; c 133 mail/ngx_mail_pop3_handler.c ngx_mail_close_connection(c); c 138 mail/ngx_mail_pop3_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "pop3 send handler busy"); c 145 mail/ngx_mail_pop3_handler.c rc = ngx_mail_read_command(s, c); c 161 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_user(s, c); c 165 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_capa(s, c, 1); c 169 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_apop(s, c); c 173 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_auth(s, c); c 184 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_stls(s, c); c 199 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_pass(s, c); c 203 mail/ngx_mail_pop3_handler.c rc = ngx_mail_pop3_capa(s, c, 0); c 225 mail/ngx_mail_pop3_handler.c rc = ngx_mail_auth_login_username(s, c, 0); c 232 mail/ngx_mail_pop3_handler.c rc = ngx_mail_auth_login_password(s, c); c 236 mail/ngx_mail_pop3_handler.c rc = ngx_mail_auth_plain(s, c, 0); c 240 mail/ngx_mail_pop3_handler.c rc = ngx_mail_auth_cram_md5(s, c); c 248 mail/ngx_mail_pop3_handler.c ngx_mail_auth(s, c); c 273 mail/ngx_mail_pop3_handler.c ngx_mail_send(c->write); c 278 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_user(ngx_mail_session_t *s, ngx_connection_t *c) c 283 mail/ngx_mail_pop3_handler.c if (ngx_mail_starttls_only(s, c)) { c 294 mail/ngx_mail_pop3_handler.c s->login.data = ngx_pnalloc(c->pool, s->login.len); c 301 mail/ngx_mail_pop3_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 311 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_pass(ngx_mail_session_t *s, ngx_connection_t *c) c 321 mail/ngx_mail_pop3_handler.c s->passwd.data = ngx_pnalloc(c->pool, s->passwd.len); c 329 mail/ngx_mail_pop3_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 338 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_capa(ngx_mail_session_t *s, ngx_connection_t *c, ngx_int_t stls) c 346 mail/ngx_mail_pop3_handler.c if (stls && c->ssl == NULL) { c 370 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_stls(ngx_mail_session_t *s, ngx_connection_t *c) c 375 mail/ngx_mail_pop3_handler.c if (c->ssl == NULL) { c 378 mail/ngx_mail_pop3_handler.c c->read->handler = ngx_mail_starttls_handler; c 390 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_apop(ngx_mail_session_t *s, ngx_connection_t *c) c 396 mail/ngx_mail_pop3_handler.c if (ngx_mail_starttls_only(s, c)) { c 414 mail/ngx_mail_pop3_handler.c s->login.data = ngx_pnalloc(c->pool, s->login.len); c 422 mail/ngx_mail_pop3_handler.c s->passwd.data = ngx_pnalloc(c->pool, s->passwd.len); c 429 mail/ngx_mail_pop3_handler.c ngx_log_debug2(NGX_LOG_DEBUG_MAIL, c->log, 0, c 439 mail/ngx_mail_pop3_handler.c ngx_mail_pop3_auth(ngx_mail_session_t *s, ngx_connection_t *c) c 445 mail/ngx_mail_pop3_handler.c if (ngx_mail_starttls_only(s, c)) { c 459 mail/ngx_mail_pop3_handler.c rc = ngx_mail_auth_parse(s, c); c 475 mail/ngx_mail_pop3_handler.c return ngx_mail_auth_login_username(s, c, 1); c 490 mail/ngx_mail_pop3_handler.c if (ngx_mail_auth_cram_md5_salt(s, c, "+ ", 2) == NGX_OK) { c 139 mail/ngx_mail_pop3_module.c ngx_str_t *c, *d; c 154 mail/ngx_mail_pop3_module.c c = ngx_array_push(&conf->capabilities); c 155 mail/ngx_mail_pop3_module.c if (c == NULL) { c 159 mail/ngx_mail_pop3_module.c *c = *d; c 168 mail/ngx_mail_pop3_module.c c = conf->capabilities.elts; c 170 mail/ngx_mail_pop3_module.c size += c[i].len + sizeof(CRLF) - 1; c 172 mail/ngx_mail_pop3_module.c if (ngx_strcasecmp(c[i].data, (u_char *) "USER") == 0) { c 176 mail/ngx_mail_pop3_module.c stls_only_size += c[i].len + sizeof(CRLF) - 1; c 198 mail/ngx_mail_pop3_module.c p = ngx_cpymem(p, c[i].data, c[i].len); c 251 mail/ngx_mail_pop3_module.c if (ngx_strcasecmp(c[i].data, (u_char *) "USER") == 0) { c 255 mail/ngx_mail_pop3_module.c p = ngx_cpymem(p, c[i].data, c[i].len); c 28 mail/ngx_mail_pop3_module.h void ngx_mail_pop3_init_session(ngx_mail_session_t *s, ngx_connection_t *c); c 199 mail/ngx_mail_proxy_module.c ngx_connection_t *c; c 205 mail/ngx_mail_proxy_module.c c = rev->data; c 206 mail/ngx_mail_proxy_module.c s = c->data; c 219 mail/ngx_mail_proxy_module.c ngx_connection_t *c; c 226 mail/ngx_mail_proxy_module.c c = rev->data; c 227 mail/ngx_mail_proxy_module.c s = c->data; c 230 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 232 mail/ngx_mail_proxy_module.c c->timedout = 1; c 256 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 275 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 292 mail/ngx_mail_proxy_module.c c->write->handler = ngx_mail_proxy_handler; c 296 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); c 298 mail/ngx_mail_proxy_module.c c->log->action = NULL; c 299 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); c 312 mail/ngx_mail_proxy_module.c if (c->send(c, line.data, line.len) < (ssize_t) line.len) { c 332 mail/ngx_mail_proxy_module.c ngx_connection_t *c; c 339 mail/ngx_mail_proxy_module.c c = rev->data; c 340 mail/ngx_mail_proxy_module.c s = c->data; c 343 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 345 mail/ngx_mail_proxy_module.c c->timedout = 1; c 371 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 390 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 410 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 426 mail/ngx_mail_proxy_module.c c->write->handler = ngx_mail_proxy_handler; c 430 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); c 432 mail/ngx_mail_proxy_module.c c->log->action = NULL; c 433 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); c 446 mail/ngx_mail_proxy_module.c if (c->send(c, line.data, line.len) < (ssize_t) line.len) { c 467 mail/ngx_mail_proxy_module.c ngx_connection_t *c; c 475 mail/ngx_mail_proxy_module.c c = rev->data; c 476 mail/ngx_mail_proxy_module.c s = c->data; c 479 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 481 mail/ngx_mail_proxy_module.c c->timedout = 1; c 507 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 544 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 576 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 600 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 620 mail/ngx_mail_proxy_module.c line.data = ngx_pnalloc(c->pool, line.len); c 650 mail/ngx_mail_proxy_module.c c->write->handler = ngx_mail_proxy_handler; c 654 mail/ngx_mail_proxy_module.c ngx_del_timer(c->read); c 656 mail/ngx_mail_proxy_module.c c->log->action = NULL; c 657 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, 0, "client logged in"); c 670 mail/ngx_mail_proxy_module.c if (c->send(c, line.data, line.len) < (ssize_t) line.len) { c 687 mail/ngx_mail_proxy_module.c ngx_connection_t *c; c 693 mail/ngx_mail_proxy_module.c c = wev->data; c 694 mail/ngx_mail_proxy_module.c s = c->data; c 843 mail/ngx_mail_proxy_module.c ngx_connection_t *c, *src, *dst; c 847 mail/ngx_mail_proxy_module.c c = ev->data; c 848 mail/ngx_mail_proxy_module.c s = c->data; c 851 mail/ngx_mail_proxy_module.c c->log->action = "proxying"; c 853 mail/ngx_mail_proxy_module.c if (c == s->connection) { c 854 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 856 mail/ngx_mail_proxy_module.c c->timedout = 1; c 859 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, c 867 mail/ngx_mail_proxy_module.c if (c == s->connection) { c 872 mail/ngx_mail_proxy_module.c dst = c; c 878 mail/ngx_mail_proxy_module.c src = c; c 888 mail/ngx_mail_proxy_module.c dst = c; c 894 mail/ngx_mail_proxy_module.c src = c; c 913 mail/ngx_mail_proxy_module.c c->log->action = send_action; c 936 mail/ngx_mail_proxy_module.c c->log->action = recv_action; c 959 mail/ngx_mail_proxy_module.c c->log->action = "proxying"; c 967 mail/ngx_mail_proxy_module.c action = c->log->action; c 968 mail/ngx_mail_proxy_module.c c->log->action = NULL; c 969 mail/ngx_mail_proxy_module.c ngx_log_error(NGX_LOG_INFO, c->log, 0, "proxied session done"); c 970 mail/ngx_mail_proxy_module.c c->log->action = action; c 996 mail/ngx_mail_proxy_module.c if (c == s->connection) { c 998 mail/ngx_mail_proxy_module.c ngx_add_timer(c->read, pcf->timeout); c 17 mail/ngx_mail_smtp_handler.c static void ngx_mail_smtp_greeting(ngx_mail_session_t *s, ngx_connection_t *c); c 20 mail/ngx_mail_smtp_handler.c ngx_connection_t *c); c 22 mail/ngx_mail_smtp_handler.c static ngx_int_t ngx_mail_smtp_helo(ngx_mail_session_t *s, ngx_connection_t *c); c 23 mail/ngx_mail_smtp_handler.c static ngx_int_t ngx_mail_smtp_auth(ngx_mail_session_t *s, ngx_connection_t *c); c 24 mail/ngx_mail_smtp_handler.c static ngx_int_t ngx_mail_smtp_mail(ngx_mail_session_t *s, ngx_connection_t *c); c 26 mail/ngx_mail_smtp_handler.c ngx_connection_t *c); c 27 mail/ngx_mail_smtp_handler.c static ngx_int_t ngx_mail_smtp_rset(ngx_mail_session_t *s, ngx_connection_t *c); c 28 mail/ngx_mail_smtp_handler.c static ngx_int_t ngx_mail_smtp_rcpt(ngx_mail_session_t *s, ngx_connection_t *c); c 31 mail/ngx_mail_smtp_handler.c ngx_connection_t *c, char *err); c 33 mail/ngx_mail_smtp_handler.c ngx_connection_t *c, char *err); c 55 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_init_session(ngx_mail_session_t *s, ngx_connection_t *c) c 65 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_greeting(s, c); c 69 mail/ngx_mail_smtp_handler.c if (c->sockaddr->sa_family != AF_INET) { c 71 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_greeting(s, c); c 75 mail/ngx_mail_smtp_handler.c c->log->action = "in resolving client address"; c 79 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 85 mail/ngx_mail_smtp_handler.c sin = (struct sockaddr_in *) c->sockaddr; c 93 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 101 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 105 mail/ngx_mail_smtp_handler.c c = s->connection; c 108 mail/ngx_mail_smtp_handler.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 110 mail/ngx_mail_smtp_handler.c &c->addr_text, ctx->state, c 127 mail/ngx_mail_smtp_handler.c c->log->action = "in resolving client hostname"; c 129 mail/ngx_mail_smtp_handler.c s->host.data = ngx_pstrdup(c->pool, &ctx->name); c 132 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 140 mail/ngx_mail_smtp_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 143 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_resolve_name; c 145 mail/ngx_mail_smtp_handler.c ngx_post_event(c->read, &ngx_posted_events); c 152 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 157 mail/ngx_mail_smtp_handler.c c = rev->data; c 158 mail/ngx_mail_smtp_handler.c s = c->data; c 164 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 175 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 185 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 190 mail/ngx_mail_smtp_handler.c c = s->connection; c 193 mail/ngx_mail_smtp_handler.c ngx_log_error(NGX_LOG_ERR, c->log, 0, c 209 mail/ngx_mail_smtp_handler.c sin = (struct sockaddr_in *) c->sockaddr; c 215 mail/ngx_mail_smtp_handler.c ngx_log_debug4(NGX_LOG_DEBUG_MAIL, c->log, 0, c 234 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_greeting(s, c); c 239 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_greeting(ngx_mail_session_t *s, ngx_connection_t *c) c 245 mail/ngx_mail_smtp_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 252 mail/ngx_mail_smtp_handler.c ngx_add_timer(c->read, timeout); c 254 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 255 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 259 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_invalid_pipelining; c 263 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_init_protocol; c 267 mail/ngx_mail_smtp_handler.c ngx_mail_send(c->write); c 274 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 279 mail/ngx_mail_smtp_handler.c c = rev->data; c 280 mail/ngx_mail_smtp_handler.c s = c->data; c 282 mail/ngx_mail_smtp_handler.c c->log->action = "in delay pipelining state"; c 286 mail/ngx_mail_smtp_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "delay greeting"); c 292 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_init_protocol; c 294 mail/ngx_mail_smtp_handler.c ngx_add_timer(c->read, cscf->timeout); c 296 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 297 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 307 mail/ngx_mail_smtp_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "invalid pipelining"); c 310 mail/ngx_mail_smtp_handler.c if (ngx_mail_smtp_create_buffer(s, c) != NGX_OK) { c 315 mail/ngx_mail_smtp_handler.c if (ngx_mail_smtp_discard_command(s, c, c 325 mail/ngx_mail_smtp_handler.c ngx_mail_send(c->write); c 332 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 335 mail/ngx_mail_smtp_handler.c c = rev->data; c 337 mail/ngx_mail_smtp_handler.c c->log->action = "in auth state"; c 340 mail/ngx_mail_smtp_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 341 mail/ngx_mail_smtp_handler.c c->timedout = 1; c 342 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 346 mail/ngx_mail_smtp_handler.c s = c->data; c 349 mail/ngx_mail_smtp_handler.c if (ngx_mail_smtp_create_buffer(s, c) != NGX_OK) { c 355 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_smtp_auth_state; c 362 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_create_buffer(ngx_mail_session_t *s, ngx_connection_t *c) c 366 mail/ngx_mail_smtp_handler.c if (ngx_array_init(&s->args, c->pool, 2, sizeof(ngx_str_t)) == NGX_ERROR) { c 373 mail/ngx_mail_smtp_handler.c s->buffer = ngx_create_temp_buf(c->pool, sscf->client_buffer_size); c 387 mail/ngx_mail_smtp_handler.c ngx_connection_t *c; c 390 mail/ngx_mail_smtp_handler.c c = rev->data; c 391 mail/ngx_mail_smtp_handler.c s = c->data; c 393 mail/ngx_mail_smtp_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "smtp auth state"); c 396 mail/ngx_mail_smtp_handler.c ngx_log_error(NGX_LOG_INFO, c->log, NGX_ETIMEDOUT, "client timed out"); c 397 mail/ngx_mail_smtp_handler.c c->timedout = 1; c 398 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 403 mail/ngx_mail_smtp_handler.c ngx_log_debug0(NGX_LOG_DEBUG_MAIL, c->log, 0, "smtp send handler busy"); c 410 mail/ngx_mail_smtp_handler.c rc = ngx_mail_read_command(s, c); c 427 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_helo(s, c); c 431 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_auth(s, c); c 440 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_mail(s, c); c 444 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_rcpt(s, c); c 448 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_rset(s, c); c 455 mail/ngx_mail_smtp_handler.c rc = ngx_mail_smtp_starttls(s, c); c 467 mail/ngx_mail_smtp_handler.c rc = ngx_mail_auth_login_username(s, c, 0); c 474 mail/ngx_mail_smtp_handler.c rc = ngx_mail_auth_login_password(s, c); c 478 mail/ngx_mail_smtp_handler.c rc = ngx_mail_auth_plain(s, c, 0); c 482 mail/ngx_mail_smtp_handler.c rc = ngx_mail_auth_cram_md5(s, c); c 490 mail/ngx_mail_smtp_handler.c ngx_mail_auth(s, c); c 513 mail/ngx_mail_smtp_handler.c ngx_mail_send(c->write); c 519 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_helo(ngx_mail_session_t *s, ngx_connection_t *c) c 534 mail/ngx_mail_smtp_handler.c s->smtp_helo.data = ngx_pnalloc(c->pool, arg[0].len); c 554 mail/ngx_mail_smtp_handler.c if (c->ssl == NULL) { c 579 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_auth(ngx_mail_session_t *s, ngx_connection_t *c) c 586 mail/ngx_mail_smtp_handler.c if (ngx_mail_starttls_only(s, c)) { c 597 mail/ngx_mail_smtp_handler.c rc = ngx_mail_auth_parse(s, c); c 613 mail/ngx_mail_smtp_handler.c return ngx_mail_auth_login_username(s, c, 1); c 633 mail/ngx_mail_smtp_handler.c if (ngx_mail_salt(s, c, cscf) != NGX_OK) { c 638 mail/ngx_mail_smtp_handler.c if (ngx_mail_auth_cram_md5_salt(s, c, "334 ", 4) == NGX_OK) { c 651 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_mail(ngx_mail_session_t *s, ngx_connection_t *c) c 661 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_log_rejected_command(s, c, "client was rejected: \"%V\""); c 698 mail/ngx_mail_smtp_handler.c s->smtp_from.data = ngx_pnalloc(c->pool, l.len); c 705 mail/ngx_mail_smtp_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 715 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_rcpt(ngx_mail_session_t *s, ngx_connection_t *c) c 751 mail/ngx_mail_smtp_handler.c s->smtp_to.data = ngx_pnalloc(c->pool, l.len); c 758 mail/ngx_mail_smtp_handler.c ngx_log_debug1(NGX_LOG_DEBUG_MAIL, c->log, 0, c 768 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_rset(ngx_mail_session_t *s, ngx_connection_t *c) c 779 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_starttls(ngx_mail_session_t *s, ngx_connection_t *c) c 784 mail/ngx_mail_smtp_handler.c if (c->ssl == NULL) { c 797 mail/ngx_mail_smtp_handler.c c->read->handler = ngx_mail_starttls_handler; c 809 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_discard_command(ngx_mail_session_t *s, ngx_connection_t *c, c 814 mail/ngx_mail_smtp_handler.c n = c->recv(c, s->buffer->last, s->buffer->end - s->buffer->last); c 817 mail/ngx_mail_smtp_handler.c ngx_mail_close_connection(c); c 826 mail/ngx_mail_smtp_handler.c if (ngx_handle_read_event(c->read, 0) != NGX_OK) { c 834 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_log_rejected_command(s, c, err); c 844 mail/ngx_mail_smtp_handler.c ngx_mail_smtp_log_rejected_command(ngx_mail_session_t *s, ngx_connection_t *c, c 851 mail/ngx_mail_smtp_handler.c if (c->log->log_level < NGX_LOG_INFO) { c 870 mail/ngx_mail_smtp_handler.c ngx_log_error(NGX_LOG_INFO, c->log, 0, err, &cmd); c 143 mail/ngx_mail_smtp_module.c ngx_str_t *c; c 199 mail/ngx_mail_smtp_module.c c = conf->capabilities.elts; c 201 mail/ngx_mail_smtp_module.c size += sizeof("250 ") - 1 + c[i].len + sizeof(CRLF) - 1; c 237 mail/ngx_mail_smtp_module.c p = ngx_cpymem(p, c[i].data, c[i].len); c 35 mail/ngx_mail_smtp_module.h void ngx_mail_smtp_init_session(ngx_mail_session_t *s, ngx_connection_t *c); c 16 os/unix/ngx_aio_read.c ngx_aio_read(ngx_connection_t *c, u_char *buf, size_t size) c 21 os/unix/ngx_aio_read.c rev = c->read; c 24 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, "second aio post"); c 28 os/unix/ngx_aio_read.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 30 os/unix/ngx_aio_read.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 36 os/unix/ngx_aio_read.c rev->aiocb.aio_fildes = c->fd; c 53 os/unix/ngx_aio_read.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 54 os/unix/ngx_aio_read.c "aio_read: #%d OK", c->fd); c 64 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, "aio_error() failed"); c 72 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_ALERT, c->log, n, c 79 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_CRIT, c->log, n, "aio_read() failed"); c 87 os/unix/ngx_aio_read.c ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno, c 96 os/unix/ngx_aio_read.c "aio_read: #%d %d", c->fd, n); c 13 os/unix/ngx_aio_read_chain.c ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl) c 20 os/unix/ngx_aio_read_chain.c if (c->read->pending_eof) { c 21 os/unix/ngx_aio_read_chain.c c->read->ready = 0; c 31 os/unix/ngx_aio_read_chain.c if (!c->read->ready) { c 47 os/unix/ngx_aio_read_chain.c n = ngx_aio_read(c, buf, size); c 49 os/unix/ngx_aio_read_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_read: %d", n); c 60 os/unix/ngx_aio_read_chain.c c->read->pending_eof = 1; c 62 os/unix/ngx_aio_read_chain.c c->read->eof = 0; c 63 os/unix/ngx_aio_read_chain.c c->read->ready = 1; c 72 os/unix/ngx_aio_read_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 16 os/unix/ngx_aio_write.c ngx_aio_write(ngx_connection_t *c, u_char *buf, size_t size) c 21 os/unix/ngx_aio_write.c wev = c->write; c 33 os/unix/ngx_aio_write.c wev->aiocb.aio_fildes = c->fd; c 13 os/unix/ngx_aio_write_chain.c ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 40 os/unix/ngx_aio_write_chain.c if (!c->write->ready) { c 67 os/unix/ngx_aio_write_chain.c n = ngx_aio_write(c, buf, len); c 69 os/unix/ngx_aio_write_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "aio_write: %z", n); c 77 os/unix/ngx_aio_write_chain.c c->sent += n; c 80 os/unix/ngx_aio_write_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, c 81 os/unix/ngx_aio_write_chain.c "aio_write sent: %O", c->sent); c 200 os/unix/ngx_channel.c ngx_connection_t *c; c 202 os/unix/ngx_channel.c c = ngx_get_connection(fd, cycle->log); c 204 os/unix/ngx_channel.c if (c == NULL) { c 208 os/unix/ngx_channel.c c->pool = cycle->pool; c 210 os/unix/ngx_channel.c rev = c->read; c 211 os/unix/ngx_channel.c wev = c->write; c 217 os/unix/ngx_channel.c rev->lock = &c->lock; c 218 os/unix/ngx_channel.c wev->lock = &c->lock; c 219 os/unix/ngx_channel.c rev->own_lock = &c->lock; c 220 os/unix/ngx_channel.c wev->own_lock = &c->lock; c 231 os/unix/ngx_channel.c if (ngx_add_conn(c) == NGX_ERROR) { c 232 os/unix/ngx_channel.c ngx_free_connection(c); c 238 os/unix/ngx_channel.c ngx_free_connection(c); c 11 os/unix/ngx_darwin.h ngx_chain_t *ngx_darwin_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, c 39 os/unix/ngx_darwin_sendfile_chain.c ngx_darwin_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 54 os/unix/ngx_darwin_sendfile_chain.c wev = c->write; c 63 os/unix/ngx_darwin_sendfile_chain.c (void) ngx_connection_error(c, wev->kq_errno, c 82 os/unix/ngx_darwin_sendfile_chain.c header.pool = c->pool; c 87 os/unix/ngx_darwin_sendfile_chain.c trailer.pool = c->pool; c 230 os/unix/ngx_darwin_sendfile_chain.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 234 os/unix/ngx_darwin_sendfile_chain.c rc = sendfile(file->file->fd, c->fd, file->file_pos, c 250 os/unix/ngx_darwin_sendfile_chain.c (void) ngx_connection_error(c, err, "sendfile() failed"); c 254 os/unix/ngx_darwin_sendfile_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, err, c 266 os/unix/ngx_darwin_sendfile_chain.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 273 os/unix/ngx_darwin_sendfile_chain.c ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0, c 278 os/unix/ngx_darwin_sendfile_chain.c rc = writev(c->fd, header.elts, header.nelts); c 280 os/unix/ngx_darwin_sendfile_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 296 os/unix/ngx_darwin_sendfile_chain.c ngx_connection_error(c, err, "writev() failed"); c 300 os/unix/ngx_darwin_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 311 os/unix/ngx_darwin_sendfile_chain.c c->sent += sent; c 183 os/unix/ngx_files.h #define ngx_path_separator(c) ((c) == '/') c 11 os/unix/ngx_freebsd.h ngx_chain_t *ngx_freebsd_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, c 41 os/unix/ngx_freebsd_sendfile_chain.c ngx_freebsd_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 56 os/unix/ngx_freebsd_sendfile_chain.c wev = c->write; c 65 os/unix/ngx_freebsd_sendfile_chain.c (void) ngx_connection_error(c, wev->kq_errno, c 86 os/unix/ngx_freebsd_sendfile_chain.c header.pool = c->pool; c 91 os/unix/ngx_freebsd_sendfile_chain.c trailer.pool = c->pool; c 224 os/unix/ngx_freebsd_sendfile_chain.c && c->tcp_nopush == NGX_TCP_NOPUSH_UNSET) c 226 os/unix/ngx_freebsd_sendfile_chain.c if (ngx_tcp_nopush(c->fd) == NGX_ERROR) { c 236 os/unix/ngx_freebsd_sendfile_chain.c (void) ngx_connection_error(c, err, c 242 os/unix/ngx_freebsd_sendfile_chain.c c->tcp_nopush = NGX_TCP_NOPUSH_SET; c 244 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, c 266 os/unix/ngx_freebsd_sendfile_chain.c flags = c->aio_sendfile ? SF_NODISKIO : 0; c 269 os/unix/ngx_freebsd_sendfile_chain.c rc = sendfile(file->file->fd, c->fd, file->file_pos, c 286 os/unix/ngx_freebsd_sendfile_chain.c c->busy_sendfile = file; c 292 os/unix/ngx_freebsd_sendfile_chain.c (void) ngx_connection_error(c, err, "sendfile() failed"); c 296 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, err, c 312 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 319 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0, c 324 os/unix/ngx_freebsd_sendfile_chain.c rc = writev(c->fd, header.elts, header.nelts); c 326 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 342 os/unix/ngx_freebsd_sendfile_chain.c ngx_connection_error(c, err, "writev() failed"); c 346 os/unix/ngx_freebsd_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 357 os/unix/ngx_freebsd_sendfile_chain.c c->sent += sent; c 397 os/unix/ngx_freebsd_sendfile_chain.c if (c->busy_sendfile) { c 11 os/unix/ngx_linux.h ngx_chain_t *ngx_linux_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, c 37 os/unix/ngx_linux_sendfile_chain.c ngx_linux_sendfile_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 56 os/unix/ngx_linux_sendfile_chain.c wev = c->write; c 75 os/unix/ngx_linux_sendfile_chain.c header.pool = c->pool; c 101 os/unix/ngx_linux_sendfile_chain.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 149 os/unix/ngx_linux_sendfile_chain.c if (c->tcp_nopush == NGX_TCP_NOPUSH_UNSET c 156 os/unix/ngx_linux_sendfile_chain.c if (c->tcp_nodelay == NGX_TCP_NODELAY_SET) { c 160 os/unix/ngx_linux_sendfile_chain.c if (setsockopt(c->fd, IPPROTO_TCP, TCP_NODELAY, c 173 os/unix/ngx_linux_sendfile_chain.c ngx_connection_error(c, err, c 179 os/unix/ngx_linux_sendfile_chain.c c->tcp_nodelay = NGX_TCP_NODELAY_UNSET; c 181 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, c 186 os/unix/ngx_linux_sendfile_chain.c if (c->tcp_nodelay == NGX_TCP_NODELAY_UNSET) { c 188 os/unix/ngx_linux_sendfile_chain.c if (ngx_tcp_nopush(c->fd) == NGX_ERROR) { c 198 os/unix/ngx_linux_sendfile_chain.c ngx_connection_error(c, err, c 204 os/unix/ngx_linux_sendfile_chain.c c->tcp_nopush = NGX_TCP_NOPUSH_SET; c 206 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, 0, c 258 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 261 os/unix/ngx_linux_sendfile_chain.c rc = sendfile(c->fd, file->file->fd, &offset, file_size); c 276 os/unix/ngx_linux_sendfile_chain.c ngx_connection_error(c, err, "sendfile() failed"); c 280 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 286 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug4(NGX_LOG_DEBUG_EVENT, c->log, 0, c 291 os/unix/ngx_linux_sendfile_chain.c rc = writev(c->fd, header.elts, header.nelts); c 306 os/unix/ngx_linux_sendfile_chain.c ngx_connection_error(c, err, "writev() failed"); c 310 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 316 os/unix/ngx_linux_sendfile_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "writev: %O", sent); c 323 os/unix/ngx_linux_sendfile_chain.c c->sent += sent; c 18 os/unix/ngx_os.h typedef ssize_t (*ngx_recv_pt)(ngx_connection_t *c, u_char *buf, size_t size); c 19 os/unix/ngx_os.h typedef ssize_t (*ngx_recv_chain_pt)(ngx_connection_t *c, ngx_chain_t *in); c 20 os/unix/ngx_os.h typedef ssize_t (*ngx_send_pt)(ngx_connection_t *c, u_char *buf, size_t size); c 21 os/unix/ngx_os.h typedef ngx_chain_t *(*ngx_send_chain_pt)(ngx_connection_t *c, ngx_chain_t *in, c 43 os/unix/ngx_os.h ssize_t ngx_unix_recv(ngx_connection_t *c, u_char *buf, size_t size); c 44 os/unix/ngx_os.h ssize_t ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *entry); c 45 os/unix/ngx_os.h ssize_t ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size); c 46 os/unix/ngx_os.h ssize_t ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size); c 47 os/unix/ngx_os.h ngx_chain_t *ngx_writev_chain(ngx_connection_t *c, ngx_chain_t *in, c 51 os/unix/ngx_os.h ssize_t ngx_aio_read(ngx_connection_t *c, u_char *buf, size_t size); c 52 os/unix/ngx_os.h ssize_t ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl); c 53 os/unix/ngx_os.h ssize_t ngx_aio_write(ngx_connection_t *c, u_char *buf, size_t size); c 54 os/unix/ngx_os.h ngx_chain_t *ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in, c 720 os/unix/ngx_process_cycle.c ngx_connection_t *c; c 778 os/unix/ngx_process_cycle.c c = cycle->connections; c 784 os/unix/ngx_process_cycle.c if (c[i].fd != -1 && c[i].idle) { c 785 os/unix/ngx_process_cycle.c c[i].close = 1; c 786 os/unix/ngx_process_cycle.c c[i].read->handler(c[i].read); c 1012 os/unix/ngx_process_cycle.c ngx_connection_t *c; c 1027 os/unix/ngx_process_cycle.c c = cycle->connections; c 1029 os/unix/ngx_process_cycle.c if (c[i].fd != -1 c 1030 os/unix/ngx_process_cycle.c && c[i].read c 1031 os/unix/ngx_process_cycle.c && !c[i].read->accept c 1032 os/unix/ngx_process_cycle.c && !c[i].read->channel c 1033 os/unix/ngx_process_cycle.c && !c[i].read->resolver) c 1037 os/unix/ngx_process_cycle.c c[i].fd, i); c 1076 os/unix/ngx_process_cycle.c ngx_connection_t *c; c 1083 os/unix/ngx_process_cycle.c c = ev->data; c 1089 os/unix/ngx_process_cycle.c n = ngx_read_channel(c->fd, &ch, sizeof(ngx_channel_t), ev->log); c 1096 os/unix/ngx_process_cycle.c ngx_del_conn(c, 0); c 1099 os/unix/ngx_process_cycle.c ngx_close_connection(c); c 18 os/unix/ngx_readv_chain.c ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *chain) c 27 os/unix/ngx_readv_chain.c rev = c->read; c 30 os/unix/ngx_readv_chain.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 39 os/unix/ngx_readv_chain.c ngx_log_error(NGX_LOG_INFO, c->log, rev->kq_errno, c 64 os/unix/ngx_readv_chain.c vec.pool = c->pool; c 87 os/unix/ngx_readv_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 90 os/unix/ngx_readv_chain.c rev = c->read; c 93 os/unix/ngx_readv_chain.c n = readv(c->fd, (struct iovec *) vec.elts, vec.nelts); c 122 os/unix/ngx_readv_chain.c ngx_log_error(NGX_LOG_ALERT, c->log, 0, c 148 os/unix/ngx_readv_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 153 os/unix/ngx_readv_chain.c n = ngx_connection_error(c, err, "readv() failed"); c 162 os/unix/ngx_readv_chain.c c->read->error = 1; c 171 os/unix/ngx_readv_chain.c ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *chain) c 188 os/unix/ngx_readv_chain.c vec.pool = c->pool; c 211 os/unix/ngx_readv_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 214 os/unix/ngx_readv_chain.c rev = c->read; c 217 os/unix/ngx_readv_chain.c n = readv(c->fd, (struct iovec *) vec.elts, vec.nelts); c 237 os/unix/ngx_readv_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 242 os/unix/ngx_readv_chain.c n = ngx_connection_error(c, err, "readv() failed"); c 251 os/unix/ngx_readv_chain.c c->read->error = 1; c 15 os/unix/ngx_recv.c ngx_unix_recv(ngx_connection_t *c, u_char *buf, size_t size) c 21 os/unix/ngx_recv.c rev = c->read; c 24 os/unix/ngx_recv.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 37 os/unix/ngx_recv.c return ngx_connection_error(c, rev->kq_errno, c 51 os/unix/ngx_recv.c n = recv(c->fd, buf, size, 0); c 53 os/unix/ngx_recv.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 54 os/unix/ngx_recv.c "recv: fd:%d %d of %d", c->fd, n, size); c 103 os/unix/ngx_recv.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 108 os/unix/ngx_recv.c n = ngx_connection_error(c, err, "recv() failed"); c 126 os/unix/ngx_recv.c ngx_unix_recv(ngx_connection_t *c, u_char *buf, size_t size) c 132 os/unix/ngx_recv.c rev = c->read; c 135 os/unix/ngx_recv.c n = recv(c->fd, buf, size, 0); c 137 os/unix/ngx_recv.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 138 os/unix/ngx_recv.c "recv: fd:%d %d of %d", c->fd, n, size); c 159 os/unix/ngx_recv.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 164 os/unix/ngx_recv.c n = ngx_connection_error(c, err, "recv() failed"); c 13 os/unix/ngx_send.c ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size) c 19 os/unix/ngx_send.c wev = c->write; c 24 os/unix/ngx_send.c (void) ngx_connection_error(c, wev->kq_errno, c 33 os/unix/ngx_send.c n = send(c->fd, buf, size, 0); c 35 os/unix/ngx_send.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 36 os/unix/ngx_send.c "send: fd:%d %d of %d", c->fd, n, size); c 43 os/unix/ngx_send.c c->sent += n; c 51 os/unix/ngx_send.c ngx_log_error(NGX_LOG_ALERT, c->log, err, "send() returned zero"); c 59 os/unix/ngx_send.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 68 os/unix/ngx_send.c (void) ngx_connection_error(c, err, "send() failed"); c 11 os/unix/ngx_solaris.h ngx_chain_t *ngx_solaris_sendfilev_chain(ngx_connection_t *c, ngx_chain_t *in, c 43 os/unix/ngx_solaris_sendfilev_chain.c ngx_solaris_sendfilev_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 57 os/unix/ngx_solaris_sendfilev_chain.c wev = c->write; c 63 os/unix/ngx_solaris_sendfilev_chain.c if (!c->sendfile) { c 64 os/unix/ngx_solaris_sendfilev_chain.c return ngx_writev_chain(c, in, limit); c 81 os/unix/ngx_solaris_sendfilev_chain.c vec.pool = c->pool; c 166 os/unix/ngx_solaris_sendfilev_chain.c n = sendfilev(c->fd, vec.elts, vec.nelts, &sent); c 181 os/unix/ngx_solaris_sendfilev_chain.c ngx_connection_error(c, err, "sendfilev() failed"); c 185 os/unix/ngx_solaris_sendfilev_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, err, c 189 os/unix/ngx_solaris_sendfilev_chain.c ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, c 196 os/unix/ngx_solaris_sendfilev_chain.c c->sent += sent; c 15 os/unix/ngx_udp_recv.c ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size) c 21 os/unix/ngx_udp_recv.c rev = c->read; c 24 os/unix/ngx_udp_recv.c n = recv(c->fd, buf, size, 0); c 26 os/unix/ngx_udp_recv.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 27 os/unix/ngx_udp_recv.c "recv: fd:%d %d of %d", c->fd, n, size); c 50 os/unix/ngx_udp_recv.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 55 os/unix/ngx_udp_recv.c n = ngx_connection_error(c, err, "recv() failed"); c 73 os/unix/ngx_udp_recv.c ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size) c 79 os/unix/ngx_udp_recv.c rev = c->read; c 82 os/unix/ngx_udp_recv.c n = recv(c->fd, buf, size, 0); c 84 os/unix/ngx_udp_recv.c ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, c 85 os/unix/ngx_udp_recv.c "recv: fd:%d %d of %d", c->fd, n, size); c 94 os/unix/ngx_udp_recv.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 99 os/unix/ngx_udp_recv.c n = ngx_connection_error(c, err, "recv() failed"); c 20 os/unix/ngx_writev_chain.c ngx_writev_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) c 32 os/unix/ngx_writev_chain.c wev = c->write; c 41 os/unix/ngx_writev_chain.c (void) ngx_connection_error(c, wev->kq_errno, c 61 os/unix/ngx_writev_chain.c vec.pool = c->pool; c 108 os/unix/ngx_writev_chain.c n = writev(c->fd, vec.elts, vec.nelts); c 123 os/unix/ngx_writev_chain.c (void) ngx_connection_error(c, err, "writev() failed"); c 127 os/unix/ngx_writev_chain.c ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, c 133 os/unix/ngx_writev_chain.c ngx_log_debug1(NGX_LOG_DEBUG_EVENT, c->log, 0, "writev: %z", sent); c 139 os/unix/ngx_writev_chain.c c->sent += sent;