426 	struct tcp_stream *cur_stream;  in FlushMonitorReadEvents()  local
436 			cur_stream =  in FlushMonitorReadEvents()
439 			if (cur_stream != NULL &&  in FlushMonitorReadEvents()
440 			    (cur_stream->actions & MOS_ACT_READ_DATA)) {  in FlushMonitorReadEvents()
441 				if (cur_stream->rcvvar != NULL &&  in FlushMonitorReadEvents()
442 						cur_stream->rcvvar->rcvbuf != NULL) {  in FlushMonitorReadEvents()
445 					if (cur_stream->side == MOS_SIDE_CLI) {  in FlushMonitorReadEvents()
446 						SOCKQ_FOREACH_REVERSE(walk, &cur_stream->msocks) {  in FlushMonitorReadEvents()
448 								       cur_stream->side, NULL,   in FlushMonitorReadEvents()
452 						SOCKQ_FOREACH_START(walk, &cur_stream->msocks) {  in FlushMonitorReadEvents()
454 								       cur_stream->side, NULL,   in FlushMonitorReadEvents()
460 				cur_stream->actions = 0;  in FlushMonitorReadEvents()
475 	struct tcp_stream *cur_stream;  in FlushBufferedReadEvents()  local
489 		cur_stream = mtcp->smap[mtcpq->events[offset++].sockid].stream;  in FlushBufferedReadEvents()
492 		if (cur_stream != NULL &&  in FlushBufferedReadEvents()
493 		    	(cur_stream->socket->events | MOS_EPOLLIN)) {  in FlushBufferedReadEvents()
494 			if (cur_stream->rcvvar != NULL &&  in FlushBufferedReadEvents()
495 					cur_stream->rcvvar->rcvbuf != NULL) {  in FlushBufferedReadEvents()
498 				if (cur_stream->side == MOS_SIDE_CLI) {  in FlushBufferedReadEvents()
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()