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

handle channel closing properly

Browse Source
This commit is contained in:
whyrusleeping 2019-08-29 20:25:31 -07:00
parent 55abcaa7d0
commit 6144f1af73
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
chain/store/store.go
View File

@ -576,7 +576,10 @@ func (cs *ChainStore) WaitForMessage(ctx context.Context, mcid cid.Cid) (cid.Cid
for { for {
select { select {
case val := <-tsub: case val, ok := <-tsub:
if !ok {
return cid.Undef, nil, ctx.Err()
}
switch val.Type { switch val.Type {
case HCRevert: case HCRevert:
continue continue