mirror of https://github.com/v2ray/v2ray-core
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
65 lines
1.7 KiB
65 lines
1.7 KiB
package hub
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"github.com/v2ray/v2ray-core/app/dispatcher"
|
|
v2net "github.com/v2ray/v2ray-core/common/net"
|
|
"github.com/v2ray/v2ray-core/transport/ray"
|
|
)
|
|
|
|
type UDPResponseCallback func(packet v2net.Packet)
|
|
|
|
type connEntry struct {
|
|
inboundRay ray.InboundRay
|
|
callback UDPResponseCallback
|
|
}
|
|
|
|
type UDPServer struct {
|
|
sync.RWMutex
|
|
conns map[string]*connEntry
|
|
packetDispatcher dispatcher.PacketDispatcher
|
|
}
|
|
|
|
func NewUDPServer(packetDispatcher dispatcher.PacketDispatcher) *UDPServer {
|
|
return &UDPServer{
|
|
conns: make(map[string]*connEntry),
|
|
packetDispatcher: packetDispatcher,
|
|
}
|
|
}
|
|
|
|
func (this *UDPServer) locateExistingAndDispatch(dest string, packet v2net.Packet) bool {
|
|
this.RLock()
|
|
defer this.RUnlock()
|
|
if entry, found := this.conns[dest]; found {
|
|
entry.inboundRay.InboundInput() <- packet.Chunk()
|
|
return true
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (this *UDPServer) Dispatch(source v2net.Destination, packet v2net.Packet, callback UDPResponseCallback) {
|
|
destString := source.String() + "-" + packet.Destination().NetAddr()
|
|
if this.locateExistingAndDispatch(destString, packet) {
|
|
return
|
|
}
|
|
|
|
this.Lock()
|
|
inboundRay := this.packetDispatcher.DispatchToOutbound(v2net.NewPacket(packet.Destination(), packet.Chunk(), true))
|
|
this.conns[destString] = &connEntry{
|
|
inboundRay: inboundRay,
|
|
callback: callback,
|
|
}
|
|
this.Unlock()
|
|
go this.handleConnection(destString, inboundRay, source, callback)
|
|
}
|
|
|
|
func (this *UDPServer) handleConnection(destString string, inboundRay ray.InboundRay, source v2net.Destination, callback UDPResponseCallback) {
|
|
for buffer := range inboundRay.InboundOutput() {
|
|
callback(v2net.NewPacket(source, buffer, false))
|
|
}
|
|
this.Lock()
|
|
delete(this.conns, destString)
|
|
this.Unlock()
|
|
}
|