Lines Matching defs:mtcp_manager
194 struct mtcp_manager struct
196 mem_pool_t bufseg_pool;
197 mem_pool_t sockent_pool; /* memory pool for msock list entry */
199 mem_pool_t timer_pool; /* memory pool for struct timer */
201 mem_pool_t evt_pool; /* memory pool for struct ev_table */
202 mem_pool_t flow_pool; /* memory pool for tcp_stream */
203 mem_pool_t rv_pool; /* memory pool for recv variables */
204 mem_pool_t sv_pool; /* memory pool for send variables */
205 mem_pool_t mv_pool; /* memory pool for monitor variables */
207 kvs_t *ev_store;
210 sb_manager_t rbm_snd;
212 struct hashtable *tcp_flow_table;
214 uint32_t s_index; /* stream index */
216 socket_map_t smap;
218 socket_map_t msmap;
224 addr_pool_t ap; /* address pool */
226 uint32_t g_id; /* id space in a thread */
227 uint32_t flow_cnt; /* number of concurrent flows */
229 struct mtcp_thread_context* ctx;
232 int sp_fd;
233 log_thread_context* logger;
234 log_buff* w_buffer;
235 FILE *log_fp;
238 struct mtcp_epoll *ep;
239 uint32_t ts_last_event;
241 struct tcp_listener *listener;
243 uint32_t num_msp; /* # of MOS_SOCK_MONITOR_STREAM */
244 uint32_t num_esp; /* # of MOS_SOCK_STREAM */
245 struct pkt_ctx *pctx; /* current pkt context */
247 stream_queue_t connectq; /* streams need to connect */
248 stream_queue_t sendq; /* streams need to send data */
249 stream_queue_t ackq; /* streams need to send ack */
251 stream_queue_t closeq; /* streams need to close */
252 stream_queue_int *closeq_int; /* internally maintained closeq */
253 stream_queue_t resetq; /* streams need to reset */
254 stream_queue_int *resetq_int; /* internally maintained resetq */
256 stream_queue_t destroyq; /* streams need to be destroyed */
258 struct mtcp_sender *g_sender;
259 struct mtcp_sender *n_sender[ETH_NUM];
262 struct rto_hashstore* rto_store;
267 int rto_list_cnt;
268 int timewait_list_cnt;
269 int timeout_list_cnt;
271 uint32_t cur_ts;
273 int wakeup_flag;
274 int is_sleeping;
298 typedef struct mtcp_manager* mtcp_manager_t; argument
312 struct mtcp_manager* mtcp_manager; member