Home
last modified time | relevance | path

Searched defs:endSeqno (Results 1 - 14 of 14) sorted by relevance

/6.0.3/kv_engine/engines/ep/src/dcp/
H A Dbackfill.h96 uint64_t endSeqno; member in DCPBackfill
37 DCPBackfill(std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfill() argument
H A Dbackfill_memory.cc29 DCPBackfillMemory(EphemeralVBucketPtr evb, std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfillMemory() argument
110 DCPBackfillMemoryBuffered( EphemeralVBucketPtr evb, std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfillMemoryBuffered() argument
[all...]
H A Dbackfill_disk.cc150 DCPBackfillDisk(EventuallyPersistentEngine& e, std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfillDisk() argument
H A Dresponse.h155 StreamRequest(uint16_t vbucket, uint32_t opaque, uint32_t flags, uint64_t startSeqno, uint64_t endSeqno, uint64_t vbucketUUID, uint64_t snapStartSeqno, uint64_t snapEndSeqno) StreamRequest() argument
H A Dstream.cc419 void ActiveStream::markDiskSnapshot(uint64_t startSeqno, uint64_t endSeqno) { in markDiskSnapshot() argument
/6.0.3/kv_engine/engines/ep/src/collections/
H A Dvbucket_manifest_entry.h249 int64_t endSeqno; global() member in Collections::VB::ManifestEntry
[all...]
H A Dvbucket_manifest.h359 replicaBeginDelete(::VBucket& vb, uid_t manifestUid, Identifier identifier, int64_t endSeqno) replicaBeginDelete() argument
H A Dvbucket_serialised_manifest_entry.h315 << R"("endSeqno" in toJson() local
278 tryConstruction(cb::char_buffer out, Identifier identifier, int64_t startSeqno, int64_t endSeqno) tryConstruction() argument
322 int64_t endSeqno; global() member in Collections::VB::SerialisedManifestEntry
[all...]
H A Dvbucket_manifest.cc82 int64_t endSeqno = std::stoll(getJsonEntry(collection, "endSeqno")); in Manifest() local
180 addNewCollectionEntry(Identifier identifier, int64_t startSeqno, int64_t endSeqno) addNewCollectionEntry() argument
/6.0.3/kv_engine/engines/ep/tests/module_tests/
H A Dbasic_ll_test.cc281 seqno_t endSeqno; in TEST_F() local
299 seqno_t endSeqno; in TEST_F() local
318 seqno_t endSeqno; in TEST_F() local
336 seqno_t endSeqno; in TEST_F() local
[all...]
/6.0.3/kv_engine/daemon/protocol/mcbp/
H A Dengine_wrapper.cc630 dcpSnapshotMarker(Cookie& cookie, uint32_t opaque, uint16_t vbid, uint64_t startSeqno, uint64_t endSeqno, uint32_t flags) dcpSnapshotMarker() argument
668 dcpStreamReq(Cookie& cookie, uint32_t flags, uint32_t opaque, uint16_t vbucket, uint64_t startSeqno, uint64_t endSeqno, uint64_t vbucketUuid, uint64_t snapStartSeqno, uint64_t snapEndSeqno, uint64_t* rollbackSeqno, dcp_add_failover_log callback) dcpStreamReq() argument
/6.0.3/kv_engine/engines/ep/src/
H A Dephemeral_vb.cc266 createDCPBackfill( EventuallyPersistentEngine& e, std::shared_ptr<ActiveStream> stream, uint64_t startSeqno, uint64_t endSeqno) createDCPBackfill() argument
H A Dep_engine.cc1396 EvpDcpStreamReq(gsl::not_null<ENGINE_HANDLE*> handle, gsl::not_null<const void*> cookie, uint32_t flags, uint32_t opaque, uint16_t vbucket, uint64_t startSeqno, uint64_t endSeqno, uint64_t vbucketUuid, uint64_t snapStartSeqno, uint64_t snapEndSeqno, uint64_t* rollbackSeqno, dcp_add_failover_log callback) EvpDcpStreamReq() argument
/6.0.3/kv_engine/engines/ep/src/rocksdb-kvstore/
H A Drocksdb-kvstore.cc1359 uint64_t endSeqno = cachedVBStates[vbid]->highSeqno; in initScanContext() local

Completed in 88 milliseconds