Home
last modified time | relevance | path

Searched refs:state (Results 1 – 25 of 57) sorted by relevance

123

/unit/src/
H A Dnxt_tstr.c36 nxt_tstr_state_t *state; member
57 nxt_tstr_state_t *state; in nxt_tstr_state_new() local
60 if (nxt_slow_path(state == NULL)) { in nxt_tstr_state_new()
64 state->pool = mp; in nxt_tstr_state_new()
65 state->test = test; in nxt_tstr_state_new()
73 state->jcf = nxt_js_conf_new(mp, test); in nxt_tstr_state_new()
79 return state; in nxt_tstr_state_new()
182 if (!state->test) { in nxt_tstr_state_done()
185 ret = nxt_js_compile(state->jcf); in nxt_tstr_state_done()
200 nxt_js_conf_release(state->jcf); in nxt_tstr_state_release()
[all …]
H A Dnxt_conn_read.c14 const nxt_conn_state_t *state; in nxt_conn_wait() local
20 state = c->read_state; in nxt_conn_wait()
28 c->socket.read_handler = state->ready_handler; in nxt_conn_wait()
29 c->socket.error_handler = state->error_handler; in nxt_conn_wait()
44 const nxt_conn_state_t *state; in nxt_conn_io_read() local
63 state = c->read_state; in nxt_conn_io_read()
68 if (state->io_read_handler == NULL) { in nxt_conn_io_read()
72 n = state->io_read_handler(task, c); in nxt_conn_io_read()
74 state = c->read_state; in nxt_conn_io_read()
84 if (state->timer_autoreset) { in nxt_conn_io_read()
[all …]
H A Dnxt_http_chunk_parse.c41 } state; in nxt_http_chunk_parse() local
47 state = hcp->state; in nxt_http_chunk_parse()
58 if (state == sw_chunk) { in nxt_http_chunk_parse()
70 state = sw_chunk_end_newline; in nxt_http_chunk_parse()
81 switch (state) { in nxt_http_chunk_parse()
84 state = sw_chunk_size; in nxt_http_chunk_parse()
132 state = sw_chunk; in nxt_http_chunk_parse()
137 state = sw_chunk_end_newline; in nxt_http_chunk_parse()
145 state = sw_chunk_end_linefeed; in nxt_http_chunk_parse()
155 state = sw_start; in nxt_http_chunk_parse()
[all …]
H A Dnxt_conn_connect.c40 const nxt_conn_state_t *state; in nxt_conn_io_connect() local
44 state = c->write_state; in nxt_conn_io_connect()
50 handler = state->ready_handler; in nxt_conn_io_connect()
59 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_conn_io_connect()
65 handler = state->close_handler; in nxt_conn_io_connect()
69 handler = state->error_handler; in nxt_conn_io_connect()
154 const nxt_conn_state_t *state; in nxt_conn_connect_error() local
163 state = c->write_state; in nxt_conn_connect_error()
175 handler = state->close_handler; in nxt_conn_connect_error()
179 handler = state->error_handler; in nxt_conn_connect_error()
H A Dnxt_tstr.h41 nxt_tstr_t *nxt_tstr_compile(nxt_tstr_state_t *state, nxt_str_t *str,
43 nxt_int_t nxt_tstr_test(nxt_tstr_state_t *state, nxt_str_t *str, u_char *error);
44 nxt_int_t nxt_tstr_state_done(nxt_tstr_state_t *state, u_char *error);
45 void nxt_tstr_state_release(nxt_tstr_state_t *state);
51 nxt_tstr_state_t *state, nxt_tstr_cache_t *cache, void *ctx,
H A Dnxt_fd_event.h47 #define nxt_fd_event_is_disabled(state) \ argument
48 ((state) < NXT_EVENT_ONESHOT)
51 #define nxt_fd_event_is_active(state) \ argument
52 ((state) >= NXT_EVENT_ONESHOT)
H A Dnxt_http_parse.c867 } state, saved_state; in nxt_http_parse_complex_target() local
871 state = sw_normal; in nxt_http_parse_complex_target()
892 switch (state) { in nxt_http_parse_complex_target()
903 state = sw_slash; in nxt_http_parse_complex_target()
908 state = sw_quoted; in nxt_http_parse_complex_target()
925 state = sw_normal; in nxt_http_parse_complex_target()
934 state = sw_dot; in nxt_http_parse_complex_target()
964 state = sw_slash; in nxt_http_parse_complex_target()
1027 state = sw_slash; in nxt_http_parse_complex_target()
1117 if (state >= sw_dot) { in nxt_http_parse_complex_target()
[all …]
H A Dnxt_time_parse.c322 } state; in nxt_term_parse() local
339 state = st_first_digit; in nxt_term_parse()
348 if (state == st_space) { in nxt_term_parse()
354 state = st_first_digit; in nxt_term_parse()
357 if (state != st_letter) { in nxt_term_parse()
364 state = st_digit; in nxt_term_parse()
368 if (state == st_first_digit) { in nxt_term_parse()
372 state = st_letter; in nxt_term_parse()
481 state = st_space; in nxt_term_parse()
H A Dnxt_var.c112 nxt_var_ref_get(nxt_tstr_state_t *state, nxt_str_t *name) in nxt_var_ref_get() argument
119 ref = state->var_refs->elts; in nxt_var_ref_get()
121 for (i = 0; i < state->var_refs->nelts; i++) { in nxt_var_ref_get()
128 ref = nxt_array_add(state->var_refs); in nxt_var_ref_get()
133 ref->index = state->var_refs->nelts - 1; in nxt_var_ref_get()
135 ref->name = nxt_str_dup(state->pool, NULL, name); in nxt_var_ref_get()
149 ret = nxt_http_unknown_var_ref(state, ref, name); in nxt_var_ref_get()
213 ref = state->var_refs->elts; in nxt_var_cache_value()
340 var = nxt_mp_get(state->pool, size); in nxt_var_compile()
360 ref = nxt_var_ref_get(state, &part); in nxt_var_compile()
[all …]
H A Dnxt_var.h56 nxt_var_t *nxt_var_compile(nxt_tstr_state_t *state, nxt_str_t *str);
57 nxt_int_t nxt_var_test(nxt_tstr_state_t *state, nxt_str_t *str, u_char *error);
59 nxt_int_t nxt_var_interpreter(nxt_task_t *task, nxt_tstr_state_t *state,
65 nxt_int_t nxt_http_unknown_var_ref(nxt_tstr_state_t *state, nxt_var_ref_t *ref,
H A Dnxt_conn.c106 const nxt_conn_state_t *state, nxt_timer_t *timer) in nxt_conn_timer() argument
110 if (state->timer_value != NULL) { in nxt_conn_timer()
111 value = state->timer_value(c, state->timer_data); in nxt_conn_timer()
114 timer->handler = state->timer_handler; in nxt_conn_timer()
H A Dnxt_string.c366 } state; in nxt_strverscmp() local
368 state = st_str; in nxt_strverscmp()
385 state = st_str; in nxt_strverscmp()
389 if (state == st_str) { in nxt_strverscmp()
390 state = (c1 != '0') ? st_num : st_zero; in nxt_strverscmp()
394 if (state == st_zero && c1 != '0') { in nxt_strverscmp()
395 state = st_frac; in nxt_strverscmp()
400 switch (state) { in nxt_strverscmp()
H A Dnxt_http_proxy.c141 us->state = &nxt_upstream_proxy_state; in nxt_upstream_proxy_handler()
162 us->state->ready(task, us); in nxt_http_proxy_server_get()
175 peer->request->state = &nxt_http_proxy_header_send_state; in nxt_http_proxy_upstream_ready()
210 r->state = &nxt_http_proxy_header_sent_state; in nxt_http_proxy_header_send()
232 r->state = &nxt_http_proxy_header_read_state; in nxt_http_proxy_header_sent()
278 r->state = &nxt_http_proxy_read_state; in nxt_http_proxy_header_read()
H A Dnxt_conf.c1298 } state; in nxt_conf_json_skip_space() local
1300 state = sw_normal; in nxt_conf_json_skip_space()
1305 switch (state) { in nxt_conf_json_skip_space()
1336 state = sw_normal; in nxt_conf_json_skip_space()
1351 state = sw_normal; in nxt_conf_json_skip_space()
1832 } state; in nxt_conf_json_parse_string() local
1836 state = 0; in nxt_conf_json_parse_string()
1842 switch (state) { in nxt_conf_json_parse_string()
1851 state = sw_escape; in nxt_conf_json_parse_string()
1878 state = sw_usual; in nxt_conf_json_parse_string()
[all …]
H A Dnxt_upstream.h61 const nxt_upstream_peer_state_t *state; member
H A Dnxt_http_variables.c138 nxt_http_unknown_var_ref(nxt_tstr_state_t *state, nxt_var_ref_t *ref, in nxt_http_unknown_var_ref() argument
155 lower = nxt_str_alloc(state->pool, str.length); in nxt_http_unknown_var_ref()
178 hash = nxt_http_header_hash(state->pool, &str); in nxt_http_unknown_var_ref()
194 hash = nxt_http_argument_hash(state->pool, &str); in nxt_http_unknown_var_ref()
210 hash = nxt_http_cookie_hash(state->pool, &str); in nxt_http_unknown_var_ref()
219 ref->data = nxt_var_field_new(state->pool, &str, (uint32_t) hash); in nxt_http_unknown_var_ref()
H A Dnxt_epoll_engine.c1063 const nxt_event_conn_state_t *state; in nxt_epoll_edge_conn_io_connect() local
1067 state = c->write_state; in nxt_epoll_edge_conn_io_connect()
1073 handler = state->ready_handler; in nxt_epoll_edge_conn_io_connect()
1081 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_epoll_edge_conn_io_connect()
1089 nxt_conn_timer(engine, c, state, &c->write_timer); in nxt_epoll_edge_conn_io_connect()
1107 c->socket.error_handler = state->error_handler; in nxt_epoll_edge_conn_io_connect()
1112 handler = state->ready_handler; in nxt_epoll_edge_conn_io_connect()
1117 handler = state->error_handler; in nxt_epoll_edge_conn_io_connect()
1121 handler = state->close_handler; in nxt_epoll_edge_conn_io_connect()
/unit/src/nodejs/unit-http/
H A Dwebsocket_connection.js75 this.state = STATE_OPEN;
172 if (this.state === STATE_CLOSED) {
180 this.state = STATE_CLOSED;
194 if (this.state === STATE_CLOSED) {
202 this.state !== STATE_ENDING) {
214 this.state = STATE_CLOSED;
245 this.state = STATE_ENDING;
274 this.state = STATE_CLOSED;
313 this.state = STATE_CLOSED;
462 this.state = STATE_CLOSED;
[all …]
/unit/src/ruby/
H A Dnxt_ruby.c262 int state, rc; in nxt_ruby_start() local
428 int state; in nxt_ruby_init_basic() local
434 if (nxt_slow_path(state == 0)) { in nxt_ruby_init_basic()
451 int state; in nxt_ruby_rack_init() local
455 if (nxt_slow_path(state != 0)) { in nxt_ruby_rack_init()
462 if (state != 0) { in nxt_ruby_rack_init()
475 if (nxt_slow_path(state != 0)) { in nxt_ruby_rack_init()
484 if (nxt_slow_path(state != 0)) { in nxt_ruby_rack_init()
638 int state; in nxt_ruby_request_handler_gvl() local
1311 int state; in nxt_ruby_thread_func() local
[all …]
/unit/src/python/
H A Dnxt_python_asgi_websocket.c40 int state; member
125 ws->state = NXT_WS_INIT; in nxt_py_asgi_websocket_create()
175 if (nxt_slow_path(ws->state == NXT_WS_INIT)) { in nxt_py_asgi_websocket_receive()
176 ws->state = NXT_WS_CONNECT; in nxt_py_asgi_websocket_receive()
265 switch(ws->state) { in nxt_py_asgi_websocket_accept()
350 ws->state = NXT_WS_ACCEPTED; in nxt_py_asgi_websocket_accept()
365 if (nxt_slow_path(ws->state == NXT_WS_INIT)) { in nxt_py_asgi_websocket_close()
408 ws->state = NXT_WS_CLOSED; in nxt_py_asgi_websocket_close()
602 ws->state = NXT_WS_CLOSED; in nxt_py_asgi_websocket_handler()
988 ws->state = NXT_WS_DISCONNECTED; in nxt_py_asgi_websocket_close_handler()
[all …]
H A Dnxt_python_asgi_lifespan.c30 PyObject *state; member
65 .offset = offsetof(nxt_py_asgi_lifespan_t, state),
191 lifespan->state = NULL; in nxt_py_asgi_lifespan_target_startup()
198 lifespan->state = PyDict_New(); in nxt_py_asgi_lifespan_target_startup()
199 if (nxt_slow_path(lifespan->state == NULL)) { in nxt_py_asgi_lifespan_target_startup()
206 lifespan->state) == -1)) in nxt_py_asgi_lifespan_target_startup()
210 Py_CLEAR(lifespan->state); in nxt_py_asgi_lifespan_target_startup()
654 Py_CLEAR(lifespan->state); in nxt_py_asgi_lifespan_dealloc()
/unit/src/java/nginx/unit/websocket/
H A DWsSession.java397 return state == State.OPEN; in isOpen()
486 if (state != State.OPEN) { in doClose()
491 if (state != State.OPEN) { in doClose()
505 state = State.OUTPUT_CLOSED; in doClose()
530 if (state != State.CLOSED) { in onClose()
542 state = State.CLOSED; in onClose()
554 if (state != State.CLOSED) { in onClose()
566 state = State.CLOSED; in onClose()
711 if (state == State.OPEN) { in registerFuture()
818 if (state == State.CLOSED) { in processFrame()
[all …]
H A DWsRemoteEndpointImplBase.java1130 private State state = State.OPEN; field in WsRemoteEndpointImplBase.StateMachine
1134 state = State.STREAM_WRITING; in streamStart()
1139 state = State.WRITER_WRITING; in writeStart()
1144 state = State.BINARY_PARTIAL_WRITING; in binaryPartialStart()
1149 state = State.BINARY_FULL_WRITING; in binaryStart()
1154 state = State.TEXT_PARTIAL_WRITING; in textPartialStart()
1159 state = State.TEXT_FULL_WRITING; in textStart()
1167 state = State.OPEN; in complete()
1172 state = State.TEXT_PARTIAL_READY; in complete()
1190 for (State state : required) { in checkState()
[all …]
H A DWsFrameBase.java85 private volatile State state = State.NEW_FRAME; field in WsFrameBase
116 if (state == State.NEW_FRAME) { in processInputBuffer()
126 if (state == State.PARTIAL_HEADER) { in processInputBuffer()
131 if (state == State.DATA) { in processInputBuffer()
221 state = State.PARTIAL_HEADER; in processInitialHeader()
280 state = State.DATA; in processRemainingHeader()
605 state = State.NEW_FRAME; in newFrame()
815 throw new IllegalStateException(sm.getString("wsFrame.illegalReadState", state)); in suspend()
863 throw new IllegalStateException(sm.getString("wsFrame.illegalReadState", state)); in resume()
/unit/auto/
H A Dsummary17 state directory: ........... "$NXT_STATEDIR"

123