| /6.0.3/kv_engine/engines/ep/src/dcp/ |
| H A D | backfill.h | 96 uint64_t endSeqno; member in DCPBackfill
37 DCPBackfill(std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfill() argument
|
| H A D | backfill_memory.cc | 29 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 D | backfill_disk.cc | 150 DCPBackfillDisk(EventuallyPersistentEngine& e, std::shared_ptr<ActiveStream> s, uint64_t startSeqno, uint64_t endSeqno) DCPBackfillDisk() argument
|
| H A D | response.h | 155 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 D | stream.cc | 419 void ActiveStream::markDiskSnapshot(uint64_t startSeqno, uint64_t endSeqno) { in markDiskSnapshot() argument
|
| /6.0.3/kv_engine/engines/ep/src/collections/ |
| H A D | vbucket_manifest_entry.h | 249 int64_t endSeqno; global() member in Collections::VB::ManifestEntry
[all...] |
| H A D | vbucket_manifest.h | 359 replicaBeginDelete(::VBucket& vb, uid_t manifestUid, Identifier identifier, int64_t endSeqno) replicaBeginDelete() argument
|
| H A D | vbucket_serialised_manifest_entry.h | 315 << 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 D | vbucket_manifest.cc | 82 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 D | basic_ll_test.cc | 281 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 D | engine_wrapper.cc | 630 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 D | ephemeral_vb.cc | 266 createDCPBackfill( EventuallyPersistentEngine& e, std::shared_ptr<ActiveStream> stream, uint64_t startSeqno, uint64_t endSeqno) createDCPBackfill() argument
|
| H A D | ep_engine.cc | 1396 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 D | rocksdb-kvstore.cc | 1359 uint64_t endSeqno = cachedVBStates[vbid]->highSeqno; in initScanContext() local
|