Lines Matching refs:walk
88 struct _tcpfrag_t *walk; in GetFragInfo() local
89 TAILQ_FOREACH(walk, &rcvbuf->frags, link) { in GetFragInfo()
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
256 SOCKQ_FOREACH_START(walk, &stream->msocks) { in RaiseReadEvent()
257 assert(walk->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE); in RaiseReadEvent()
258 eq = walk->monitor_stream->monitor_listener->eq; in RaiseReadEvent()
335 struct mon_listener *walk; in AddMonitorStreamSockets() local
338 TAILQ_FOREACH(walk, &mtcp->monitors, link) { in AddMonitorStreamSockets()
339 socktype = walk->socket->socktype; in AddMonitorStreamSockets()
348 if (!walk->is_stream_syn_filter_hit) { in AddMonitorStreamSockets()
359 s->monitor_stream->monitor_listener = walk; in AddMonitorStreamSockets()
360 s->monitor_stream->client_buf_mgmt = walk->client_buf_mgmt; in AddMonitorStreamSockets()
361 s->monitor_stream->server_buf_mgmt = walk->server_buf_mgmt; in AddMonitorStreamSockets()
362 s->monitor_stream->client_mon = walk->client_mon; in AddMonitorStreamSockets()
363 s->monitor_stream->server_mon = walk->server_mon; 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
606 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) {
607 SOCKQ_INSERT_TAIL(&paired_stream->msocks, walk);
695 struct socket_map *walk; local
700 SOCKQ_FOREACH_START(walk, &stream->msocks) {
701 HandleCallback(mtcp, MOS_HK_RCV, walk, stream->side, NULL,
703 HandleCallback(mtcp, MOS_HK_SND, walk, stream->side, NULL,
839 SOCKQ_FOREACH_START(walk, &stream->msocks) {
840 SOCKQ_REMOVE(&stream->msocks, walk);
842 DestroyMonitorStreamSocket(mtcp, walk);