| /third_party/libuv/test/ |
| D | test-mutexes.c | 98 static void synchronize(void) { in synchronize() function
116 synchronize(); in thread_rwlock_trylock_peer()
122 synchronize(); in thread_rwlock_trylock_peer()
126 synchronize(); in thread_rwlock_trylock_peer()
131 synchronize(); in thread_rwlock_trylock_peer()
151 synchronize(); /* Releases the mutex to the other thread. */ in TEST_IMPL()
158 synchronize(); in TEST_IMPL()
162 synchronize(); in TEST_IMPL()
167 synchronize(); in TEST_IMPL()
173 synchronize(); in TEST_IMPL()
|
| /third_party/grpc/src/ruby/pb/grpc/health/ |
| D | checker.rb | 36 @status_mutex.synchronize do
47 @status_mutex.synchronize { @statuses["#{service}"] = status }
52 @status_mutex.synchronize do
59 @status_mutex.synchronize do
66 @status_mutex.synchronize { @statuses.delete("#{service}") }
71 @status_mutex.synchronize { @statuses = {} }
|
| /third_party/boost/libs/graph_parallel/test/ |
| D | distributed_property_map_test.cpp | 111 synchronize(pg); in colored_test()
136 synchronize(pg); in colored_test()
146 synchronize(pg); in colored_test()
157 synchronize(pg); in colored_test()
174 synchronize(pg); in colored_test()
196 synchronize(pg); in bool_test()
221 synchronize(pg); in bool_test()
231 synchronize(pg); in bool_test()
242 synchronize(pg); in bool_test()
259 synchronize(pg); in bool_test()
[all …]
|
| D | named_vertices_test.cpp | 99 synchronize(map); in test_main()
109 synchronize(map); in test_main()
118 synchronize(map); in test_main()
|
| D | adjlist_remove_test.cpp | 46 synchronize(g.process_group()); in test_bidirectional_graph()
72 synchronize(g); in test_bidirectional_graph()
100 synchronize(g.process_group()); in test_undirected_graph()
122 synchronize(g); in test_undirected_graph()
|
| /third_party/grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 60 @stop_mutex.synchronize do
76 @stop_mutex.synchronize do
95 @stop_mutex.synchronize do # wait @keep_alive seconds for workers to stop
128 @stop_mutex.synchronize do
145 @stop_mutex.synchronize do
250 @run_mutex.synchronize do
261 @run_mutex.synchronize do
295 @run_mutex.synchronize do
334 @run_mutex.synchronize do
352 @run_mutex.synchronize do
[all …]
|
| D | active_call.rb | 119 @send_initial_md_mutex.synchronize do
229 @send_initial_md_mutex.synchronize do
358 @send_initial_md_mutex.synchronize do
441 @send_initial_md_mutex.synchronize do
572 @send_initial_md_mutex.synchronize do
588 @call_finished_mu.synchronize do
598 @call_finished_mu.synchronize do
620 @client_call_executed_mu.synchronize do
|
| /third_party/grpc/src/ruby/end2end/ |
| D | call_credentials_returning_bad_metadata_doesnt_kill_background_thread_test.rb | 74 call_creds_invocation_count_mu.synchronize do
82 call_creds_invocation_count_mu.synchronize do
89 call_creds_invocation_count_mu.synchronize do
96 call_creds_invocation_count_mu.synchronize do
103 call_creds_invocation_count_mu.synchronize do
144 call_creds_invocation_count_mu.synchronize do
|
| D | call_credentials_returning_bad_metadata_doesnt_kill_background_thread_driver.rb | 83 call_creds_invocation_count_mu.synchronize do
91 call_creds_invocation_count_mu.synchronize do
98 call_creds_invocation_count_mu.synchronize do
105 call_creds_invocation_count_mu.synchronize do
112 call_creds_invocation_count_mu.synchronize do
153 call_creds_invocation_count_mu.synchronize do
|
| D | call_credentials_timeout_test.rb | 71 jwt_aud_uri_extraction_success_count_mu.synchronize do
78 token_fetch_attempts_mu.synchronize do
129 jwt_aud_uri_extraction_success_count_mu.synchronize do
|
| D | call_credentials_timeout_driver.rb | 80 jwt_aud_uri_extraction_success_count_mu.synchronize do
87 token_fetch_attempts_mu.synchronize do
138 jwt_aud_uri_extraction_success_count_mu.synchronize do
|
| D | graceful_sig_stop_driver.rb | 43 client_started_mu.synchronize do
55 client_started_mu.synchronize do
|
| D | sig_handling_driver.rb | 43 client_started_mu.synchronize do
55 client_started_mu.synchronize do
|
| /third_party/boost/libs/thread/example/ |
| D | synchronized_person.cpp | 159 auto memberSync = member.synchronize(); in GetName()
161 boost::const_strict_lock_ptr<Member> memberSync = member.synchronize(); in GetName()
168 auto memberSync = member.synchronize(); in SetName()
170 boost::strict_lock_ptr<Member> memberSync = member.synchronize(); in SetName()
265 auto t = boost::synchronize(p1,p2,p3); in main()
275 auto t = boost::synchronize(p1,p2,p3); in main()
|
| D | synchronized_value.cpp | 15 boost::strict_lock_ptr<std::string> u=path.synchronize(); in addTrailingSlashIfMissing()
33 boost::strict_lock_ptr<std::string> u=path.synchronize(); in checkIfMissingTrailingSlash()
49 boost::strict_lock_ptr<int> u=v1.synchronize(); in main()
79 s.synchronize()->append("foo"); in main()
|
| /third_party/boost/boost/graph/distributed/ |
| D | distributed_graph_utility.hpp | 28 synchronize(p); in property_on_inedges()
38 synchronize(p); in property_on_outedges()
47 synchronize(p); in property_on_successors()
56 synchronize(p); in property_on_predecessors()
69 synchronize(p); in property_on_adjacents()
|
| D | connected_components.hpp | 107 synchronize(pg); in build_local_metagraph()
192 synchronize(p); in build_local_metagraph()
264 synchronize(pg); in request_parent_map_entries()
275 synchronize(pg); in request_parent_map_entries()
378 synchronize(p); in parallel_connected_components()
407 synchronize(p); in parallel_connected_components()
436 synchronize(p); in parallel_connected_components()
457 synchronize(p); in parallel_connected_components()
503 synchronize(p); in parallel_connected_components()
581 synchronize(pg); in parallel_connected_components()
[all …]
|
| D | graphviz.hpp | 159 synchronize(pg); in write_graphviz()
177 synchronize(pg); in write_graphviz()
179 synchronize(pg); in write_graphviz()
180 synchronize(pg); in write_graphviz()
181 synchronize(pg); in write_graphviz()
|
| /third_party/python/Lib/multiprocessing/ |
| D | context.py | 67 from .synchronize import Lock
72 from .synchronize import RLock
77 from .synchronize import Condition
82 from .synchronize import Semaphore
87 from .synchronize import BoundedSemaphore
92 from .synchronize import Event
97 from .synchronize import Barrier
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | xds_client.rb | 134 $watchers_mutex.synchronize do
166 $accumulated_stats_mu.synchronize do
189 $accumulated_stats_mu.synchronize do
208 $accumulated_stats_mu.synchronize do
215 $accumulated_stats_mu.synchronize do
247 $accumulated_stats_mu.synchronize do
279 $watchers_mutex.synchronize do
|
| /third_party/boost/libs/thread/doc/ |
| D | synchronized_value_ref.qbk | 73 std::tuple<typename synchronized_value_strict_lock_ptr<SV>::type ...> synchronize(SV& ...sv);
111 strict_lock_ptr<T,Lockable> synchronize();
112 const_strict_lock_ptr<T,Lockable> synchronize() const;
333 [section:synchronize `synchronize()`]
335 strict_lock_ptr<T,Lockable> synchronize();
337 …synchronize() factory make easier to lock on a scope. As discussed, `operator->` can only lock ove…
342 auto vec2=vec.synchronize();
356 [section:synchronize_const `synchronize() const`]
358 const_strict_lock_ptr<T,Lockable> synchronize() const;
402 [section:synchronize Non-Member Function `synchronize`]
[all …]
|
| /third_party/boost/boost/property_map/parallel/ |
| D | global_index_map.hpp | 35 synchronize(pg); in global_index_map()
47 synchronize(pg); in global_index_map()
49 synchronize(pg); in global_index_map()
|
| /third_party/grpc/src/ruby/spec/generic/ |
| D | rpc_server_pool_spec.rb | 49 wait_mu.synchronize do
61 wait_mu.synchronize do
104 wait_forever_mu.synchronize do
|
| /third_party/grpc/src/ruby/lib/grpc/ |
| D | notifier.rb | 30 @mutex.synchronize do
36 @mutex.synchronize do
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/synchronized_value/ |
| D | synchronize_pass.cpp | 29 boost::strict_lock_ptr<S> ptr = v.synchronize(); in main()
35 boost::const_strict_lock_ptr<S> ptr = v.synchronize(); in main()
|