cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

move select

Browse Source
This commit is contained in:
wanghui 2019-10-31 17:39:42 +08:00
parent 8cb14335c3
commit 2aa8eebb99
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/jsonrpc/client.go
View File

@ -189,12 +189,13 @@ func (c *client) makeOutChan(ctx context.Context, ftyp reflect.Type, valOut int)
}, },
} }
switch chosen, _, _ := reflect.Select(cases); chosen { chosen, _, _ := reflect.Select(cases)
bufLk.Lock()
switch chosen {
case 0: case 0:
bufLk.Lock()
buf.Init() buf.Init()
case 1: case 1:
bufLk.Lock()
buf.Remove(front) buf.Remove(front)
} }
} }