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