schollz/croc
1
0
Fork 0
mirror of https://github.com/schollz/croc.git synced 2024-12-02 23:22:23 +03:00
Code Issues Projects Releases Wiki Activity

fix corruption

Browse Source
This commit is contained in:
Zack Scholl 2018-10-09 21:15:00 -07:00
parent d1e1694631
commit 42344a4c6e
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/comm/comm.go
View File

@ -18,7 +18,7 @@ type Comm struct {
func New(c net.Conn) Comm { func New(c net.Conn) Comm {
c.SetReadDeadline(time.Now().Add(3 * time.Hour)) c.SetReadDeadline(time.Now().Add(3 * time.Hour))
c.SetDeadline(time.Now().Add(3 * time.Hour)) c.SetDeadline(time.Now().Add(3 * time.Hour))
c.SetWriteDeadline(time.Now().Add(3 * time.Hour)) c.SetWriteDeadline(time.Now().Add(5 * time.Second))
return Comm{c} return Comm{c}
} }

2
src/recipient/recipient.go
View File

@ -383,7 +383,7 @@ func receive(forceSend int, serverAddress string, tcpPorts []string, isLocal boo
defer wg.Done() defer wg.Done()
for { for {
// read from TCP connection // read from TCP connection
message, _, _, err = tcpConnection.Read() message, _, _, err := tcpConnection.Read()
// log.Debugf("message: %s", message) // log.Debugf("message: %s", message)
if err != nil { if err != nil {
log.Error(err) log.Error(err)