| /mOS-networking-stack/core/src/ |
| H A D | timer.c | 42 "rto and timewait list.\n", cur_stream->id); in AddtoRTOList()
96 "timewait and rto list.\n", cur_stream->id); in AddtoTimewaitList()
197 TRACE_RTO("Stream %d: Exceed MAX_RTX\n", cur_stream->id); in HandleRTO()
229 cur_stream->id, cur_stream->sndvar->rto, rto_prev, in HandleRTO()
267 cur_stream->id); in HandleRTO()
314 cur_stream->id, in HandleRTO()
331 TRACE_ERROR("Stream %u: fss not set.\n", cur_stream->id); in HandleRTO()
418 TRACE_ERROR("Stream %d: not on rto list.\n", walk->id); in CheckRtmTimeout()
476 TRACE_STATE("Stream %d: TCP_ST_CLOSED_RSVD\n", walk->id); in CheckTimewaitExpire()
564 t->id = id; in NewTimer()
[all …]
|
| H A D | tcp_in.c | 591 cur_stream->id); in ProcessTCPPayload()
688 cur_stream->id, pctx->p.payloadlen, in ProcessTCPPayload()
897 cur_stream->id); in Handle_TCP_ST_SYN_RCVD()
1017 "No FIN sent yet.\n", cur_stream->id); in Handle_TCP_ST_LAST_ACK()
1037 cur_stream->id); in Handle_TCP_ST_LAST_ACK()
1048 cur_stream->id); in Handle_TCP_ST_LAST_ACK()
1086 cur_stream->id, pctx->p.ack_seq);
1097 cur_stream->id);
1118 cur_stream->id);
1179 cur_stream->id);
[all …]
|
| H A D | tcp_out.c | 295 cur_stream->id, in SendTCPPacket()
553 cur_stream->id); in SendControlPacket()
591 cnt, cur_stream->id); in WriteTCPControlList()
639 cnt, cur_stream->id); in WriteTCPDataList()
879 cur_stream->id); in AddtoSendList()
1044 cur_stream->id, in UpdatePassiveSendTCPContext()
1088 cur_stream->id, in UpdatePassiveSendTCPContext()
1112 cur_stream->id, in UpdatePassiveSendTCPContext()
1143 cur_stream->id, in UpdatePassiveSendTCPContext()
1147 cur_stream->id, in UpdatePassiveSendTCPContext()
[all …]
|
| H A D | pipe.c | 53 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
61 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
62 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
70 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
71 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
79 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
80 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
89 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
90 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
103 pipeid[0] = socket[0]->id; in mtcp_pipe()
[all …]
|
| H A D | eventpoll.c | 118 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
126 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
135 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
149 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
157 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
162 return epsocket->id; in mtcp_epoll_create()
211 stream->id, TCPStateToString(stream)); in RaisePendingStreamEvents()
296 socket->id, socket->socktype, in mtcp_epoll_ctl()
478 event_socket->id, in mtcp_epoll_wait()
516 event_socket->id, in mtcp_epoll_wait()
[all …]
|
| H A D | scalable_event.c | 35 #define NEWID(id, ev, cb) (id ^ hash64(ev, cb)) argument
187 nstree->id = id; in stree_create()
230 kvs_remove(store, stree->id); in stree_dec_ref()
376 uint64_t id = 0, nid; in RegCb() local
388 id = stree->id; in RegCb()
392 nid = NEWID(id, ev, cb); in RegCb()
438 kvs_remove(store, stree->id); in RegCb()
568 uint64_t id = 0, nid; in UnregCb() local
577 id = stree->id; in UnregCb()
580 nid = NEWID(id, ev, cb); in UnregCb()
[all …]
|
| H A D | tcp_stream.c | 407 sockid = msock->id; in DestroyMonitorStreamSocket()
472 stream->id = mtcp->g_id++;
572 "%u.%u.%u.%u(%d) -> %u.%u.%u.%u(%d) (ISS: %u)\n", stream->id,
712 "Stream %d abnormally closed.\n", stream->id);
723 "%u.%u.%u.%u(%d) -> %u.%u.%u.%u(%d) (%s)\n", stream->id,
731 "cum_len: %lu, len: %u\n", stream->id,
737 "cum_len: %lu, merged_len: %u, last_len: %u\n", stream->id,
748 stream->id,
763 stream->id,
910 stream->id, stream->stream_type,
[all …]
|
| H A D | tcp_rb.c | 92 tmp->id = 0; in buf_first()
106 if ((rb->lbufsegs <= buf->id + 1) || ((tmp = bufseg_new(rb->mp)) == NULL)) in buf_next()
109 tmp->id = buf->id + 1; in buf_next()
119 int id = off / UNITBUFSIZE; in buf_getbuf() local
120 assert(id >= 0); in buf_getbuf()
125 if (max / 2 > id) { in buf_getbuf()
127 while (id--) in buf_getbuf()
131 while (max - ++id) in buf_getbuf()
136 while (id--) in buf_getbuf()
851 printf("[%d]:'", walk->id); in tcprb_printbufsegs()
|
| H A D | api.c | 559 int sockid = sock->id; in mtcp_monitor()
675 return socket->id; in mtcp_socket()
899 TRACE_API("Stream %d accepted.\n", accepted->id); in mtcp_accept()
909 return accepted->socket->id; in mtcp_accept()
967 iph->id = htons(0); in eval_bpf_5tuple()
1219 sockid, cur_stream->id); in CloseStreamSocket()
1231 cur_stream->id); in CloseStreamSocket()
1250 cur_stream->id, TCPStateToString(cur_stream)); in CloseStreamSocket()
1723 cur_stream->id, bytes_read); in mtcp_readv()
1763 cur_stream->id, sndvar->snd_wnd); in CopyFromUser()
[all …]
|
| H A D | icmp.c | 109 iph->id = htons(0); in ICMPOutput()
175 uint16_t seq, id; in ProcessICMPECHOReply()
181 id = ntohs(ICMP_ECHO_GET_ID(icmph)); in ProcessICMPECHOReply()
|
| H A D | core.c | 613 TRACE_STATE("Stream %d: TCP_ST_CLOSED_RSVD\n", stream->id); in HandleApplicationCalls()
635 TRACE_STATE("Stream %d: TCP_ST_FIN_WAIT_1\n", stream->id); in HandleApplicationCalls()
640 TRACE_STATE("Stream %d: TCP_ST_LAST_ACK\n", stream->id); in HandleApplicationCalls()
649 TRACE_STATE("Stream %d: TCP_ST_FIN_WAIT_1\n", stream->id); in HandleApplicationCalls()
654 TRACE_STATE("Stream %d: TCP_ST_LAST_ACK\n", stream->id); in HandleApplicationCalls()
679 TRACE_STATE("Stream %d: TCP_ST_FIN_WAIT_1\n", stream->id); in HandleApplicationCalls()
684 TRACE_STATE("Stream %d: TCP_ST_LAST_ACK\n", stream->id); in HandleApplicationCalls()
705 TRACE_STATE("Stream %d: TCP_ST_CLOSED_RSVD\n", stream->id); in HandleApplicationCalls()
926 walk->cb(&mctx, walk->id, 0, 0 /* FIXME */, NULL); in RunMainLoop()
1189 mtcp->smap[i].id = i; in InitializeMTCPManager()
[all …]
|
| H A D | debug.c | 115 thread_printf(mtcp, mtcp->log_fp, " IP_ID=%d", ntohs(iph->id)); in DumpPacket()
180 thread_printf(mtcp, mtcp->log_fp, " IP_ID=%d", ntohs(iph->id)); in DumpIPPacket()
238 fprintf(fout, " IP_ID=%d", ntohs(iph->id)); in DumpIPPacketToFile()
|
| H A D | ip_out.c | 161 iph->id = htons(ip_id); in IPOutputStandalone()
223 iph->id = htons(stream->sndvar->ip_id++); in IPOutput()
|
| /mOS-networking-stack/core/test/tree/ |
| H A D | test.c | 6 int id; member
20 nodes[i].id = i; in main()
31 printf("DFS: %d\n", walk->id); in main()
34 printf("BFS: %d\n", walk->id); in main()
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | mod_setenv.c | 164 if (con->plugin_ctx[p->id]) { in URIHANDLER_FUNC()
165 hctx = con->plugin_ctx[p->id]; in URIHANDLER_FUNC()
169 con->plugin_ctx[p->id] = hctx; in URIHANDLER_FUNC()
223 if (con->plugin_ctx[p->id]) { in CONNECTION_FUNC()
224 handler_ctx_free(con->plugin_ctx[p->id]); in CONNECTION_FUNC()
225 con->plugin_ctx[p->id] = NULL; in CONNECTION_FUNC()
|
| H A D | mod_rewrite.c | 338 if (con->plugin_ctx[p->id]) { in URIHANDLER_FUNC()
339 handler_ctx_free(con->plugin_ctx[p->id]); in URIHANDLER_FUNC()
340 con->plugin_ctx[p->id] = NULL; in URIHANDLER_FUNC()
350 if (con->plugin_ctx[p->id]) { in process_rewrite_rules()
351 hctx = con->plugin_ctx[p->id]; in process_rewrite_rules()
432 if (con->plugin_ctx[p->id] == NULL) { in process_rewrite_rules()
434 con->plugin_ctx[p->id] = hctx; in process_rewrite_rules()
436 hctx = con->plugin_ctx[p->id]; in process_rewrite_rules()
|
| H A D | mod_extforward.c | 447 if (con->plugin_ctx[p->id]) { in URIHANDLER_FUNC()
450 handler_ctx_free(con->plugin_ctx[p->id]); in URIHANDLER_FUNC()
451 con->plugin_ctx[p->id] = NULL; in URIHANDLER_FUNC()
454 con->plugin_ctx[p->id] = handler_ctx_init(con->dst_addr, con->dst_addr_buf); in URIHANDLER_FUNC()
479 handler_ctx *hctx = con->plugin_ctx[p->id]; in CONNECTION_FUNC()
490 con->plugin_ctx[p->id] = NULL; in CONNECTION_FUNC()
|
| H A D | mod_mysql_vhost.c | 125 plugin_connection_data *c = con->plugin_ctx[p->id]; in mod_mysql_vhost_connection_data()
142 return con->plugin_ctx[p->id] = c; in mod_mysql_vhost_connection_data()
148 plugin_connection_data *c = con->plugin_ctx[p->id]; in CONNECTION_FUNC()
166 con->plugin_ctx[p->id] = NULL; in CONNECTION_FUNC()
|
| H A D | mod_cgi.c | 527 if (con->mode != p->id) return HANDLER_GO_ON; in cgi_connection_close()
552 con->plugin_ctx[p->id] = NULL; in cgi_connection_close()
619 return cgi_connection_close(srv, con->plugin_ctx[p->id]); in cgi_connection_close_callback()
1163 con->mode = p->id; in cgi_create_env()
1174 con->plugin_ctx[p->id] = hctx; in cgi_create_env()
1191 con->plugin_ctx[p->id] = NULL; in cgi_create_env()
1345 handler_ctx *hctx = con->plugin_ctx[p->id]; in SUBREQUEST_FUNC()
1347 if (con->mode != p->id) return HANDLER_GO_ON; in SUBREQUEST_FUNC()
1393 con->plugin_ctx[p->id] = NULL; in SUBREQUEST_FUNC()
1425 con->plugin_ctx[p->id] = NULL; in SUBREQUEST_FUNC()
|
| H A D | mod_scgi.c | 56 size_t id; /* id will be between 1 and max_procs */ member
1126 proc->id = df->num_procs++; in SETDEFAULTS_FUNC()
1160 fp->id = df->num_procs++; in SETDEFAULTS_FUNC()
1231 con->plugin_ctx[p->id] = NULL; in scgi_connection_cleanup()
2375 handler_ctx *hctx = con->plugin_ctx[p->id]; in SUBREQUEST_FUNC()
2808 con->plugin_ctx[p->id] = hctx; in scgi_check_extension()
2812 con->mode = p->id; in scgi_check_extension()
2867 con->plugin_ctx[p->id] = hctx; in scgi_check_extension()
2871 con->mode = p->id; in scgi_check_extension()
2990 fp->id = host->max_id++; in TRIGGER_FUNC()
[all …]
|
| H A D | mod_fastcgi.c | 103 buffer *id; member
394 buffer_append_long(b, proc->id); in fastcgi_status_copy_procname()
553 f->id = buffer_init(); in fastcgi_host_init()
568 buffer_free(h->id); in fastcgi_host_free()
1377 proc->id = host->num_procs++; in SETDEFAULTS_FUNC()
1413 proc->id = host->num_procs++; in SETDEFAULTS_FUNC()
1501 con->plugin_ctx[p->id] = NULL; in fcgi_connection_close()
3604 con->plugin_ctx[p->id] = hctx; in fcgi_check_extension()
3606 con->mode = p->id; in fcgi_check_extension()
3671 con->plugin_ctx[p->id] = hctx; in fcgi_check_extension()
[all …]
|
| /mOS-networking-stack/core/src/include/ |
| H A D | icmp.h | 27 #define ICMP_ECHO_SET_ID(icmph, id) (icmph->un.echo.icmp_id = id) argument
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/ |
| H A D | rewrite.txt | 58 url.rewrite-once = ( "^/id/([0-9]+)$" => "/index.php?id=$1",
|
| /mOS-networking-stack/core/src/include/bpf/ |
| H A D | gencode.h | 227 int id; member
237 int id; member
|
| /mOS-networking-stack/core/src/bpf/ |
| H A D | sf_optimize.c | 297 SET_INSERT(b->dom, b->id);
309 SET_INSERT(ep->edom, ep->id);
368 SET_INSERT(b->closure, b->id);
1521 if (!SET_MEMBER((*diffp)->dom, b->id))
1539 if (!SET_MEMBER((*samep)->dom, b->id))
1616 if (!SET_MEMBER((*diffp)->dom, b->id))
1634 if (!SET_MEMBER((*samep)->dom, b->id))
1994 p->id = n;
2097 b->et.id = i;
2099 b->ef.id = n_blocks + i;
[all …]
|