@@ -56,7 +56,7 @@ void local_uds_client_endpoint_impl::restart(bool _force) {
5656 queue_size_ = 0 ;
5757 }
5858 {
59- std::lock_guard<std::mutex> its_lock (socket_mutex_);
59+ std::lock_guard its_lock (socket_mutex_);
6060 shutdown_and_close_socket_unlocked (true );
6161 }
6262 state_ = cei_state_e::CONNECTING;
@@ -77,19 +77,19 @@ void local_uds_client_endpoint_impl::start() {
7777
7878void local_uds_client_endpoint_impl::stop () {
7979 {
80- std::lock_guard<std::recursive_mutex> its_lock (mutex_);
80+ std::lock_guard its_lock (mutex_);
8181 sending_blocked_ = true ;
8282 }
8383 {
84- std::lock_guard<std::mutex> its_lock (connect_timer_mutex_);
84+ std::lock_guard its_lock (connect_timer_mutex_);
8585 boost::system::error_code ec;
8686 connect_timer_.cancel (ec);
8787 }
8888 connect_timeout_ = VSOMEIP_DEFAULT_CONNECT_TIMEOUT;
8989
9090 bool is_open (false );
9191 {
92- std::lock_guard<std::mutex> its_lock (socket_mutex_);
92+ std::lock_guard its_lock (socket_mutex_);
9393 is_open = socket_->is_open ();
9494 }
9595 if (is_open) {
@@ -116,7 +116,7 @@ void local_uds_client_endpoint_impl::connect() {
116116 start_connecting_timer ();
117117 boost::system::error_code its_connect_error;
118118 {
119- std::lock_guard<std::mutex> its_lock (socket_mutex_);
119+ std::lock_guard its_lock (socket_mutex_);
120120 boost::system::error_code its_error;
121121 socket_->open (remote_.protocol (), its_error);
122122
@@ -153,7 +153,7 @@ void local_uds_client_endpoint_impl::connect() {
153153 }
154154 std::size_t operations_cancelled;
155155 {
156- std::lock_guard<std::mutex> its_lock (connecting_timer_mutex_);
156+ std::lock_guard its_lock (connecting_timer_mutex_);
157157 operations_cancelled = connecting_timer_.cancel ();
158158 connecting_timer_state_ = connecting_timer_state_e::FINISH_ERROR;
159159 if (operations_cancelled != 0 ) {
@@ -174,7 +174,7 @@ void local_uds_client_endpoint_impl::connect() {
174174}
175175
176176void local_uds_client_endpoint_impl::receive () {
177- std::lock_guard<std::mutex> its_lock (socket_mutex_);
177+ std::lock_guard its_lock (socket_mutex_);
178178 if (socket_->is_open ()) {
179179 socket_->async_receive (
180180 boost::asio::buffer (recv_buffer_),
@@ -232,7 +232,7 @@ void local_uds_client_endpoint_impl::send_queued(std::pair<message_buffer_ptr_t,
232232 bufs.push_back (boost::asio::buffer (its_end_tag));
233233
234234 {
235- std::lock_guard<std::mutex> its_lock (socket_mutex_);
235+ std::lock_guard its_lock (socket_mutex_);
236236 if (socket_->is_open ()) {
237237 boost::asio::async_write (
238238 *socket_, bufs,
@@ -284,7 +284,7 @@ void local_uds_client_endpoint_impl::receive_cbk(
284284 }
285285 error_handler_t handler;
286286 {
287- std::lock_guard<std::mutex> its_lock (error_handler_mutex_);
287+ std::lock_guard its_lock (error_handler_mutex_);
288288 handler = error_handler_;
289289 }
290290 if (handler)
@@ -391,7 +391,7 @@ void local_uds_client_endpoint_impl::max_allowed_reconnects_reached() {
391391 << get_remote_information ();
392392 error_handler_t handler;
393393 {
394- std::lock_guard<std::mutex> its_lock (error_handler_mutex_);
394+ std::lock_guard its_lock (error_handler_mutex_);
395395 handler = error_handler_;
396396 }
397397 if (handler)
0 commit comments