Home
last modified time | relevance | path

Searched refs:ExecCtx (Results 1 – 25 of 212) sorted by relevance

123456789

/external/grpc-grpc/test/core/iomgr/
Dresource_quota_test.cc88 grpc_core::ExecCtx exec_ctx; in destroy_user()
121 grpc_core::ExecCtx exec_ctx; in test_instant_alloc_then_free()
125 grpc_core::ExecCtx exec_ctx; in test_instant_alloc_then_free()
139 grpc_core::ExecCtx exec_ctx; in test_instant_alloc_free_pair()
156 grpc_core::ExecCtx exec_ctx; in test_simple_async_alloc()
158 grpc_core::ExecCtx::Get()->Flush(); in test_simple_async_alloc()
163 grpc_core::ExecCtx exec_ctx; in test_simple_async_alloc()
179 grpc_core::ExecCtx exec_ctx; in test_async_alloc_blocked_by_size()
181 grpc_core::ExecCtx::Get()->Flush(); in test_async_alloc_blocked_by_size()
190 grpc_core::ExecCtx exec_ctx; in test_async_alloc_blocked_by_size()
[all …]
Dtimer_list_test.cc51 grpc_core::ExecCtx exec_ctx; in add_test()
60 grpc_millis start = grpc_core::ExecCtx::Get()->Now(); in add_test()
77 grpc_core::ExecCtx::Get()->TestOnlySetNow(start + 500); in add_test()
79 grpc_core::ExecCtx::Get()->Flush(); in add_test()
85 grpc_core::ExecCtx::Get()->TestOnlySetNow(start + 600); in add_test()
87 grpc_core::ExecCtx::Get()->Flush(); in add_test()
94 grpc_core::ExecCtx::Get()->TestOnlySetNow(start + 1500); in add_test()
96 grpc_core::ExecCtx::Get()->Flush(); in add_test()
102 grpc_core::ExecCtx::Get()->TestOnlySetNow(start + 1600); in add_test()
115 grpc_core::ExecCtx exec_ctx; in destruction_test()
[all …]
Dresolve_address_test.cc72 grpc_core::ExecCtx::Get()->Flush(); in args_finish()
83 grpc_core::ExecCtx exec_ctx; in poll_pollset_until_request_done()
90 grpc_millis time_left = deadline - grpc_core::ExecCtx::Get()->Now(); in poll_pollset_until_request_done()
98 grpc_core::ExecCtx::Get()->Flush(); in poll_pollset_until_request_done()
124 grpc_core::ExecCtx exec_ctx; in test_localhost()
131 grpc_core::ExecCtx::Get()->Flush(); in test_localhost()
137 grpc_core::ExecCtx exec_ctx; in test_default_port()
144 grpc_core::ExecCtx::Get()->Flush(); in test_default_port()
150 grpc_core::ExecCtx exec_ctx; in test_non_numeric_default_port()
157 grpc_core::ExecCtx::Get()->Flush(); in test_non_numeric_default_port()
[all …]
Dev_epollex_linux_test.cc38 grpc_core::ExecCtx exec_ctx; in test_pollable_owner_fd()
57 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
62 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
66 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
70 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
79 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
83 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
90 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
98 grpc_core::ExecCtx exec_ctx; in main()
Dev_epollsig_linux_test.cc80 grpc_core::ExecCtx::Get()->Flush(); in test_fd_cleanup()
83 grpc_core::ExecCtx::Get()->Flush(); in test_fd_cleanup()
112 grpc_core::ExecCtx::Get()->Flush(); in test_pollset_cleanup()
132 grpc_core::ExecCtx exec_ctx; in test_add_fd_to_pollset()
170 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
175 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
180 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
186 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
191 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
195 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
[all …]
Dpollset_set_test.cc87 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_pollsets()
132 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_fds()
140 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_fds()
201 grpc_core::ExecCtx exec_ctx; in pollset_set_test_basic()
238 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
261 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
264 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
272 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
279 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
303 grpc_core::ExecCtx exec_ctx; in pollset_set_test_dup_fds()
[all …]
Dcombiner_test.cc31 grpc_core::ExecCtx exec_ctx; in test_no_op()
45 grpc_core::ExecCtx exec_ctx; in test_execute_one()
49 grpc_core::ExecCtx::Get()->Flush(); in test_execute_one()
75 grpc_core::ExecCtx exec_ctx; in execute_many_loop()
85 grpc_core::ExecCtx::Get()->Flush(); in execute_many_loop()
114 grpc_core::ExecCtx exec_ctx; in test_execute_many()
135 grpc_core::ExecCtx exec_ctx; in test_execute_finally()
140 grpc_core::ExecCtx::Get()->Flush(); in test_execute_finally()
Dresolve_address_posix_test.cc74 grpc_core::ExecCtx::Get()->Flush(); in args_finish()
88 grpc_core::ExecCtx exec_ctx; in actually_poll()
93 grpc_millis time_left = deadline - grpc_core::ExecCtx::Get()->Now(); in actually_poll()
101 grpc_core::ExecCtx::Get()->Flush(); in actually_poll()
127 grpc_core::ExecCtx exec_ctx; in test_unix_socket()
139 grpc_core::ExecCtx exec_ctx; in test_unix_socket_path_name_too_long()
165 grpc_core::ExecCtx exec_ctx; in main()
/external/grpc-grpc/test/core/backoff/
Dbackoff_test.cc39 grpc_core::ExecCtx exec_ctx; in TEST()
48 EXPECT_EQ(next_attempt_start_time - grpc_core::ExecCtx::Get()->Now(), in TEST()
52 EXPECT_EQ(next_attempt_start_time - grpc_core::ExecCtx::Get()->Now(), in TEST()
62 grpc_core::ExecCtx exec_ctx; in TEST()
70 EXPECT_EQ(next - grpc_core::ExecCtx::Get()->Now(), initial_backoff); in TEST()
86 grpc_core::ExecCtx exec_ctx; in TEST()
87 grpc_core::ExecCtx::Get()->TestOnlySetNow(0); in TEST()
90 grpc_core::ExecCtx::Get()->TestOnlySetNow(next); in TEST()
93 grpc_core::ExecCtx::Get()->TestOnlySetNow(next); in TEST()
96 grpc_core::ExecCtx::Get()->TestOnlySetNow(next); in TEST()
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc38 grpc_core::ExecCtx exec_ctx; in BM_NoOpExecCtx()
46 grpc_core::ExecCtx exec_ctx; in BM_WellFlushed()
48 grpc_core::ExecCtx::Get()->Flush(); in BM_WellFlushed()
72 grpc_core::ExecCtx exec_ctx; in BM_ClosureInitAgainstCombiner()
87 grpc_core::ExecCtx exec_ctx; in BM_ClosureRunOnExecCtx()
90 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureRunOnExecCtx()
99 grpc_core::ExecCtx exec_ctx; in BM_ClosureCreateAndRun()
112 grpc_core::ExecCtx exec_ctx; in BM_ClosureInitAndRun()
128 grpc_core::ExecCtx exec_ctx; in BM_ClosureSchedOnExecCtx()
131 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSchedOnExecCtx()
[all …]
Dbm_metadata.cc94 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromNonInternedSlices()
107 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromInternedSlices()
123 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromInternedSlicesAlreadyInIndex()
140 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromInternedKey()
156 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromNonInternedSlicesWithBackingStore()
172 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromInternedSlicesWithBackingStore()
190 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromInternedKeyWithBackingStore()
205 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromStaticMetadataStrings()
220 grpc_core::ExecCtx exec_ctx; in BM_MetadataFromStaticMetadataStringsNotIndexed()
233 grpc_core::ExecCtx exec_ctx; in BM_MetadataRefUnrefExternal()
[all …]
Dbm_pollset.cc54 grpc_core::ExecCtx exec_ctx; in BM_CreateDestroyPollset()
64 grpc_core::ExecCtx::Get()->Flush(); in BM_CreateDestroyPollset()
66 grpc_core::ExecCtx::Get()->Flush(); in BM_CreateDestroyPollset()
118 grpc_core::ExecCtx exec_ctx; in BM_PollEmptyPollset()
128 grpc_core::ExecCtx::Get()->Flush(); in BM_PollEmptyPollset()
140 grpc_core::ExecCtx exec_ctx; in BM_PollAddFd()
147 grpc_core::ExecCtx::Get()->Flush(); in BM_PollAddFd()
156 grpc_core::ExecCtx::Get()->Flush(); in BM_PollAddFd()
222 grpc_core::ExecCtx exec_ctx; in BM_SingleThreadPollOneFd()
252 grpc_core::ExecCtx::Get()->Flush(); in BM_SingleThreadPollOneFd()
/external/grpc-grpc/src/core/lib/iomgr/
Dexec_ctx.h88 class ExecCtx {
92 ExecCtx() : flags_(GRPC_EXEC_CTX_FLAG_IS_FINISHED) { in ExecCtx() function
98 ExecCtx(uintptr_t fl) : flags_(fl) { in ExecCtx() function
106 virtual ~ExecCtx() { in ~ExecCtx()
116 ExecCtx(const ExecCtx&) = delete;
117 ExecCtx& operator=(const ExecCtx&) = delete;
204 static ExecCtx* Get() { in Get()
205 return reinterpret_cast<ExecCtx*>(gpr_tls_get(&exec_ctx_)); in Get()
208 static void Set(ExecCtx* exec_ctx) { in Set()
234 ExecCtx* last_exec_ctx_ = Get();
Dcombiner.cc134 if (grpc_core::ExecCtx::Get()->combiner_data()->active_combiner == nullptr) { in push_last_on_exec_ctx()
135 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner = in push_last_on_exec_ctx()
136 grpc_core::ExecCtx::Get()->combiner_data()->last_combiner = lock; in push_last_on_exec_ctx()
138 grpc_core::ExecCtx::Get() in push_last_on_exec_ctx()
141 grpc_core::ExecCtx::Get()->combiner_data()->last_combiner = lock; in push_last_on_exec_ctx()
147 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner; in push_first_on_exec_ctx()
148 grpc_core::ExecCtx::Get()->combiner_data()->active_combiner = lock; in push_first_on_exec_ctx()
150 grpc_core::ExecCtx::Get()->combiner_data()->last_combiner = lock; in push_first_on_exec_ctx()
170 (gpr_atm)grpc_core::ExecCtx::Get()); in combiner_exec()
179 if (initiator != 0 && initiator != (gpr_atm)grpc_core::ExecCtx::Get()) { in combiner_exec()
[all …]
Dpollset_custom.cc71 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in pollset_work()
78 grpc_core::ExecCtx* curr = grpc_core::ExecCtx::Get(); in pollset_work()
79 grpc_core::ExecCtx::Set(nullptr); in pollset_work()
81 grpc_core::ExecCtx::Set(curr); in pollset_work()
82 grpc_core::ExecCtx::Get()->InvalidateNow(); in pollset_work()
83 if (grpc_core::ExecCtx::Get()->HasWork()) { in pollset_work()
84 grpc_core::ExecCtx::Get()->Flush(); in pollset_work()
Diocp_windows.cc50 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in deadline_to_millis_timeout()
69 grpc_core::ExecCtx::Get()->InvalidateNow(); in grpc_iocp_work()
122 grpc_core::ExecCtx exec_ctx; in grpc_iocp_flush()
128 grpc_core::ExecCtx::Get()->Flush()); in grpc_iocp_flush()
132 grpc_core::ExecCtx exec_ctx; in grpc_iocp_shutdown()
135 grpc_core::ExecCtx::Get()->Flush(); in grpc_iocp_shutdown()
Dexec_ctx.cc50 grpc_closure_list_append(grpc_core::ExecCtx::Get()->closure_list(), closure, in exec_ctx_sched()
110 GPR_TLS_CLASS_DEF(ExecCtx::exec_ctx_);
113 void ExecCtx::TestOnlyGlobalInit(gpr_timespec new_val) { in TestOnlyGlobalInit()
118 void ExecCtx::GlobalInit(void) { in GlobalInit()
123 bool ExecCtx::Flush() { in Flush()
145 grpc_millis ExecCtx::Now() { in Now()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel_index.cc140 grpc_avl_unref(g_subchannel_index, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_unref()
150 grpc_avl index = grpc_avl_ref(g_subchannel_index, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_find()
154 (grpc_subchannel*)grpc_avl_get(index, key, grpc_core::ExecCtx::Get()), in grpc_subchannel_index_find()
156 grpc_avl_unref(index, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_find()
173 grpc_avl_ref(g_subchannel_index, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_register()
178 grpc_avl_get(index, key, grpc_core::ExecCtx::Get())); in grpc_subchannel_index_register()
188 grpc_avl_add(grpc_avl_ref(index, grpc_core::ExecCtx::Get()), in grpc_subchannel_index_register()
191 grpc_core::ExecCtx::Get()); in grpc_subchannel_index_register()
203 grpc_avl_unref(updated, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_register()
205 grpc_avl_unref(index, grpc_core::ExecCtx::Get()); in grpc_subchannel_index_register()
[all …]
/external/grpc-grpc/test/core/transport/
Dconnectivity_state_test.cc62 grpc_core::ExecCtx exec_ctx; in test_check()
78 grpc_core::ExecCtx exec_ctx; in test_subscribe_then_unsubscribe()
84 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_unsubscribe()
88 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_unsubscribe()
100 grpc_core::ExecCtx exec_ctx; in test_subscribe_then_destroy()
106 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_destroy()
111 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_destroy()
121 grpc_core::ExecCtx exec_ctx; in test_subscribe_with_failure_then_destroy()
127 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_with_failure_then_destroy()
131 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_with_failure_then_destroy()
/external/grpc-grpc/test/core/security/
Djwt_verifier_test.cc212 grpc_core::ExecCtx exec_ctx; in test_claims_success()
234 grpc_core::ExecCtx exec_ctx; in test_expired_claims_failure()
255 grpc_core::ExecCtx exec_ctx; in test_invalid_claims_failure()
265 grpc_core::ExecCtx exec_ctx; in test_bad_audience_claims_failure()
279 grpc_core::ExecCtx exec_ctx; in test_bad_subject_claims_failure()
353 grpc_core::ExecCtx exec_ctx; in test_jwt_verifier_google_email_issuer_success()
369 grpc_core::ExecCtx::Get()->Flush(); in test_jwt_verifier_google_email_issuer_success()
386 grpc_core::ExecCtx exec_ctx; in test_jwt_verifier_custom_email_issuer_success()
402 grpc_core::ExecCtx::Get()->Flush(); in test_jwt_verifier_custom_email_issuer_success()
433 grpc_core::ExecCtx exec_ctx; in test_jwt_verifier_url_issuer_success()
[all …]
Dcredentials_test.cc159 grpc_core::ExecCtx exec_ctx; in test_empty_md_array()
168 grpc_core::ExecCtx exec_ctx; in test_add_to_empty_md_array()
183 grpc_core::ExecCtx exec_ctx; in test_add_abunch_to_md_array()
202 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_ok()
219 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_bad_http_status()
231 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_empty_http_body()
242 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_invalid_json()
257 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_missing_token()
271 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_missing_token_type()
287 grpc_core::ExecCtx exec_ctx; in test_oauth2_token_fetcher_creds_parsing_missing_token_lifetime()
[all …]
/external/grpc-grpc/test/core/end2end/fuzzers/
Dserver_fuzzer.cc45 grpc_core::ExecCtx exec_ctx; in LLVMFuzzerTestOneInput()
82 grpc_core::ExecCtx::Get()->Flush(); in LLVMFuzzerTestOneInput()
106 grpc_millis deadline = grpc_core::ExecCtx::Get()->Now() + 5000; in LLVMFuzzerTestOneInput()
120 grpc_core::ExecCtx::Get()->InvalidateNow(); in LLVMFuzzerTestOneInput()
122 grpc_core::ExecCtx::Get()->Now() < deadline); in LLVMFuzzerTestOneInput()
130 grpc_core::ExecCtx::Get()->InvalidateNow(); in LLVMFuzzerTestOneInput()
132 grpc_core::ExecCtx::Get()->Now() < deadline); in LLVMFuzzerTestOneInput()
/external/grpc-grpc/test/core/channel/
Dchannelz_test.cc223 grpc_core::ExecCtx::Get()->InvalidateNow(); in ChannelzSleep()
231 grpc_core::ExecCtx exec_ctx; in TEST_P()
239 grpc_core::ExecCtx exec_ctx; in TEST()
248 grpc_core::ExecCtx exec_ctx; in TEST_P()
266 grpc_core::ExecCtx exec_ctx; in TEST_P()
290 grpc_core::ExecCtx exec_ctx; in TEST()
296 grpc_core::ExecCtx exec_ctx; in TEST()
301 grpc_core::ExecCtx exec_ctx; in TEST()
308 grpc_core::ExecCtx exec_ctx; in TEST()
328 grpc_core::ExecCtx exec_ctx; in TEST_P()
[all …]
/external/grpc-grpc/test/core/util/
Dport_server_client.cc66 grpc_core::ExecCtx exec_ctx; in grpc_free_port_using_server()
90 grpc_core::ExecCtx::Get()->Now() + 30 * GPR_MS_PER_SEC, in grpc_free_port_using_server()
95 grpc_core::ExecCtx::Get()->Flush(); in grpc_free_port_using_server()
103 grpc_core::ExecCtx::Get()->Now() + GPR_MS_PER_SEC))) { in grpc_free_port_using_server()
174 grpc_core::ExecCtx::Get()->Now() + 30 * GPR_MS_PER_SEC, in got_port_from_server()
204 grpc_core::ExecCtx exec_ctx; in grpc_pick_port_using_server()
224 grpc_core::ExecCtx::Get()->Now() + 30 * GPR_MS_PER_SEC, in grpc_pick_port_using_server()
229 grpc_core::ExecCtx::Get()->Flush(); in grpc_pick_port_using_server()
237 grpc_core::ExecCtx::Get()->Now() + GPR_MS_PER_SEC))) { in grpc_pick_port_using_server()
248 grpc_core::ExecCtx::Get()->Flush(); in grpc_pick_port_using_server()
/external/grpc-grpc/test/core/client_channel/resolvers/
Dfake_resolver_test.cc117 grpc_core::ExecCtx exec_ctx; in test_fake_resolver()
136 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
149 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
164 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
167 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
179 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
192 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
202 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
211 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()

123456789