MCPcopy Create free account
hub / github.com/couchbase/sync_gateway / handleSetCheckpoint

Method handleSetCheckpoint

db/blip_handler.go:240–261  ·  view source on GitHub ↗

Received a "setCheckpoint" request

(rq *blip.Message)

Source from the content-addressed store, hash-verified

238
239// Received a "setCheckpoint" request
240func (bh *blipHandler) handleSetCheckpoint(rq *blip.Message) error {
241
242 checkpointMessage := SetCheckpointMessage{rq}
243 bh.logEndpointEntry(rq.Profile(), checkpointMessage.String())
244
245 var checkpoint Body
246 if err := checkpointMessage.ReadJSONBody(&checkpoint); err != nil {
247 return err
248 }
249 if revID := checkpointMessage.rev(); revID != "" {
250 checkpoint[BodyRev] = revID
251 }
252 revID, _, err := bh.collection.PutSpecial(DocTypeLocal, CheckpointDocIDPrefix+checkpointMessage.client(), checkpoint)
253 if err != nil {
254 return err
255 }
256
257 checkpointResponse := SetCheckpointResponse{checkpointMessage.Response()}
258 checkpointResponse.setRev(revID)
259
260 return nil
261}
262
263// ////// CHANGES
264

Callers

nothing calls this directly

Calls 7

logEndpointEntryMethod · 0.95
StringMethod · 0.95
revMethod · 0.95
clientMethod · 0.95
setRevMethod · 0.95
PutSpecialMethod · 0.80
ResponseMethod · 0.45

Tested by

no test coverage detected