237 RaiseReadEvent(mtcp_manager_t mtcp, tcp_stream *stream)  in RaiseReadEvent()  argument
245 			AddEpollEvent(mtcp->ep, MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN);  in RaiseReadEvent()
285 RaiseWriteEvent(mtcp_manager_t mtcp, tcp_stream *stream)  in RaiseWriteEvent()  argument
289 			AddEpollEvent(mtcp->ep,   in RaiseWriteEvent()
298 RaiseCloseEvent(mtcp_manager_t mtcp, tcp_stream *stream)  in RaiseCloseEvent()  argument
302 			AddEpollEvent(mtcp->ep,   in RaiseCloseEvent()
305 			AddEpollEvent(mtcp->ep,   in RaiseCloseEvent()
314 RaiseErrorEvent(mtcp_manager_t mtcp, tcp_stream *stream)  in RaiseErrorEvent()  argument
319 			return AddEpollEvent(mtcp->ep,   in RaiseErrorEvent()
329 AddMonitorStreamSockets(mtcp_manager_t mtcp, struct tcp_stream *stream)  in AddMonitorStreamSockets()  argument
334 	mctx.cpu = mtcp->ctx->cpu;  in AddMonitorStreamSockets()
338 	TAILQ_FOREACH(walk, &mtcp->monitors, link) {  in AddMonitorStreamSockets()
393 DestroyMonitorStreamSocket(mtcp_manager_t mtcp, socket_map_t msock)  in DestroyMonitorStreamSocket()  argument
405 	mctx.cpu = mtcp->ctx->cpu;  in DestroyMonitorStreamSocket()
427 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,   argument
438 		pthread_mutex_lock(&mtcp->ctx->flow_pool_lock);
440 	stream = (tcp_stream *)MPAllocateChunk(mtcp->flow_pool);
444 				g_config.mos->max_concurrency, mtcp->flow_cnt);
446 			pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
451 	stream->rcvvar = (struct tcp_recv_vars *)MPAllocateChunk(mtcp->rv_pool);
453 		MPFreeChunk(mtcp->flow_pool, stream);
455 			pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
461 	stream->sndvar = (struct tcp_send_vars *)MPAllocateChunk(mtcp->sv_pool);
463 		MPFreeChunk(mtcp->rv_pool, stream->rcvvar);
464 		MPFreeChunk(mtcp->flow_pool, stream);
466 			pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
472 	stream->id = mtcp->g_id++;
478 	ret = HTInsert(mtcp->tcp_flow_table, stream, hash);
482 		MPFreeChunk(mtcp->flow_pool, stream);
484 			pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
488 	mtcp->flow_cnt++;
497 	if ((mtcp->num_msp > 0) &&
499 		if (AddMonitorStreamSockets(mtcp, stream) < 0)
503 		pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
582 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr,   argument
588         cur_stream = CreateTCPStream(mtcp, socket, type,
595 		paired_stream = CreateTCPStream(mtcp, NULL, MOS_SOCK_UNUSED,
598                 DestroyTCPStream(mtcp, cur_stream);
615 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,  argument
622 	cs = CreateTCPStream(mtcp, socket, type, daddr, dport, saddr, sport, hash);
650 AttachServerTCPStream(mtcp_manager_t mtcp, tcp_stream *cs, int type,  argument
657 	ss = CreateTCPStream(mtcp, NULL, MOS_SOCK_UNUSED, saddr, sport, daddr, dport, NULL);
687 DestroySingleTCPStream(mtcp_manager_t mtcp, tcp_stream *stream)  argument
701 		HandleCallback(mtcp, MOS_HK_RCV, walk, stream->side, NULL,
703 		HandleCallback(mtcp, MOS_HK_SND, walk, stream->side, NULL,
711 		thread_printf(mtcp, mtcp->log_fp, 
713 		DumpStream(mtcp, stream);
714 		DumpControlList(mtcp, mtcp->n_sender[0]);
798 		RemoveFromControlList(mtcp, stream);
799 		RemoveFromSendList(mtcp, stream);
800 		RemoveFromACKList(mtcp, stream);
803 			RemoveFromRTOList(mtcp, stream);
812 			SBFree(mtcp->rbm_snd, stream->sndvar->sndbuf);
818 		RemoveFromTimewaitList(mtcp, stream);
821 		RemoveFromTimeoutList(mtcp, stream);
829 		pthread_mutex_lock(&mtcp->ctx->flow_pool_lock);
832 	HTRemove(mtcp->tcp_flow_table, stream);
835 	mtcp->flow_cnt--;
842 			DestroyMonitorStreamSocket(mtcp, walk);
850 	MPFreeChunk(mtcp->rv_pool, stream->rcvvar);
851 	MPFreeChunk(mtcp->sv_pool, stream->sndvar);
852 	MPFreeChunk(mtcp->flow_pool, stream);
856 		pthread_mutex_unlock(&mtcp->ctx->flow_pool_lock);
859 		if (mtcp->ap) {
860 			ret = FreeAddress(mtcp->ap, &addr);
878 	TRACE_STREAM("Destroyed. Remaining flows: %u\n", mtcp->flow_cnt);
885 DestroyTCPStream(mtcp_manager_t mtcp, tcp_stream *stream)  argument
889 	DestroySingleTCPStream(mtcp, stream);
892 		DestroySingleTCPStream(mtcp, pair_stream);
896 DumpStream(mtcp_manager_t mtcp, tcp_stream *stream)  argument
904 	thread_printf(mtcp, mtcp->log_fp, "========== Stream %u: "
908 	thread_printf(mtcp, mtcp->log_fp, 
914 		thread_printf(mtcp, mtcp->log_fp, "Socket id: %d, type: %d, opts: %u\n"
925 		thread_printf(mtcp, mtcp->log_fp, "Socket: (null)\n");
928 	thread_printf(mtcp, mtcp->log_fp, 
949 	thread_printf(mtcp, mtcp->log_fp, "========== Send variables ==========\n");
950 	thread_printf(mtcp, mtcp->log_fp, 
954 	thread_printf(mtcp, mtcp->log_fp, 
961 		thread_printf(mtcp, mtcp->log_fp, 
967 		thread_printf(mtcp, mtcp->log_fp, "Send buffer: (null)\n");
969 	thread_printf(mtcp, mtcp->log_fp, 
974 	thread_printf(mtcp, mtcp->log_fp, 
976 	thread_printf(mtcp, mtcp->log_fp, 
982 		thread_printf(mtcp, mtcp->log_fp, "Receive buffer: (null)\n");
984 	thread_printf(mtcp, mtcp->log_fp, "last_ack_seq: %u, dup_acks: %u\n", 
986 	thread_printf(mtcp, mtcp->log_fp, 
990 	thread_printf(mtcp, mtcp->log_fp,