Skip to content

Commit 3d345d3

Browse files
committed
TUN-6595: Enable datagramv2 and icmp proxy by default
1 parent b1995b4 commit 3d345d3

File tree

2 files changed

+7
-21
lines changed

2 files changed

+7
-21
lines changed

cmd/cloudflared/tunnel/configuration.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ var (
4444
LogFieldHostname = "hostname"
4545

4646
secretFlags = [2]*altsrc.StringFlag{credentialsContentsFlag, tunnelTokenFlag}
47-
defaultFeatures = []string{supervisor.FeatureAllowRemoteConfig, supervisor.FeatureSerializedHeaders}
47+
defaultFeatures = []string{supervisor.FeatureAllowRemoteConfig, supervisor.FeatureSerializedHeaders, supervisor.FeatureDatagramV2}
4848

4949
configFlags = []string{"autoupdate-freq", "no-autoupdate", "retries", "protocol", "loglevel", "transport-loglevel", "origincert", "metrics", "metrics-update-freq", "edge-ip-version"}
5050
)

supervisor/supervisor.go

Lines changed: 6 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -116,14 +116,12 @@ func NewSupervisor(config *TunnelConfig, orchestrator *orchestration.Orchestrato
116116
gracefulShutdownC: gracefulShutdownC,
117117
connAwareLogger: log,
118118
}
119-
if useDatagramV2(config) {
120-
// TODO: TUN-6701: Decouple upgrade of datagram v2 and using icmp proxy
121-
icmpRouter, err := ingress.NewICMPRouter(config.Log)
122-
if err != nil {
123-
log.Logger().Warn().Err(err).Msg("Failed to create icmp router, will continue to use datagram v1")
124-
} else {
125-
edgeTunnelServer.icmpRouter = icmpRouter
126-
}
119+
120+
icmpRouter, err := ingress.NewICMPRouter(config.Log)
121+
if err != nil {
122+
log.Logger().Warn().Err(err).Msg("Failed to create icmp router, ICMP proxy feature is disabled")
123+
} else {
124+
edgeTunnelServer.icmpRouter = icmpRouter
127125
}
128126

129127
useReconnectToken := false
@@ -435,15 +433,3 @@ func (s *Supervisor) authenticate(ctx context.Context, numPreviousAttempts int)
435433
registrationOptions.NumPreviousAttempts = uint8(numPreviousAttempts)
436434
return rpcClient.Authenticate(ctx, s.config.ClassicTunnel, registrationOptions)
437435
}
438-
439-
func useDatagramV2(config *TunnelConfig) bool {
440-
if config.NamedTunnel == nil {
441-
return false
442-
}
443-
for _, feature := range config.NamedTunnel.Client.Features {
444-
if feature == FeatureDatagramV2 {
445-
return true
446-
}
447-
}
448-
return false
449-
}

0 commit comments

Comments
 (0)