diff --git a/src/cpp/fastdds/log/Log.cpp b/src/cpp/fastdds/log/Log.cpp index 9063fd4efb9..b1f46e1a492 100644 --- a/src/cpp/fastdds/log/Log.cpp +++ b/src/cpp/fastdds/log/Log.cpp @@ -18,13 +18,13 @@ #include #include -#include - +#include #include #include #include #include -#include + +#include #include #include #include @@ -341,7 +341,7 @@ struct LogResources return true; } - fastrtps::DBQueue logs_; + DBQueue logs_; std::vector> consumers_; eprosima::thread logging_thread_; diff --git a/src/cpp/rtps/builtin/discovery/database/DiscoveryDataBase.hpp b/src/cpp/rtps/builtin/discovery/database/DiscoveryDataBase.hpp index 2c363f12f32..7077b10e2c3 100644 --- a/src/cpp/rtps/builtin/discovery/database/DiscoveryDataBase.hpp +++ b/src/cpp/rtps/builtin/discovery/database/DiscoveryDataBase.hpp @@ -27,17 +27,17 @@ #include #include +#include + +#include #include #include -#include -#include #include -#include -#include #include - -#include +#include +#include +#include namespace eprosima { namespace fastdds { @@ -520,9 +520,9 @@ class DiscoveryDataBase //////////////// // Variables - fastrtps::DBQueue pdp_data_queue_; + DBQueue pdp_data_queue_; - fastrtps::DBQueue edp_data_queue_; + DBQueue edp_data_queue_; //! Covenient per-topic mapping of readers and writers to speed-up queries std::map> readers_by_topic_; diff --git a/src/cpp/rtps/transport/shared_mem/SharedMemLog.hpp b/src/cpp/rtps/transport/shared_mem/SharedMemLog.hpp index 22754952850..04d2ac249c6 100644 --- a/src/cpp/rtps/transport/shared_mem/SharedMemLog.hpp +++ b/src/cpp/rtps/transport/shared_mem/SharedMemLog.hpp @@ -19,9 +19,9 @@ #include #include -#include #include +#include #include #include #include @@ -334,7 +334,7 @@ class PacketsLog struct Resources { - eprosima::fastrtps::DBQueue logs; + DBQueue logs; std::vector> consumers; eprosima::thread logging_thread; diff --git a/include/fastrtps/utils/DBQueue.h b/src/cpp/utils/DBQueue.hpp similarity index 97% rename from include/fastrtps/utils/DBQueue.h rename to src/cpp/utils/DBQueue.hpp index f2d91b6cebc..5e74ca5e1b6 100644 --- a/include/fastrtps/utils/DBQueue.h +++ b/src/cpp/utils/DBQueue.hpp @@ -12,16 +12,16 @@ // See the License for the specific language governing permissions and // limitations under the License. // -#ifndef DBQUEUE_H -#define DBQUEUE_H +#ifndef _FASTDDS_DBQUEUE_HPP +#define _FASTDDS_DBQUEUE_HPP -#include -#include -#include #include +#include +#include +#include namespace eprosima { -namespace fastrtps { +namespace fastdds { /** * Double buffered, threadsafe queue for MPSC (multi-producer, single-consumer) comms. @@ -151,7 +151,7 @@ class DBQueue }; -} // namespace fastrtps +} // namespace fastdds } // namespace eprosima #endif // ifndef DBQUEUE_H