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

shadowsocks log

Browse Source
This commit is contained in:
Darien Raymond 2016-11-21 23:06:26 +01:00
parent 15cb543abb
commit bc822985ab
No known key found for this signature in database
GPG Key ID: 7251FFA14BB18169
1 changed files with 21 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
proxy/shadowsocks/client.go
View File

@ -2,7 +2,7 @@ package shadowsocks
import (
"errors"
"io"
"sync"
"v2ray.com/core/app"
"v2ray.com/core/common/alloc"
@ -113,11 +113,19 @@ func (this *Client) Dispatch(destination v2net.Destination, payload *alloc.Buffe
return
}
v2io.Pipe(responseReader, ray.OutboundOutput())
if err := v2io.Pipe(responseReader, ray.OutboundOutput()); err != nil {
if err != io.EOF {
log.Info("Shadowsocks|Client: Failed to transport all TCP response: ", err)
}
}
}()
bufferedWriter.SetCached(false)
v2io.Pipe(ray.OutboundInput(), bodyWriter)
if err := v2io.Pipe(ray.OutboundInput(), bodyWriter); err != nil {
if err != io.EOF {
log.Info("Shadowsocks|Client: Failed to trasnport all TCP request: ", err)
}
}
responseMutex.Lock()
}
@ -135,7 +143,11 @@ func (this *Client) Dispatch(destination v2net.Destination, payload *alloc.Buffe
User: user,
}
v2io.Pipe(reader, ray.OutboundOutput())
if err := v2io.Pipe(reader, ray.OutboundOutput()); err != nil {
if err != io.EOF {
log.Info("Shadowsocks|Client: Failed to transport all UDP response: ", err)
}
}
}()
writer := &UDPWriter{
@ -147,7 +159,11 @@ func (this *Client) Dispatch(destination v2net.Destination, payload *alloc.Buffe
return errors.New("Shadowsocks|Client: Failed to write payload: " + err.Error())
}
}
v2io.Pipe(ray.OutboundInput(), writer)
if err := v2io.Pipe(ray.OutboundInput(), writer); err != nil {
if err != io.EOF {
log.Info("Shadowsocks|Client: Failed to transport all UDP request: ", err)
}
}
responseMutex.Lock()
}