nxt_router.c (167:06ebbe0a5c07) nxt_router.c (174:9585902ff351)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_router.h>

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

1925 nxt_buf_chain_add(&c->write, b);
1926 }
1927}
1928
1929
1930static void
1931nxt_router_send_sw_request(nxt_task_t *task, void *obj, void *data)
1932{
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_router.h>

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

1925 nxt_buf_chain_add(&c->write, b);
1926 }
1927}
1928
1929
1930static void
1931nxt_router_send_sw_request(nxt_task_t *task, void *obj, void *data)
1932{
1933 size_t size;
1933 nxt_buf_t *b;
1934 nxt_app_t *app;
1935 nxt_port_t *port;
1936 nxt_runtime_t *rt;
1937 nxt_start_worker_t *sw;
1938
1939 sw = obj;
1940 app = sw->app;

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

1956
1957 nxt_debug(task, "sw #%uxD send", sw->stream);
1958
1959 nxt_router_sw_add(task, nxt_router, sw);
1960
1961 rt = task->thread->runtime;
1962 port = rt->port_by_type[NXT_PROCESS_MASTER];
1963
1934 nxt_buf_t *b;
1935 nxt_app_t *app;
1936 nxt_port_t *port;
1937 nxt_runtime_t *rt;
1938 nxt_start_worker_t *sw;
1939
1940 sw = obj;
1941 app = sw->app;

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

1957
1958 nxt_debug(task, "sw #%uxD send", sw->stream);
1959
1960 nxt_router_sw_add(task, nxt_router, sw);
1961
1962 rt = task->thread->runtime;
1963 port = rt->port_by_type[NXT_PROCESS_MASTER];
1964
1964 b = nxt_buf_mem_alloc(port->mem_pool, app->conf.length, 0);
1965 size = app->name.length + 1 + app->conf.length;
1965
1966
1967 b = nxt_buf_mem_alloc(port->mem_pool, size, 0);
1968
1969 nxt_buf_cpystr(b, &app->name);
1970 *b->mem.free++ = '\0';
1966 nxt_buf_cpystr(b, &app->conf);
1967
1968 nxt_port_socket_write(task, port, NXT_PORT_MSG_DATA, -1, sw->stream, 0, b);
1969}
1970
1971
1972static nxt_bool_t
1973nxt_router_app_free(nxt_task_t *task, nxt_app_t *app)

--- 707 unchanged lines hidden ---
1971 nxt_buf_cpystr(b, &app->conf);
1972
1973 nxt_port_socket_write(task, port, NXT_PORT_MSG_DATA, -1, sw->stream, 0, b);
1974}
1975
1976
1977static nxt_bool_t
1978nxt_router_app_free(nxt_task_t *task, nxt_app_t *app)

--- 707 unchanged lines hidden ---