/aosp_15_r20/external/sdv/vsomeip/implementation/routing/src/ |
D | routing_manager_proxy.cpp | 61 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 …]
|
D | event.cpp | 98 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 …]
|
D | eventgroupinfo.cpp | 94 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 …]
|
D | routing_manager_stub.cpp | 63 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 …]
|
D | routing_manager_base.cpp | 102 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 …]
|
D | routing_manager_impl.cpp | 192 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 …]
|
D | remote_subscription.cpp | 151 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 …]
|
D | serviceinfo.cpp | 70 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/ |
D | tcp_server_endpoint_impl.cpp | 73 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 …]
|
D | endpoint_manager_impl.cpp | 46 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 …]
|
D | local_client_endpoint_impl.cpp | 58 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 …]
|
D | udp_server_endpoint_impl.cpp | 148 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 …]
|
D | client_endpoint_impl.cpp | 75 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 …]
|
D | udp_client_endpoint_impl.cpp | 56 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 …]
|
D | tcp_client_endpoint_impl.cpp | 96 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 …]
|
D | local_server_endpoint_impl.cpp | 102 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/ |
D | application_impl.cpp | 106 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/ |
D | service_discovery_impl.cpp | 151 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 …]
|
D | subscription.cpp | 50 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/ |
D | security_impl.cpp | 85 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/ |
D | initial_event_test_client.cpp | 100 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/ |
D | second_address_test_client.cpp | 121 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/ |
D | notify-sample.cpp | 35 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/ |
D | subscribe_notify_test_service.cpp | 127 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/ |
D | someip_tp_test_service.cpp | 131 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
|