| /third_party/grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 190 static void ru_unref_by(grpc_resource_user* resource_user, gpr_atm amount);
196 static void rulist_add_head(grpc_resource_user* resource_user, in rulist_add_head() argument
198 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_add_head()
201 *root = resource_user; in rulist_add_head()
202 resource_user->links[list].next = resource_user->links[list].prev = in rulist_add_head()
203 resource_user; in rulist_add_head()
205 resource_user->links[list].next = *root; in rulist_add_head()
206 resource_user->links[list].prev = (*root)->links[list].prev; in rulist_add_head()
207 resource_user->links[list].next->links[list].prev = in rulist_add_head()
208 resource_user->links[list].prev->links[list].next = resource_user; in rulist_add_head()
[all …]
|
| D | resource_quota.h | 95 grpc_resource_user* resource_user);
97 void grpc_resource_user_ref(grpc_resource_user* resource_user);
98 void grpc_resource_user_unref(grpc_resource_user* resource_user);
99 void grpc_resource_user_shutdown(grpc_resource_user* resource_user);
104 bool grpc_resource_user_allocate_threads(grpc_resource_user* resource_user,
114 void grpc_resource_user_free_threads(grpc_resource_user* resource_user,
121 bool grpc_resource_user_safe_alloc(grpc_resource_user* resource_user,
133 bool grpc_resource_user_alloc(grpc_resource_user* resource_user, size_t size,
137 void grpc_resource_user_free(grpc_resource_user* resource_user, size_t size);
142 void grpc_resource_user_post_reclaimer(grpc_resource_user* resource_user,
[all …]
|
| D | tcp_custom.cc | 67 grpc_resource_user* resource_user; member
78 grpc_resource_user_unref(tcp->resource_user); in tcp_free()
302 grpc_resource_user_shutdown(tcp->resource_user); in endpoint_shutdown()
339 return tcp->resource_user; in endpoint_get_resource_user()
386 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in custom_tcp_endpoint_create()
388 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in custom_tcp_endpoint_create()
|
| D | endpoint_cfstream.cc | 62 grpc_resource_user* resource_user; member
66 grpc_resource_user_unref(ep->resource_user); in CFStreamFree()
297 grpc_resource_user_shutdown(ep_impl->resource_user); in CFStreamShutdown()
313 return ep_impl->resource_user; in CFStreamGetResourceUser()
392 ep_impl->resource_user = in grpc_cfstream_endpoint_create()
395 ep_impl->resource_user, in grpc_cfstream_endpoint_create()
|
| D | tcp_windows.cc | 120 grpc_resource_user* resource_user; member
136 grpc_resource_user_unref(tcp->resource_user); in tcp_free()
470 grpc_resource_user_shutdown(tcp->resource_user); in win_shutdown()
491 return tcp->resource_user; in win_get_resource_user()
543 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in grpc_tcp_create()
|
| D | tcp_posix.cc | 395 grpc_resource_user* resource_user; member
590 grpc_resource_quota* rq = grpc_resource_user_quota(tcp->resource_user); in get_target_read_size()
625 grpc_resource_user_shutdown(tcp->resource_user); in tcp_shutdown()
632 grpc_resource_user_unref(tcp->resource_user); in tcp_free()
1663 return tcp->resource_user; in tcp_get_resource_user()
1809 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in grpc_tcp_create()
1811 &tcp->slice_allocator, tcp->resource_user, tcp_read_allocation_done, tcp); in grpc_tcp_create()
|
| /third_party/grpc/test/core/util/ |
| D | mock_endpoint.cc | 44 grpc_resource_user* resource_user; member
89 grpc_resource_user_shutdown(m->resource_user); in me_shutdown()
96 grpc_resource_user_unref(m->resource_user); in me_destroy()
107 return m->resource_user; in me_get_resource_user()
131 m->resource_user = grpc_resource_user_create(resource_quota, name.c_str()); in grpc_mock_endpoint_create()
|
| D | passthru_endpoint.cc | 48 grpc_resource_user* resource_user; member
134 grpc_resource_user_shutdown(m->resource_user); in me_shutdown()
147 grpc_resource_user_unref(p->client.resource_user); in me_destroy()
148 grpc_resource_user_unref(p->server.resource_user); in me_destroy()
168 return m->resource_user; in me_get_resource_user()
194 m->resource_user = grpc_resource_user_create(resource_quota, name.c_str()); in half_init()
|
| /third_party/grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 249 grpc_resource_user* resource_user = in OnHandshakeDone() local
254 if (resource_user != nullptr) { in OnHandshakeDone()
255 grpc_resource_user_free(resource_user, in OnHandshakeDone()
277 args->args, args->endpoint, false, resource_user); in OnHandshakeDone()
280 grpc_chttp2_transport_get_socket_node(transport), resource_user); in OnHandshakeDone()
313 if (resource_user != nullptr) { in OnHandshakeDone()
314 grpc_resource_user_free(resource_user, in OnHandshakeDone()
320 if (resource_user != nullptr) { in OnHandshakeDone()
321 grpc_resource_user_free(resource_user, in OnHandshakeDone()
453 grpc_resource_user* resource_user = server_->default_resource_user(); in CreateHandshakeManager() local
[all …]
|
| /third_party/grpc/src/core/lib/channel/ |
| D | channel_stack_builder.cc | 43 grpc_resource_user* resource_user; member
178 grpc_channel_stack_builder* builder, grpc_resource_user* resource_user) { in grpc_channel_stack_builder_set_resource_user() argument
179 GPR_ASSERT(builder->resource_user == nullptr); in grpc_channel_stack_builder_set_resource_user()
180 builder->resource_user = resource_user; in grpc_channel_stack_builder_set_resource_user()
185 return builder->resource_user; in grpc_channel_stack_builder_get_resource_user()
|
| D | channel_stack_builder.h | 59 grpc_channel_stack_builder* builder, grpc_resource_user* resource_user);
|
| /third_party/grpc/src/core/lib/surface/ |
| D | channel.cc | 65 grpc_resource_user* resource_user = in grpc_channel_create_with_builder() local
90 channel->resource_user = resource_user; in grpc_channel_create_with_builder()
227 grpc_resource_user* resource_user, in grpc_channel_create() argument
262 grpc_channel_stack_builder_set_resource_user(builder, resource_user); in grpc_channel_create()
265 if (resource_user != nullptr) { in grpc_channel_create()
266 grpc_resource_user_free(resource_user, GRPC_RESOURCE_QUOTA_CHANNEL_SIZE); in grpc_channel_create()
510 if (channel->resource_user != nullptr) { in destroy_channel()
511 grpc_resource_user_free(channel->resource_user, in destroy_channel()
|
| D | channel.h | 37 grpc_resource_user* resource_user = nullptr,
109 grpc_resource_user* resource_user; member
|
| D | server.h | 131 grpc_resource_user* resource_user = nullptr);
|
| D | server.cc | 604 grpc_resource_user* resource_user) { in SetupTransport() argument
608 nullptr, args, GRPC_SERVER_CHANNEL, transport, resource_user, &error); in SetupTransport()
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.h | 39 grpc_resource_user* resource_user = nullptr);
|
| D | internal.h | 291 grpc_resource_user* resource_user);
299 grpc_resource_user* resource_user; member
|
| D | chttp2_transport.cc | 421 grpc_resource_user* resource_user) in grpc_chttp2_transport() argument
427 resource_user(resource_user), in grpc_chttp2_transport()
684 if (t->resource_user != nullptr) { in ~grpc_chttp2_stream()
685 grpc_resource_user_free(t->resource_user, GRPC_RESOURCE_QUOTA_CALL_SIZE); in ~grpc_chttp2_stream()
739 if (t->resource_user != nullptr && in grpc_chttp2_parsing_accept_stream()
740 !grpc_resource_user_safe_alloc(t->resource_user, in grpc_chttp2_parsing_accept_stream()
3288 grpc_resource_user* resource_user) { in grpc_create_chttp2_transport() argument
3290 new grpc_chttp2_transport(channel_args, ep, is_client, resource_user); in grpc_create_chttp2_transport()
|
| /third_party/grpc/test/core/iomgr/ |
| D | resource_quota_test.cc | 56 grpc_resource_user* resource_user; member
63 grpc_resource_user_free(a->resource_user, a->size); in reclaimer_cb()
64 grpc_resource_user_finish_reclamation(a->resource_user); in reclaimer_cb()
69 grpc_closure* make_reclaimer(grpc_resource_user* resource_user, size_t size, in make_reclaimer() argument
73 a->resource_user = resource_user; in make_reclaimer()
|