Home
last modified time | relevance | path

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

12

/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dconnections-glue.c4 const char *connection_get_state(connection_state_t state) { in connection_get_state() argument
5 switch (state) { in connection_get_state()
21 const char *connection_get_short_state(connection_state_t state) { in connection_get_short_state() argument
22 switch (state) { in connection_get_short_state()
38 int connection_set_state(server *srv, connection *con, connection_state_t state) { in connection_set_state() argument
41 con->state = state; in connection_set_state()
H A Dmd5.c118 context->state[0] = 0x67452301; in li_MD5_Init()
119 context->state[1] = 0xefcdab89; in li_MD5_Init()
120 context->state[2] = 0x98badcfe; in li_MD5_Init()
121 context->state[3] = 0x10325476; in li_MD5_Init()
153 li_MD5Transform (context->state, &input[i]); in li_MD5_Update()
187 Encode (digest, context->state, 16); in li_MD5_Final()
198 UINT4 a = state[0], b = state[1], c = state[2], d = state[3], x[16]; in li_MD5Transform()
275 state[0] += a; in li_MD5Transform()
276 state[1] += b; in li_MD5Transform()
277 state[2] += c; in li_MD5Transform()
[all …]
H A Dlemon.c236 struct state { struct
756 struct state *stp;
850 struct state *stp;
1941 x,psp->state);
2704 struct state *stp;
3202 struct state *stp;
3631 struct state *stp;
4138 struct state *new; in State_new()
4139 new = (struct state *)malloc( sizeof(struct state) ); in State_new()
4191 struct state *data; in State_insert()
[all …]
H A Dconnections.h14 int connection_set_state(server *srv, connection *con, connection_state_t state);
15 const char * connection_get_state(connection_state_t state);
16 const char * connection_get_short_state(connection_state_t state);
H A Dmod_scgi.c79 } state; member
304 scgi_connection_state_t state; member
362 hctx->state = FCGI_STATE_INIT; in handler_ctx_init()
908 proc->state = PROC_STATE_RUNNING; in scgi_spawn_connection()
1188 hctx->state = state; in scgi_set_state()
2075 proc->state, in scgi_restart_dead_procs()
2126 proc->state = PROC_STATE_DIED; in scgi_restart_dead_procs()
2185 switch(hctx->state) { in scgi_write_request()
2613 hctx->state); in scgi_handle_fdevent()
2646 hctx->state); in scgi_handle_fdevent()
[all …]
H A Dconnections.c913 connection_state_t ostate = con->state;
1232 if (con->state == CON_STATE_CLOSE) {
1264 if (con->state == CON_STATE_READ ||
1269 if (con->state == CON_STATE_WRITE &&
1282 if (con->state == CON_STATE_CLOSE) {
1414 connection_get_state(con->state));
1418 size_t ostate = con->state;
1420 switch (con->state) {
1826 } else if (ostate == con->state) {
1835 connection_get_state(con->state));
[all …]
H A Dmod_fastcgi.c98 } state; member
345 fcgi_connection_state_t state; member
497 hctx->state = FCGI_STATE_INIT; in handler_ctx_init()
1150 proc->state = PROC_STATE_RUNNING; in fcgi_spawn_connection()
1461 hctx->state = state; in fcgi_set_state()
2714 proc->state, in fcgi_restart_dead_procs()
2724 switch (proc->state) { in fcgi_restart_dead_procs()
2904 switch(hctx->state) { in fcgi_write_request()
3372 hctx->state); in fcgi_handle_fdevent()
3401 hctx->state); in fcgi_handle_fdevent()
[all …]
H A Dmod_status.c452 const char *state; in mod_status_handle_server_status_html() local
454 if (CON_STATE_READ == c->state && c->request.orig_uri->used > 0) { in mod_status_handle_server_status_html()
455 state = "k"; in mod_status_handle_server_status_html()
457 state = connection_get_short_state(c->state); in mod_status_handle_server_status_html()
460 buffer_append_string_len(b, state, 1); in mod_status_handle_server_status_html()
506 if (CON_STATE_READ == c->state && c->request.orig_uri->used > 0) { in mod_status_handle_server_status_html()
509 buffer_append_string(b, connection_get_state(c->state)); in mod_status_handle_server_status_html()
608 const char *state = connection_get_short_state(c->state); in mod_status_handle_server_status_text() local
609 buffer_append_string_len(b, state, 1); in mod_status_handle_server_status_text()
H A Dmod_proxy.c94 proxy_connection_state_t state; member
123 hctx->state = PROXY_STATE_INIT; in handler_ctx_init()
547 hctx->state = state; in proxy_set_state()
760 switch(hctx->state) { in proxy_write_request()
964 hctx->state == PROXY_STATE_READ) { in proxy_handle_fdevent()
968 "proxy: fdevent-in", hctx->state); in proxy_handle_fdevent()
999 "proxy: fdevent-out", hctx->state); in proxy_handle_fdevent()
1002 if (hctx->state == PROXY_STATE_CONNECT) { in proxy_handle_fdevent()
1034 hctx->state == PROXY_STATE_WRITE) { in proxy_handle_fdevent()
1043 "proxy: out", hctx->state); in proxy_handle_fdevent()
[all …]
H A Dmd5.h39 UINT4 state[4]; /* state (ABCD) */ member
H A Dmod_rewrite.c35 enum { REWRITE_STATE_UNSET, REWRITE_STATE_FINISHED} state; member
53 hctx->state = REWRITE_STATE_UNSET; in handler_ctx_init()
360 if (hctx->state == REWRITE_STATE_FINISHED) return HANDLER_GO_ON; in process_rewrite_rules()
439 if (rule->once) hctx->state = REWRITE_STATE_FINISHED; in process_rewrite_rules()
H A Dserver.c759 if (con->state == CON_STATE_READ || in start_server()
760 con->state == CON_STATE_READ_POST) { in start_server()
784 if ((con->state == CON_STATE_WRITE) && in start_server()
810 …if (con->state == CON_STATE_CLOSE && (srv->cur_ts - con->close_timeout_ts > HTTP_LINGER_TIMEOUT)) { in start_server()
841 connection_get_state(con->state)); in start_server()
1995 if (con->state == CON_STATE_READ || in main()
1996 con->state == CON_STATE_READ_POST) { in main()
2020 if ((con->state == CON_STATE_WRITE) && in main()
2046 …if (con->state == CON_STATE_CLOSE && (srv->cur_ts - con->close_timeout_ts > HTTP_LINGER_TIMEOUT)) { in main()
2077 connection_get_state(con->state)); in main()
/mOS-networking-stack/core/src/
H A Dtimer.c198 if (cur_stream->state < TCP_ST_ESTABLISHED) { in HandleRTO()
199 cur_stream->state = TCP_ST_CLOSED_RSVD; in HandleRTO()
204 cur_stream->state = TCP_ST_CLOSED_RSVD; in HandleRTO()
220 if (cur_stream->state >= TCP_ST_ESTABLISHED) { in HandleRTO()
260 if (cur_stream->state == TCP_ST_SYN_SENT) { in HandleRTO()
263 cur_stream->state = TCP_ST_CLOSED_RSVD; in HandleRTO()
322 cur_stream->state == TCP_ST_CLOSE_WAIT) { in HandleRTO()
327 cur_stream->state == TCP_ST_CLOSING || in HandleRTO()
328 cur_stream->state == TCP_ST_LAST_ACK) { in HandleRTO()
473 walk->state = TCP_ST_CLOSED_RSVD; in CheckTimewaitExpire()
[all …]
H A Dtcp_in.c202 cur_stream->state = TCP_ST_CLOSED_RSVD; in ProcessRST()
220 cur_stream->state == TCP_ST_CLOSING || in ProcessRST()
222 cur_stream->state = TCP_ST_CLOSED_RSVD; in ProcessRST()
240 cur_stream->state = TCP_ST_CLOSED_RSVD; in ProcessRST()
326 cur_stream->state == TCP_ST_CLOSING || in ProcessACK()
328 cur_stream->state == TCP_ST_LAST_ACK) { in ProcessACK()
709 cur_stream->state = TCP_ST_SYN_RCVD; in Handle_TCP_ST_LISTEN()
815 cur_stream->state = TCP_ST_SYN_RCVD; in Handle_TCP_ST_SYN_SENT()
1144 cur_stream->state = TCP_ST_CLOSING;
1257 cur_stream->state = TCP_ST_TIME_WAIT;
[all …]
H A Dpipe.c26 int state; member
97 pp->state = PIPE_ACTIVE; in mtcp_pipe()
157 if (pp->state == PIPE_CLOSED) { in PipeRead()
189 if (pp->state == PIPE_ACTIVE) { in PipeRead()
192 } else if (pp->state == PIPE_CLOSE_WAIT) { in PipeRead()
260 if (pp->state == PIPE_CLOSED) { in PipeWrite()
264 if (pp->state == PIPE_CLOSE_WAIT) { in PipeWrite()
342 if (pp->state < PIPE_ACTIVE) in RaisePendingPipeEvents()
389 if (pp->state == PIPE_CLOSED) { in PipeClose()
394 if (pp->state == PIPE_ACTIVE) { in PipeClose()
[all …]
H A Dtcp_out.c521 switch (cur_stream->state) { in SendControlPacket()
658 cur_stream->state == TCP_ST_LAST_ACK) { in WriteTCPDataList()
990 if (cur_stream->state < TCP_ST_SYN_SENT) { in UpdatePassiveSendTCPContext_SynSent()
1000 cur_stream->state = TCP_ST_SYN_SENT; in UpdatePassiveSendTCPContext_SynSent()
1041 cur_stream->state = TCP_ST_CLOSED_RSVD; in UpdatePassiveSendTCPContext()
1053 switch (cur_stream->state) { in UpdatePassiveSendTCPContext()
1059 cur_stream->state = TCP_ST_ESTABLISHED; in UpdatePassiveSendTCPContext()
1080 cur_stream->state = TCP_ST_ESTABLISHED; in UpdatePassiveSendTCPContext()
1106 cur_stream->state = TCP_ST_FIN_WAIT_1; in UpdatePassiveSendTCPContext()
1137 cur_stream->state = TCP_ST_LAST_ACK; in UpdatePassiveSendTCPContext()
[all …]
H A Dapi.c83 if (cur_stream->state == TCP_ST_CLOSED_RSVD) { in GetSocketError()
94 if (cur_stream->state == TCP_ST_CLOSE_WAIT || in GetSocketError()
95 cur_stream->state == TCP_ST_CLOSED_RSVD) { in GetSocketError()
104 if (cur_stream->state == TCP_ST_SYN_SENT && in GetSocketError()
1149 cur_stream->state = TCP_ST_SYN_SENT; in mtcp_connect()
1248 cur_stream->state != TCP_ST_CLOSE_WAIT) { in CloseStreamSocket()
1410 cur_stream->state = TCP_ST_CLOSED_RSVD; in mtcp_abort()
1420 cur_stream->state == TCP_ST_LAST_ACK || in mtcp_abort()
1421 cur_stream->state == TCP_ST_TIME_WAIT) { in mtcp_abort()
1422 cur_stream->state = TCP_ST_CLOSED_RSVD; in mtcp_abort()
[all …]
H A Dlogger.c49 ctx->state = ACTIVE_LOGT; in EnqueueJobBuffer()
67 ctx->state = IDLE_LOGT; in DequeueJobBuffer()
85 ctx->state = IDLE_LOGT; in InitLogThreadContext()
143 while (ctx->state == IDLE_LOGT && !ctx->done) { in ThreadLogMain()
H A Dcore.c564 if (stream->state != TCP_ST_SYN_SENT) { in HandleApplicationCalls()
611 stream->state = TCP_ST_CLOSED_RSVD; in HandleApplicationCalls()
633 stream->state = TCP_ST_FIN_WAIT_1; in HandleApplicationCalls()
638 stream->state = TCP_ST_LAST_ACK; in HandleApplicationCalls()
647 stream->state = TCP_ST_FIN_WAIT_1; in HandleApplicationCalls()
652 stream->state = TCP_ST_LAST_ACK; in HandleApplicationCalls()
677 stream->state = TCP_ST_FIN_WAIT_1; in HandleApplicationCalls()
682 stream->state = TCP_ST_LAST_ACK; in HandleApplicationCalls()
703 stream->state = TCP_ST_CLOSED_RSVD; in HandleApplicationCalls()
720 stream->state = TCP_ST_CLOSED_RSVD; in HandleApplicationCalls()
[all …]
H A Dutil.c510 XXH32_state_t state; in XXH32()
511 XXH32_reset(&state, seed); in XXH32()
512 XXH32_update(&state, input, len); in XXH32()
513 return XXH32_digest(&state); in XXH32()
650 XXH64_state_t state; in XXH64()
651 XXH64_reset(&state, seed); in XXH64()
652 XXH64_update(&state, input, len); in XXH64()
653 return XXH64_digest(&state); in XXH64()
H A Dtcp.c394 if (((recvside_stream->state == TCP_ST_TIME_WAIT && in HandleMonitorStream()
396 recvside_stream->state == TCP_ST_CLOSED_RSVD || in HandleMonitorStream()
398 ((sendside_stream->state == TCP_ST_TIME_WAIT && in HandleMonitorStream()
400 sendside_stream->state == TCP_ST_CLOSED_RSVD || in HandleMonitorStream()
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dstate.txt14 This is a short summary of the state-engine which is driving the lighttpd
19 :keywords: lighttpd, state-engine
29 The state-engine is currently made of 11 states which are walk-through on
56 .. image:: state.png
61 The connection is idling in the 'connect' state waiting for a connection.
71 is set back to the 'connect' state again.
90 the 'read' state.
95 For really hard errors we use the 'error' state which resets the
102 the error condition the 'close' state is used the init a half-close and
115 Important functions used by the state-engine
[all …]
H A DMakefile.am7 fastcgi-state.txt \
21 state.txt \
45 fastcgi-state.html \
59 state.html \
78 state.dot fastcgi-state.dot \
H A Dfastcgi-state.txt14 This is a short summary of the state-engine which is driving the FastCGI
19 :keywords: lighttpd, state-engine, fastcgi
29 The state-engine is currently made of 6 states which are walk-through on
45 .. image:: fastcgi-state.png
51 for the loop in the state-diagram.
H A DMakefile.in287 fastcgi-state.txt \
301 state.txt \
325 fastcgi-state.html \
339 state.html \
358 state.dot fastcgi-state.dot \

12