github
/
v2ray-core
mirror of https://github.com/v2ray/v2ray-core
1
0
Fork 0
Code Issues Releases Wiki Activity

comments

pull/255/merge
Darien Raymond 2016-12-29 01:05:16 +01:00
parent e6214b7a87
commit bdfb879963
No known key found for this signature in database
GPG Key ID: 7251FFA14BB18169
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/proxy/proxy.go
View File

@ -39,6 +39,7 @@ func (v *OutboundProxy) RegisterDialer() {
internet.ProxyDialer = v.Dial internet.ProxyDialer = v.Dial
} }
// Dial implements internet.Dialer.
func (v *OutboundProxy) Dial(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error) { func (v *OutboundProxy) Dial(src v2net.Address, dest v2net.Destination, options internet.DialerOptions) (internet.Connection, error) {
handler := v.outboundManager.GetHandler(options.Proxy.Tag) handler := v.outboundManager.GetHandler(options.Proxy.Tag)
if handler == nil { if handler == nil {
@ -53,6 +54,7 @@ func (v *OutboundProxy) Dial(src v2net.Address, dest v2net.Destination, options
return NewConnection(src, dest, stream), nil return NewConnection(src, dest, stream), nil
} }
// Release implements common.Releasable.Release().
func (v *OutboundProxy) Release() { func (v *OutboundProxy) Release() {
} }
@ -83,6 +85,7 @@ func NewConnection(src v2net.Address, dest v2net.Destination, stream ray.Ray) *C
} }
} }
// Read implements net.Conn.Read().
func (v *Connection) Read(b []byte) (int, error) { func (v *Connection) Read(b []byte) (int, error) {
if v.closed { if v.closed {
return 0, io.EOF return 0, io.EOF
@ -90,6 +93,7 @@ func (v *Connection) Read(b []byte) (int, error) {
return v.reader.Read(b) return v.reader.Read(b)
} }
// Write implements net.Conn.Write().
func (v *Connection) Write(b []byte) (int, error) { func (v *Connection) Write(b []byte) (int, error) {
if v.closed { if v.closed {
return 0, io.ErrClosedPipe return 0, io.ErrClosedPipe
@ -97,6 +101,7 @@ func (v *Connection) Write(b []byte) (int, error) {
return v.writer.Write(b) return v.writer.Write(b)
} }
// Close implements net.Conn.Close().
func (v *Connection) Close() error { func (v *Connection) Close() error {
v.closed = true v.closed = true
v.stream.InboundInput().Close() v.stream.InboundInput().Close()
@ -106,10 +111,12 @@ func (v *Connection) Close() error {
return nil return nil
} }
// LocalAddr implements net.Conn.LocalAddr().
func (v *Connection) LocalAddr() net.Addr { func (v *Connection) LocalAddr() net.Addr {
return v.localAddr return v.localAddr
} }
// RemoteAddr implements net.Conn.RemoteAddr().
func (v *Connection) RemoteAddr() net.Addr { func (v *Connection) RemoteAddr() net.Addr {
return v.remoteAddr return v.remoteAddr
} }