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

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

154 nxt_debug(task, "current thread is %PT, expected %PT",
155 task->thread->tid, engine->task.thread->tid);
156
157 nxt_event_engine_post(engine, &msg->work);
158
159 return;
160 }
161
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

154 nxt_debug(task, "current thread is %PT, expected %PT",
155 task->thread->tid, engine->task.thread->tid);
156
157 nxt_event_engine_post(engine, &msg->work);
158
159 return;
160 }
161
162 nxt_mp_release(engine->mem_pool, obj);
162 nxt_mp_free(engine->mem_pool, obj);
163 nxt_mp_release(engine->mem_pool);
163}
164
165
166static nxt_port_send_msg_t *
167nxt_port_msg_create(nxt_task_t *task, nxt_port_send_msg_t *m)
168{
164}
165
166
167static nxt_port_send_msg_t *
168nxt_port_msg_create(nxt_task_t *task, nxt_port_send_msg_t *m)
169{
170 nxt_mp_t *mp;
169 nxt_port_send_msg_t *msg;
170
171 nxt_port_send_msg_t *msg;
172
171 msg = nxt_mp_retain(task->thread->engine->mem_pool,
172 sizeof(nxt_port_send_msg_t));
173 mp = task->thread->engine->mem_pool;
174
175 msg = nxt_mp_alloc(mp, sizeof(nxt_port_send_msg_t));
173 if (nxt_slow_path(msg == NULL)) {
174 return NULL;
175 }
176
176 if (nxt_slow_path(msg == NULL)) {
177 return NULL;
178 }
179
180 nxt_mp_retain(mp);
181
177 msg->link.next = NULL;
178 msg->link.prev = NULL;
179
180 msg->buf = m->buf;
181 msg->fd = m->fd;
182 msg->close_fd = m->close_fd;
183 msg->port_msg = m->port_msg;
184

--- 698 unchanged lines hidden ---
182 msg->link.next = NULL;
183 msg->link.prev = NULL;
184
185 msg->buf = m->buf;
186 msg->fd = m->fd;
187 msg->close_fd = m->close_fd;
188 msg->port_msg = m->port_msg;
189

--- 698 unchanged lines hidden ---