mirror of
https://github.com/fumiama/WireGold.git
synced 2026-06-27 06:10:26 +08:00
fix(link): early use of new listen buf
This commit is contained in:
@@ -86,10 +86,9 @@ func (m *Me) listen() (conn p2p.Conn, err error) {
|
|||||||
q := make(listenqueue, n)
|
q := make(listenqueue, n)
|
||||||
defer close(q)
|
defer close(q)
|
||||||
go q.listen(m, hasntfinished)
|
go q.listen(m, hasntfinished)
|
||||||
i := uint(0)
|
|
||||||
for {
|
for {
|
||||||
usenewbuf := false
|
usenewbuf := false
|
||||||
i %= n
|
i := uint(0)
|
||||||
for !hasntfinished[i].TryLock() {
|
for !hasntfinished[i].TryLock() {
|
||||||
i++
|
i++
|
||||||
i %= n
|
i %= n
|
||||||
|
|||||||
Reference in New Issue
Block a user