| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 68 gpr_mu_unlock(&g_mu); in gc_completed_threads()
83 gpr_mu_unlock(&g_mu); in start_timer_thread_and_unlock()
115 gpr_mu_unlock(&g_mu); in run_some_timers()
127 gpr_mu_unlock(&g_mu); in run_some_timers()
137 gpr_mu_unlock(&g_mu); in wait_until()
210 gpr_mu_unlock(&g_mu); in wait_until()
259 gpr_mu_unlock(&g_mu); in timer_thread_cleanup()
280 gpr_mu_unlock(&g_mu); in start_threads()
318 gpr_mu_unlock(&g_mu); in stop_threads()
344 gpr_mu_unlock(&g_mu); in grpc_kick_poller()
|
| D | udp_server.cc | 241 gpr_mu_unlock(sp->mutex()); in shutdown_fd()
268 gpr_mu_unlock(&s->mu); in destroyed_port()
271 gpr_mu_unlock(&s->mu); in destroyed_port()
285 gpr_mu_unlock(&s->mu); in deactivated_all_ports()
292 gpr_mu_unlock(&s->mu); in deactivated_all_ports()
321 gpr_mu_unlock(&s->mu); in grpc_udp_server_destroy()
323 gpr_mu_unlock(&s->mu); in grpc_udp_server_destroy()
343 gpr_mu_unlock(&mutex_); in OnFdAboutToOrphan()
458 gpr_mu_unlock(sp->mutex()); in do_read()
471 gpr_mu_unlock(&server_->mu); in OnRead()
[all …]
|
| D | tcp_server_posix.cc | 107 gpr_mu_unlock(&s->mu); in finish_shutdown()
129 gpr_mu_unlock(&s->mu); in destroyed_port()
133 gpr_mu_unlock(&s->mu); in destroyed_port()
155 gpr_mu_unlock(&s->mu); in deactivated_all_ports()
157 gpr_mu_unlock(&s->mu); in deactivated_all_ports()
175 gpr_mu_unlock(&s->mu); in tcp_server_destroy()
177 gpr_mu_unlock(&s->mu); in tcp_server_destroy()
215 gpr_mu_unlock(&sp->server->mu); in on_read()
259 gpr_mu_unlock(&sp->server->mu); in on_read()
262 gpr_mu_unlock(&sp->server->mu); in on_read()
[all …]
|
| D | ev_epollex_linux.cc | 378 gpr_mu_unlock(&fd_freelist_mu);
407 gpr_mu_unlock(&fd_freelist_mu);
424 gpr_mu_unlock(&fd_freelist_mu);
474 gpr_mu_unlock(&fd->pollable_mu);
504 gpr_mu_unlock(&pollable_obj->owner_orphan_mu);
507 gpr_mu_unlock(&fd->orphan_mu);
652 gpr_mu_unlock(&p->mu);
667 gpr_mu_unlock(&p->mu);
901 gpr_mu_unlock(&fd->pollable_mu);
1077 gpr_mu_unlock(&pollset->mu);
[all …]
|
| D | iomgr.cc | 107 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
142 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
149 gpr_mu_unlock(&g_mu); in grpc_iomgr_shutdown()
163 gpr_mu_unlock(&g_mu); in grpc_iomgr_register_object()
171 gpr_mu_unlock(&g_mu); in grpc_iomgr_unregister_object()
|
| D | ev_epoll1_linux.cc | 277 gpr_mu_unlock(&fd_freelist_mu); in fd_global_shutdown()
297 gpr_mu_unlock(&fork_fd_list_mu); in fork_fd_list_add_grpc_fd()
314 gpr_mu_unlock(&fork_fd_list_mu); in fork_fd_list_remove_grpc_fd()
326 gpr_mu_unlock(&fd_freelist_mu); in fd_create()
419 gpr_mu_unlock(&fd_freelist_mu); in fd_orphan()
549 gpr_mu_unlock(&pollset->mu); in pollset_destroy()
555 gpr_mu_unlock(&neighborhood->mu); in pollset_destroy()
557 gpr_mu_unlock(&pollset->mu); in pollset_destroy()
567 gpr_mu_unlock(&pollset->neighborhood->mu); in pollset_destroy()
569 gpr_mu_unlock(&pollset->mu); in pollset_destroy()
[all …]
|
| D | socket_windows.cc | 73 gpr_mu_unlock(&winsocket->state_mu); in grpc_winsocket_shutdown()
77 gpr_mu_unlock(&winsocket->state_mu); in grpc_winsocket_shutdown()
111 gpr_mu_unlock(&winsocket->state_mu); in grpc_winsocket_destroy()
129 gpr_mu_unlock(&socket->state_mu); in socket_notify_on_iocp()
152 gpr_mu_unlock(&socket->state_mu); in grpc_socket_become_ready()
|
| D | ev_epollsig_linux.cc | 558 gpr_mu_unlock(&pi->mu); in polling_island_lock()
640 gpr_mu_unlock(&pi_1->mu); in polling_island_lock_pair()
641 gpr_mu_unlock(&pi_2->mu); in polling_island_lock_pair()
650 gpr_mu_unlock(&p->mu); in polling_island_unlock_pair()
652 gpr_mu_unlock(&p->mu); in polling_island_unlock_pair()
653 gpr_mu_unlock(&q->mu); in polling_island_unlock_pair()
774 gpr_mu_unlock(&fd_freelist_mu);
800 gpr_mu_unlock(&fd_freelist_mu);
818 gpr_mu_unlock(&fd_freelist_mu);
848 gpr_mu_unlock(&new_fd->po.mu);
[all …]
|
| D | ev_poll_posix.cc | 326 gpr_mu_unlock(&fork_fd_list_mu); in fork_fd_list_remove_node()
338 gpr_mu_unlock(&fork_fd_list_mu); in fork_fd_list_add_node()
442 gpr_mu_unlock(&watcher->pollset->mu);
506 gpr_mu_unlock(&fd->mu);
592 gpr_mu_unlock(&fd->mu);
598 gpr_mu_unlock(&fd->mu);
605 gpr_mu_unlock(&fd->mu);
611 gpr_mu_unlock(&fd->mu);
624 gpr_mu_unlock(&fd->mu);
630 gpr_mu_unlock(&fd->mu);
[all …]
|
| D | wakeup_fd_cv.cc | 65 gpr_mu_unlock(&g_cvfds.mu); in cv_fd_init()
78 gpr_mu_unlock(&g_cvfds.mu); in cv_fd_wakeup()
85 gpr_mu_unlock(&g_cvfds.mu); in cv_fd_consume()
98 gpr_mu_unlock(&g_cvfds.mu); in cv_fd_destroy()
|
| D | timer_generic.cc | 115 gpr_mu_unlock(&g_hash_mu[i]); in is_in_ht()
143 gpr_mu_unlock(&g_hash_mu[i]); in add_to_ht()
165 gpr_mu_unlock(&g_hash_mu[i]); in remove_from_ht()
384 gpr_mu_unlock(&shard->mu); in timer_init()
407 gpr_mu_unlock(&shard->mu); in timer_init()
447 gpr_mu_unlock(&g_shared_mutables.mu); in timer_init()
484 gpr_mu_unlock(&shard->mu); in timer_cancel()
571 gpr_mu_unlock(&shard->mu); in pop_timers()
598 gpr_mu_unlock(&g_shared_mutables.mu); in run_some_expired_timers()
662 gpr_mu_unlock(&g_shared_mutables.mu); in run_some_expired_timers()
[all …]
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | tcp_client_uv_test.cc | 54 gpr_mu_unlock(g_mu); in finish_connection()
105 gpr_mu_unlock(g_mu); in test_succeeds()
123 gpr_mu_unlock(g_mu); in test_succeeds()
131 gpr_mu_unlock(g_mu); in test_succeeds()
149 gpr_mu_unlock(g_mu); in test_fails()
175 gpr_mu_unlock(g_mu); in test_fails()
180 gpr_mu_unlock(g_mu); in test_fails()
|
| D | tcp_client_posix_test.cc | 60 gpr_mu_unlock(g_mu); in finish_connection()
104 gpr_mu_unlock(g_mu); in test_succeeds()
131 gpr_mu_unlock(g_mu); in test_succeeds()
136 gpr_mu_unlock(g_mu); in test_succeeds()
155 gpr_mu_unlock(g_mu); in test_fails()
180 gpr_mu_unlock(g_mu); in test_fails()
185 gpr_mu_unlock(g_mu); in test_fails()
|
| D | fd_posix_test.cc | 180 gpr_mu_unlock(g_mu); in listen_shutdown_cb()
255 gpr_mu_unlock(g_mu); in server_wait_and_shutdown()
259 gpr_mu_unlock(g_mu); in server_wait_and_shutdown()
308 gpr_mu_unlock(g_mu); in client_session_write()
327 gpr_mu_unlock(g_mu); in client_session_write()
371 gpr_mu_unlock(g_mu); in client_wait_and_shutdown()
375 gpr_mu_unlock(g_mu); in client_wait_and_shutdown()
414 gpr_mu_unlock(g_mu); in first_read_callback()
425 gpr_mu_unlock(g_mu); in second_read_callback()
473 gpr_mu_unlock(g_mu); in test_grpc_fd_change()
[all …]
|
| D | tcp_posix_test.cc | 192 gpr_mu_unlock(g_mu); in read_cb()
195 gpr_mu_unlock(g_mu); in read_cb()
239 gpr_mu_unlock(g_mu); in read_test()
244 gpr_mu_unlock(g_mu); in read_test()
290 gpr_mu_unlock(g_mu); in large_read_test()
295 gpr_mu_unlock(g_mu); in large_read_test()
339 gpr_mu_unlock(g_mu); in write_done()
362 gpr_mu_unlock(g_mu); in drain_socket_blocking()
463 gpr_mu_unlock(g_mu); in write_test()
467 gpr_mu_unlock(g_mu); in write_test()
[all …]
|
| /external/grpc-grpc/test/core/gpr/ |
| D | sync_test.cc | 88 gpr_mu_unlock(&q->mu); in queue_append()
104 gpr_mu_unlock(&q->mu); in queue_try_append()
131 gpr_mu_unlock(&q->mu); in queue_remove()
209 gpr_mu_unlock(&m->mu); in test_wait()
220 gpr_mu_unlock(&m->mu); in thread_id()
233 gpr_mu_unlock(&m->mu); in mark_thread_done()
292 gpr_mu_unlock(&m->mu); in inc()
305 gpr_mu_unlock(&m->mu); in inctry()
325 gpr_mu_unlock(&m->mu); in inc_by_turns()
343 gpr_mu_unlock(&m->mu); in inc_with_1ms_delay()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 93 gpr_mu_unlock(&g_poller_mu); in g_poller_unref()
99 gpr_mu_unlock(p->pollset_mu); in g_poller_unref()
102 gpr_mu_unlock(&g_poller_mu); in g_poller_unref()
117 gpr_mu_unlock(p->pollset_mu); in run_poller()
123 gpr_mu_unlock(p->pollset_mu); in run_poller()
162 gpr_mu_unlock(&g_poller_mu); in grpc_client_channel_start_backup_polling()
|
| D | http_connect_handshaker.cc | 131 gpr_mu_unlock(&handshaker->mu); in on_write_done()
139 gpr_mu_unlock(&handshaker->mu); in on_write_done()
202 gpr_mu_unlock(&handshaker->mu); in on_read_done()
222 gpr_mu_unlock(&handshaker->mu); in on_read_done()
246 gpr_mu_unlock(&handshaker->mu); in http_connect_handshaker_shutdown()
265 gpr_mu_unlock(&handshaker->mu); in http_connect_handshaker_do_handshake()
324 gpr_mu_unlock(&handshaker->mu); in http_connect_handshaker_do_handshake()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 408 gpr_mu_unlock(cq->mu); in grpc_completion_queue_thread_local_cache_flush()
555 gpr_mu_unlock(cq->mu); in grpc_get_cq_poll_num()
619 gpr_mu_unlock(cq->mu);
671 gpr_mu_unlock(cq->mu);
728 gpr_mu_unlock(cq->mu);
740 gpr_mu_unlock(cq->mu);
748 gpr_mu_unlock(cq->mu);
798 gpr_mu_unlock(cq->mu);
811 gpr_mu_unlock(cq->mu);
856 gpr_mu_unlock(cq->mu);
[all …]
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 70 gpr_mu_unlock(&mu_); in IncExecCtxCount()
85 gpr_mu_unlock(&mu_); in BlockExecCtx()
96 gpr_mu_unlock(&mu_); in AllowExecCtx()
121 gpr_mu_unlock(&mu_); in IncThreadCount()
131 gpr_mu_unlock(&mu_); in DecThreadCount()
141 gpr_mu_unlock(&mu_); in AwaitThreads()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 213 gpr_mu_unlock(&h->mu); in on_peer_checked()
286 gpr_mu_unlock(&h->mu); in on_handshake_next_done_grpc_wrapper()
289 gpr_mu_unlock(&h->mu); in on_handshake_next_done_grpc_wrapper()
322 gpr_mu_unlock(&h->mu); in on_handshake_data_received_from_peer()
334 gpr_mu_unlock(&h->mu); in on_handshake_data_received_from_peer()
337 gpr_mu_unlock(&h->mu); in on_handshake_data_received_from_peer()
348 gpr_mu_unlock(&h->mu); in on_handshake_data_sent_to_peer()
360 gpr_mu_unlock(&h->mu); in on_handshake_data_sent_to_peer()
365 gpr_mu_unlock(&h->mu); in on_handshake_data_sent_to_peer()
387 gpr_mu_unlock(&h->mu); in security_handshaker_shutdown()
[all …]
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_channel.c | 138 gpr_mu_unlock(&global_connection_polling_mu); in grpc_rb_channel_safe_destroy()
282 gpr_mu_unlock(&global_connection_polling_mu); in get_state_without_gil()
333 gpr_mu_unlock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_without_gvl()
350 gpr_mu_unlock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_without_gvl()
361 gpr_mu_unlock(&global_connection_polling_mu); in wait_for_watch_state_op_complete_unblocking_func()
558 gpr_mu_unlock(&global_connection_polling_mu); in channel_init_try_register_connection_polling_without_gil()
613 gpr_mu_unlock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
636 gpr_mu_unlock(&global_connection_polling_mu); in run_poll_channels_loop_no_gil()
656 gpr_mu_unlock(&global_connection_polling_mu); in run_poll_channels_loop_unblocking_func()
673 gpr_mu_unlock(&global_connection_polling_mu); in run_poll_channels_loop_unblocking_func()
[all …]
|
| D | rb_event_thread.c | 66 gpr_mu_unlock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
95 gpr_mu_unlock(&event_queue.mu); in grpc_rb_wait_for_event_no_gil()
101 gpr_mu_unlock(&event_queue.mu); in grpc_rb_wait_for_event_no_gil()
110 gpr_mu_unlock(&event_queue.mu); in grpc_rb_event_unblocking_func()
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamClientTests.mm | 43 gpr_mu_unlock(&g_mu);
101 gpr_mu_unlock(&g_mu);
124 gpr_mu_unlock(&g_mu);
130 gpr_mu_unlock(&g_mu);
157 gpr_mu_unlock(&g_mu);
170 gpr_mu_unlock(&g_mu);
177 gpr_mu_unlock(&g_mu);
|
| /external/grpc-grpc/test/core/http/ |
| D | httpcli_test.cc | 60 gpr_mu_unlock(g_mu); in on_finish()
93 gpr_mu_unlock(g_mu); in test_get()
97 gpr_mu_unlock(g_mu); in test_get()
132 gpr_mu_unlock(g_mu); in test_post()
136 gpr_mu_unlock(g_mu); in test_post()
|