Home
last modified time | relevance | path

Searched defs:its_lock (Results 1 – 25 of 100) sorted by relevance

1234

/aosp_15_r20/external/sdv/vsomeip/implementation/routing/src/
Drouting_manager_proxy.cpp61 std::lock_guard<std::mutex> its_lock(sender_mutex_); in init() local
69 std::lock_guard<std::mutex> its_lock(sender_mutex_); in start() local
81 std::unique_lock<std::mutex> its_lock(state_mutex_); in stop() local
110 std::lock_guard<std::mutex> its_lock(request_timer_mutex_); in stop() local
120 std::lock_guard<std::mutex> its_lock(sender_mutex_); in stop() local
160 std::lock_guard<std::mutex> its_lock(state_mutex_); in offer_service() local
193 std::lock_guard<std::mutex> its_lock(sender_mutex_); in send_offer_service() local
208 std::lock_guard<std::mutex> its_lock(stop_mutex_); in stop_offer_service() local
219 std::lock_guard<std::mutex> its_lock(state_mutex_); in stop_offer_service() local
239 std::lock_guard<std::mutex> its_lock(sender_mutex_); in stop_offer_service() local
[all …]
Devent.cpp98 std::lock_guard<std::mutex> its_lock(mutex_); in get_payload() local
103 std::lock_guard<std::mutex> its_lock(mutex_); in set_payload_dont_notify() local
118 std::lock_guard<std::mutex> its_lock(mutex_); in set_payload() local
142 std::lock_guard<std::mutex> its_lock(mutex_); in set_payload() local
162 std::lock_guard<std::mutex> its_lock(mutex_); in set_payload() local
179 std::lock_guard<std::mutex> its_lock(mutex_); in set_payload_notify_pending() local
198 std::lock_guard<std::mutex> its_lock(mutex_); in unset_payload() local
214 std::lock_guard<std::mutex> its_lock(mutex_); in set_update_cycle() local
233 std::lock_guard<std::mutex> its_lock(mutex_); in set_epsilon_change_function() local
241 std::lock_guard<std::mutex> its_lock(eventgroups_mutex_); in get_eventgroups() local
[all …]
Deventgroupinfo.cpp94 std::lock_guard<std::mutex> its_lock(address_mutex_); in is_multicast() local
106 std::lock_guard<std::mutex> its_lock(address_mutex_); in get_multicast() local
117 std::lock_guard<std::mutex> its_lock(address_mutex_); in set_multicast() local
123 std::lock_guard<std::mutex> its_lock(events_mutex_); in get_events() local
128 std::lock_guard<std::mutex> its_lock(events_mutex_); in add_event() local
161 std::lock_guard<std::mutex> its_lock(events_mutex_); in remove_event() local
181 std::lock_guard<std::mutex> its_lock(subscriptions_mutex_); in get_unreliable_target_count() local
205 std::lock_guard<std::mutex> its_lock(subscriptions_mutex_); in get_remote_subscriptions() local
224 std::lock_guard<std::mutex> its_lock(subscriptions_mutex_); in update_remote_subscription() local
282 std::lock_guard<std::mutex> its_lock(events_mutex_); in update_remote_subscription() local
[all …]
Drouting_manager_stub.cpp63 std::lock_guard<std::mutex> its_lock(used_client_ids_mutex_); in start() local
100 std::lock_guard<std::mutex> its_lock(routing_info_mutex_); in start() local
107 std::lock_guard<std::mutex> its_lock(client_registration_mutex_); in stop() local
116 std::lock_guard<std::mutex> its_lock(watchdog_timer_mutex_); in stop() local
121 std::lock_guard<std::mutex> its_lock(used_client_ids_mutex_); in stop() local
794 std::lock_guard<std::mutex> its_lock(routing_info_mutex_); in on_register_application() local
814 std::lock_guard<std::mutex> its_lock(routing_info_mutex_); in on_deregister_application() local
846 std::unique_lock<std::mutex> its_lock(client_registration_mutex_); in client_registration_func() local
1584 std::lock_guard<std::mutex> its_lock(routing_info_mutex_); in on_pong() local
1605 std::lock_guard<std::mutex> its_lock(watchdog_timer_mutex_); in start_watchdog() local
[all …]
Drouting_manager_base.cpp102 std::lock_guard<std::mutex> its_lock(events_mutex_); in offer_service() local
126 std::lock_guard<std::mutex> its_lock(events_mutex_); in stop_offer_service() local
175 std::lock_guard<std::mutex> its_lock(local_services_mutex_); in release_service() local
464 std::lock_guard<std::mutex> its_lock(eventgroups_mutex_); in register_event() local
470 std::lock_guard<std::mutex> its_lock(events_mutex_); in register_event() local
479 std::lock_guard<std::mutex> its_lock(events_mutex_); in unregister_event() local
516 std::lock_guard<std::mutex> its_lock(eventgroups_mutex_); in find_events() local
534 std::lock_guard<std::mutex> its_lock(events_mutex_); in find_events() local
556 std::lock_guard<std::mutex> its_lock(local_services_mutex_); in is_response_allowed() local
753 std::lock_guard<std::recursive_mutex> its_lock(pending_notify_ones_mutex_); in notify_one() local
[all …]
Drouting_manager_impl.cpp192 std::lock_guard<std::mutex> its_lock(version_log_timer_mutex_); in start() local
200 std::lock_guard<std::mutex> its_lock(memory_log_timer_mutex_); in start() local
209 std::lock_guard<std::mutex> its_lock(status_log_timer_mutex_); in start() local
218 std::lock_guard<std::mutex> its_lock(statistics_log_timer_mutex_); in start() local
231 std::lock_guard<std::mutex> its_lock(local_services_mutex_); in stop() local
249 std::lock_guard<std::mutex> its_lock(version_log_timer_mutex_); in stop() local
255 std::lock_guard<std::mutex> its_lock(memory_log_timer_mutex_); in stop() local
264 std::lock_guard<std::mutex> its_lock(status_log_timer_mutex_); in stop() local
270 std::lock_guard<std::mutex> its_lock(statistics_log_timer_mutex_); in stop() local
290 std::lock_guard<std::mutex> its_lock(offer_serialization_mutex_); in insert_offer_command() local
[all …]
Dremote_subscription.cpp151 std::lock_guard<std::mutex> its_lock(mutex_); in get_clients() local
160 std::lock_guard<std::mutex> its_lock(mutex_); in has_client() local
166 std::lock_guard<std::mutex> its_lock(mutex_); in has_client() local
172 std::lock_guard<std::mutex> its_lock(mutex_); in remove_client() local
178 std::lock_guard<std::mutex> its_lock(mutex_); in get_client_state() local
189 std::lock_guard<std::mutex> its_lock(mutex_); in set_client_state() local
204 std::lock_guard<std::mutex> its_lock(mutex_); in set_all_client_states() local
244 std::lock_guard<std::mutex> its_lock(mutex_); in is_pending() local
256 std::lock_guard<std::mutex> its_lock(mutex_); in is_acknowledged() local
268 std::lock_guard<std::mutex> its_lock(mutex_); in get_expiration() local
[all …]
Dserviceinfo.cpp70 std::lock_guard<std::mutex> its_lock(ttl_mutex_); in get_ttl() local
76 std::lock_guard<std::mutex> its_lock(ttl_mutex_); in set_ttl() local
82 std::lock_guard<std::mutex> its_lock(ttl_mutex_); in get_precise_ttl() local
87 std::lock_guard<std::mutex> its_lock(ttl_mutex_); in set_precise_ttl() local
92 std::lock_guard<std::mutex> its_lock(endpoint_mutex_); in get_endpoint() local
98 std::lock_guard<std::mutex> its_lock(endpoint_mutex_); in set_endpoint() local
107 std::lock_guard<std::mutex> its_lock(requesters_mutex_); in add_client() local
112 std::lock_guard<std::mutex> its_lock(requesters_mutex_); in remove_client() local
117 std::lock_guard<std::mutex> its_lock(requesters_mutex_); in get_requesters_size() local
/aosp_15_r20/external/sdv/vsomeip/implementation/endpoints/src/
Dtcp_server_endpoint_impl.cpp73 std::lock_guard<std::mutex> its_lock(acceptor_mutex_); in start() local
95 std::lock_guard<std::mutex> its_lock(acceptor_mutex_); in stop() local
102 std::lock_guard<std::mutex> its_lock(connections_mutex_); in stop() local
113 std::lock_guard<std::mutex> its_lock(mutex_); in send_to() local
122 std::lock_guard<std::mutex> its_lock(mutex_); in send_error() local
145 std::lock_guard<std::mutex> its_lock(connections_mutex_); in send_queued() local
209 std::lock_guard<std::mutex> its_lock(connections_mutex_); in is_established() local
229 std::lock_guard<std::mutex> its_lock(connections_mutex_); in remove_connection() local
262 std::lock_guard<std::mutex> its_lock(connections_mutex_); in accept_cbk() local
360 std::lock_guard<std::mutex> its_lock(socket_mutex_); in receive() local
[all …]
Dendpoint_manager_impl.cpp46 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in find_or_create_remote_client() local
67 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in find_or_create_remote_client() local
96 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in is_remote_service_known() local
154 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in add_remote_service_info() local
181 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in add_remote_service_info() local
208 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in clear_remote_service_info() local
227 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in create_server_endpoint() local
280 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in find_server_endpoint() local
303 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in find_or_create_server_endpoint() local
314 std::lock_guard<std::recursive_mutex> its_lock(endpoint_mutex_); in remove_server_endpoint() local
[all …]
Dlocal_client_endpoint_impl.cpp58 std::lock_guard<std::mutex> its_lock(mutex_); in restart() local
64 std::lock_guard<std::mutex> its_lock(socket_mutex_); in restart() local
78 std::lock_guard<std::mutex> its_lock(mutex_); in stop() local
82 std::lock_guard<std::mutex> its_lock(connect_timer_mutex_); in stop() local
90 std::lock_guard<std::mutex> its_lock(socket_mutex_); in stop() local
115 std::lock_guard<std::mutex> its_lock(socket_mutex_); in connect() local
162 std::lock_guard<std::mutex> its_lock(socket_mutex_); in receive() local
183 std::lock_guard<std::mutex> its_lock(mutex_); in send() local
216 std::lock_guard<std::mutex> its_lock(socket_mutex_); in send_queued() local
264 std::lock_guard<std::mutex> its_lock(error_handler_mutex_); in receive_cbk() local
[all …]
Dudp_server_endpoint_impl.cpp148 std::lock_guard<std::mutex> its_lock(unicast_mutex_); in stop() local
158 std::lock_guard<std::mutex> its_lock(multicast_mutex_); in stop() local
176 std::lock_guard<std::mutex> its_lock(unicast_mutex_); in receive_unicast() local
220 std::lock_guard<std::mutex> its_lock(mutex_); in send_to() local
230 std::lock_guard<std::mutex> its_lock(mutex_); in send_error() local
263 std::lock_guard<std::mutex> its_lock(unicast_mutex_); in send_queued() local
312 std::lock_guard<std::mutex> its_lock(multicast_mutex_); in join() local
333 std::lock_guard<std::mutex> its_lock(local_mutex_); in join_unlocked() local
465 std::lock_guard<std::mutex> its_lock(multicast_mutex_); in leave() local
479 std::lock_guard<std::mutex> its_lock(local_mutex_); in leave_unlocked() local
[all …]
Dclient_endpoint_impl.cpp75 std::lock_guard<std::mutex> its_lock(socket_mutex_); in set_established() local
90 std::lock_guard<std::mutex> its_lock(socket_mutex_); in set_connected() local
111 std::lock_guard<std::mutex> its_lock(mutex_); in stop() local
118 std::lock_guard<std::mutex> its_lock(connect_timer_mutex_); in stop() local
168 std::lock_guard<std::mutex> its_lock(mutex_); in send() local
367 std::lock_guard<std::mutex> its_lock(mutex_); in flush() local
410 std::lock_guard<std::mutex> its_lock(connect_timer_mutex_); in connect_cbk() local
418 std::lock_guard<std::mutex> its_lock(mutex_); in connect_cbk() local
451 std::lock_guard<std::mutex> its_lock(mutex_); in send_cbk() local
463 std::lock_guard<std::mutex> its_lock(mutex_); in send_cbk() local
[all …]
Dudp_client_endpoint_impl.cpp56 std::lock_guard<std::mutex> its_lock(socket_mutex_); in connect() local
197 std::lock_guard<std::mutex> its_lock(mutex_); in restart() local
202 std::lock_guard<std::mutex> its_lock(socket_mutex_); in restart() local
224 std::lock_guard<std::mutex> its_lock(socket_mutex_); in send_queued() local
248 std::lock_guard<std::mutex> its_lock(socket_mutex_); in receive() local
280 std::lock_guard<std::mutex> its_lock(socket_mutex_); in set_local_port() local
447 std::lock_guard<std::mutex> its_lock(mutex_); in print_status() local
453 std::lock_guard<std::mutex> its_lock(socket_mutex_); in print_status() local
473 std::lock_guard<std::mutex> its_lock(mutex_); in send_cbk() local
485 std::lock_guard<std::mutex> its_lock(mutex_); in send_cbk() local
[all …]
Dtcp_client_endpoint_impl.cpp96 std::lock_guard<std::mutex> its_lock(self->socket_mutex_); in restart() local
104 std::lock_guard<std::mutex> its_lock(self->mutex_); in restart() local
139 std::lock_guard<std::mutex> its_lock(socket_mutex_); in connect() local
256 std::lock_guard<std::mutex> its_lock(socket_mutex_); in receive() local
268 std::lock_guard<std::mutex> its_lock(socket_mutex_); in receive() local
354 std::lock_guard<std::mutex> its_lock(socket_mutex_); in send_queued() local
403 std::lock_guard<std::mutex> its_lock(socket_mutex_); in set_local_port() local
508 std::unique_lock<std::mutex> its_lock(socket_mutex_); in receive_cbk() local
817 std::lock_guard<std::mutex> its_lock(mutex_); in handle_recv_buffer_exception() local
821 std::lock_guard<std::mutex> its_lock(connect_timer_mutex_); in handle_recv_buffer_exception() local
[all …]
Dlocal_server_endpoint_impl.cpp102 std::lock_guard<std::mutex> its_lock(acceptor_mutex_); in start() local
111 std::unique_lock<std::mutex> its_lock(new_connection->get_socket_lock()); in start() local
130 std::lock_guard<std::mutex> its_lock(acceptor_mutex_); in stop() local
137 std::lock_guard<std::mutex> its_lock(connections_mutex_); in stop() local
153 std::lock_guard<std::mutex> its_lock(mutex_); in send() local
163 std::lock_guard<std::mutex> its_lock(connections_mutex_); in send() local
215 std::lock_guard<std::mutex> its_lock(connections_mutex_); in add_connection() local
229 std::lock_guard<std::mutex> its_lock(connections_mutex_); in remove_connection() local
375 std::lock_guard<std::mutex> its_lock(socket_mutex_); in start() local
432 std::lock_guard<std::mutex> its_lock(socket_mutex_); in stop() local
[all …]
/aosp_15_r20/external/sdv/vsomeip/implementation/runtime/src/
Dapplication_impl.cpp106 std::lock_guard<std::mutex> its_lock(dispatcher_mutex_); in ~application_impl() local
363 std::lock_guard<std::mutex> its_lock(start_stop_mutex_); in start() local
392 std::lock_guard<std::mutex> its_lock(dispatcher_mutex_); in start() local
488 std::lock_guard<std::mutex> its_lock(start_stop_mutex_); in start() local
629 std::lock_guard<std::recursive_mutex> its_lock(availability_mutex_); in is_available() local
703 std::lock_guard<std::recursive_mutex> its_lock(availability_mutex_); in are_available() local
870 std::lock_guard<std::mutex> its_lock(state_handler_mutex_); in register_state_handler() local
875 std::lock_guard<std::mutex> its_lock(state_handler_mutex_); in unregister_state_handler() local
918 std::lock_guard<std::recursive_mutex> its_lock(availability_mutex_); in unregister_availability_handler() local
950 std::lock_guard<std::mutex> its_lock(subscription_mutex_); in on_subscription() local
[all …]
/aosp_15_r20/external/sdv/vsomeip/implementation/service_discovery/src/
Dservice_discovery_impl.cpp151 std::lock_guard<std::mutex> its_lock(sessions_received_mutex_); in start() local
155 std::lock_guard<std::mutex> its_lock(serialize_mutex_); in start() local
161 std::lock_guard<std::mutex> its_lock(requested_mutex_); in start() local
193 std::lock_guard<std::mutex> its_lock(requested_mutex_); in request_service() local
210 std::lock_guard<std::mutex> its_lock(requested_mutex_); in release_service() local
219 std::lock_guard<std::mutex> its_lock(requested_mutex_); in update_request() local
247 std::lock_guard<std::mutex> its_lock(subscribed_mutex_); in subscribe() local
419 std::lock_guard<std::mutex> its_lock(subscribed_mutex_); in unsubscribe() local
493 std::lock_guard<std::mutex> its_lock(subscribed_mutex_); in unsubscribe_all() local
534 std::lock_guard<std::mutex> its_lock(subscribed_mutex_); in unsubscribe_all_on_suspend() local
[all …]
Dsubscription.cpp50 std::lock_guard<std::mutex> its_lock(clients_mutex_); in get_state() local
60 std::lock_guard<std::mutex> its_lock(clients_mutex_); in set_state() local
82 std::lock_guard<std::mutex> its_lock(clients_mutex_); in add_client() local
93 std::lock_guard<std::mutex> its_lock(clients_mutex_); in remove_client() local
102 std::lock_guard<std::mutex> its_lock(clients_mutex_); in get_clients() local
110 std::lock_guard<std::mutex> its_lock(clients_mutex_); in has_client() local
115 std::lock_guard<std::mutex> its_lock(clients_mutex_); in has_client() local
/aosp_15_r20/external/sdv/vsomeip/implementation/security/src/
Dsecurity_impl.cpp85 std::lock_guard<std::mutex> its_lock(any_client_policies_mutex_); in check_credentials() local
143 std::lock_guard<std::mutex> its_lock(any_client_policies_mutex_); in is_client_allowed() local
234 std::lock_guard<std::mutex> its_lock(any_client_policies_mutex_); in is_offer_allowed() local
302 std::lock_guard<std::mutex> its_lock(ids_mutex_); in store_client_to_uid_gid_mapping() local
325 std::lock_guard<std::mutex> its_lock(ids_mutex_); in get_client_to_uid_gid_mapping() local
340 std::lock_guard<std::mutex> its_lock(ids_mutex_); in remove_client_to_uid_gid_mapping() local
349 std::lock_guard<std::mutex> its_lock(uid_to_clients_mutex_); in remove_client_to_uid_gid_mapping() local
385 std::lock_guard<std::mutex> its_lock(uid_to_clients_mutex_); in store_uid_gid_to_client_mapping() local
403 std::lock_guard<std::mutex> its_lock(uid_to_clients_mutex_); in get_uid_gid_to_client_mapping() local
414 std::lock_guard<std::mutex> its_lock(any_client_policies_mutex_); in remove_security_policy() local
[all …]
/aosp_15_r20/external/sdv/vsomeip/test/initial_event_tests/
Dinitial_event_test_client.cpp100 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in initial_event_test_client() local
108 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in initial_event_test_client() local
132 std::unique_lock<std::mutex> its_lock(signal_mutex_); in initial_event_test_client() local
158 std::lock_guard<std::mutex> its_lock(mutex_); in on_state() local
211 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in on_message() local
267 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in on_message() local
275 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in on_message() local
287 std::lock_guard<std::mutex> its_lock(stop_mutex_); in on_message() local
380 std::lock_guard<std::mutex> its_lock(received_notifications_mutex_); in all_notifications_received_tcp_and_udp() local
460 std::lock_guard<std::mutex> its_lock(signal_mutex_); in wait_for_signal() local
[all …]
/aosp_15_r20/external/sdv/vsomeip/test/second_address_tests/
Dsecond_address_test_client.cpp121 std::lock_guard<std::mutex> its_lock(mutex_); in on_state() local
135 std::lock_guard<std::mutex> its_lock(mutex_); in on_availability() local
146 std::lock_guard<std::mutex> its_lock(mutex_); in on_message() local
170 std::lock_guard<std::mutex> its_lock(mutex_); in on_notification() local
178 std::lock_guard<std::mutex> its_lock(mutex_); in on_notification() local
203 std::lock_guard<std::mutex> its_lock(mutex_); in on_subscription_status_changed() local
213 std::lock_guard<std::mutex> its_lock(mutex_); in on_subscription_status_changed() local
225 std::lock_guard<std::mutex> its_lock(mutex_); in on_shutdown_method_called() local
231 std::unique_lock<std::mutex> its_lock(mutex_); in send() local
/aosp_15_r20/external/sdv/vsomeip/examples/
Dnotify-sample.cpp35 std::lock_guard<std::mutex> its_lock(mutex_); in init() local
69 std::lock_guard<std::mutex> its_lock(payload_mutex_); in init() local
100 std::lock_guard<std::mutex> its_lock(notify_mutex_); in offer() local
129 std::lock_guard<std::mutex> its_lock(payload_mutex_); in on_get() local
139 std::lock_guard<std::mutex> its_lock(payload_mutex_); in on_set() local
150 std::unique_lock<std::mutex> its_lock(mutex_); in run() local
180 std::unique_lock<std::mutex> its_lock(notify_mutex_); in notify() local
191 std::lock_guard<std::mutex> its_lock(payload_mutex_); in notify() local
/aosp_15_r20/external/sdv/vsomeip/test/subscribe_notify_tests/
Dsubscribe_notify_test_service.cpp127 std::lock_guard<std::mutex> its_lock(mutex_); in on_state() local
153 std::lock_guard<std::mutex> its_lock(mutex_); in on_availability() local
181 std::lock_guard<std::mutex> its_lock(subscribers_mutex_); in on_subscription() local
202 std::lock_guard<std::mutex> its_lock(notify_mutex_); in on_subscription() local
241 std::lock_guard<std::mutex> its_lock(stop_mutex_); in on_message() local
289 std::unique_lock<std::mutex> its_lock(mutex_); in run() local
341 std::unique_lock<std::mutex> its_lock(notify_mutex_); in notify() local
374 std::unique_lock<std::mutex> its_lock(stop_mutex_); in wait_for_stop() local
388 std::lock_guard<std::mutex> its_lock(mutex_); in wait_for_stop() local
/aosp_15_r20/external/sdv/vsomeip/test/someip_tp_tests/
Dsomeip_tp_test_service.cpp131 std::lock_guard<std::mutex> its_lock(mutex_); in on_state() local
141 std::lock_guard<std::mutex> its_lock(mutex_); in on_availability() local
160 std::lock_guard<std::mutex> its_lock(mutex_); in on_message() local
199 std::lock_guard<std::mutex> its_lock(mutex_); in on_notification() local
210 std::lock_guard<std::mutex> its_lock(mutex_); in on_shutdown_method_called() local
279 std::lock_guard<std::mutex> its_lock(mutex_); in on_response_from_slave() local
298 std::unique_lock<std::mutex> its_lock(mutex_); in run() local
349 std::lock_guard<std::mutex> its_lock(mutex_); in subscription_handler_async() local

1234