791d790 < nxt_mp_t *mp; 827,832d825 < mp = nxt_mp_create(1024, 128, 256, 32); < if (nxt_slow_path(mp == NULL)) { < return NXT_ERROR; < } < < port->mem_pool = mp; 1443a1437,1438 > nxt_mp_t *port_mp; > nxt_int_t res; 1468a1464 > 1478a1475,1477 > port_mp = port->mem_pool; > port->mem_pool = c->mem_pool; > 1483c1482,1488 < (void) nxt_port_send_port(task, port, engine->port); --- > res = nxt_port_send_port(task, port, engine->port); > > if (nxt_slow_path(res != NXT_OK)) { > // 500 Failed to send reply port > nxt_log_alert(task->log, "failed to send reply port to application"); > } > 1492c1497 < (void)nxt_app->prepare_msg(task, &ap->r, &wmsg); --- > res = nxt_app->prepare_msg(task, &ap->r, &wmsg); 1493a1499,1503 > if (nxt_slow_path(res != NXT_OK)) { > // 500 Failed to prepare message > nxt_log_alert(task->log, "failed to prepare message for application"); > } > 1498c1508 < (void) nxt_port_socket_write(task, wmsg.port, NXT_PORT_MSG_DATA, --- > res = nxt_port_socket_write(task, wmsg.port, NXT_PORT_MSG_DATA, 1499a1510,1516 > > if (nxt_slow_path(res != NXT_OK)) { > // 500 Failed to send message > nxt_log_alert(task->log, "failed to send message to application"); > } > > port->mem_pool = port_mp; 1600c1617,1619 < nxt_mp_destroy(c->mem_pool); --- > nxt_queue_remove(&c->link); > > nxt_mp_release(c->mem_pool, c);