1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
// Copyright 2024 Proyectos y Sistemas de Mantenimiento SL (eProsima
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
#include <fstream>
#include <mutex>
#ifdef _WIN32
#include <windows.h>
#else
#include <limits.h>
#include <unistd.h>
#endif // ifdef _WIN32
#include <gtest/gtest.h>
#include <fastdds/dds/log/Log.hpp>
#include "../logging/mock/MockConsumer.h"
#include <xmlparser/XMLProfileManager.h>
#include <xmlparser/XMLParserCommon.h>
using namespace eprosima::fastdds::dds;
using namespace eprosima::fastdds;
using namespace ::testing;
class XMLLoadFileTests : public ::testing::Test
{
public:
void helper_block_for_at_least_entries_for(
uint32_t amount,
std::chrono::seconds timeout)
{
mock_consumer_->wait_for_at_least_entries_for(
amount,
timeout);
}
protected:
void SetUp() override
{
mock_consumer_ = new eprosima::fastdds::dds::MockConsumer();
log_consumer_.reset(mock_consumer_);
}
void TearDown() override
{
//! mock_consumer_ is going to be cleared in log_consumer_ destructor
}
eprosima::fastdds::dds::MockConsumer* mock_consumer_;
std::unique_ptr<LogConsumer> log_consumer_;
private:
std::mutex xml_mutex_;
};
/*
* This test checks that the default XML file is loaded only once when there is a DEFAULT_FASTDDS_PROFILES.xml file
* in the current directory and the environment variable FASTDDS_DEFAULT_PROFILES_FILE is set pointing to the same
* file.
* 1. Initialize Mock Consumer to consume the LogInfo entry that the library generates when the file has been already
* parsed. Set filters to consume only the desired entry.
* 2. Get current path to set the environment variable to the DEFAULT_FASTDDS_PROFILES.xml file.
* 3. Write the DEFAULT_FASTDDS_PROFILES.xml file in the current directory.
* 4. Load the default XML file.
* 5. Wait for the log entry to be consumed.
*/
TEST_F(XMLLoadFileTests, load_twice_default_xml)
{
// Register Mock Consumer
Log::ClearConsumers();
Log::RegisterConsumer(std::move(log_consumer_));
Log::SetVerbosity(Log::Info);
Log::SetCategoryFilter(std::regex("(XMLPARSER)"));
Log::SetErrorStringFilter(std::regex("(already parsed)"));
// Current directory
#ifdef _WIN32
char current_directory[MAX_PATH];
uint32_t ret = GetCurrentDirectory(MAX_PATH, current_directory);
ASSERT_NE(ret, 0u);
strcat_s(current_directory, MAX_PATH, "\\");
strcat_s(current_directory, MAX_PATH, xmlparser::DEFAULT_FASTDDS_PROFILES);
// Set environment variable
_putenv_s("FASTDDS_DEFAULT_PROFILES_FILE", current_directory);
#else
char current_directory[PATH_MAX];
ASSERT_NE(getcwd(current_directory, PATH_MAX), (void*)NULL);
strcat(current_directory, "/");
strcat(current_directory, xmlparser::DEFAULT_FASTDDS_PROFILES);
// Set environment variable
setenv("FASTDDS_DEFAULT_PROFILES_FILE", current_directory, 1);
#endif // _WIN32
// Write DEFAULT_FASTDDS_PROFILES.xml
std::ofstream xmlFile;
xmlFile.open("DEFAULT_FASTDDS_PROFILES.xml");
xmlFile << "<dds xmlns=\"http://www.eprosima.com\">";
xmlFile << "<profiles><participant profile_name=\"test_participant_profile\" is_default_profile=\"true\">";
xmlFile << "<rtps><useBuiltinTransports>true</useBuiltinTransports><name>test_name</name></rtps></participant>";
xmlFile << "</profiles></dds>";
xmlFile.close();
// Load default XML file
xmlparser::XMLProfileManager::loadDefaultXMLFile();
// Log consumer
helper_block_for_at_least_entries_for(1, std::chrono::seconds(2));
auto consumed_entries = mock_consumer_->ConsumedEntries();
EXPECT_EQ(consumed_entries.size(), 1u);
Log::Reset();
Log::KillThread();
std::remove("DEFAULT_FASTDDS_PROFILES.xml");
}
int main(
int argc,
char** argv)
{
testing::InitGoogleTest(&argc, argv);
return RUN_ALL_TESTS();
}
|
