Home
last modified time | relevance | path

Searched refs:VB (Results 1 - 25 of 37) sorted by relevance

12

/5.5.2/kv_engine/engines/ep/src/collections/
H A Dvbucket_filter.cc28 Collections::VB::Filter::Filter(const Collections::Filter& filter, in Filter()
29 const Collections::VB::Manifest& manifest) in Filter()
39 // Lock for reading and create a VB filter in Filter()
46 // The VB::Manifest no longer has $default so don't filter it in Filter()
48 "VB::Filter::Filter: dropping $default as it's not in the " in Filter()
49 "VB::Manifest"); in Filter()
70 // The VB::Manifest doesn't have the collection, or the collection in Filter()
74 "VB::Filter::Filter: dropping collection:%s:%" PRIu64 in Filter()
80 "VB::Filter::Filter: dropping collection:%s as it's not " in Filter()
88 bool Collections::VB
[all...]
H A Dvbucket_manifest_entry.cc20 SystemEvent Collections::VB::ManifestEntry::completeDeletion() { in completeDeletion()
32 std::string Collections::VB::ManifestEntry::getExceptionString( in getExceptionString()
35 ss << "VB::ManifestEntry::" << thrower << ": " << error in getExceptionString()
40 std::ostream& Collections::VB::operator<<( in operator <<()
42 const Collections::VB::ManifestEntry& manifestEntry) { in operator <<()
H A Dvbucket_serialised_manifest_entry.h26 namespace VB { namespace
31 * A VB::Manifest is serialised into an Item when it is updated. The
32 * Item carries a copy of the VB::Manifest down to the flusher so that
35 * The serialised data is created by VB::Manifest and is a copy of the
114 friend Collections::VB::Manifest;
223 friend Collections::VB::Manifest;
226 const Collections::VB::ManifestEntry& me, in make()
237 SerialisedManifestEntry(const Collections::VB::ManifestEntry& me, in SerialisedManifestEntry()
328 } // end namespace VB
H A Dvbucket_filter.h36 namespace VB { namespace
41 * The VB filter is used to decide if keys on a DCP stream should be sent
47 * ::VB::Filter becomes the intersection of the producer's filter and the
50 * Note: There is no locking on a VB::Filter as at the moment it is constructed
57 * Construct a Collections::VB::Filter using the producer's
66 * (allowAllCollections returns true) then so will the resulting VB filter.
72 const ::Collections::VB::Manifest& manifest);
148 } // end namespace VB
H A Dcollections_callbacks.cc23 namespace VB { namespace
39 } // end namespace VB
H A Dcollections_callbacks.h25 namespace VB { namespace
40 } // end namespace VB
H A Dscan_context.h27 namespace VB { namespace
58 } // end VB
H A Deraser_context.cc28 namespace VB { namespace
54 } // end VB
H A Deraser_context.h29 namespace VB { namespace
62 } // end VB
H A Dscan_context.cc22 namespace VB { namespace
45 } // end VB
H A Dvbucket_manifest_entry.h30 namespace VB { namespace
33 * The Collections::VB::ManifestEntry stores the data a collection
38 * Additionally this object is designed for use by Collections::VB::Manifest,
207 * "VB::ManifestEntry::<thrower>:<error>, this:<ostream *this>"
218 * "VB::ManifestEntry::<thrower>:<error>, this:<ostream *this>"
232 * way ManifestEntry objects are stored in the VB::Manifest
254 } // end namespace VB
/5.5.2/kv_engine/engines/ep/tests/module_tests/collections/
H A Dvbucket_manifest_entry_test.cc25 Collections::VB::ManifestEntry m({collection, 100}, in TEST()
42 Collections::VB::ManifestEntry m({collection, 1}, in TEST()
69 Collections::VB::ManifestEntry m({collection, 1}, in TEST()
99 EXPECT_THROW(Collections::VB::ManifestEntry({collection, 1}, 100, 100), in TEST()
107 Collections::VB::ManifestEntry entry1({collection, 5}, 2, 9); in TEST()
110 Collections::VB::ManifestEntry entry2(std::move(entry1)); in TEST()
117 Collections::VB::ManifestEntry entry3(entry2); in TEST()
H A Dfilter_test.cc287 * successfully, but later when a stream request occurs, the VB's view of
314 Collections::VB::Manifest vbm({});
322 Collections::VB::Filter vbf(f, vbm);
328 * i.e. they aren't writable so should never feature in a new VB::Filter
350 Collections::VB::Manifest vbm({});
356 Collections::VB::Filter vbf(f, vbm);
376 Collections::VB::Manifest vbm({});
379 Collections::VB::Filter vbf(f, vbm);
413 Collections::VB::Manifest vbm({});
416 Collections::VB
[all...]
H A Dvbucket_manifest_test.cc30 class MockVBManifest : public Collections::VB::Manifest {
32 MockVBManifest() : Collections::VB::Manifest({/* no collection data*/}) { in MockVBManifest()
35 MockVBManifest(const std::string& json) : Collections::VB::Manifest(json) { in MockVBManifest()
83 bool compareEntry(const Collections::VB::ManifestEntry& entry) const { in compareEntry()
408 * collections against this VB.
409 * @param replicaManfiest The replica VB's manifest, we will create/delete
422 auto dcpData = Collections::VB::Manifest::getSystemEventData( in applyCheckpointEventsToReplica()
444 auto dcpData = Collections::VB::Manifest:: in applyCheckpointEventsToReplica()
481 Collections::VB::Manifest::serialToJson(manifest)); in checkJson()
/5.5.2/ns_server/src/
H A Dmenelaus_web_xdcr_target.erl61 VB = proplists:get_value(vb, Props),
63 case ns_memcached:get_failover_log(Bucket, VB) of
67 do_handle_pre_replicate(Req, Props, Bucket, VB, FailoverLog)
70 do_handle_pre_replicate(Req, Props, Bucket, VB, FailoverLog) ->
83 "Bucket: ~p, VB: ~p, Return Code: ~p, CommitOpaque: ~p, FailoverLog: ~p",
84 [Bucket, VB, Code, CommitOpaque, FailoverLog]),
H A Dns_rebalance_observer.erl175 BuildDestinations0 = [{MasterNode, VB} || {VB, [MasterNode|_], _ChainAfter} <- Diff],
176 BuildDestinations1 = [{N, VB} || {VB, [MasterNode|_], ChainAfter} <- Diff,
191 [{{Node, VB}, {VBEstimate, VBChkItems}} ||
192 {VB, {VBEstimate, VBChkItems, _}} <-
203 {_, {MasterEstimate, MasterChkItems}} = lists:keyfind({MasterNode, VB}, 1, SomeEstimates),
206 {_, {ReplicaEstimate, _}} = lists:keyfind({Replica, VB}, 1, SomeEstimates),
225 #move_state{vbucket = VB,
229 end || {VB, [MasterNod
[all...]
H A Dns_config_log.erl226 VB = list_to_binary(io_lib:print(VS, 0, 80, 100)),
227 ?log_debug("config change:~n~p ->~n~s", [K, VB]).
H A Djanitor_agent.erl419 Replications = [{Src, Dst, VB}
422 VB <- VBs],
655 WantedReplications = [{Src, [VB || {_, VB} <- Pairs]}
675 WantedReplications = [{Src, [VB || {_, VB} <- Pairs]}
966 [ok = ns_memcached:sync_delete_vbucket(BucketName, VB)
967 || {VB, _} <- VBStates],
H A Dmc_client_binary.erl895 {ok, [case get_dcp_docs_estimate(Sock, VB, <<>>) of
897 end || VB <- VBuckets]}.
972 get_failover_log(Sock, VB) ->
974 {#mc_header{vbucket = VB}, #mc_entry{}}) of
/5.5.2/ns_server/deps/ns_couchdb/src/
H A Dcapi_utils.erl83 {[VB, U], undefined} ->
84 {VB, U};
85 {[VB, _], UUID} ->
86 {VB, UUID};
87 {[VB], UUID} ->
88 {VB, UUID}
H A Dcapi_replication.erl243 VB = proplists:get_value(<<"vb">>, Body),
244 case VB =:= undefined of
251 Fun(Req, Bucket, VB, VBOpaque)
355 handle_commit_for_checkpoint(Req, Bucket, VB, VBOpaque) ->
360 do_checkpoint_commit(Bucket, VB)
363 {UUID, Seqno} = get_vbucket_seqno_stats(Bucket, VB),
365 ?xdcr_debug("VB: ~p, UUID: ~p, VBOpaque: ~p", [VB, {UUID, Seqno}, VBOpaque]),
377 do_checkpoint_commit(Bucket, VB) ->
381 case ns_memcached:perform_checkpoint_commit_for_xdcr(Bucket, VB,
[all...]
/5.5.2/kv_engine/engines/ep/src/
H A Dvbucket.h606 Collections::VB::Manifest::ReadHandle lockCollections() const { in lockCollections()
621 Collections::VB::Manifest::CachingReadHandle lockCollections( in lockCollections()
626 Collections::VB::Manifest::CachingReadHandle lockCollections( in lockCollections()
632 * Update the Collections::VB::Manifest and the VBucket.
636 * @param m A Collections::Manifest to apply to the VB::Manifest
653 * this VB is a replica.
667 * this VB is a replica.
682 * this VB is a replica.
700 const Collections::VB::Manifest& getManifest() const { in getManifest()
832 const Collections::VB
[all...]
H A Dsystemevent.cc159 Collections::VB::Manifest::getSystemEventData( in make()
168 Collections::VB::Manifest::getSystemEventSeparatorData( in make()
H A Dkvstore.h111 Collections::VB::EraserContext eraserContext;
113 const DocKey, int64_t, bool, Collections::VB::EraserContext&)>
246 Collections::VB::ScanContext collectionsContext;
H A Dvbucket.cc782 // queueDirty only allowed on active VB in fetchValidValue()
953 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in replace()
1115 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in setWithMeta()
1248 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in deleteItem()
1386 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in deleteWithMeta()
1604 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in add()
1657 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in processGetAndUpdateTtl()
1722 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in getAndUpdateTtl()
1758 const Collections::VB::Manifest::CachingReadHandle& readHandle) { in getInternal()
1861 const Collections::VB in getMetaData()
[all...]

Completed in 76 milliseconds

12