nxt_port_socket.c (430:3a24c399394f) nxt_port_socket.c (521:93dc4a28dd37)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

859 }
860
861 wq = &task->thread->engine->fast_work_queue;
862
863 nxt_thread_mutex_lock(&port->write_mutex);
864
865 nxt_queue_each(msg, &port->messages, nxt_port_send_msg_t, link) {
866
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

859 }
860
861 wq = &task->thread->engine->fast_work_queue;
862
863 nxt_thread_mutex_lock(&port->write_mutex);
864
865 nxt_queue_each(msg, &port->messages, nxt_port_send_msg_t, link) {
866
867 for(b = msg->buf; b != NULL; b = b->next) {
867 for (b = msg->buf; b != NULL; b = b->next) {
868 if (nxt_buf_is_sync(b)) {
869 continue;
870 }
871
872 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent);
873 }
874
875 nxt_queue_remove(&msg->link);

--- 12 unchanged lines hidden ---
868 if (nxt_buf_is_sync(b)) {
869 continue;
870 }
871
872 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent);
873 }
874
875 nxt_queue_remove(&msg->link);

--- 12 unchanged lines hidden ---