}
Subscription subscription(
running_sess_->onModuleChange(model, callback, nullopt, 0, options));
- subscriptions_.emplace(server, forward<Subscription>(subscription));
+ subscriptions_.emplace(server, std::forward<Subscription>(subscription));
} catch (exception const& ex) {
ostringstream msg;
msg << "module change subscribe failed with " << ex.what();
};
try {
Subscription subscription(running_sess_->onNotification(model, callback));
- subscriptions_.emplace(server, forward<Subscription>(subscription));
+ subscriptions_.emplace(server, std::forward<Subscription>(subscription));
} catch (exception const& ex) {
ostringstream msg;
msg << "event notification subscription for model " << model <<
partnerStateTest();
}
+TEST_F(CommunicationStateTest, partnerStateUnavailableTest) {
+ partnerStateUnavailableTest();
+}
+
+TEST_F(CommunicationStateTest, partnerStateUnavailableTestMultiThreading) {
+ MultiThreadingMgr::instance().setMode(true);
+ partnerStateUnavailableTest();
+}
+
TEST_F(CommunicationStateTest, partnerScopesTest) {
partnerScopesTest();
}
// The value specified is 100.
ElementPtr json = Element::fromJSON("{ \"bar\": 100 }");
- int64_t x;
+ int64_t x = -1;
// Positive case: we expect value in range 0..200. All ok.
EXPECT_NO_THROW(x = SimpleParser::getInteger(json, "bar", 0, 200));
ASSERT_EQ(3, option->getDataFieldsNum());
// Check that the values have been correctly set.
- uint16_t value0;
+ uint16_t value0 = 0;
ASSERT_NO_THROW(value0 = option->readInteger<uint16_t>(0));
EXPECT_EQ(67, value0);
- uint16_t value1;
+ uint16_t value1 = 0;
ASSERT_NO_THROW(value1 = option->readInteger<uint16_t>(1));
EXPECT_EQ(876, value1);
- uint16_t value2;
+ uint16_t value2 = 0;
ASSERT_NO_THROW(value2 = option->readInteger<uint16_t>(2));
EXPECT_EQ(32222, value2);
}
ASSERT_EQ(9, option->getDataFieldsNum());
// Check that the default values have been correctly set.
- uint16_t value0;
+ uint16_t value0 = 0;
ASSERT_NO_THROW(value0 = option->readInteger<uint16_t>(0));
EXPECT_EQ(0, value0);
bool value1 = true;
ASSERT_EQ(9, option->getDataFieldsNum());
// Check that the default values have been correctly set.
- uint16_t value0;
+ uint16_t value0 = 0;
ASSERT_NO_THROW(value0 = option->readInteger<uint16_t>(0));
EXPECT_EQ(0, value0);
bool value1 = true;
ASSERT_EQ(4, option->getDataFieldsNum());
// We expect a 16 bit integer
- uint16_t value0;
+ uint16_t value0 = 0;
ASSERT_NO_THROW(value0 = option->readInteger<uint16_t>(0));
EXPECT_EQ(8712, value0);
"\"option-data\": [ ] }");
};
- std::string expected = "[\n" +
- add_defaults("one") + ",\n" +
- add_defaults("two") + ",\n" +
- add_defaults("three") + "]\n";
+ std::string expected = "[\n";
+ expected += add_defaults("one") + ",\n";
+ expected += add_defaults("two") + ",\n";
+ expected += add_defaults("three") + "]\n";
runToElementTest<ClientClassDictionary>(expected, *dictionary);
}
"\"option-data\": [ ] }");
};
- std::string expected = "[\n" +
- add_defaults("one") + ",\n" +
- add_defaults("two") + ",\n" +
- add_defaults("three") + "]\n";
+ std::string expected = "[\n";
+ expected += add_defaults("one") + ",\n";
+ expected += add_defaults("two") + ",\n";
+ expected += add_defaults("three") + "]\n";
runToElementTest<ClientClassDictionary>(expected, *dictionary);
}
(getOptionPtr(MAPE_V6_OPTION_SPACE, D6O_S46_RULE));
ASSERT_TRUE(s46_rule);
- uint8_t flags;
- uint8_t ea_len;
- uint8_t prefix4_len;
+ uint8_t flags = 0;
+ uint8_t ea_len = 0;
+ uint8_t prefix4_len = 0;
IOAddress ipv4_prefix(IOAddress::IPV4_ZERO_ADDRESS());
PrefixTuple ipv6_prefix(PrefixLen(0), IOAddress::IPV6_ZERO_ADDRESS());;
ASSERT_NO_THROW(content_type = request_->getHeaderValue("Content-Type"));
EXPECT_EQ("application/json", content_type);
- uint64_t content_length;
+ uint64_t content_length = 0;
ASSERT_NO_THROW(
content_length = request_->getHeaderValueAsUint64("Content-Length")
);