| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 75 gpr_mu_lock(&g_mu); in gc_completed_threads()
101 gpr_mu_lock(&g_mu); in run_some_timers()
122 gpr_mu_lock(&g_mu); in run_some_timers()
134 gpr_mu_lock(&g_mu); in wait_until()
249 gpr_mu_lock(&g_mu); in timer_thread_cleanup()
275 gpr_mu_lock(&g_mu); in start_threads()
300 gpr_mu_lock(&g_mu); in stop_threads()
338 gpr_mu_lock(&g_mu); in grpc_kick_poller()
|
| D | iomgr.cc | 92 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
110 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
148 gpr_mu_lock(&g_mu); in grpc_iomgr_shutdown()
159 gpr_mu_lock(&g_mu); in grpc_iomgr_register_object()
167 gpr_mu_lock(&g_mu); in grpc_iomgr_unregister_object()
|
| D | udp_server.cc | 231 gpr_mu_lock(sp->mutex()); in shutdown_fd()
265 gpr_mu_lock(&s->mu); in destroyed_port()
280 gpr_mu_lock(&s->mu); in deactivated_all_ports()
307 gpr_mu_lock(&s->mu); in grpc_udp_server_destroy()
329 gpr_mu_lock(&mutex_); in OnFdAboutToOrphan()
446 gpr_mu_lock(sp->mutex()); in do_read()
469 gpr_mu_lock(&server_->mu); in OnRead()
499 gpr_mu_lock(sp->mutex()); in fd_notify_on_write_wrapper()
510 gpr_mu_lock(sp->mutex()); in do_write()
534 gpr_mu_lock(&server_->mu); in OnCanWrite()
[all …]
|
| D | tcp_server_posix.cc | 105 gpr_mu_lock(&s->mu); in finish_shutdown()
126 gpr_mu_lock(&s->mu); in destroyed_port()
142 gpr_mu_lock(&s->mu); in deactivated_all_ports()
163 gpr_mu_lock(&s->mu); in tcp_server_destroy()
208 gpr_mu_lock(&sp->server->mu); in on_read()
257 gpr_mu_lock(&sp->server->mu); in on_read()
450 gpr_mu_lock(&s->mu); in tcp_server_port_fd_count()
461 gpr_mu_lock(&s->mu); in tcp_server_port_fd()
480 gpr_mu_lock(&s->mu); in tcp_server_start()
522 gpr_mu_lock(&s->mu); in tcp_server_shutdown_starting_add()
[all …]
|
| D | wakeup_fd_cv.cc | 45 gpr_mu_lock(&g_cvfds.mu); in cv_fd_init()
71 gpr_mu_lock(&g_cvfds.mu); in cv_fd_wakeup()
83 gpr_mu_lock(&g_cvfds.mu); in cv_fd_consume()
93 gpr_mu_lock(&g_cvfds.mu); in cv_fd_destroy()
|
| D | ev_poll_posix.cc | 315 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_remove_node()
331 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_add_node()
438 gpr_mu_lock(&watcher->pollset->mu);
499 gpr_mu_lock(&fd->mu);
580 gpr_mu_lock(&fd->mu);
596 gpr_mu_lock(&fd->mu);
603 gpr_mu_lock(&fd->mu);
609 gpr_mu_lock(&fd->mu);
622 gpr_mu_lock(&fd->mu);
628 gpr_mu_lock(&fd->mu);
[all …]
|
| D | ev_epoll1_linux.cc | 276 gpr_mu_lock(&fd_freelist_mu); in fd_global_shutdown()
288 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_add_grpc_fd()
303 gpr_mu_lock(&fork_fd_list_mu); in fork_fd_list_remove_grpc_fd()
321 gpr_mu_lock(&fd_freelist_mu); in fd_create()
416 gpr_mu_lock(&fd_freelist_mu); in fd_orphan()
546 gpr_mu_lock(&pollset->mu); in pollset_destroy()
551 gpr_mu_lock(&neighborhood->mu); in pollset_destroy()
552 gpr_mu_lock(&pollset->mu); in pollset_destroy()
756 gpr_mu_lock(&neighborhood->mu); in begin_worker()
757 gpr_mu_lock(&pollset->mu); in begin_worker()
[all …]
|
| D | socket_windows.cc | 71 gpr_mu_lock(&winsocket->state_mu); in grpc_winsocket_shutdown()
107 gpr_mu_lock(&winsocket->state_mu); in grpc_winsocket_destroy()
122 gpr_mu_lock(&socket->state_mu); in socket_notify_on_iocp()
144 gpr_mu_lock(&socket->state_mu); in grpc_socket_become_ready()
|
| D | timer_generic.cc | 110 gpr_mu_lock(&g_hash_mu[i]); in is_in_ht()
124 gpr_mu_lock(&g_hash_mu[i]); in add_to_ht()
150 gpr_mu_lock(&g_hash_mu[i]); in remove_from_ht()
378 gpr_mu_lock(&shard->mu); in timer_init()
421 gpr_mu_lock(&g_shared_mutables.mu); in timer_init()
465 gpr_mu_lock(&shard->mu); in timer_cancel()
564 gpr_mu_lock(&shard->mu); in pop_timers()
596 gpr_mu_lock(&g_shared_mutables.mu); in run_some_expired_timers()
606 gpr_mu_lock(&g_shared_mutables.mu); in run_some_expired_timers()
685 gpr_mu_lock(&g_shared_mutables.mu); in timer_check()
|
| D | ev_epollex_linux.cc | 375 gpr_mu_lock(&fd_freelist_mu);
406 gpr_mu_lock(&fd_freelist_mu);
419 gpr_mu_lock(&fd_freelist_mu);
468 gpr_mu_lock(&fd->orphan_mu);
472 gpr_mu_lock(&fd->pollable_mu);
477 gpr_mu_lock(&pollable_obj->owner_orphan_mu);
636 gpr_mu_lock(&p->mu);
880 gpr_mu_lock(&fd->pollable_mu);
1072 gpr_mu_lock(&worker->pollable_obj->mu);
1116 gpr_mu_lock(&pollset->mu);
[all …]
|
| D | ev_epollsig_linux.cc | 549 gpr_mu_lock(&pi->mu); in polling_island_lock()
627 gpr_mu_lock(&pi_1->mu); in polling_island_lock_pair()
628 gpr_mu_lock(&pi_2->mu); in polling_island_lock_pair()
630 gpr_mu_lock(&pi_2->mu); in polling_island_lock_pair()
631 gpr_mu_lock(&pi_1->mu); in polling_island_lock_pair()
765 gpr_mu_lock(&fd_freelist_mu);
799 gpr_mu_lock(&fd_freelist_mu);
813 gpr_mu_lock(&fd_freelist_mu);
831 gpr_mu_lock(&new_fd->po.mu);
859 gpr_mu_lock(&fd->po.mu);
[all …]
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | tcp_client_uv_test.cc | 50 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()
147 gpr_mu_lock(g_mu); in test_fails()
156 gpr_mu_lock(g_mu); in test_fails()
177 gpr_mu_lock(g_mu); in test_fails()
|
| D | tcp_client_posix_test.cc | 54 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()
|
| D | fd_posix_test.cc | 176 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 …]
|
| D | tcp_posix_test.cc | 182 gpr_mu_lock(g_mu); in read_cb()
234 gpr_mu_lock(g_mu); in read_test()
241 gpr_mu_lock(g_mu); in read_test()
285 gpr_mu_lock(g_mu); in large_read_test()
292 gpr_mu_lock(g_mu); in large_read_test()
335 gpr_mu_lock(g_mu); in write_done()
356 gpr_mu_lock(g_mu); in drain_socket_blocking()
453 gpr_mu_lock(g_mu); in write_test()
465 gpr_mu_lock(g_mu); in write_test()
524 gpr_mu_lock(g_mu); in release_fd_test()
[all …]
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 64 gpr_mu_lock(&mu_); in IncExecCtxCount()
83 gpr_mu_lock(&mu_); in BlockExecCtx()
92 gpr_mu_lock(&mu_); in AllowExecCtx()
119 gpr_mu_lock(&mu_); in IncThreadCount()
125 gpr_mu_lock(&mu_); in DecThreadCount()
134 gpr_mu_lock(&mu_); in AwaitThreads()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | sync_test.cc | 70 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 …]
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamClientTests.mm | 41 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);
|
| /external/grpc-grpc/test/core/http/ |
| D | httpcli_test.cc | 55 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()
|
| D | httpscli_test.cc | 57 gpr_mu_lock(g_mu); in on_finish()
90 gpr_mu_lock(g_mu); in test_get()
98 gpr_mu_lock(g_mu); in test_get()
130 gpr_mu_lock(g_mu); in test_post()
138 gpr_mu_lock(g_mu); in test_post()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_channel.c | 128 gpr_mu_lock(&global_connection_polling_mu); in grpc_rb_channel_safe_destroy()
274 gpr_mu_lock(&global_connection_polling_mu); in get_state_without_gil()
329 gpr_mu_lock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_without_gvl()
356 gpr_mu_lock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_unblocking_func()
554 gpr_mu_lock(&global_connection_polling_mu); in channel_init_try_register_connection_polling_without_gil()
609 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
621 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
650 gpr_mu_lock(&global_connection_polling_mu); in run_poll_channels_loop_unblocking_func()
694 gpr_mu_lock(&global_connection_polling_mu); in wait_until_channel_polling_thread_started_no_gil()
708 gpr_mu_lock(&global_connection_polling_mu); in wait_until_channel_polling_thread_started_unblocking_func()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 89 gpr_mu_lock(&g_poller_mu); in g_poller_unref()
94 gpr_mu_lock(p->pollset_mu); in g_poller_unref()
115 gpr_mu_lock(p->pollset_mu); in run_poller()
154 gpr_mu_lock(&g_poller_mu); in grpc_client_channel_start_backup_polling()
|
| D | subchannel_index.cc | 149 gpr_mu_lock(&g_mu); in grpc_subchannel_index_find()
171 gpr_mu_lock(&g_mu); in grpc_subchannel_index_register()
196 gpr_mu_lock(&g_mu); in grpc_subchannel_index_register()
221 gpr_mu_lock(&g_mu); in grpc_subchannel_index_unregister()
241 gpr_mu_lock(&g_mu); in grpc_subchannel_index_unregister()
|
| /external/grpc-grpc/test/core/util/ |
| D | trickle_endpoint.cc | 67 gpr_mu_lock(&te->mu); in te_write()
100 gpr_mu_lock(&te->mu); in te_shutdown()
136 gpr_mu_lock(&te->mu); in te_finish_write()
175 gpr_mu_lock(&te->mu); in grpc_trickle_endpoint_trickle()
201 gpr_mu_lock(&te->mu); in grpc_trickle_get_backlog()
|
| D | port_server_client.cc | 52 gpr_mu_lock(pr->mu); in freed_port_from_server()
96 gpr_mu_lock(pr.mu); in grpc_free_port_using_server()
151 gpr_mu_lock(pr->mu); in got_port_from_server()
188 gpr_mu_lock(pr->mu); in got_port_from_server()
230 gpr_mu_lock(pr.mu); in grpc_pick_port_using_server()
|