Robot
/
croc
mirror of https://github.com/schollz/croc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update

This commit is contained in:
Zack Scholl 2019-11-13 07:38:47 -08:00
parent 768fc3b8b6
commit f23ce6e246
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/croc/croc.go
View File

@ -421,14 +421,9 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
}
log.Debug(float64(fstat.Size()) / float64(time.Since(timeStart).Seconds()) / 1000000)
sendData([]byte{1, 2, 3})
time.Sleep(100 * time.Millisecond)
sendData([]byte{1, 2, 3})
time.Sleep(100 * time.Millisecond)
sendData([]byte{1, 2, 3})
time.Sleep(100 * time.Millisecond)
for {
time.Sleep(10 * time.Millisecond)
sendData([]byte{1, 2, 3})
time.Sleep(100 * time.Millisecond)
if readyToEnd {
break
}
@ -457,6 +452,9 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
// Register the OnMessage to handle incoming messages
dc.OnMessage(func(dcMsg webrtc.DataChannelMessage) {
var fd FileData
if len(dcMsg.Data) >= 3 {
log.Debugf("%+x", dcMsg.Data[:3])
}
if bytes.Equal(dcMsg.Data, []byte{1, 2, 3}) {
log.Debug("received magic")
fwrite.Close()