Lines Matching refs:thresh
767 int thresh = g_config.mos->max_concurrency; in WritePacketsToChunks() local
774 WriteTCPControlList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
776 WriteTCPACKList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
778 WriteTCPDataList(mtcp, mtcp->g_sender, cur_ts, thresh); in WritePacketsToChunks()
783 WriteTCPControlList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
785 WriteTCPACKList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
787 WriteTCPDataList(mtcp, mtcp->n_sender[i], cur_ts, thresh); in WritePacketsToChunks()
865 int thresh; in RunMainLoop() local
935 thresh = (int)mtcp->flow_cnt / (TS_TO_USEC(PER_STREAM_TCHECK)); in RunMainLoop()
936 assert(thresh >= 0); in RunMainLoop()
937 if (thresh == 0) in RunMainLoop()
938 thresh = 1; in RunMainLoop()
939 if (recv_cnt > 0 && thresh > recv_cnt) in RunMainLoop()
940 thresh = recv_cnt; in RunMainLoop()
942 thresh = g_config.mos->max_concurrency; in RunMainLoop()
948 if (thresh == -1) in RunMainLoop()
949 thresh = g_config.mos->max_concurrency; in RunMainLoop()
951 CheckRtmTimeout(mtcp, ts, thresh); in RunMainLoop()
952 CheckTimewaitExpire(mtcp, ts, thresh); in RunMainLoop()
955 CheckConnectionTimeout(mtcp, ts, thresh); in RunMainLoop()