Home
last modified time | relevance | path

Searched refs:gpr_mu_lock (Results 1 – 25 of 110) sorted by relevance

12345

/third_party/grpc/test/core/iomgr/
Dpollset_windows_starvation_test.cc84 gpr_mu_lock(mu); in main()
86 gpr_mu_lock(&tparams->mu); in main()
100 gpr_mu_lock(&tparams->mu); in main()
111 gpr_mu_lock(&params.mu); in main()
125 gpr_mu_lock(params.pollset_mu[i]); in main()
132 gpr_mu_lock(&params.mu); in main()
Dtcp_client_posix_test.cc54 gpr_mu_lock(g_mu); in finish_connection()
102 gpr_mu_lock(g_mu); in test_succeeds()
122 gpr_mu_lock(g_mu); in test_succeeds()
133 gpr_mu_lock(g_mu); in test_succeeds()
153 gpr_mu_lock(g_mu); in test_fails()
162 gpr_mu_lock(g_mu); in test_fails()
182 gpr_mu_lock(g_mu); in test_fails()
Dtcp_client_uv_test.cc50 gpr_mu_lock(g_mu); in finish_connection()
103 gpr_mu_lock(g_mu); in test_succeeds()
114 gpr_mu_lock(g_mu); in test_succeeds()
125 gpr_mu_lock(g_mu); in test_succeeds()
148 gpr_mu_lock(g_mu); in test_fails()
157 gpr_mu_lock(g_mu); in test_fails()
178 gpr_mu_lock(g_mu); in test_fails()
Dfd_posix_test.cc176 gpr_mu_lock(g_mu); in listen_shutdown_cb()
248 gpr_mu_lock(g_mu); in server_wait_and_shutdown()
257 gpr_mu_lock(g_mu); in server_wait_and_shutdown()
306 gpr_mu_lock(g_mu); in client_session_write()
318 gpr_mu_lock(g_mu); in client_session_write()
364 gpr_mu_lock(g_mu); in client_wait_and_shutdown()
373 gpr_mu_lock(g_mu); in client_wait_and_shutdown()
410 gpr_mu_lock(g_mu); in first_read_callback()
421 gpr_mu_lock(g_mu); in second_read_callback()
467 gpr_mu_lock(g_mu); in test_grpc_fd_change()
[all …]
Dtcp_posix_test.cc182 gpr_mu_lock(g_mu); in read_cb()
235 gpr_mu_lock(g_mu); in read_test()
242 gpr_mu_lock(g_mu); in read_test()
286 gpr_mu_lock(g_mu); in large_read_test()
293 gpr_mu_lock(g_mu); in large_read_test()
336 gpr_mu_lock(g_mu); in write_done()
357 gpr_mu_lock(g_mu); in drain_socket_blocking()
454 gpr_mu_lock(g_mu); in write_test()
466 gpr_mu_lock(g_mu); in write_test()
525 gpr_mu_lock(g_mu); in release_fd_test()
[all …]
/third_party/grpc/src/core/lib/iomgr/
Dtimer_manager.cc78 gpr_mu_lock(&g_mu); in gc_completed_threads()
111 gpr_mu_lock(&g_mu); in run_some_timers()
135 gpr_mu_lock(&g_mu); in run_some_timers()
147 gpr_mu_lock(&g_mu); in wait_until()
264 gpr_mu_lock(&g_mu); in timer_thread_cleanup()
290 gpr_mu_lock(&g_mu); in start_threads()
315 gpr_mu_lock(&g_mu); in stop_threads()
354 gpr_mu_lock(&g_mu); in grpc_kick_poller()
Diomgr.cc99 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
117 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
155 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
178 gpr_mu_lock(&g_mu); in grpc_iomgr_register_object()
186 gpr_mu_lock(&g_mu); in grpc_iomgr_unregister_object()
Dudp_server.cc231 gpr_mu_lock(sp->mutex()); in shutdown_fd()
266 gpr_mu_lock(&s->mu); in destroyed_port()
281 gpr_mu_lock(&s->mu); in deactivated_all_ports()
308 gpr_mu_lock(&s->mu); in grpc_udp_server_destroy()
330 gpr_mu_lock(&mutex_); in OnFdAboutToOrphan()
445 gpr_mu_lock(sp->mutex()); in do_read()
470 gpr_mu_lock(&server_->mu); in OnRead()
502 gpr_mu_lock(sp->mutex()); in fd_notify_on_write_wrapper()
513 gpr_mu_lock(sp->mutex()); in do_write()
537 gpr_mu_lock(&server_->mu); in OnCanWrite()
[all …]
Dev_poll_posix.cc267 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_remove_node()
283 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_add_node()
398 gpr_mu_lock(&watcher->pollset->mu);
459 gpr_mu_lock(&fd->mu);
541 gpr_mu_lock(&fd->mu);
557 gpr_mu_lock(&fd->mu);
564 gpr_mu_lock(&fd->mu);
570 gpr_mu_lock(&fd->mu);
583 gpr_mu_lock(&fd->mu);
589 gpr_mu_lock(&fd->mu);
[all …]
Dtcp_server_posix.cc111 gpr_mu_lock(&s->mu); in finish_shutdown()
134 gpr_mu_lock(&s->mu); in destroyed_port()
150 gpr_mu_lock(&s->mu); in deactivated_all_ports()
171 gpr_mu_lock(&s->mu); in tcp_server_destroy()
214 gpr_mu_lock(&sp->server->mu); in on_read()
274 gpr_mu_lock(&sp->server->mu); in on_read()
467 gpr_mu_lock(&s->mu); in tcp_server_port_fd_count()
478 gpr_mu_lock(&s->mu); in tcp_server_port_fd()
497 gpr_mu_lock(&s->mu); in tcp_server_start()
538 gpr_mu_lock(&s->mu); in tcp_server_shutdown_starting_add()
[all …]
Dev_epoll1_linux.cc290 gpr_mu_lock(&fd_freelist_mu); in fd_global_shutdown()
302 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_add_grpc_fd()
317 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_remove_grpc_fd()
335 gpr_mu_lock(&fd_freelist_mu); in fd_create()
435 gpr_mu_lock(&fd_freelist_mu); in fd_orphan()
565 gpr_mu_lock(&pollset->mu); in pollset_destroy()
570 gpr_mu_lock(&neighborhood->mu); in pollset_destroy()
571 gpr_mu_lock(&pollset->mu); in pollset_destroy()
776 gpr_mu_lock(&neighborhood->mu); in begin_worker()
777 gpr_mu_lock(&pollset->mu); in begin_worker()
[all …]
Dtimer_generic.cc112 gpr_mu_lock(&g_hash_mu[i]); in is_in_ht()
126 gpr_mu_lock(&g_hash_mu[i]); in add_to_ht()
152 gpr_mu_lock(&g_hash_mu[i]); in remove_from_ht()
381 gpr_mu_lock(&shard->mu); in timer_init()
424 gpr_mu_lock(&g_shared_mutables.mu); in timer_init()
468 gpr_mu_lock(&shard->mu); in timer_cancel()
567 gpr_mu_lock(&shard->mu); in pop_timers()
600 gpr_mu_lock(&g_shared_mutables.mu); in run_some_expired_timers()
610 gpr_mu_lock(&g_shared_mutables.mu); in run_some_expired_timers()
689 gpr_mu_lock(&g_shared_mutables.mu); in timer_check()
/third_party/grpc/src/core/lib/gprpp/
Dfork.cc74 gpr_mu_lock(&mu_); in IncExecCtxCount()
93 gpr_mu_lock(&mu_); in BlockExecCtx()
102 gpr_mu_lock(&mu_); in AllowExecCtx()
129 gpr_mu_lock(&mu_); in IncThreadCount()
135 gpr_mu_lock(&mu_); in DecThreadCount()
144 gpr_mu_lock(&mu_); in AwaitThreads()
/third_party/grpc/include/grpcpp/impl/codegen/
Dsync.h72 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
75 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
89 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
92 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
103 g_core_codegen_interface->gpr_mu_lock(mu_); in Lock()
/third_party/grpc/test/core/gpr/
Dsync_test.cc70 gpr_mu_lock(&q->mu); in queue_append()
114 gpr_mu_lock(&q->mu); in queue_remove()
205 gpr_mu_lock(&m->mu); in test_wait()
218 gpr_mu_lock(&m->mu); in thread_id()
227 gpr_mu_lock(&m->mu); in mark_thread_done()
290 gpr_mu_lock(&m->mu); in inc()
319 gpr_mu_lock(&m->mu); in inc_by_turns()
337 gpr_mu_lock(&m->mu); in inc_with_1ms_delay()
358 gpr_mu_lock(&m->mu); in inc_with_1ms_delay_event()
396 gpr_mu_lock(&m->mu); in consumer()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/
Dglobal_subchannel_pool.cc66 gpr_mu_lock(&mu_); in RegisterSubchannel()
109 gpr_mu_lock(&mu_); in RegisterSubchannel()
127 gpr_mu_lock(&mu_); in UnregisterSubchannel()
138 gpr_mu_lock(&mu_); in UnregisterSubchannel()
152 gpr_mu_lock(&mu_); in FindSubchannel()
Dbackup_poller.cc97 gpr_mu_lock(&g_poller_mu); in g_poller_unref()
102 gpr_mu_lock(p->pollset_mu); in g_poller_unref()
124 gpr_mu_lock(p->pollset_mu); in run_poller()
162 gpr_mu_lock(&g_poller_mu); in grpc_client_channel_start_backup_polling()
/third_party/grpc/test/core/iomgr/ios/CFStreamTests/
DCFStreamClientTests.mm41 gpr_mu_lock(&g_mu);
99 gpr_mu_lock(&g_mu);
121 gpr_mu_lock(&g_mu);
126 gpr_mu_lock(&g_mu);
155 gpr_mu_lock(&g_mu);
167 gpr_mu_lock(&g_mu);
172 gpr_mu_lock(&g_mu);
/third_party/grpc/test/core/http/
Dhttpcli_test.cc55 gpr_mu_lock(g_mu); in on_finish()
87 gpr_mu_lock(g_mu); in test_get()
95 gpr_mu_lock(g_mu); in test_get()
126 gpr_mu_lock(g_mu); in test_post()
134 gpr_mu_lock(g_mu); in test_post()
Dhttpscli_test.cc58 gpr_mu_lock(g_mu); in on_finish()
91 gpr_mu_lock(g_mu); in test_get()
99 gpr_mu_lock(g_mu); in test_get()
131 gpr_mu_lock(g_mu); in test_post()
139 gpr_mu_lock(g_mu); in test_post()
/third_party/grpc/src/ruby/ext/grpc/
Drb_channel.c128 gpr_mu_lock(&global_connection_polling_mu); in grpc_rb_channel_safe_destroy()
277 gpr_mu_lock(&global_connection_polling_mu); in get_state_without_gil()
332 gpr_mu_lock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_without_gvl()
359 gpr_mu_lock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_unblocking_func()
557 gpr_mu_lock(&global_connection_polling_mu); in channel_init_try_register_connection_polling_without_gil()
612 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
624 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
653 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_unblocking_func()
698 gpr_mu_lock(&global_connection_polling_mu); in wait_until_channel_polling_thread_started_no_gil()
712 gpr_mu_lock(&global_connection_polling_mu); in wait_until_channel_polling_thread_started_unblocking_func()
[all …]
/third_party/grpc/test/core/end2end/tests/
Dfilter_status_code.cc129 gpr_mu_lock(&g_mu); in test_request()
141 gpr_mu_lock(&g_mu); in test_request()
186 gpr_mu_lock(&g_mu); in test_request()
238 gpr_mu_lock(&g_mu); in test_request()
263 gpr_mu_lock(&g_mu); in server_start_transport_stream_op_batch()
289 gpr_mu_lock(&g_mu); in client_destroy_call_elem()
304 gpr_mu_lock(&g_mu); in server_destroy_call_elem()
/third_party/grpc/test/core/util/
Dtrickle_endpoint.cc68 gpr_mu_lock(&te->mu); in te_write()
101 gpr_mu_lock(&te->mu); in te_shutdown()
139 gpr_mu_lock(&te->mu); in te_finish_write()
179 gpr_mu_lock(&te->mu); in grpc_trickle_endpoint_trickle()
205 gpr_mu_lock(&te->mu); in grpc_trickle_get_backlog()
Dport_server_client.cc52 gpr_mu_lock(pr->mu); in freed_port_from_server()
97 gpr_mu_lock(pr.mu); in grpc_free_port_using_server()
152 gpr_mu_lock(pr->mu); in got_port_from_server()
189 gpr_mu_lock(pr->mu); in got_port_from_server()
231 gpr_mu_lock(pr.mu); in grpc_pick_port_using_server()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_cq.cc173 gpr_mu_lock(&mu); in Run()
193 gpr_mu_lock(&shutdown_mu); in Run()
232 gpr_mu_lock(&mu); in BM_Callback_CQ_Pass1Core()
240 gpr_mu_lock(&shutdown_mu); in BM_Callback_CQ_Pass1Core()
277 gpr_mu_lock(&mu); in BM_Callback_CQ_Pass1CoreHeapCompletion()
285 gpr_mu_lock(&shutdown_mu); in BM_Callback_CQ_Pass1CoreHeapCompletion()

12345