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
1 change: 1 addition & 0 deletions docs/root/version_history/current.rst
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ Removed Config or Runtime
* http: removed ``envoy.reloadable_features.allow_response_for_timeout`` and legacy code paths.
* http: removed ``envoy.reloadable_features.http2_consume_stream_refused_errors`` and legacy code paths.
* http: removed ``envoy.reloadable_features.internal_redirects_with_body`` and legacy code paths.
* listener: removed ``envoy.reloadable_features.listener_reuse_port_default_enabled`` and legacy code paths.
* udp: removed ``envoy.reloadable_features.udp_per_event_loop_read_limit`` and legacy code paths.
* upstream: removed ``envoy.reloadable_features.health_check.graceful_goaway_handling`` and legacy code paths.
* xds: removed ``envoy.reloadable_features.vhds_heartbeats`` and legacy code paths.
Expand Down
1 change: 0 additions & 1 deletion source/common/runtime/runtime_features.cc
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,6 @@ constexpr absl::Flag<bool>* runtime_features[] = {
&FLAGS_envoy_reloadable_features_http_reject_path_with_fragment,
&FLAGS_envoy_reloadable_features_http_strip_fragment_from_path_unsafe_if_disabled,
&FLAGS_envoy_reloadable_features_internal_address,
&FLAGS_envoy_reloadable_features_listener_reuse_port_default_enabled,
&FLAGS_envoy_reloadable_features_listener_wildcard_match_ip_family,
&FLAGS_envoy_reloadable_features_new_tcp_connection_pool,
&FLAGS_envoy_reloadable_features_proxy_102_103,
Expand Down
25 changes: 4 additions & 21 deletions source/server/server.cc
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ InstanceImpl::InstanceImpl(
grpc_context_(store.symbolTable()), http_context_(store.symbolTable()),
router_context_(store.symbolTable()), process_context_(std::move(process_context)),
hooks_(hooks), quic_stat_names_(store.symbolTable()), server_contexts_(*this),
stats_flush_in_progress_(false) {
enable_reuse_port_default_(true), stats_flush_in_progress_(false) {
TRY_ASSERT_MAIN_THREAD {
if (!options.logPath().empty()) {
TRY_ASSERT_MAIN_THREAD {
Expand Down Expand Up @@ -525,12 +525,8 @@ void InstanceImpl::initialize(Network::Address::InstanceConstSharedPtr local_add
const auto parent_admin_shutdown_response = restarter_.sendParentAdminShutdownRequest();
if (parent_admin_shutdown_response.has_value()) {
original_start_time_ = parent_admin_shutdown_response.value().original_start_time_;
enable_reuse_port_default_ = parent_admin_shutdown_response.value().enable_reuse_port_default_
? ReusePortDefault::True
: ReusePortDefault::False;
} else {
// This is needed so that we don't read the value until runtime is fully initialized.
enable_reuse_port_default_ = ReusePortDefault::Runtime;
enable_reuse_port_default_ =
parent_admin_shutdown_response.value().enable_reuse_port_default_ ? true : false;
}
admin_ = std::make_unique<AdminImpl>(initial_config.admin().profilePath(), *this,
initial_config.admin().ignoreGlobalConnLimit());
Expand Down Expand Up @@ -1002,20 +998,7 @@ ProtobufTypes::MessagePtr InstanceImpl::dumpBootstrapConfig() {
return config_dump;
}

bool InstanceImpl::enableReusePortDefault() {
ASSERT(enable_reuse_port_default_.has_value());
switch (enable_reuse_port_default_.value()) {
case ReusePortDefault::True:
return true;
case ReusePortDefault::False:
return false;
case ReusePortDefault::Runtime:
return Runtime::runtimeFeatureEnabled(
"envoy.reloadable_features.listener_reuse_port_default_enabled");
}

return false; // for gcc
}
bool InstanceImpl::enableReusePortDefault() { return enable_reuse_port_default_; }

} // namespace Server
} // namespace Envoy
4 changes: 1 addition & 3 deletions source/server/server.h
Original file line number Diff line number Diff line change
Expand Up @@ -304,8 +304,6 @@ class InstanceImpl final : Logger::Loggable<Logger::Id::main>,
registerCallback(Stage stage, StageCallbackWithCompletion callback) override;

private:
enum class ReusePortDefault { True, False, Runtime };

ProtobufTypes::MessagePtr dumpBootstrapConfig();
void flushStatsInternal();
void updateServerStats();
Expand Down Expand Up @@ -394,7 +392,7 @@ class InstanceImpl final : Logger::Loggable<Logger::Id::main>,
ListenerHooks& hooks_;
Quic::QuicStatNames quic_stat_names_;
ServerFactoryContextImpl server_contexts_;
absl::optional<ReusePortDefault> enable_reuse_port_default_;
bool enable_reuse_port_default_;

bool stats_flush_in_progress_ : 1;

Expand Down
1 change: 0 additions & 1 deletion test/server/server_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1029,7 +1029,6 @@ TEST_P(ServerInstanceImplTest, BootstrapNodeWithOptionsOverride) {
TEST_P(ServerInstanceImplTest, BootstrapRuntime) {
options_.service_cluster_name_ = "some_service";
initialize("test/server/test_data/server/runtime_bootstrap.yaml");
EXPECT_FALSE(server_->enableReusePortDefault());
EXPECT_EQ("bar", server_->runtime().snapshot().get("foo").value().get());
// This should access via the override/some_service overlay.
EXPECT_EQ("fozz", server_->runtime().snapshot().get("fizz").value().get());
Expand Down
1 change: 0 additions & 1 deletion test/server/test_data/server/runtime_bootstrap.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ layered_runtime:
- name: some_static_layer
static_layer:
foo: bar
envoy.reloadable_features.listener_reuse_port_default_enabled: false
- name: base_disk_layer
disk_layer: {symlink_root: "{{ test_rundir }}/test/server/test_data/runtime/primary"}
- name: overlay_disk_layer
Expand Down