From 6ff1cfa25372271f30c422c19fe6407526a1d842 Mon Sep 17 00:00:00 2001 From: Shelikhoo Date: Sat, 11 Dec 2021 23:05:19 +0000 Subject: [PATCH] add Closable to dispatcher interface --- transport/internet/udp/dispatcher.go | 2 ++ transport/internet/udp/dispatcher_split.go | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/transport/internet/udp/dispatcher.go b/transport/internet/udp/dispatcher.go index 63d79bbdc..26ae09fa0 100644 --- a/transport/internet/udp/dispatcher.go +++ b/transport/internet/udp/dispatcher.go @@ -2,10 +2,12 @@ package udp import ( "context" + "github.com/v2fly/v2ray-core/v5/common" "github.com/v2fly/v2ray-core/v5/common/buf" "github.com/v2fly/v2ray-core/v5/common/net" ) type DispatcherI interface { + common.Closable Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer) } diff --git a/transport/internet/udp/dispatcher_split.go b/transport/internet/udp/dispatcher_split.go index 6c89e9d85..b7650cd1f 100644 --- a/transport/internet/udp/dispatcher_split.go +++ b/transport/internet/udp/dispatcher_split.go @@ -32,6 +32,10 @@ type Dispatcher struct { callback ResponseCallback } +func (v *Dispatcher) Close() error { + return nil +} + func NewSplitDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) DispatcherI { return &Dispatcher{ conns: make(map[net.Destination]*connEntry),