| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | resource_quota.cc | 67 grpc_resource_quota* resource_quota; member
198 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_add_head() local
199 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_add_head()
215 grpc_resource_quota* resource_quota = resource_user->resource_quota; in rulist_add_tail() local
216 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_add_tail()
229 static bool rulist_empty(grpc_resource_quota* resource_quota, in rulist_empty() argument
231 return resource_quota->roots[list] == nullptr; in rulist_empty()
234 static grpc_resource_user* rulist_pop_head(grpc_resource_quota* resource_quota, in rulist_pop_head() argument
236 grpc_resource_user** root = &resource_quota->roots[list]; in rulist_pop_head()
256 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()
90 socket, connect->resource_quota, connect->addr_name.c_str()); in custom_connect_callback_internal()
121 grpc_resource_quota* resource_quota = grpc_resource_quota_create(nullptr); in tcp_connect() local
125 grpc_resource_quota_unref_internal(resource_quota); in tcp_connect()
126 resource_quota = in tcp_connect()
140 connect->resource_quota = resource_quota; in tcp_connect()
|
| D | resource_quota.h | 74 grpc_resource_quota* resource_quota);
75 void grpc_resource_quota_unref_internal(grpc_resource_quota* resource_quota);
83 grpc_resource_quota* resource_quota);
85 size_t grpc_resource_quota_peek_size(grpc_resource_quota* resource_quota);
90 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()
133 connect->addr_name.c_str(), connect->resource_quota, in OnOpen()
174 grpc_resource_quota* resource_quota = grpc_resource_quota_create(NULL); in CFStreamClientConnect() local
178 grpc_resource_quota_unref_internal(resource_quota); in CFStreamClientConnect()
179 resource_quota = grpc_resource_quota_ref_internal( in CFStreamClientConnect()
184 connect->resource_quota = resource_quota; in CFStreamClientConnect()
|
| D | tcp_server_custom.cc | 80 grpc_resource_quota* resource_quota; member
90 s->resource_quota = grpc_resource_quota_create(nullptr); in tcp_server_create()
97 grpc_resource_quota_unref_internal(s->resource_quota); in tcp_server_create()
98 s->resource_quota = grpc_resource_quota_ref_internal( in tcp_server_create()
101 grpc_resource_quota_unref_internal(s->resource_quota); in tcp_server_create()
147 grpc_resource_quota_unref_internal(s->resource_quota); in finish_shutdown()
238 ep = custom_tcp_endpoint_create(socket, sp->server->resource_quota, in finish_accept()
|
| /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()
|
| /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()
|
| /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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/http/ |
| D | httpcli.cc | 66 grpc_resource_quota* resource_quota; member
109 grpc_resource_quota_unref_internal(req->resource_quota); in finish()
212 const_cast<char*>(GRPC_ARG_RESOURCE_QUOTA), req->resource_quota, in next_address()
231 grpc_resource_quota* resource_quota, in internal_request_begin() argument
249 req->resource_quota = grpc_resource_quota_ref_internal(resource_quota); in internal_request_begin()
270 grpc_resource_quota* resource_quota, in grpc_httpcli_get() argument
278 internal_request_begin(context, pollent, resource_quota, request, deadline, in grpc_httpcli_get()
285 grpc_resource_quota* resource_quota, in grpc_httpcli_post() argument
297 context, pollent, resource_quota, request, deadline, on_done, response, in grpc_httpcli_post()
|
| /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/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/external/ |
| D | aws_external_account_credentials.cc | 170 grpc_resource_quota* resource_quota = in RetrieveRegion() local
175 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveRegion()
177 grpc_resource_quota_unref_internal(resource_quota); in RetrieveRegion()
220 grpc_resource_quota* resource_quota = in RetrieveRoleName() local
225 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveRoleName()
227 grpc_resource_quota_unref_internal(resource_quota); in RetrieveRoleName()
283 grpc_resource_quota* resource_quota = in RetrieveSigningKeys() local
288 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveSigningKeys()
290 grpc_resource_quota_unref_internal(resource_quota); in RetrieveSigningKeys()
|
| /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/rust/crates/grpcio-sys/grpc/test/core/security/ |
| D | ssl_server_fuzzer.cc | 62 grpc_resource_quota* resource_quota = in LLVMFuzzerTestOneInput() local
65 grpc_mock_endpoint_create(discard_write, resource_quota); in LLVMFuzzerTestOneInput()
66 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/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/oauth2/ |
| D | oauth2_credentials.cc | 398 grpc_resource_quota* resource_quota = in fetch_oauth2() local
400 grpc_httpcli_get(http_context, pollent, resource_quota, &request, deadline, in fetch_oauth2()
404 grpc_resource_quota_unref_internal(resource_quota); in fetch_oauth2()
458 grpc_resource_quota* resource_quota = in fetch_oauth2() local
460 grpc_httpcli_post(httpcli_context, pollent, resource_quota, &request, in fetch_oauth2()
465 grpc_resource_quota_unref_internal(resource_quota); in fetch_oauth2()
590 grpc_resource_quota* resource_quota = in fetch_oauth2() local
593 http_context, pollent, resource_quota, &request, body, body_length, in fetch_oauth2()
598 grpc_resource_quota_unref_internal(resource_quota); in fetch_oauth2()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/ |
| D | grpc.h | 495 GRPCAPI void grpc_resource_quota_ref(grpc_resource_quota* resource_quota);
498 GRPCAPI void grpc_resource_quota_unref(grpc_resource_quota* resource_quota);
501 GRPCAPI void grpc_resource_quota_resize(grpc_resource_quota* resource_quota,
506 grpc_resource_quota* resource_quota, int new_max_threads);
|