From b1f78a1ffcb4d19bf16f973247d03aa5d4b0fd33 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Sun, 27 Nov 2016 09:02:27 +0100 Subject: [PATCH] enable conn reuse settings in mkcp --- transport/internet/kcp/connection.go | 6 ++++-- transport/internet/kcp/listener.go | 1 + 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go index e6ba390d2..ac7b20d04 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -439,10 +439,12 @@ func (this *Connection) updateTask() { } func (this *Connection) Reusable() bool { - return false + return this.Config.ConnectionReuse.IsEnabled() && this.reusable } -func (this *Connection) SetReusable(b bool) {} +func (this *Connection) SetReusable(b bool) { + this.reusable = b +} func (this *Connection) Terminate() { if this == nil { diff --git a/transport/internet/kcp/listener.go b/transport/internet/kcp/listener.go index 28b20489e..b682c8a02 100644 --- a/transport/internet/kcp/listener.go +++ b/transport/internet/kcp/listener.go @@ -100,6 +100,7 @@ func NewListener(address v2net.Address, port v2net.Port, options internet.Listen return nil, err } kcpSettings := networkSettings.(*Config) + kcpSettings.ConnectionReuse = &ConnectionReuse{Enable: false} auth, err := kcpSettings.GetAuthenticator() if err != nil {