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