gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

Do snapshot setup in go routine as well for checkMsgs

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-05-30 11:28:43 -07:00
parent e12907ffa6
commit 8e407f8db4
1 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
server/jetstream_api.go
View File

@@ -1185,19 +1185,23 @@ func (s *Server) jsStreamSnapshotRequest(sub *subscription, c *client, subject,
return
}
sr, err := mset.Snapshot(0, !req.NoConsumers, req.CheckMsgs)
if err != nil {
resp.Error = jsError(err)
s.sendAPIResponse(c, subject, reply, string(msg), s.jsonResponse(&resp))
return
}
// We will do the snapshot in a go routine as well since check msgs may
// stall this go routine.
go func() {
sr, err := mset.Snapshot(0, !req.NoConsumers, req.CheckMsgs)
if err != nil {
resp.Error = jsError(err)
s.sendAPIResponse(c, subject, reply, string(msg), s.jsonResponse(&resp))
return
}
resp.NumBlks = sr.NumBlks
resp.BlkSize = sr.BlkSize
s.sendAPIResponse(c, subject, reply, string(msg), s.jsonResponse(resp))
resp.NumBlks = sr.NumBlks
resp.BlkSize = sr.BlkSize
s.sendAPIResponse(c, subject, reply, string(msg), s.jsonResponse(resp))
// Now do the real streaming in a separate go routine.
go s.streamSnapshot(c, mset, sr, &req)
// Now do the real streaming.
s.streamSnapshot(c, mset, sr, &req)
}()
}
// Default chunk size for now.