Home
last modified time | relevance | path

Searched refs:walk (Results 1 – 21 of 21) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtimer.c356 tcp_stream *walk, *next; in RearrangeRTOStore() local
361 walk != NULL; walk = next) { in RearrangeRTOStore()
383 tcp_stream *walk, *next; in CheckRtmTimeout() local
403 walk != NULL; walk = next) { in CheckRtmTimeout()
410 cnt, walk->s_id); in CheckRtmTimeout()
451 walk != NULL; walk = next) { in CheckTimewaitExpire()
457 cnt, walk->s_id); in CheckTimewaitExpire()
503 walk != NULL; walk = next) { in CheckConnectionTimeout()
521 if (walk->socket && HAS_STREAM_TYPE(walk, MOS_SOCK_STREAM)) { in CheckConnectionTimeout()
538 struct timer *walk; in RegTimer() local
[all …]
H A Daddr_pool.c229 while (walk) { in FetchAddress()
234 walk = next; in FetchAddress()
240 walk = next; in FetchAddress()
251 walk = next; in FetchAddress()
254 if (walk) { in FetchAddress()
255 *saddr = walk->addr; in FetchAddress()
282 if (walk) { in FetchAddressPerCore()
315 walk = NULL; in FreeAddress()
320 while (walk) { in FreeAddress()
327 walk = next; in FreeAddress()
[all …]
H A Dconfig.c458 walk->haddr[0], walk->haddr[1], walk->haddr[2], in NetdevConfPrint()
459 walk->haddr[3], walk->haddr[4], walk->haddr[5], in NetdevConfPrint()
478 walk->haddr[0], walk->haddr[1], walk->haddr[2], in ArpConfPrint()
479 walk->haddr[3], walk->haddr[4], walk->haddr[5]); in ArpConfPrint()
495 ntohl(walk->ip), ntohl(walk->mask), walk->dev_name, walk->nif); in RouteConfPrint()
869 walk->print(walk); in PrintConf()
874 walk->print(walk); in PrintConf()
883 if (!walk->isvalid || !walk->isvalid(walk)) in CheckConfValidity()
890 if (!walk->isvalid || !walk->isvalid(walk)) in CheckConfValidity()
910 if (walk && walk->print) in CheckConfValidity()
[all …]
H A Dtcp.c32 struct mon_listener *walk; in DetectStreamType() local
42 TAILQ_FOREACH(walk, &mtcp->monitors, link) { in DetectStreamType()
44 socktype = walk->socket->socktype; in DetectStreamType()
49 fcode = walk->stream_syn_fcode; in DetectStreamType()
116 struct socket_map *walk; in CreateMonitorStream() local
151 SOCKQ_FOREACH_START(walk, &stream->msocks) { in CreateMonitorStream()
288 struct socket_map *walk; in UpdateMonitor() local
415 struct mon_listener *walk; in ProcessInTCPPacket() local
424 TAILQ_FOREACH(walk, &mtcp->monitors, link) in ProcessInTCPPacket()
480 struct mon_listener *walk; in ProcessInTCPPacket() local
[all …]
H A Dkey_value_store.c98 struct kvs_entry *walk; in kvs_remove() local
102 TAILQ_FOREACH(walk, head, link) { in kvs_remove()
103 if (key == walk->key) { in kvs_remove()
104 TAILQ_REMOVE(head, walk, link); in kvs_remove()
105 TAILQ_INSERT_TAIL(&ht->kvs_free, walk, link); in kvs_remove()
109 return walk->value; in kvs_remove()
124 struct kvs_entry *walk; in kvs_search() local
128 TAILQ_FOREACH(walk, head, link) { in kvs_search()
129 if (key == walk->key) in kvs_search()
130 return walk->value; in kvs_search()
H A Dscalable_event.c140 del = walk; in tree_del_recursive()
161 return walk; in tree_search()
333 del = walk;
777 walk; in mtcp_define_event()
778 walk = TREE_YOUNGER(walk, link)) in mtcp_define_event()
840 walk; in RaiseEv()
841 walk = TREE_YOUNGER(walk, link)) { in RaiseEv()
842 if (walk->ev == event && IS_FLOATING_EVENT(walk)) { in RaiseEv()
907 if (walk != bev && walk->ft && in HandleCb()
908 walk->ft(mctx, sock, side, walk->ev, &walk->arg) == false) { in HandleCb()
[all …]
H A Dtcp_stream.c88 struct _tcpfrag_t *walk; in GetFragInfo() local
92 out[*len].offset = walk->head; in GetFragInfo()
93 out[*len].len = walk->tail - walk->head; in GetFragInfo()
254 struct socket_map *walk; in RaiseReadEvent() local
335 struct mon_listener *walk; in AddMonitorStreamSockets() local
339 socktype = walk->socket->socktype; in AddMonitorStreamSockets()
379 &walk->dontcare_evb); in AddMonitorStreamSockets()
381 &walk->pre_tcp_evb); in AddMonitorStreamSockets()
383 &walk->post_tcp_evb); in AddMonitorStreamSockets()
586 struct socket_map *walk; local
[all …]
H A Dip_in.c35 struct mon_listener *walk; in ProcessInIPv4Packet() local
56 TAILQ_FOREACH(walk, &mtcp->monitors, link) in ProcessInIPv4Packet()
57 if (walk->socket->socktype == MOS_SOCK_MONITOR_RAW) { in ProcessInIPv4Packet()
58 if (ISSET_BPFFILTER(walk->raw_pkt_fcode) && in ProcessInIPv4Packet()
59 EVAL_BPFFILTER(walk->raw_pkt_fcode, (uint8_t *)pctx->p.ethh, in ProcessInIPv4Packet()
61 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in ProcessInIPv4Packet()
H A Devent_callback.c127 struct ev_table *walk, *tmp; in CleanupEvB() local
128 for (walk = TAILQ_FIRST(&evb->evth); walk != NULL; walk = tmp) { in CleanupEvB()
129 tmp = TAILQ_NEXT(walk, link); in CleanupEvB()
131 MPFreeChunk(mtcp->evt_pool, walk); in CleanupEvB()
290 int walk = i; in UnregCb() local
301 if ((walk = g_udes[walk - UDE_OFFSET].parent) < UDE_OFFSET) in UnregCb()
336 struct ev_table *walk; in FindReusableEvT() local
347 if (walk->ent[i].cb != cb) in FindReusableEvT()
356 return walk; in FindReusableEvT()
360 if (walk->ent[i].cb != cb) in FindReusableEvT()
[all …]
H A Dtcp_rb.c53 struct _tcpfrag_t *walk; in frags_insert() local
56 if (walk->head > f->head) { in frags_insert()
61 if (!walk) in frags_insert()
804 struct _tcpfrag_t *walk; in tcprb_printfrags() local
808 printf("[%lu - %lu]:'", walk->head, walk->tail - 1); in tcprb_printfrags()
810 if (walk->empty) in tcprb_printfrags()
814 for (i = walk->head; i < walk->tail; i++) { in tcprb_printfrags()
847 struct _tcpbufseg_t *walk; in tcprb_printbufsegs() local
851 printf("[%d]:'", walk->id); in tcprb_printbufsegs()
855 char c = walk->buf[j]; in tcprb_printbufsegs()
[all …]
H A Dcore.c427 struct mon_listener *walk; in FlushMonitorReadEvents() local
432 !(mtcpq = walk->eq)) in FlushMonitorReadEvents()
444 struct socket_map *walk; in FlushMonitorReadEvents() local
497 struct socket_map *walk; in FlushBufferedReadEvents() local
796 tcp_stream *walk; in DestroyRemainingFlows() local
809 DumpStream(mtcp, walk); in DestroyRemainingFlows()
811 DestroyTCPStream(mtcp, walk); in DestroyRemainingFlows()
919 struct timer *walk, *tmp; in RunMainLoop() local
920 for (walk = TAILQ_FIRST(&mtcp->timer_list); walk != NULL; walk = tmp) { in RunMainLoop()
926 walk->cb(&mctx, walk->id, 0, 0 /* FIXME */, NULL); in RunMainLoop()
[all …]
H A Dfhash.c186 tcp_stream *walk; in HTSearch() local
208 TAILQ_FOREACH(walk, head, rcvvar->he_link) { in HTSearch()
209 if (EQUAL_FLOW(walk, item)) in HTSearch()
210 return walk; in HTSearch()
H A Dtcp_out.c233 struct mon_listener *walk; in SendTCPPacketStandalone() local
235 TAILQ_FOREACH(walk, &mtcp->monitors, link) in SendTCPPacketStandalone()
236 if (walk->socket->socktype == MOS_SOCK_MONITOR_RAW) in SendTCPPacketStandalone()
237 if (ISSET_BPFFILTER(walk->raw_pkt_fcode) && in SendTCPPacketStandalone()
238 EVAL_BPFFILTER(walk->raw_pkt_fcode, (uint8_t *)pctx.p.ethh, in SendTCPPacketStandalone()
240 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in SendTCPPacketStandalone()
377 struct mon_listener *walk; in SendTCPPacket() local
379 TAILQ_FOREACH(walk, &mtcp->monitors, link) in SendTCPPacket()
380 if (walk->socket->socktype == MOS_SOCK_MONITOR_RAW) in SendTCPPacket()
381 if (ISSET_BPFFILTER(walk->raw_pkt_fcode) && in SendTCPPacket()
[all …]
H A Dtcp_in.c554 struct socket_map *walk; in ProcessTCPPayload() local
573 SOCKQ_FOREACH_REVERSE(walk, &cur_stream->msocks) { in ProcessTCPPayload()
574 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
578 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { in ProcessTCPPayload()
579 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
631 SOCKQ_FOREACH_REVERSE(walk, &cur_stream->msocks) { in ProcessTCPPayload()
632 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
634 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
638 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { in ProcessTCPPayload()
639 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
[all …]
H A Dmos_api.c710 struct socket_map *walk; in mtcp_cb_stop() local
738 SOCKQ_FOREACH_START(walk, &stream->msocks) { in mtcp_cb_stop()
739 if (walk->monitor_stream->client_mon == 1) { in mtcp_cb_stop()
759 SOCKQ_FOREACH_START(walk, &stream->msocks) { in mtcp_cb_stop()
760 if (walk->monitor_stream->server_mon == 1) { in mtcp_cb_stop()
H A Dapi.c993 struct mon_listener *walk; in mtcp_connect() local
1085 TAILQ_FOREACH(walk, &mtcp->monitors, link) { in mtcp_connect()
1086 fcode = walk->stream_syn_fcode; in mtcp_connect()
1091 walk->is_stream_syn_filter_hit = 1; // set the 'filter hit' flag to 1 in mtcp_connect()
1139 struct socket_map *walk; in mtcp_connect() local
1140 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { in mtcp_connect()
1141 uint8_t bm = walk->monitor_stream->monitor_listener->server_buf_mgmt; in mtcp_connect()
/mOS-networking-stack/core/test/tree/
H A Dtest.c17 struct tree *walk; in main() local
30 TREE_DFS_FOREACH(walk, &nodes[0], &scratch, link) in main()
31 printf("DFS: %d\n", walk->id); in main()
33 TREE_BFS_FOREACH(walk, &nodes[0], &scratch, link) in main()
34 printf("BFS: %d\n", walk->id); in main()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dbuffer.c944 char *start, *slash, *walk, *out; in buffer_path_simplify() local
955 walk = src->ptr; in buffer_path_simplify()
965 for (walk = src->ptr; *walk; walk++) { in buffer_path_simplify()
966 if (*walk == '\\') *walk = '/'; in buffer_path_simplify()
968 walk = src->ptr; in buffer_path_simplify()
971 while (*walk == ' ') { in buffer_path_simplify()
972 walk++; in buffer_path_simplify()
975 pre1 = *(walk++); in buffer_path_simplify()
976 c = *(walk++); in buffer_path_simplify()
1017 c = *walk; in buffer_path_simplify()
[all …]
/mOS-networking-stack/core/src/include/
H A Dscalable_event.h25 struct socket_map *walk; \
26 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { \
27 HandleCallback(mtcp, MOS_NULL, walk, (stream)->side, \
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dfastcgi-state.txt29 The state-engine is currently made of 6 states which are walk-through on
H A Dstate.txt29 The state-engine is currently made of 11 states which are walk-through on