| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 64 grpc_resource_quota* resource_quota; member
191 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_add_head() local
192 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_add_head()
208 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_add_tail() local
209 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_add_tail()
222 static bool rulist_empty(grpc_resource_quota* resource_quota, in rulist_empty() argument
224 return resource_quota->roots[list] == nullptr; in rulist_empty()
227 static grpc_resource_user* rulist_pop_head(grpc_resource_quota* resource_quota, in rulist_pop_head() argument
229 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_pop_head()
249 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_remove() local
[all …]
|
| D | tcp_client_custom.cc | 46 grpc_resource_quota* resource_quota; member
51 grpc_resource_quota_unref_internal(connect->resource_quota); in custom_tcp_connect_cleanup()
93 socket, connect->resource_quota, connect->addr_name); in custom_connect_callback()
112 grpc_resource_quota* resource_quota = grpc_resource_quota_create(nullptr); in tcp_connect() local
116 grpc_resource_quota_unref_internal(resource_quota); in tcp_connect()
117 resource_quota = grpc_resource_quota_ref_internal( in tcp_connect()
131 connect->resource_quota = resource_quota; in tcp_connect()
|
| D | resource_quota.h | 69 grpc_resource_quota* resource_quota);
70 void grpc_resource_quota_unref_internal(grpc_resource_quota* resource_quota);
78 grpc_resource_quota* resource_quota);
80 size_t grpc_resource_quota_peek_size(grpc_resource_quota* resource_quota);
85 grpc_resource_quota* resource_quota, const char* name);
|
| D | tcp_client_cfstream.cc | 69 grpc_resource_quota* resource_quota; member
73 grpc_resource_quota_unref_internal(connect->resource_quota); in CFStreamConnectCleanup()
134 connect->resource_quota, connect->stream_handle); in OnOpen()
177 grpc_resource_quota* resource_quota = grpc_resource_quota_create(NULL); in CFStreamClientConnect() local
181 grpc_resource_quota_unref_internal(resource_quota); in CFStreamClientConnect()
182 resource_quota = grpc_resource_quota_ref_internal( in CFStreamClientConnect()
187 connect->resource_quota = resource_quota; in CFStreamClientConnect()
|
| D | tcp_server_custom.cc | 76 grpc_resource_quota* resource_quota; member
83 s->resource_quota = grpc_resource_quota_create(nullptr); in tcp_server_create()
87 grpc_resource_quota_unref_internal(s->resource_quota); in tcp_server_create()
88 s->resource_quota = grpc_resource_quota_ref_internal( in tcp_server_create()
91 grpc_resource_quota_unref_internal(s->resource_quota); in tcp_server_create()
136 grpc_resource_quota_unref_internal(s->resource_quota); in finish_shutdown()
231 ep = custom_tcp_endpoint_create(socket, sp->server->resource_quota, in finish_accept()
|
| D | tcp_windows.cc | 444 grpc_resource_quota* resource_quota = grpc_resource_quota_create(NULL); in grpc_tcp_create() local
448 grpc_resource_quota_unref_internal(resource_quota); in grpc_tcp_create()
449 resource_quota = grpc_resource_quota_ref_internal( in grpc_tcp_create()
463 tcp->resource_user = grpc_resource_user_create(resource_quota, peer_string); in grpc_tcp_create()
466 grpc_resource_quota_unref_internal(resource_quota); in grpc_tcp_create()
|
| D | endpoint_cfstream.h | 44 const char* peer_string, grpc_resource_quota* resource_quota,
|
| /external/grpc-grpc/test/core/util/ |
| D | port_server_client.cc | 87 grpc_resource_quota* resource_quota = in grpc_free_port_using_server() local
89 grpc_httpcli_get(&context, &pr.pops, resource_quota, &req, in grpc_free_port_using_server()
94 grpc_resource_quota_unref_internal(resource_quota); in grpc_free_port_using_server()
171 grpc_resource_quota* resource_quota = in got_port_from_server() local
173 grpc_httpcli_get(pr->ctx, &pr->pops, resource_quota, &req, in got_port_from_server()
178 grpc_resource_quota_unref_internal(resource_quota); in got_port_from_server()
221 grpc_resource_quota* resource_quota = in grpc_pick_port_using_server() local
223 grpc_httpcli_get(&context, &pr.pops, resource_quota, &req, in grpc_pick_port_using_server()
228 grpc_resource_quota_unref_internal(resource_quota); in grpc_pick_port_using_server()
|
| D | passthru_endpoint.cc | 177 grpc_resource_quota* resource_quota, in half_init() argument
186 m->resource_user = grpc_resource_user_create(resource_quota, name); in half_init()
192 grpc_resource_quota* resource_quota, in grpc_passthru_endpoint_create() argument
204 half_init(&m->client, m, resource_quota, "client"); in grpc_passthru_endpoint_create()
205 half_init(&m->server, m, resource_quota, "server"); in grpc_passthru_endpoint_create()
|
| D | mock_endpoint.cc | 120 grpc_resource_quota* resource_quota) { in grpc_mock_endpoint_create() argument
125 m->resource_user = grpc_resource_user_create(resource_quota, name); in grpc_mock_endpoint_create()
|
| D | mock_endpoint.h | 25 grpc_resource_quota* resource_quota);
|
| D | passthru_endpoint.h | 36 grpc_resource_quota* resource_quota,
|
| /external/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 61 grpc_resource_quota* resource_quota; member
105 grpc_resource_quota_unref_internal(req->resource_quota); in finish()
209 (char*)GRPC_ARG_RESOURCE_QUOTA, req->resource_quota, in next_address()
228 grpc_resource_quota* resource_quota, in internal_request_begin() argument
245 req->resource_quota = grpc_resource_quota_ref_internal(resource_quota); in internal_request_begin()
266 grpc_resource_quota* resource_quota, in grpc_httpcli_get() argument
274 internal_request_begin(context, pollent, resource_quota, request, deadline, in grpc_httpcli_get()
282 grpc_resource_quota* resource_quota, in grpc_httpcli_post() argument
294 context, pollent, resource_quota, request, deadline, on_done, response, in grpc_httpcli_post()
|
| D | httpcli.h | 85 grpc_resource_quota* resource_quota,
106 grpc_resource_quota* resource_quota,
|
| /external/grpc-grpc/test/core/http/ |
| D | httpcli_test.cc | 81 grpc_resource_quota* resource_quota = grpc_resource_quota_create("test_get"); in test_get() local
83 &g_context, &g_pops, resource_quota, &req, n_seconds_time(15), in test_get()
86 grpc_resource_quota_unref_internal(resource_quota); in test_get()
120 grpc_resource_quota* resource_quota = grpc_resource_quota_create("test_post"); in test_post() local
122 &g_context, &g_pops, resource_quota, &req, "hello", 5, n_seconds_time(15), in test_post()
125 grpc_resource_quota_unref_internal(resource_quota); in test_post()
|
| D | httpscli_test.cc | 84 grpc_resource_quota* resource_quota = grpc_resource_quota_create("test_get"); in test_get() local
86 &g_context, &g_pops, resource_quota, &req, n_seconds_time(15), in test_get()
89 grpc_resource_quota_unref_internal(resource_quota); in test_get()
124 grpc_resource_quota* resource_quota = grpc_resource_quota_create("test_post"); in test_post() local
126 &g_context, &g_pops, resource_quota, &req, "hello", 5, n_seconds_time(15), in test_post()
129 grpc_resource_quota_unref_internal(resource_quota); in test_post()
|
| /external/grpc-grpc/test/core/security/ |
| D | ssl_server_fuzzer.cc | 61 grpc_resource_quota* resource_quota = in LLVMFuzzerTestOneInput() local
64 grpc_mock_endpoint_create(discard_write, resource_quota); in LLVMFuzzerTestOneInput()
65 grpc_resource_quota_unref_internal(resource_quota); in LLVMFuzzerTestOneInput()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | fd_conservation_posix_test.cc | 42 grpc_resource_quota* resource_quota = in main() local
52 grpc_resource_quota_unref(resource_quota); in main()
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| D | server_fuzzer.cc | 48 grpc_resource_quota* resource_quota = in LLVMFuzzerTestOneInput() local
51 grpc_mock_endpoint_create(discard_write, resource_quota); in LLVMFuzzerTestOneInput()
52 grpc_resource_quota_unref_internal(resource_quota); in LLVMFuzzerTestOneInput()
|
| D | client_fuzzer.cc | 51 grpc_resource_quota* resource_quota = in LLVMFuzzerTestOneInput() local
54 grpc_mock_endpoint_create(discard_write, resource_quota); in LLVMFuzzerTestOneInput()
55 grpc_resource_quota_unref_internal(resource_quota); in LLVMFuzzerTestOneInput()
|
| /external/grpc-grpc/include/grpc/ |
| D | grpc.h | 467 GRPCAPI void grpc_resource_quota_ref(grpc_resource_quota* resource_quota);
470 GRPCAPI void grpc_resource_quota_unref(grpc_resource_quota* resource_quota);
473 GRPCAPI void grpc_resource_quota_resize(grpc_resource_quota* resource_quota,
478 grpc_resource_quota* resource_quota, int new_max_threads);
|
| /external/grpc-grpc/src/core/lib/security/credentials/oauth2/ |
| D | oauth2_credentials.cc | 369 grpc_resource_quota* resource_quota = in compute_engine_fetch_oauth2() local
372 httpcli_context, pollent, resource_quota, &request, deadline, in compute_engine_fetch_oauth2()
375 grpc_resource_quota_unref_internal(resource_quota); in compute_engine_fetch_oauth2()
429 grpc_resource_quota* resource_quota = in refresh_token_fetch_oauth2() local
432 httpcli_context, pollent, resource_quota, &request, body, strlen(body), in refresh_token_fetch_oauth2()
436 grpc_resource_quota_unref_internal(resource_quota); in refresh_token_fetch_oauth2()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | resource_quota_server.cc | 109 grpc_resource_quota* resource_quota = in resource_quota_server() local
111 grpc_resource_quota_resize(resource_quota, 5 * 1024 * 1024); in resource_quota_server()
122 arg.value.pointer.p = resource_quota; in resource_quota_server()
363 grpc_resource_quota_unref(resource_quota); in resource_quota_server()
|
| /external/grpc-grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 52 grpc_resource_quota* resource_quota, in ThreadManager() argument
60 resource_user_ = grpc_resource_user_create(resource_quota, name); in ThreadManager()
|
| /external/grpc-grpc/src/core/lib/security/credentials/jwt/ |
| D | jwt_verifier.cc | 680 grpc_resource_quota* resource_quota = nullptr; in on_openid_config_retrieved() local
708 resource_quota = grpc_resource_quota_create("jwt_verifier"); in on_openid_config_retrieved()
710 &ctx->verifier->http_ctx, &ctx->pollent, resource_quota, &req, in on_openid_config_retrieved()
714 grpc_resource_quota_unref_internal(resource_quota); in on_openid_config_retrieved()
776 grpc_resource_quota* resource_quota = nullptr; in retrieve_key_and_verify() local
836 resource_quota = grpc_resource_quota_create("jwt_verifier"); in retrieve_key_and_verify()
838 &ctx->verifier->http_ctx, &ctx->pollent, resource_quota, &req, in retrieve_key_and_verify()
841 grpc_resource_quota_unref_internal(resource_quota); in retrieve_key_and_verify()
|