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

constant com

Browse source
This commit is contained in:
Zack Scholl 2019-11-13 07:43:20 -08:00
parent f23ce6e246
commit fa44849180
1 changed files with 10 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

22
src/croc/croc.go
View file

@ -384,12 +384,6 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
dc.OnOpen(func() { dc.OnOpen(func() {
if c.Options.IsSender { if c.Options.IsSender {
for {
time.Sleep(10 * time.Millisecond)
if readyToBegin {
break
}
}
log.Debug("sending file") log.Debug("sending file")
pos := uint64(0) pos := uint64(0)
f, errOpen := os.Open("croc1") f, errOpen := os.Open("croc1")
@ -399,6 +393,12 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
fstat, _ := f.Stat() fstat, _ := f.Stat()
timeStart := time.Now() timeStart := time.Now()
for { for {
for {
time.Sleep(10 * time.Millisecond)
if readyToBegin {
break
}
}
data := make([]byte, maxPacketSizeHalf) data := make([]byte, maxPacketSizeHalf)
n, errRead := f.Read(data) n, errRead := f.Read(data)
if errRead != nil { if errRead != nil {
@ -417,7 +417,7 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
return return
} }
pos += uint64(n) pos += uint64(n)
time.Sleep(1 * time.Millisecond) readyToBegin = false
} }
log.Debug(float64(fstat.Size()) / float64(time.Since(timeStart).Seconds()) / 1000000) log.Debug(float64(fstat.Size()) / float64(time.Since(timeStart).Seconds()) / 1000000)
@ -432,11 +432,6 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
} else { } else {
sendData([]byte{2, 3, 4}) sendData([]byte{2, 3, 4})
time.Sleep(100 * time.Millisecond)
sendData([]byte{2, 3, 4})
time.Sleep(100 * time.Millisecond)
sendData([]byte{2, 3, 4})
time.Sleep(100 * time.Millisecond)
} }
}) })
@ -459,7 +454,9 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
log.Debug("received magic") log.Debug("received magic")
fwrite.Close() fwrite.Close()
sendData([]byte{1, 3, 4}) sendData([]byte{1, 3, 4})
time.Sleep(100 * time.Millisecond)
sendData([]byte{1, 3, 4}) sendData([]byte{1, 3, 4})
time.Sleep(100 * time.Millisecond)
sendData([]byte{1, 3, 4}) sendData([]byte{1, 3, 4})
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
finished <- nil finished <- nil
@ -477,6 +474,7 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
if err == nil { if err == nil {
log.Debug(fd.Position) log.Debug(fd.Position)
fwrite.Write(fd.Data) fwrite.Write(fd.Data)
sendData([]byte{2, 3, 4})
} else { } else {
log.Error(err) log.Error(err)
} }