427 	struct mon_listener *walk;  in FlushMonitorReadEvents()  local
430 	TAILQ_FOREACH(walk, &mtcp->monitors, link) {  in FlushMonitorReadEvents()
431 		if (walk->socket->socktype != MOS_SOCK_MONITOR_STREAM ||  in FlushMonitorReadEvents()
432 			!(mtcpq = walk->eq))  in FlushMonitorReadEvents()
444 					struct socket_map *walk;  in FlushMonitorReadEvents()  local
446 						SOCKQ_FOREACH_REVERSE(walk, &cur_stream->msocks) {  in FlushMonitorReadEvents()
447 							HandleCallback(mtcp, MOS_NULL, walk,  in FlushMonitorReadEvents()
452 						SOCKQ_FOREACH_START(walk, &cur_stream->msocks) {  in FlushMonitorReadEvents()
453 							HandleCallback(mtcp, MOS_NULL, walk,  in FlushMonitorReadEvents()
497 				struct socket_map *walk;  in FlushBufferedReadEvents()  local
499 					SOCKQ_FOREACH_REVERSE(walk, &cur_stream->msocks) {  in FlushBufferedReadEvents()
500 						HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in FlushBufferedReadEvents()
504 					SOCKQ_FOREACH_START(walk, &cur_stream->msocks) {  in FlushBufferedReadEvents()
505 						HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in FlushBufferedReadEvents()
796 	tcp_stream *walk;  in DestroyRemainingFlows()  local
805 		TAILQ_FOREACH(walk, &ht->ht_table[i], rcvvar->he_link) {  in DestroyRemainingFlows()
807 					"CPU %d: Destroying stream %d\n", mtcp->ctx->cpu, walk->id);  in DestroyRemainingFlows()
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()
921 			tmp = TAILQ_NEXT(walk, timer_link);  in RunMainLoop()
922 			if (TIMEVAL_LT(&cur_ts, &walk->exp))  in RunMainLoop()
926 			walk->cb(&mctx, walk->id, 0, 0 /* FIXME */, NULL);  in RunMainLoop()
927 			DelTimer(mtcp, walk);  in RunMainLoop()