mirror of
https://github.com/schollz/croc.git
synced 2025-10-11 13:21:00 +02:00
ping
This commit is contained in:
parent
e8ea1045a2
commit
511ad0e49e
1 changed files with 4 additions and 2 deletions
|
@ -350,11 +350,11 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
|
||||||
|
|
||||||
// ordered := true
|
// ordered := true
|
||||||
// maxRetransmits := uint16(0)
|
// maxRetransmits := uint16(0)
|
||||||
var id uint16 = 5
|
// var id uint16 = 5
|
||||||
options := &webrtc.DataChannelInit{
|
options := &webrtc.DataChannelInit{
|
||||||
// Ordered: &ordered,
|
// Ordered: &ordered,
|
||||||
// MaxRetransmits: &maxRetransmits,
|
// MaxRetransmits: &maxRetransmits,
|
||||||
ID: &id,
|
// ID: &id,
|
||||||
}
|
}
|
||||||
|
|
||||||
sendMoreCh := make(chan struct{})
|
sendMoreCh := make(chan struct{})
|
||||||
|
@ -412,7 +412,9 @@ func (c *Client) CreateOfferer(finished chan<- error) (pc *webrtc.PeerConnection
|
||||||
timeStart := time.Now()
|
timeStart := time.Now()
|
||||||
for {
|
for {
|
||||||
for {
|
for {
|
||||||
|
|
||||||
time.Sleep(1 * time.Millisecond)
|
time.Sleep(1 * time.Millisecond)
|
||||||
|
log.Debug(time.Since(lastSignal).Seconds())
|
||||||
if readyToBegin && time.Since(lastSignal).Seconds() < 2 {
|
if readyToBegin && time.Since(lastSignal).Seconds() < 2 {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue