| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 39 static gpr_mu g_mu; variable
68 gpr_mu_unlock(&g_mu); in gc_completed_threads()
75 gpr_mu_lock(&g_mu); in gc_completed_threads()
83 gpr_mu_unlock(&g_mu); in start_timer_thread_and_unlock()
101 gpr_mu_lock(&g_mu); in run_some_timers()
115 gpr_mu_unlock(&g_mu); in run_some_timers()
122 gpr_mu_lock(&g_mu); in run_some_timers()
127 gpr_mu_unlock(&g_mu); in run_some_timers()
134 gpr_mu_lock(&g_mu); in wait_until()
137 gpr_mu_unlock(&g_mu); in wait_until()
[all …]
|
| D | iomgr.cc | 43 static gpr_mu g_mu; variable
52 gpr_mu_init(&g_mu); in grpc_iomgr_init()
92 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
107 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
110 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
126 if (gpr_cv_wait(&g_rcv, &g_mu, short_deadline)) { in grpc_iomgr_shutdown()
142 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
148 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
149 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
153 gpr_mu_destroy(&g_mu); in grpc_iomgr_shutdown()
[all …]
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | tcp_client_uv_test.cc | 40 static gpr_mu* g_mu; variable
50 gpr_mu_lock(g_mu); in finish_connection()
54 gpr_mu_unlock(g_mu); in finish_connection()
103 gpr_mu_lock(g_mu); in test_succeeds()
105 gpr_mu_unlock(g_mu); in test_succeeds()
114 gpr_mu_lock(g_mu); in test_succeeds()
123 gpr_mu_unlock(g_mu); in test_succeeds()
125 gpr_mu_lock(g_mu); in test_succeeds()
131 gpr_mu_unlock(g_mu); in test_succeeds()
147 gpr_mu_lock(g_mu); in test_fails()
[all …]
|
| D | tcp_client_posix_test.cc | 44 static gpr_mu* g_mu; variable
54 gpr_mu_lock(g_mu); in finish_connection()
60 gpr_mu_unlock(g_mu); in finish_connection()
102 gpr_mu_lock(g_mu); in test_succeeds()
104 gpr_mu_unlock(g_mu); in test_succeeds()
122 gpr_mu_lock(g_mu); in test_succeeds()
131 gpr_mu_unlock(g_mu); in test_succeeds()
133 gpr_mu_lock(g_mu); in test_succeeds()
136 gpr_mu_unlock(g_mu); in test_succeeds()
153 gpr_mu_lock(g_mu); in test_fails()
[all …]
|
| D | fd_posix_test.cc | 49 static gpr_mu* g_mu; variable
176 gpr_mu_lock(g_mu); in listen_shutdown_cb()
180 gpr_mu_unlock(g_mu); in listen_shutdown_cb()
248 gpr_mu_lock(g_mu); in server_wait_and_shutdown()
255 gpr_mu_unlock(g_mu); in server_wait_and_shutdown()
257 gpr_mu_lock(g_mu); in server_wait_and_shutdown()
259 gpr_mu_unlock(g_mu); in server_wait_and_shutdown()
306 gpr_mu_lock(g_mu); in client_session_write()
308 gpr_mu_unlock(g_mu); in client_session_write()
318 gpr_mu_lock(g_mu); in client_session_write()
[all …]
|
| D | udp_server_test.cc | 49 static gpr_mu* g_mu; variable
74 gpr_mu_lock(g_mu); in Read()
84 gpr_mu_unlock(g_mu); in Read()
90 gpr_mu_lock(g_mu); in OnCanWrite()
95 gpr_mu_unlock(g_mu); in OnCanWrite()
178 gpr_mu_lock(g_mu); in shutdown_and_destroy_pollset()
182 gpr_mu_unlock(g_mu); in shutdown_and_destroy_pollset()
188 grpc_pollset_init(g_pollset, &g_mu); in test_no_op()
197 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_start()
207 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_port()
[all …]
|
| D | tcp_posix_test.cc | 46 static gpr_mu* g_mu; variable
182 gpr_mu_lock(g_mu); in read_cb()
192 gpr_mu_unlock(g_mu); in read_cb()
195 gpr_mu_unlock(g_mu); in read_cb()
234 gpr_mu_lock(g_mu); in read_test()
239 gpr_mu_unlock(g_mu); in read_test()
241 gpr_mu_lock(g_mu); in read_test()
244 gpr_mu_unlock(g_mu); in read_test()
285 gpr_mu_lock(g_mu); in large_read_test()
290 gpr_mu_unlock(g_mu); in large_read_test()
[all …]
|
| D | endpoint_tests.cc | 49 static gpr_mu* g_mu; variable
127 gpr_mu_lock(g_mu); in read_and_write_test_read_handler()
130 gpr_mu_unlock(g_mu); in read_and_write_test_read_handler()
161 gpr_mu_lock(g_mu); in read_and_write_test_write_handler()
164 gpr_mu_unlock(g_mu); in read_and_write_test_write_handler()
231 gpr_mu_lock(g_mu); in read_and_write_test()
238 gpr_mu_unlock(g_mu); in read_and_write_test()
249 gpr_mu_lock(g_mu); in inc_on_failure()
252 gpr_mu_unlock(g_mu); in inc_on_failure()
257 gpr_mu_lock(g_mu); in wait_for_fail_count()
[all …]
|
| D | tcp_server_posix_test.cc | 50 static gpr_mu* g_mu; variable
157 gpr_mu_lock(g_mu); in on_connect()
162 gpr_mu_unlock(g_mu); in on_connect()
233 gpr_mu_lock(g_mu); in tcp_connect()
238 gpr_mu_unlock(g_mu); in tcp_connect()
244 gpr_mu_unlock(g_mu); in tcp_connect()
255 gpr_mu_unlock(g_mu); in tcp_connect()
259 gpr_mu_unlock(g_mu); in tcp_connect()
261 gpr_mu_lock(g_mu); in tcp_connect()
265 gpr_mu_unlock(g_mu); in tcp_connect()
[all …]
|
| D | tcp_server_uv_test.cc | 44 static gpr_mu* g_mu; variable
109 gpr_mu_lock(g_mu); in on_connect()
114 gpr_mu_unlock(g_mu); in on_connect()
189 gpr_mu_lock(g_mu); in tcp_connect()
203 gpr_mu_unlock(g_mu); in tcp_connect()
205 gpr_mu_lock(g_mu); in tcp_connect()
212 gpr_mu_unlock(g_mu); in tcp_connect()
291 grpc_pollset_init(g_pollset, &g_mu); in main()
|
| D | endpoint_pair_test.cc | 29 static gpr_mu* g_mu; variable
68 grpc_pollset_init(g_pollset, &g_mu); in main()
69 grpc_endpoint_tests(configs[0], g_pollset, g_mu); in main()
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamClientTests.mm | 36 static gpr_mu g_mu;
41 gpr_mu_lock(&g_mu);
43 gpr_mu_unlock(&g_mu);
71 gpr_mu_init(&g_mu);
99 gpr_mu_lock(&g_mu);
101 gpr_mu_unlock(&g_mu);
121 gpr_mu_lock(&g_mu);
124 gpr_mu_unlock(&g_mu);
126 gpr_mu_lock(&g_mu);
130 gpr_mu_unlock(&g_mu);
[all …]
|
| /external/grpc-grpc/test/core/http/ |
| D | httpcli_test.cc | 36 static gpr_mu* g_mu; variable
55 gpr_mu_lock(g_mu); in on_finish()
60 gpr_mu_unlock(g_mu); in on_finish()
87 gpr_mu_lock(g_mu); in test_get()
93 gpr_mu_unlock(g_mu); in test_get()
95 gpr_mu_lock(g_mu); in test_get()
97 gpr_mu_unlock(g_mu); in test_get()
126 gpr_mu_lock(g_mu); in test_post()
132 gpr_mu_unlock(g_mu); in test_post()
134 gpr_mu_lock(g_mu); in test_post()
[all …]
|
| D | httpscli_test.cc | 38 static gpr_mu* g_mu; variable
57 gpr_mu_lock(g_mu); in on_finish()
62 gpr_mu_unlock(g_mu); in on_finish()
90 gpr_mu_lock(g_mu); in test_get()
96 gpr_mu_unlock(g_mu); in test_get()
98 gpr_mu_lock(g_mu); in test_get()
100 gpr_mu_unlock(g_mu); in test_get()
130 gpr_mu_lock(g_mu); in test_post()
136 gpr_mu_unlock(g_mu); in test_post()
138 gpr_mu_lock(g_mu); in test_post()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | subchannel_index.cc | 37 static gpr_mu g_mu; variable
126 gpr_mu_init(&g_mu); in grpc_subchannel_index_init()
139 gpr_mu_destroy(&g_mu); in grpc_subchannel_index_unref()
149 gpr_mu_lock(&g_mu); in grpc_subchannel_index_find()
151 gpr_mu_unlock(&g_mu); in grpc_subchannel_index_find()
171 gpr_mu_lock(&g_mu); in grpc_subchannel_index_register()
174 gpr_mu_unlock(&g_mu); in grpc_subchannel_index_register()
196 gpr_mu_lock(&g_mu); in grpc_subchannel_index_register()
201 gpr_mu_unlock(&g_mu); in grpc_subchannel_index_register()
221 gpr_mu_lock(&g_mu); in grpc_subchannel_index_unregister()
[all …]
|
| D | retry_throttle.cc | 153 static gpr_mu g_mu; variable
157 gpr_mu_init(&g_mu); in Init()
162 gpr_mu_destroy(&g_mu); in Shutdown()
170 gpr_mu_lock(&g_mu); in GetDataForServer()
186 gpr_mu_unlock(&g_mu); in GetDataForServer()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_status_code.cc | 45 static gpr_mu g_mu; variable
129 gpr_mu_lock(&g_mu); in test_request()
134 gpr_mu_unlock(&g_mu); in test_request()
141 gpr_mu_lock(&g_mu); in test_request()
143 gpr_mu_unlock(&g_mu); in test_request()
186 gpr_mu_lock(&g_mu); in test_request()
188 gpr_mu_unlock(&g_mu); in test_request()
238 gpr_mu_lock(&g_mu); in test_request()
240 GPR_ASSERT(gpr_cv_wait(&g_client_code_cv, &g_mu, in test_request()
244 GPR_ASSERT(gpr_cv_wait(&g_server_code_cv, &g_mu, in test_request()
[all …]
|
| D | filter_latency.cc | 38 static gpr_mu g_mu; variable
121 gpr_mu_lock(&g_mu); in test_request()
124 gpr_mu_unlock(&g_mu); in test_request()
233 gpr_mu_lock(&g_mu); in test_request()
243 gpr_mu_unlock(&g_mu); in test_request()
258 gpr_mu_lock(&g_mu); in client_destroy_call_elem()
260 gpr_mu_unlock(&g_mu); in client_destroy_call_elem()
266 gpr_mu_lock(&g_mu); in server_destroy_call_elem()
268 gpr_mu_unlock(&g_mu); in server_destroy_call_elem()
328 gpr_mu_init(&g_mu); in init_plugin()
[all …]
|
| /external/grpc-grpc/src/core/lib/profiling/ |
| D | basic_timers.cc | 67 static pthread_mutex_t g_mu; variable
155 pthread_mutex_lock(&g_mu); in writing_thread()
158 pthread_cond_wait(&g_cv, &g_mu); in writing_thread()
161 pthread_mutex_unlock(&g_mu); in writing_thread()
164 pthread_mutex_lock(&g_mu); in writing_thread()
167 pthread_mutex_unlock(&g_mu); in writing_thread()
182 pthread_mutex_lock(&g_mu); in finish_writing()
185 pthread_mutex_unlock(&g_mu); in finish_writing()
190 pthread_mutex_lock(&g_mu); in finish_writing()
193 pthread_mutex_unlock(&g_mu); in finish_writing()
[all …]
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_connectivity_test.cc | 34 static gpr_mu g_mu; variable
42 gpr_mu_lock(&g_mu); in my_resolve_address()
47 gpr_mu_unlock(&g_mu); in my_resolve_address()
50 gpr_mu_unlock(&g_mu); in my_resolve_address()
68 gpr_mu_lock(&g_mu); in my_dns_lookup_ares_locked()
73 gpr_mu_unlock(&g_mu); in my_dns_lookup_ares_locked()
76 gpr_mu_unlock(&g_mu); in my_dns_lookup_ares_locked()
147 gpr_mu_init(&g_mu); in main()
182 gpr_mu_destroy(&g_mu); in main()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 37 static gpr_mu g_mu; variable
156 gpr_mu_lock(&g_mu); in BM_Cq_Throughput()
164 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
167 gpr_mu_unlock(&g_mu); in BM_Cq_Throughput()
181 gpr_mu_lock(&g_mu); in BM_Cq_Throughput()
187 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
190 gpr_mu_unlock(&g_mu); in BM_Cq_Throughput()
210 gpr_mu_init(&g_mu); in main()
|
| /external/grpc-grpc/src/core/lib/security/credentials/alts/ |
| D | check_gcp_environment_linux.cc | 36 static gpr_mu g_mu; variable
54 static void init_mu(void) { gpr_mu_init(&g_mu); } in init_mu()
58 gpr_mu_lock(&g_mu); in grpc_alts_is_running_on_gcp()
64 gpr_mu_unlock(&g_mu); in grpc_alts_is_running_on_gcp()
|
| D | check_gcp_environment_windows.cc | 44 static gpr_mu g_mu; variable
61 static void init_mu(void) { gpr_mu_init(&g_mu); } in init_mu()
103 gpr_mu_lock(&g_mu); in grpc_alts_is_running_on_gcp()
110 gpr_mu_unlock(&g_mu); in grpc_alts_is_running_on_gcp()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | goaway_server_test.cc | 44 static gpr_mu g_mu; variable
54 gpr_mu_lock(&g_mu); in set_resolve_port()
56 gpr_mu_unlock(&g_mu); in set_resolve_port()
70 gpr_mu_lock(&g_mu); in my_resolve_address()
72 gpr_mu_unlock(&g_mu); in my_resolve_address()
86 gpr_mu_unlock(&g_mu); in my_resolve_address()
113 gpr_mu_lock(&g_mu); in my_dns_lookup_ares_locked()
115 gpr_mu_unlock(&g_mu); in my_dns_lookup_ares_locked()
127 gpr_mu_unlock(&g_mu); in my_dns_lookup_ares_locked()
141 gpr_mu_init(&g_mu); in main()
[all …]
|
| /external/grpc-grpc/test/core/security/ |
| D | secure_endpoint_test.cc | 35 static gpr_mu* g_mu; variable
217 grpc_pollset_init(g_pollset, &g_mu); in main()
218 grpc_endpoint_tests(configs[0], g_pollset, g_mu); in main()
219 grpc_endpoint_tests(configs[1], g_pollset, g_mu); in main()
|