Home
last modified time | relevance | path

Searched refs:Collections (Results 1 - 25 of 54) sorted by relevance

123

/5.5.2/kv_engine/engines/ep/tests/module_tests/collections/
H A Dcollection_dockey_test.cc25 auto key1 = makeStoredDocKey("beer::bud", DocNamespace::Collections); in TEST()
26 auto key2 = makeStoredDocKey("beerbud", DocNamespace::Collections); in TEST()
31 Collections::DocKey::make(key1, "::").getCollectionLen()); in TEST()
33 EXPECT_EQ(0, Collections::DocKey::make(key2, "::").getCollectionLen()); in TEST()
35 EXPECT_EQ(0, Collections::DocKey::make(key1, "##").getCollectionLen()); in TEST()
40 Collections::DocKey::make(key1, "beer::bud").getCollectionLen()); in TEST()
45 Collections::DocKey::make(key1, "bud").getCollectionLen()); in TEST()
48 Collections::DocKey::make(key1, "longerthanthekey") in TEST()
52 EXPECT_EQ(strlen(Collections::SystemEventPrefix), in TEST()
53 Collections in TEST()
[all...]
H A Dfilter_test.cc66 Collections::Manifest m(
81 Collections::Filter f(json, &m);
95 Collections::Manifest m(
115 Collections::Filter f(json, &m);
127 Collections::Manifest m(
156 Collections::Filter f(json, &m);
172 Collections::Manifest m(
180 Collections::Filter f(json, &m);
197 Collections::Filter f(json, nullptr);
207 * Construct a valid Collections
[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()
38 bool exists(Collections::Identifier identifier) const { in exists()
43 bool isOpen(Collections::Identifier identifier) const { in isOpen()
50 bool isExclusiveOpen(Collections::Identifier identifier) const { in isExclusiveOpen()
57 bool isDeleting(Collections::Identifier identifier) const { in isDeleting()
64 bool isExclusiveDeleting(Collections::Identifier identifier) const { in isExclusiveDeleting()
71 bool isOpenAndDeleting(Collections::Identifier identifier) const { in isOpenAndDeleting()
83 bool compareEntry(const Collections
[all...]
H A Devp_store_collections_eraser_test.cc60 store_item(vbid, {"dairy:milk", DocNamespace::Collections}, "nice"); in TEST_P()
61 store_item(vbid, {"dairy:butter", DocNamespace::Collections}, "lovely"); in TEST_P()
68 evict_key(vbid, {"dairy:butter", DocNamespace::Collections}); in TEST_P()
97 store_item(vbid, {"dairy:milk", DocNamespace::Collections}, "nice"); in TEST_P()
98 store_item(vbid, {"dairy:butter", DocNamespace::Collections}, "lovely"); in TEST_P()
99 store_item(vbid, {"fruit:apple", DocNamespace::Collections}, "nice"); in TEST_P()
100 store_item(vbid, {"fruit:apricot", DocNamespace::Collections}, "lovely"); in TEST_P()
135 store_item(vbid, {"dairy:milk", DocNamespace::Collections}, "nice"); in TEST_P()
136 store_item(vbid, {"dairy:butter", DocNamespace::Collections}, "lovely"); in TEST_P()
137 store_item(vbid, {"fruit:apple", DocNamespace::Collections}, "nic in TEST_P()
[all...]
H A Devp_store_collections_test.cc90 {"meat:beef", DocNamespace::Collections}, in TEST_F()
106 store_item(vbid, {"meat:beef", DocNamespace::Collections}, "value"); in TEST_F()
116 {"meat:beef", DocNamespace::Collections}, vbid, cookie, options); in TEST_F()
121 {"meat:sausage", DocNamespace::Collections}, vbid, cookie, options); in TEST_F()
133 {"meat:beef", DocNamespace::Collections}, vbid, cookie, options); in TEST_F()
152 vbid, {"dairy:milk", DocNamespace::Collections}, "creamy", 0, 0); in TEST_F()
157 vbid, {"dairy:cream", DocNamespace::Collections}, "creamy", 0, 0); in TEST_F()
198 {"meat:sausage", DocNamespace::Collections}, vbid, item2)); in TEST_F()
204 {"meat:sausage", DocNamespace::Collections}, vbid, cookie)); in TEST_F()
274 vbid, {"dairy:milk", DocNamespace::Collections}, "cream in TEST_F()
[all...]
H A Devp_store_collections_dcp_test.cc205 Collections::uid_t uid = 4; in TEST_F()
206 Collections::uid_t manifestUid = 0xcafef00d; in TEST_F()
207 Collections::SystemEventDCPData eventData{htonll(manifestUid), htonll(uid)}; in TEST_F()
219 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
236 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
239 Collections::Identifier{"meat", 4})); in TEST_F()
257 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
285 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
292 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
305 {"meat:bacon", DocNamespace::Collections})); in TEST_F()
[all...]
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 Dmanifest_test.cc147 Collections::Manifest m(manifest); in TEST()
157 Collections::Manifest m(manifest); in TEST()
180 Collections::Manifest m(manifest.second); in TEST()
186 std::vector<std::pair<Collections::uid_t, std::string> > validManifests = { in TEST()
205 Collections::Manifest m(manifest.second); in TEST()
216 std::vector<Collections::Manifest::Identifier> collectionT = { in TEST()
218 std::vector<Collections::Manifest::Identifier> collectionF = { in TEST()
221 Collections::Manifest m(manifest); in TEST()
255 Collections::Manifest m(manifest); in TEST()
/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()
88 bool Collections::VB::Filter::checkAndUpdateSlow(const Item& item) { in checkAndUpdateSlow()
90 if (item.getKey().getDocNamespace() == DocNamespace::Collections && in checkAndUpdateSlow()
92 // Collections require a look up in the filter in checkAndUpdateSlow()
93 const auto cKey = Collections::DocKey::make(item.getKey(), separator); in checkAndUpdateSlow()
105 void Collections::VB::Filter::remove(const Item& item) { in remove()
110 const auto cKey = Collections::DocKey::make(item.getKey()); in remove()
118 bool Collections
[all...]
H A Dmanager.cc25 Collections::Manager::Manager() { in Manager()
28 cb::engine_error Collections::Manager::update(KVBucket& bucket, in update()
35 "Collections::Manager::update already locked"); in update()
48 "Collections::Manager::update can't construct manifest e.what:%s", in update()
52 "Collections::Manager::update manifest json invalid:" + json); in update()
66 "Collections::Manager::update"); in update()
69 cb::EngineErrorStringPair Collections::Manager::getManifest() const { in getManifest()
78 void Collections::Manager::update(VBucket& vb) const { in update()
86 Collections::Filter Collections
[all...]
H A Dscan_context.cc21 namespace Collections { namespace
26 auto cKey = Collections::DocKey::make(key); in manageSeparator()
27 if (cKey.getCollection() == Collections::SeparatorChangePrefix) { in manageSeparator()
32 // Make a new Collections::DocKey from cKey.getKey, which returns in manageSeparator()
34 auto cKey2 = Collections::DocKey::make( in manageSeparator()
46 } // end Collections
H A Dfilter.cc31 * Construct a Collections::Filter, optionally using a JSON document with the
47 Collections::Filter::Filter(boost::optional<const std::string&> jsonFilter, in Filter()
154 void Collections::Filter::addCollection(const char* collection, in addCollection()
176 void Collections::Filter::addCollection(cJSON* object, in addCollection()
210 void Collections::Filter::dump() const { in dump()
214 std::ostream& Collections::operator<<(std::ostream& os, in operator <<()
215 const Collections::Filter& filter) { in operator <<()
216 os << "Collections::Filter" in operator <<()
221 case Collections::Filter::Type::Name: in operator <<()
224 case Collections in operator <<()
[all...]
H A Dvbucket_manifest_entry.cc20 SystemEvent Collections::VB::ManifestEntry::completeDeletion() { in completeDeletion()
32 std::string Collections::VB::ManifestEntry::getExceptionString( in getExceptionString()
40 std::ostream& Collections::VB::operator<<( in operator <<()
42 const Collections::VB::ManifestEntry& manifestEntry) { in operator <<()
H A Dcollections_types.h22 namespace Collections { namespace
118 Collections::uid_t manifestUid;
130 Collections::uid_t manifestUid;
132 Collections::uid_t collectionUid;
141 Collections::uid_t manifestUid;
150 } // end namespace Collections
H A Dcollections_dockey.h25 namespace Collections { namespace
28 * Collections::DocKey extends a DocKey so that the length of the collection
42 * Factory method to create a Collections::DocKey from a DocKey
48 case DocNamespace::Collections: { in make()
67 * Factory method to create a Collections::DocKey from a DocKey
69 static Collections::DocKey make(const ::DocKey& key);
108 "Collections::DocKey invalid separatorLen:" + in DocKey()
143 } // end namespace Collections
147 struct hash<Collections::DocKey> {
148 std::size_t operator()(const Collections
[all...]
H A Dvbucket_filter.h32 namespace Collections { namespace
44 * A filter is built from the Collections::Filter that was established when
57 * Construct a Collections::VB::Filter using the producer's
58 * Collections::Filter and the vbucket's collections manifest.
71 Filter(const ::Collections::Filter& filter,
72 const ::Collections::VB::Manifest& manifest);
149 } // end namespace Collections
H A Dvbucket_manifest.cc30 namespace Collections { namespace
93 void Manifest::update(::VBucket& vb, const Collections::Manifest& manifest) { in update()
94 std::vector<Collections::Manifest::Identifier> additions, deletions; in update()
324 const Collections::Manifest& manifest) const { in processManifest()
325 std::vector<Collections::Manifest::Identifier> additions, deletions; in processManifest()
355 } else if (key.getDocNamespace() == DocNamespace::Collections) { in doesKeyContainValidCollection()
356 const auto cKey = Collections::DocKey::make(key, separator); in doesKeyContainValidCollection()
379 } else if (key.getDocNamespace() == DocNamespace::Collections) { in getManifestEntry()
380 const auto cKey = Collections::DocKey::make(key, separator); in getManifestEntry()
383 const auto cKey = Collections in getManifestEntry()
[all...]
H A Dcollections_dockey.cc23 * Factory method to create a Collections::DocKey from a DocKey
25 Collections::DocKey Collections::DocKey::make(const ::DocKey& key) { in make()
H A Dvbucket_serialised_manifest_entry.h25 namespace Collections { namespace
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()
329 } // end namespace Collections
H A Dmanager.h30 namespace Collections { namespace
36 * Collections::Manager provides some bucket level management functions
69 * make a Collections::Filter
73 * @returns a Collections::Filter
74 * @throws exceptions generated by Collections::Filter::Filter
76 Collections::Filter makeFilter(uint32_t dcpOpenFlags,
H A Dmanifest.h28 namespace Collections { namespace
59 bool operator==(const Collections::Identifier& rhs) const { in operator ==()
109 const Collections::Identifier& identifier) const { in find()
199 } // end namespace Collections
H A Dvbucket_manifest.h35 namespace Collections { namespace
39 * Collections::VB::Manifest is a container for all of the collections a VBucket
42 * Each collection is represented by a Collections::VB::ManifestEntry and all of
133 return Collections::DocKey::make(key, manifest.getSeparator()); in makeCollectionsDocKey()
301 * Update from a Collections::Manifest
312 void update(::VBucket& vb, const Collections::Manifest& newManifest) { in update()
410 * - Separator defined as Collections::DefaultSeparator
496 * Update from a Collections::Manifest
507 void update(::VBucket& vb, const Collections::Manifest& manifest);
726 * Process a Collections
[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
638 void updateFromManifest(const Collections::Manifest& m) { in updateFromManifest()
659 void replicaAddCollection(Collections::uid_t manifestUid, in replicaAddCollection()
660 Collections::Identifier identifier, in replicaAddCollection()
673 void replicaBeginDeleteCollection(Collections::uid_t manifestUid, in replicaBeginDeleteCollection()
674 Collections in replicaBeginDeleteCollection()
[all...]
H A Dsystemevent.cc70 key = Collections::SystemEventPrefixWithSeparator + keyExtra; in makeKey()
75 key = Collections::DeleteKey + keyExtra; in makeKey()
80 key = Collections::SeparatorChangePrefixWithSeparator + keyExtra; in makeKey()
159 Collections::VB::Manifest::getSystemEventData( in make()
168 Collections::VB::Manifest::getSystemEventSeparatorData( in make()
/5.5.2/kv_engine/engines/ep/src/dcp/
H A Dresponse.h635 const Collections::SystemEventData& data) in CollectionsProducerMessage()
646 Collections::SystemEventDCPData eventData;
653 Collections::SystemEventSeparatorData data) in ChangeSeparatorProducerMessage()
666 Collections::uid_t manifestUid;
700 : CollectionsEvent(e, sizeof(Collections::SystemEventDCPData)) { in CreateOrDeleteCollectionEvent()
706 Collections::Identifier getCollection() const { in getCollection()
713 Collections::uid_t getManifestUid() const { in getManifestUid()
714 return ntohll(*reinterpret_cast<const Collections::uid_t*>( in getManifestUid()
722 Collections::uid_t getUid() const { in getUid()
723 return ntohll(*reinterpret_cast<const Collections in getUid()
[all...]

Completed in 61 milliseconds

123