lzhr/v2fly
1
0
Fork 0
mirror of https://github.com/v2fly/v2ray-core.git synced 2024-09-28 23:06:14 -04:00
Code Issues Releases Wiki Activity

KCP: fix: meta type

Browse Source
This commit is contained in:
Shelikhoo 2016-06-12 13:43:05 +08:00
parent c07d478ab5
commit 4f9a9d1f0c
No known key found for this signature in database
GPG Key ID: 7791BDB0709ABD21
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
transport/hub/dialer.go
View File

@ -64,19 +64,19 @@ func DialWithoutCache(src v2net.Address, dest v2net.Destination) (net.Conn, erro
return dialer.Dial(dest.Network().String(), dest.NetAddr()) return dialer.Dial(dest.Network().String(), dest.NetAddr())
} }
func Dial3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.InboundHandlerMeta) (*Connection, error) { func Dial3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.OutboundHandlerMeta) (*Connection, error) {
if proxyMeta.KcpSupported && transport.IsKcpEnabled() { if proxyMeta.KcpSupported && transport.IsKcpEnabled() {
DialKCP3(src, dest, proxyMeta) DialKCP3(src, dest, proxyMeta)
} }
return Dial(src, dest) return Dial(src, dest)
} }
func DialWithoutCache3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.InboundHandlerMeta) (net.Conn, error) { func DialWithoutCache3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.OutboundHandlerMeta) (net.Conn, error) {
if proxyMeta.KcpSupported && transport.IsKcpEnabled() { if proxyMeta.KcpSupported && transport.IsKcpEnabled() {
} }
return DialWithoutCache(src, dest) return DialWithoutCache(src, dest)
} }
func DialKCP3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.InboundHandlerMeta) (*Connection, error) { func DialKCP3(src v2net.Address, dest v2net.Destination, proxyMeta proxy.OutboundHandlerMeta) (*Connection, error) {
if src == nil { if src == nil {
src = v2net.AnyIP src = v2net.AnyIP
} }