Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion mobile/examples/cc/fetch_client/fetch_client_main.cc
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ int main(int argc, char** argv) {
absl::Notification engine_running;
Envoy::Platform::EngineSharedPtr engine =
Envoy::Platform::EngineBuilder()
.setLogLevel(Envoy::Logger::Logger::trace)
.setLogLevel(Envoy::Logger::Levels::trace)
.addRuntimeGuard("dns_cache_set_ip_version_to_remove", true)
.addRuntimeGuard("quic_no_tcp_delay", true)
.setOnEngineRunning([&engine_running]() { engine_running.Notify(); })
Expand Down
2 changes: 1 addition & 1 deletion mobile/library/cc/engine_builder.cc
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ EngineBuilder& EngineBuilder::setBufferHighWatermark(size_t high_watermark) {
return *this;
}

EngineBuilder& EngineBuilder::setLogLevel(Logger::Logger::Levels log_level) {
EngineBuilder& EngineBuilder::setLogLevel(Logger::Levels log_level) {
log_level_ = log_level;
return *this;
}
Expand Down
4 changes: 2 additions & 2 deletions mobile/library/cc/engine_builder.h
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ class EngineBuilder {
virtual ~EngineBuilder() = default;
static std::string nativeNameToConfig(absl::string_view name);

EngineBuilder& setLogLevel(Logger::Logger::Levels log_level);
EngineBuilder& setLogLevel(Logger::Levels log_level);
EngineBuilder& setLogger(std::unique_ptr<EnvoyLogger> logger);
EngineBuilder& enableLogger(bool logger_on);
EngineBuilder& setEngineCallbacks(std::unique_ptr<EngineCallbacks> callbacks);
Expand Down Expand Up @@ -199,7 +199,7 @@ class EngineBuilder {
Protobuf::Any typed_config_{};
};

Logger::Logger::Levels log_level_ = Logger::Logger::Levels::info;
Logger::Levels log_level_ = Logger::Levels::info;
std::unique_ptr<EnvoyLogger> logger_{nullptr};
bool enable_logger_{true};
std::unique_ptr<EngineCallbacks> callbacks_;
Expand Down
4 changes: 2 additions & 2 deletions mobile/library/cc/engine_builder_base.h
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ template <typename T> class EngineBuilderBase {
virtual ~EngineBuilderBase() = default;
EngineBuilderBase(EngineBuilderBase&&) = default;

T& setLogLevel(Logger::Logger::Levels log_level) {
T& setLogLevel(Logger::Levels log_level) {
log_level_ = log_level;
return static_cast<T&>(*this);
}
Expand Down Expand Up @@ -420,7 +420,7 @@ template <typename T> class EngineBuilderBase {
std::vector<envoy::config::listener::v3::Listener> custom_listeners_;

// Common fields for InternalEngine
Logger::Logger::Levels log_level_ = Logger::Logger::Levels::info;
Logger::Levels log_level_ = Logger::Levels::info;
std::unique_ptr<EnvoyLogger> logger_{nullptr};
bool enable_logger_{true};
std::unique_ptr<EngineCallbacks> callbacks_;
Expand Down
4 changes: 2 additions & 2 deletions mobile/library/common/engine_types.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ struct EngineCallbacks {

/** The callbacks for Envoy Logger. */
struct EnvoyLogger {
absl::AnyInvocable<void(Logger::Logger::Levels, const std::string&)> on_log_ =
[](Logger::Logger::Levels, const std::string&) {};
absl::AnyInvocable<void(Logger::Levels, const std::string&)> on_log_ = [](Logger::Levels,
const std::string&) {};
absl::AnyInvocable<void()> on_exit_ = [] {};
};

Expand Down
4 changes: 2 additions & 2 deletions mobile/library/common/logger/logger_delegate.cc
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,8 @@ LambdaDelegate::~LambdaDelegate() {
}

void LambdaDelegate::log(absl::string_view msg, const spdlog::details::log_msg& log_msg) {
// Logger::Levels is simply an alias to spdlog::level::level_enum, so we can safely cast it.
logger_->on_log_(static_cast<Logger::Levels>(log_msg.level), std::string(msg));
// Levels is simply an alias to spdlog::level::level_enum, so we can safely cast it.
logger_->on_log_(static_cast<Levels>(log_msg.level), std::string(msg));
}

DefaultDelegate::DefaultDelegate(absl::Mutex& mutex, DelegatingLogSinkSharedPtr log_sink)
Expand Down
2 changes: 1 addition & 1 deletion mobile/library/jni/jni_impl.cc
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ extern "C" JNIEXPORT jlong JNICALL Java_io_envoyproxy_envoymobile_engine_JniLibr
std::unique_ptr<Envoy::EnvoyLogger> logger = std::make_unique<Envoy::EnvoyLogger>();
if (envoy_logger != nullptr) {
jobject envoy_logger_global_ref = env->NewGlobalRef(envoy_logger);
logger->on_log_ = [envoy_logger_global_ref](Envoy::Logger::Logger::Levels level,
logger->on_log_ = [envoy_logger_global_ref](Envoy::Logger::Levels level,
const std::string& message) {
Envoy::JNI::JniHelper jni_helper(Envoy::JNI::JniHelper::getThreadLocalEnv());
Envoy::JNI::LocalRefUniquePtr<jstring> java_message =
Expand Down
4 changes: 2 additions & 2 deletions mobile/library/objective-c/EnvoyEngineImpl.mm
Original file line number Diff line number Diff line change
Expand Up @@ -416,12 +416,12 @@ - (instancetype)initWithRunningCallback:(nullable void (^)())onEngineRunning

std::unique_ptr<Envoy::EnvoyLogger> native_logger = std::make_unique<Envoy::EnvoyLogger>();
if (logger) {
native_logger->on_log_ = [logger = std::move(logger)](Envoy::Logger::Logger::Levels level,
native_logger->on_log_ = [logger = std::move(logger)](Envoy::Logger::Levels level,
const std::string &message) {
// This code block runs inside the Envoy event loop. Therefore, an explicit autoreleasepool
// block is necessary to act as a breaker for any Objective-C allocation that happens.
@autoreleasepool {
logger(level, @(message.c_str()));
logger((long)level, @(message.c_str()));
}
};
}
Expand Down
18 changes: 9 additions & 9 deletions mobile/library/python/module_definition.cc
Original file line number Diff line number Diff line change
Expand Up @@ -28,14 +28,14 @@ PYBIND11_MODULE(envoy_engine, m) {

// -- Enums --

py::enum_<Envoy::Logger::Logger::Levels>(m, "LogLevel")
.value("trace", Envoy::Logger::Logger::Levels::trace)
.value("debug", Envoy::Logger::Logger::Levels::debug)
.value("info", Envoy::Logger::Logger::Levels::info)
.value("warn", Envoy::Logger::Logger::Levels::warn)
.value("error", Envoy::Logger::Logger::Levels::error)
.value("critical", Envoy::Logger::Logger::Levels::critical)
.value("off", Envoy::Logger::Logger::Levels::off);
py::enum_<Envoy::Logger::Levels>(m, "LogLevel")
.value("trace", Envoy::Logger::Levels::trace)
.value("debug", Envoy::Logger::Levels::debug)
.value("info", Envoy::Logger::Levels::info)
.value("warn", Envoy::Logger::Levels::warn)
.value("error", Envoy::Logger::Levels::error)
.value("critical", Envoy::Logger::Levels::critical)
.value("off", Envoy::Logger::Levels::off);

py::enum_<envoy_status_t>(m, "EnvoyStatus")
.value("success", ENVOY_SUCCESS)
Expand Down Expand Up @@ -178,7 +178,7 @@ PYBIND11_MODULE(envoy_engine, m) {
.def(py::init<>())
.def(
"set_log_level",
[](Envoy::Platform::EngineBuilder& self, Envoy::Logger::Logger::Levels level)
[](Envoy::Platform::EngineBuilder& self, Envoy::Logger::Levels level)
-> Envoy::Platform::EngineBuilder& { return self.setLogLevel(level); },
py::arg("log_level"), py::return_value_policy::reference)
.def(
Expand Down
12 changes: 6 additions & 6 deletions mobile/test/cc/engine_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,13 @@ namespace Envoy {
TEST(EngineTest, SetLogger) {
std::atomic<bool> logging_was_called{false};
auto logger = std::make_unique<EnvoyLogger>();
logger->on_log_ = [&](Logger::Logger::Levels, const std::string&) { logging_was_called = true; };
logger->on_log_ = [&](Logger::Levels, const std::string&) { logging_was_called = true; };

absl::Notification engine_running;
auto engine_callbacks = std::make_unique<EngineCallbacks>();
engine_callbacks->on_engine_running_ = [&] { engine_running.Notify(); };
Platform::EngineBuilder engine_builder;
engine_builder.setLogLevel(Logger::Logger::debug)
engine_builder.setLogLevel(Logger::Levels::debug)
.setLogger(std::move(logger))
.setEngineCallbacks(std::move(engine_callbacks))
.enforceTrustChainVerification(false);
Expand Down Expand Up @@ -68,7 +68,7 @@ TEST(EngineTest, SetEngineCallbacks) {
auto engine_callbacks = std::make_unique<EngineCallbacks>();
engine_callbacks->on_engine_running_ = [&] { engine_running.Notify(); };
Platform::EngineBuilder engine_builder;
engine_builder.setLogLevel(Logger::Logger::debug)
engine_builder.setLogLevel(Logger::Levels::debug)
.setEngineCallbacks(std::move(engine_callbacks))
.enforceTrustChainVerification(false);
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS);
Expand Down Expand Up @@ -126,7 +126,7 @@ TEST(EngineTest, SetEventTracker) {
event_tracker->on_exit_ = [&] { on_track_exit.Notify(); };

Platform::EngineBuilder engine_builder;
engine_builder.setLogLevel(Logger::Logger::debug)
engine_builder.setLogLevel(Logger::Levels::debug)
.setEngineCallbacks(std::move(engine_callbacks))
.setEventTracker(std::move(event_tracker))
.enforceTrustChainVerification(false);
Expand All @@ -141,7 +141,7 @@ TEST(EngineTest, SetEventTracker) {

TEST(EngineTest, DontWaitForOnEngineRunning) {
Platform::EngineBuilder engine_builder;
engine_builder.setLogLevel(Logger::Logger::debug).enforceTrustChainVerification(false);
engine_builder.setLogLevel(Logger::Levels::debug).enforceTrustChainVerification(false);
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS);

std::string actual_status_code;
Expand Down Expand Up @@ -185,7 +185,7 @@ TEST(EngineTest, TerminateWithoutWaitingForOnEngineRunning) {
engine_callbacks->on_engine_running_ = [&] { engine_running.Notify(); };

Platform::EngineBuilder engine_builder;
auto engine = engine_builder.setLogLevel(Logger::Logger::debug).build();
auto engine = engine_builder.setLogLevel(Logger::Levels::debug).build();

engine->terminate();
}
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/base/integration_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ class BaseEngineBuilderTest : public testing::TestWithParam<TestServerType> {
engine_builder.addHcmHttpFilter(std::move(assertion_filter));
}

engine_builder.enableLogger(false).setLogLevel(Logger::Logger::debug).setOnEngineRunning([&]() {
engine_builder.enableLogger(false).setLogLevel(Logger::Levels::debug).setOnEngineRunning([&]() {
engine_running.Notify();
});
client_engine_with_test_server_ = std::make_unique<TestEngineAndServer>(
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/lifetimes_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ void sendRequest() {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS);
engine_running.WaitForNotification();
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/receive_data_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ TEST(ReceiveDataTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS,
/* headers= */ {}, /* body= */ "hello world",
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/receive_headers_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ TEST(ReceiveHeadersTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS,
{{"foo", "bar"}});
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/receive_trailers_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ TEST(ReceiveTrailersTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS,
/* headers= */ {},
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/send_data_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ TEST(SendDataTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.addNativeFilter("envoy.filters.http.assertion", typed_config)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS);
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/send_headers_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ TEST(SendHeadersTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.addNativeFilter("envoy.filters.http.assertion", typed_config)
.setOnEngineRunning([&]() { engine_running.Notify(); });
EngineWithTestServer engine_with_test_server(engine_builder, TestServerType::HTTP2_WITH_TLS);
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/integration/send_trailers_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ TEST(SendTrailersTest, Success) {
Platform::EngineBuilder engine_builder;
engine_builder.enforceTrustChainVerification(false)
.enableLogger(false)
.setLogLevel(Logger::Logger::debug)
.setLogLevel(Logger::Levels::debug)
.addNativeFilter("envoy.filters.http.assertion", typed_config)

.setOnEngineRunning([&]() { engine_running.Notify(); });
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/cc/unit/fetch_client_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ envoy_status_t fetchUrls(const std::vector<std::string> urls,
std::vector<Http::Protocol>* used_protocols) {
absl::Notification engine_running;
Platform::EngineBuilder engine_builder;
engine_builder.setLogLevel(Envoy::Logger::Logger::info)
engine_builder.setLogLevel(Envoy::Logger::Levels::info)
.enableLogger(false)
.addRuntimeGuard("dns_cache_set_ip_version_to_remove", true)
.addRuntimeGuard("quic_no_tcp_delay", true)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,7 @@ BaseClientIntegrationTest::BaseClientIntegrationTest(Network::Address::IpVersion
defer_listener_finalization_ = true;
memset(&last_stream_final_intel_, 0, sizeof(envoy_final_stream_intel));

builder_.setLogLevel(
static_cast<Logger::Logger::Levels>(TestEnvironment::getOptions().logLevel()));
builder_.setLogLevel(static_cast<Logger::Levels>(TestEnvironment::getOptions().logLevel()));
// The admin interface gets added by default in the ConfigHelper's constructor. Since the admin
// interface gets compiled out by default in Envoy Mobile, remove it from the ConfigHelper's
// bootstrap config.
Expand Down
68 changes: 32 additions & 36 deletions mobile/test/common/integration/client_integration_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ class ClientIntegrationTest : public BaseClientIntegrationTest,
}

protected:
Logger::Logger::Levels log_level_ = Logger::Logger::info;
Logger::Levels log_level_ = Logger::Levels::info;
std::unique_ptr<test::SystemHelperPeer::Handle> helper_handle_;
bool add_quic_hints_ = false;
bool add_fake_dns_ = false;
Expand Down Expand Up @@ -296,13 +296,12 @@ TEST_P(ClientIntegrationTest, Basic) {
#if not defined(__APPLE__)
TEST_P(ClientIntegrationTest, DisableDnsRefreshOnFailure) {
std::atomic<bool> found_cache_miss{false};
LogExpectation log_expect(
Envoy::GetLogSink(), [&](Logger::Logger::Levels, const std::string& msg) {
if (msg.find("ignoring failed address cache hit for miss for host 'doesnotexist") !=
std::string::npos) {
found_cache_miss = true;
}
});
LogExpectation log_expect(Envoy::GetLogSink(), [&](Logger::Levels, const std::string& msg) {
if (msg.find("ignoring failed address cache hit for miss for host 'doesnotexist") !=
std::string::npos) {
found_cache_miss = true;
}
});

// Configure MockDnsResolver with "doesnotexist" as a non-existent domain
envoy::config::core::v3::TypedExtensionConfig dns_resolver_config;
Expand All @@ -313,7 +312,7 @@ TEST_P(ClientIntegrationTest, DisableDnsRefreshOnFailure) {
builder_.setDnsResolver(dns_resolver_config);

builder_.setDisableDnsRefreshOnFailure(true);
log_level_ = Logger::Logger::debug;
log_level_ = Logger::Levels::debug;
initialize();

default_request_headers_.setHost("doesnotexist");
Expand All @@ -333,14 +332,13 @@ TEST_P(ClientIntegrationTest, DisableDnsRefreshOnFailure) {

TEST_P(ClientIntegrationTest, DisableDnsRefreshOnNetworkChange) {
std::atomic<bool> found_force_dns_refresh{false};
LogExpectation log_expect(
Envoy::GetLogSink(), [&](Logger::Logger::Levels, const std::string& msg) {
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh = true;
}
});
LogExpectation log_expect(Envoy::GetLogSink(), [&](Logger::Levels, const std::string& msg) {
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh = true;
}
});
builder_.setDisableDnsRefreshOnNetworkChange(true);
log_level_ = Logger::Logger::debug;
log_level_ = Logger::Levels::debug;
initialize();

internalEngine()->onDefaultNetworkChanged(1);
Expand All @@ -352,16 +350,15 @@ TEST_P(ClientIntegrationTest, HandleNetworkChangeEvents) {
std::atomic<bool> found_force_dns_refresh{false};
std::vector<absl::Notification> handled_network_changes(5);
std::atomic<int> current_change_event{0};
LogExpectation log_expect(
Envoy::GetLogSink(), [&](Logger::Logger::Levels, const std::string& msg) {
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh = true;
} else if (msg.find("Finished the network changed callback") != std::string::npos) {
handled_network_changes[current_change_event].Notify();
}
});
LogExpectation log_expect(Envoy::GetLogSink(), [&](Logger::Levels, const std::string& msg) {
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh = true;
} else if (msg.find("Finished the network changed callback") != std::string::npos) {
handled_network_changes[current_change_event].Notify();
}
});
builder_.setDisableDnsRefreshOnNetworkChange(false);
log_level_ = Logger::Logger::trace;
log_level_ = Logger::Levels::trace;
initialize();

// Set the network type to WIFI. This should trigger a network change.
Expand Down Expand Up @@ -411,18 +408,17 @@ TEST_P(ClientIntegrationTest, HandleNetworkChangeEvents) {
TEST_P(ClientIntegrationTest, HandleNetworkChangeEventsAndroid) {
absl::Notification found_force_dns_refresh;
std::atomic<bool> handled_network_change{false};
LogExpectation log_expect(
Envoy::GetLogSink(), [&](Logger::Logger::Levels, const std::string& msg) {
if (msg.find("Default network state has been changed. Current net configuration key") !=
std::string::npos) {
handled_network_change = true;
}
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh.Notify();
}
});
LogExpectation log_expect(Envoy::GetLogSink(), [&](Logger::Levels, const std::string& msg) {
if (msg.find("Default network state has been changed. Current net configuration key") !=
std::string::npos) {
handled_network_change = true;
}
if (msg.find("beginning DNS cache force refresh") != std::string::npos) {
found_force_dns_refresh.Notify();
}
});
builder_.setDisableDnsRefreshOnNetworkChange(false);
log_level_ = Logger::Logger::trace;
log_level_ = Logger::Levels::trace;
initialize();

// A new WIFI network appears and becomes the default network. Even though
Expand Down
2 changes: 1 addition & 1 deletion mobile/test/common/integration/rtds_integration_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ class RtdsIntegrationTest : public XdsIntegrationTest {
xds_builder.addRuntimeDiscoveryService("some_rtds_resource", /*timeout_in_seconds=*/1)
.setSslRootCerts(getUpstreamCert());
builder_.setXds(std::move(xds_builder));
builder_.setLogLevel(Logger::Logger::info);
builder_.setLogLevel(Logger::Levels::info);
builder_.enforceTrustChainVerification(false);
XdsIntegrationTest::createEnvoy();
}
Expand Down
Loading
Loading