Home
last modified time | relevance | path

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

/third_party/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()