Home
last modified time | relevance | path

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

123

/unit/src/
H A Dnxt_fastcgi_record_parse.c39 } state; in nxt_fastcgi_record_parse() local
47 state = fp->state; in nxt_fastcgi_record_parse()
64 if (state == sw_fastcgi_data) { in nxt_fastcgi_record_parse()
85 state = sw_fastcgi_version; in nxt_fastcgi_record_parse()
88 state = sw_fastcgi_padding; in nxt_fastcgi_record_parse()
102 switch (state) { in nxt_fastcgi_record_parse()
106 state = sw_fastcgi_type; in nxt_fastcgi_record_parse()
157 state = sw_fastcgi_reserved; in nxt_fastcgi_record_parse()
166 state = sw_fastcgi_data; in nxt_fastcgi_record_parse()
170 state = sw_fastcgi_end_request; in nxt_fastcgi_record_parse()
[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_cache.c169 nxt_cache_query_state_t *state; in nxt_cache_query_locked() local
177 state = q->state; in nxt_cache_query_locked()
191 return state->ready_handler; in nxt_cache_query_locked()
196 return state->stale_handler; in nxt_cache_query_locked()
209 nxt_cache_query_state_t *state; in nxt_cache_node_hold() local
211 state = q->state; in nxt_cache_node_hold()
215 return state->error_handler; in nxt_cache_node_hold()
239 return state->error_handler; in nxt_cache_node_hold()
257 return state->error_handler; in nxt_cache_node_hold()
293 state = q->state; in nxt_cache_node_test()
[all …]
H A Dnxt_file_cache.c104 state = q->state; in nxt_file_cache_query_locked()
108 return state->error_handler; in nxt_file_cache_query_locked()
127 return state->update_handler; in nxt_file_cache_query_locked()
133 return state->error_handler; in nxt_file_cache_query_locked()
149 return state->error_handler; in nxt_file_cache_query_locked()
185 nxt_cache_query_state_t *state; in nxt_cache_node_test() local
188 state = q->state; in nxt_cache_node_test()
194 return state->ready_handler; in nxt_cache_node_test()
228 return state->stale_handler; in nxt_cache_node_test()
232 return state->update_handler; in nxt_cache_node_test()
[all …]
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_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_fastcgi_source.h30 uint8_t state; member
74 uint32_t state; /* 2 bits */ member
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_fastcgi_source.c343 switch (fs->state) { in nxt_fastcgi_next_param()
355 fs->state = sw_value_length; in nxt_fastcgi_next_param()
362 fs->state = sw_name; in nxt_fastcgi_next_param()
369 fs->state = sw_value; in nxt_fastcgi_next_param()
375 fs->state = sw_name_length; in nxt_fastcgi_next_param()
672 fs->upstream->state->ready_handler(fs); in nxt_fastcgi_source_header_ready()
696 b->completion_handler = fs->upstream->state->completion_handler; in nxt_fastcgi_source_body_filter()
722 b->completion_handler = fs->upstream->state->completion_handler; in nxt_fastcgi_source_last_buf()
749 fs->upstream->state->error_handler(task, fs, NULL); in nxt_fastcgi_source_fail()
H A Dnxt_conf.c1284 } state; in nxt_conf_json_skip_space() local
1286 state = sw_normal; in nxt_conf_json_skip_space()
1291 switch (state) { in nxt_conf_json_skip_space()
1322 state = sw_normal; in nxt_conf_json_skip_space()
1337 state = sw_normal; in nxt_conf_json_skip_space()
1818 } state; in nxt_conf_json_parse_string() local
1822 state = 0; in nxt_conf_json_parse_string()
1828 switch (state) { in nxt_conf_json_parse_string()
1837 state = sw_escape; in nxt_conf_json_parse_string()
1864 state = sw_usual; in nxt_conf_json_parse_string()
[all …]
H A Dnxt_http_request.c113 } state; in nxt_http_validate_host() local
121 state = sw_usual; in nxt_http_validate_host()
142 if (state == sw_usual) { in nxt_http_validate_host()
144 state = sw_rest; in nxt_http_validate_host()
151 state = sw_literal; in nxt_http_validate_host()
157 if (state == sw_literal) { in nxt_http_validate_host()
159 state = sw_rest; in nxt_http_validate_host()
275 r->state = &nxt_http_request_init_state; in nxt_http_request_create()
303 r->state = &nxt_http_request_body_state; in nxt_http_request_start()
H A Dnxt_upstream.h61 const nxt_upstream_peer_state_t *state; member
H A Dnxt_upstream_source.h56 const nxt_upstream_state_t *state; member
/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.c263 int state, rc; in nxt_ruby_start() local
461 int state; in nxt_ruby_init_basic() local
466 state = rb_enc_find_index("encdb"); in nxt_ruby_init_basic()
467 if (nxt_slow_path(state == 0)) { in nxt_ruby_init_basic()
484 int state; in nxt_ruby_rack_init() local
488 if (nxt_slow_path(state != 0)) { in nxt_ruby_rack_init()
495 if (state != 0) { in nxt_ruby_rack_init()
508 if (nxt_slow_path(state != 0)) { in nxt_ruby_rack_init()
666 int state; in nxt_ruby_request_handler_gvl() local
1339 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 …]
/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 Dsummary16 state directory: ........... "$NXT_STATE"

123