Home
last modified time | relevance | path

Searched refs:slice_allocator (Results 1 – 10 of 10) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dresource_quota.cc596 grpc_resource_user_slice_allocator* slice_allocator) { in ru_alloc_slices() argument
597 for (size_t i = 0; i < slice_allocator->count; i++) { in ru_alloc_slices()
599 slice_allocator->dest, ru_slice_create(slice_allocator->resource_user, in ru_alloc_slices()
600 slice_allocator->length)); in ru_alloc_slices()
605 grpc_resource_user_slice_allocator* slice_allocator = in ru_allocated_slices() local
607 if (error == GRPC_ERROR_NONE) ru_alloc_slices(slice_allocator); in ru_allocated_slices()
608 grpc_core::Closure::Run(DEBUG_LOCATION, &slice_allocator->on_done, in ru_allocated_slices()
989 grpc_resource_user_slice_allocator* slice_allocator, in grpc_resource_user_slice_allocator_init() argument
991 GRPC_CLOSURE_INIT(&slice_allocator->on_allocated, ru_allocated_slices, in grpc_resource_user_slice_allocator_init()
992 slice_allocator, grpc_schedule_on_exec_ctx); in grpc_resource_user_slice_allocator_init()
[all …]
Dresource_quota.h166 grpc_resource_user_slice_allocator* slice_allocator,
174 grpc_resource_user_slice_allocator* slice_allocator, size_t length,
Dtcp_custom.cc68 grpc_resource_user_slice_allocator slice_allocator; member
208 if (grpc_resource_user_alloc_slices(&tcp->slice_allocator, in endpoint_read()
388 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in custom_tcp_endpoint_create()
Dendpoint_cfstream.cc63 grpc_resource_user_slice_allocator slice_allocator; member
268 if (grpc_resource_user_alloc_slices(&ep_impl->slice_allocator, in CFStreamRead()
394 grpc_resource_user_slice_allocator_init(&ep_impl->slice_allocator, in grpc_cfstream_endpoint_create()
Dtcp_posix.cc396 grpc_resource_user_slice_allocator slice_allocator; member
877 if (GPR_UNLIKELY(!grpc_resource_user_alloc_slices(&tcp->slice_allocator, in tcp_continue_read()
1811 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in grpc_tcp_create()
/external/grpc-grpc/src/core/lib/iomgr/
Dresource_quota.cc572 grpc_resource_user_slice_allocator* slice_allocator = in ru_allocated_slices() local
575 for (size_t i = 0; i < slice_allocator->count; i++) { in ru_allocated_slices()
577 slice_allocator->dest, ru_slice_create(slice_allocator->resource_user, in ru_allocated_slices()
578 slice_allocator->length)); in ru_allocated_slices()
581 GRPC_CLOSURE_RUN(&slice_allocator->on_done, GRPC_ERROR_REF(error)); in ru_allocated_slices()
931 grpc_resource_user_slice_allocator* slice_allocator, in grpc_resource_user_slice_allocator_init() argument
933 GRPC_CLOSURE_INIT(&slice_allocator->on_allocated, ru_allocated_slices, in grpc_resource_user_slice_allocator_init()
934 slice_allocator, grpc_schedule_on_exec_ctx); in grpc_resource_user_slice_allocator_init()
935 GRPC_CLOSURE_INIT(&slice_allocator->on_done, cb, p, in grpc_resource_user_slice_allocator_init()
937 slice_allocator->resource_user = resource_user; in grpc_resource_user_slice_allocator_init()
[all …]
Dresource_quota.h149 grpc_resource_user_slice_allocator* slice_allocator,
155 grpc_resource_user_slice_allocator* slice_allocator, size_t length,
Dtcp_custom.cc68 grpc_resource_user_slice_allocator slice_allocator; member
204 grpc_resource_user_alloc_slices(&tcp->slice_allocator, in endpoint_read()
360 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in custom_tcp_endpoint_create()
Dendpoint_cfstream.cc60 grpc_resource_user_slice_allocator slice_allocator; member
264 grpc_resource_user_alloc_slices(&ep_impl->slice_allocator, in CFStreamRead()
365 grpc_resource_user_slice_allocator_init(&ep_impl->slice_allocator, in grpc_cfstream_endpoint_create()
Dtcp_posix.cc108 grpc_resource_user_slice_allocator slice_allocator; member
499 grpc_resource_user_alloc_slices(&tcp->slice_allocator, target_read_size, 1, in tcp_continue_read()
1070 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in grpc_tcp_create()