mirror of https://github.com/cbeuw/Cloak
Fix WriteTo receive loop
This commit is contained in:
parent
128f653ea4
commit
501f7dda97
|
|
@ -92,9 +92,8 @@ func (p *bufferedPipe) WriteTo(w io.Writer) (n int64, err error) {
|
||||||
return n, er
|
return n, er
|
||||||
}
|
}
|
||||||
p.rwCond.Broadcast()
|
p.rwCond.Broadcast()
|
||||||
} else {
|
|
||||||
p.rwCond.Wait()
|
|
||||||
}
|
}
|
||||||
|
p.rwCond.Wait()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -98,9 +98,8 @@ func (d *datagramBuffer) WriteTo(w io.Writer) (n int64, err error) {
|
||||||
return n, er
|
return n, er
|
||||||
}
|
}
|
||||||
d.rwCond.Broadcast()
|
d.rwCond.Broadcast()
|
||||||
} else {
|
|
||||||
d.rwCond.Wait()
|
|
||||||
}
|
}
|
||||||
|
d.rwCond.Wait()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue