1
0
mirror of https://github.com/v2fly/v2ray-core.git synced 2024-12-09 03:36:40 -05:00

BlackHole proxy

This commit is contained in:
V2Ray 2015-10-28 17:41:14 +01:00
parent fdb952fb01
commit 9b8632d01a
2 changed files with 55 additions and 0 deletions

View File

@ -0,0 +1,40 @@
package blackhole
import (
"io/ioutil"
v2net "github.com/v2ray/v2ray-core/common/net"
"github.com/v2ray/v2ray-core/proxy"
"github.com/v2ray/v2ray-core/transport/ray"
)
// BlackHole is an outbound connection that sliently swallow the entire payload.
type BlackHole struct {
}
func NewBlackHole() *BlackHole {
return &BlackHole{}
}
func (bh *BlackHole) Dispatch(firstPacket v2net.Packet, ray ray.OutboundRay) error {
if chunk := firstPacket.Chunk(); chunk != nil {
chunk.Release()
}
close(ray.OutboundOutput())
if firstPacket.MoreChunks() {
v2net.ChanToWriter(ioutil.Discard, ray.OutboundInput())
}
return nil
}
type BlackHoleFactory struct {
}
func (factory BlackHoleFactory) Create(config interface{}) (proxy.OutboundConnectionHandler, error) {
return NewBlackHole(), nil
}
func init() {
proxy.RegisterOutboundConnectionHandlerFactory("blackhole", BlackHoleFactory{})
}

View File

@ -0,0 +1,15 @@
package json
import (
"github.com/v2ray/v2ray-core/config"
"github.com/v2ray/v2ray-core/config/json"
)
type BlackHoleConfig struct {
}
func init() {
json.RegisterConfigType("blackhole", config.TypeInbound, func() interface{} {
return new(BlackHoleConfig)
})
}