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

Use MessageIndex in WaitForMessage

Browse Source
This commit is contained in:
Fridrik Asmundsson 2023-03-29 13:15:42 +02:00 committed by Maciej Witowski
parent 84b0a37e08
commit a29622520a
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain/stmgr/searchwait.go
View File

@ -57,11 +57,16 @@ func (sm *StateManager) WaitForMessage(ctx context.Context, mcid cid.Cid, confid
var backFm cid.Cid var backFm cid.Cid
backSearchWait := make(chan struct{}) backSearchWait := make(chan struct{})
go func() { go func() {
fts, r, foundMsg, err := sm.searchBackForMsg(ctx, head[0].Val, msg, lookbackLimit, allowReplaced) fts, r, foundMsg, err := sm.searchForIndexedMsg(ctx, mcid, msg)
found := (err == nil && r != nil && foundMsg.Defined())
if !found {
fts, r, foundMsg, err = sm.searchBackForMsg(ctx, head[0].Val, msg, lookbackLimit, allowReplaced)
if err != nil { if err != nil {
log.Warnf("failed to look back through chain for message: %v", err) log.Warnf("failed to look back through chain for message: %v", err)
return return
} }
}
backTs = fts backTs = fts
backRcp = r backRcp = r