mirrors_public/schollz_croc
0
0
Fork 0
mirror of https://github.com/schollz/croc.git synced 2025-10-11 13:21:00 +02:00
Code Activity

ping

Browse source
This commit is contained in:
Zack Scholl 2019-11-19 15:55:18 -08:00
parent 2265b5c416
commit e8ea1045a2
1 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/croc/croc.go
View file

@ -384,6 +384,7 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
return nil return nil
} }
var lastSignal = time.Now()
var readyToBegin = false var readyToBegin = false
var readyToEnd = false var readyToEnd = false
var bar *progressbar.ProgressBar var bar *progressbar.ProgressBar
@ -411,8 +412,8 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
timeStart := time.Now() timeStart := time.Now()
for { for {
for { for {
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
if readyToBegin { if readyToBegin && time.Since(lastSignal).Seconds() < 2 {
break break
} }
} }
@ -483,6 +484,7 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
return return
} else if bytes.Equal(dcMsg.Data, []byte{2, 3, 4}) { } else if bytes.Equal(dcMsg.Data, []byte{2, 3, 4}) {
// log.Debug("got ready to begin") // log.Debug("got ready to begin")
lastSignal = time.Now()
readyToBegin = true readyToBegin = true
return return
} else if bytes.Equal(dcMsg.Data, []byte{1, 3, 4}) { } else if bytes.Equal(dcMsg.Data, []byte{1, 3, 4}) {
@ -509,7 +511,10 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
n, _ := fwrite.Write(fd.Data) n, _ := fwrite.Write(fd.Data)
bar.Add(n) bar.Add(n)
// sendData([]byte{2, 3, 4}) if time.Since(lastSignal).Seconds() > 1 {
sendData([]byte{2, 3, 4})
lastSignal = time.Now()
}
} else { } else {
log.Error(err) log.Error(err)
} }