diff options
| -rw-r--r-- | src/components/transport_manager/src/transport_adapter/threaded_socket_connection.cc | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/components/transport_manager/src/transport_adapter/threaded_socket_connection.cc b/src/components/transport_manager/src/transport_adapter/threaded_socket_connection.cc index 9f01ccde3..eddf8b27c 100644 --- a/src/components/transport_manager/src/transport_adapter/threaded_socket_connection.cc +++ b/src/components/transport_manager/src/transport_adapter/threaded_socket_connection.cc @@ -232,7 +232,7 @@ void ThreadedSocketConnection::Transmit() { return; } - bool is_queue_empty = true; + bool is_queue_empty = true; { // Check Frames queue is empty or not sync_primitives::AutoLock auto_lock(frames_to_send_mutex_); @@ -298,10 +298,10 @@ bool ThreadedSocketConnection::Send() { LOG4CXX_AUTO_TRACE(logger_); FrameQueue frames_to_send; -{ - sync_primitives::AutoLock auto_lock(frames_to_send_mutex_); - std::swap(frames_to_send, frames_to_send_); -} + { + sync_primitives::AutoLock auto_lock(frames_to_send_mutex_); + std::swap(frames_to_send, frames_to_send_); + } size_t offset = 0; while (!frames_to_send.empty()) { |