Home
last modified time | relevance | path

Searched refs:concurrency (Results 1 – 5 of 5) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_send_buffer.c29 SBManagerCreate(size_t chunk_size, uint8_t disable_rings, uint32_t concurrency) in SBManagerCreate() argument
38 sbm->cnum = concurrency; in SBManagerCreate()
40 (uint64_t)chunk_size * (!disable_rings * concurrency), in SBManagerCreate()
48 sbm->freeq = CreateSBQueue(concurrency); in SBManagerCreate()
/mOS-networking-stack/samples/epwget/
H A Depwget.c71 static int concurrency; variable
220 …while (/*ctx->pending*/ mtcp_get_connection_cnt(ctx->mctx) < concurrency && ctx->started < ctx->ta… in CloseConnection()
539 concurrency = 100; in GlbInitWget()
577 concurrency = total_concurrency / core_limit; in GlbInitWget()
580 max_fds = concurrency * 3; in GlbInitWget()
691 …while (/*ctx->pending*/ mtcp_get_connection_cnt(ctx->mctx) < concurrency && ctx->started < ctx->ta… in RunWget()
H A Depwget-mp.c70 static int concurrency; variable
219 …while (/*ctx->pending*/ mtcp_get_connection_cnt(ctx->mctx) < concurrency && ctx->started < ctx->ta… in CloseConnection()
537 concurrency = 100; in GlbInitWget()
575 concurrency = total_concurrency / core_limit; in GlbInitWget()
578 max_fds = concurrency * 3; in GlbInitWget()
689 …while (/*ctx->pending*/ mtcp_get_connection_cnt(ctx->mctx) < concurrency && ctx->started < ctx->ta… in RunWget()
/mOS-networking-stack/core/src/include/
H A Dtcp_send_buffer.h29 SBManagerCreate(size_t chunk_size, uint8_t disable_rings, uint32_t concurrency);
H A Dtcp_ring_buffer.h68 rb_manager_t RBManagerCreate(size_t chunk_size, uint8_t disable_rings, uint32_t concurrency);