Home
last modified time | relevance | path

Searched refs:vb (Results 1 - 25 of 192) sorted by relevance

12345678

/5.5.2/kv_engine/engines/ep/src/
H A Dvb_count_visitor.cc22 void VBucketCountVisitor::visitBucket(VBucketPtr& vb) { in visitBucket() argument
24 numItems += vb->getNumItems(); in visitBucket()
25 numTempItems += vb->getNumTempItems(); in visitBucket()
26 nonResident += vb->getNumNonResidentItems(); in visitBucket()
28 if (vb->getHighPriorityChkSize() > 0) { in visitBucket()
33 htMemory += vb->ht.memorySize(); in visitBucket()
34 htItemMemory += vb->ht.getItemMemory(); in visitBucket()
35 htUncompressedItemMemory += vb->ht.getUncompressedItemMemory(); in visitBucket()
36 htCacheSize += vb->ht.getCacheSize(); in visitBucket()
37 numEjects += vb in visitBucket()
82 visitBucket(VBucketPtr &vb) visitBucket() argument
[all...]
H A Dep_bucket.cc41 VBucketPtr vb = store.getVBucket(vbucketId); in callback() local
42 if (vb) { in callback()
47 bool tempFilterInitialized = vb->isTempFilterAvailable(); in callback()
65 vb->addToTempFilter(key); in callback()
75 vb->isResidentRatioUnderThreshold( in callback()
78 vb->addToTempFilter(key); in callback()
80 if (isDeleted || !store.isMetaDataResident(vb, key)) { in callback()
81 vb->addToTempFilter(key); in callback()
95 VBucketPtr vb = store.getVBucket(vbucketId); in initTempFilter() local
96 if (!vb) { in initTempFilter()
264 auto vb = getLockedVBucket(vbid, std::try_to_lock); flushVBucket() local
600 VBucketPtr vb = vbMap.getBucket(vbid); scheduleCompaction() local
640 auto vb = getLockedVBucket(i); flushOneDeleteAll() local
656 flushOneDelOrSet( const queued_item& qi, VBucketPtr& vb) flushOneDelOrSet() argument
721 VBucketPtr vb = getVBucket(vbid); compactInternal() local
755 auto vb = getVBucket(uint16_t(ctx->db_file_id)); compactInternal() local
774 auto vb = getLockedVBucket(vbid, std::try_to_lock); doCompact() local
826 getLastPersistedCheckpointId(uint16_t vb) getLastPersistedCheckpointId() argument
932 VBucketPtr vb = getVBucket(vbucket); statsVKey() local
947 VBucketPtr vb = getVBucket(vbid); completeStatsVKey() local
991 VBucketPtr vb = engine.getVBucket(itm->getVBucketId()); callback() local
1019 removeDeletedDoc(VBucket& vb, const DocKey& key) removeDeletedDoc() argument
1042 rollbackUnpersistedItems(VBucket& vb, int64_t rollbackSeqno) rollbackUnpersistedItems() argument
[all...]
H A Dkv_bucket.cc205 PendingOpsNotification(EventuallyPersistentEngine& e, VBucketPtr& vb) in PendingOpsNotification() argument
208 vbucket(vb), in PendingOpsNotification()
226 "vb", in run()
511 VBucketPtr vb = getVBucket(vbucket); in evictKey() local
512 if (!vb || (vb->getState() != vbucket_state_active)) { in evictKey()
516 return vb->evictKey(key, msg); in evictKey()
527 "KVBucket::getValue failed get for item vb:%" PRIu16 in getValue()
538 void KVBucket::runPreExpiryHook(VBucket& vb, Item& it) { in runPreExpiryHook() argument
541 it.toItemInfo(vb in runPreExpiryHook()
557 VBucketPtr vb = getVBucket(it.getVBucketId()); deleteExpiredItem() local
590 isMetaDataResident(VBucketPtr &vb, const DocKey& key) isMetaDataResident() argument
621 VBucketPtr vb = getVBucket(itm.getVBucketId()); set() local
658 VBucketPtr vb = getVBucket(itm.getVBucketId()); add() local
699 VBucketPtr vb = getVBucket(itm.getVBucketId()); replace() local
736 VBucketPtr vb = getVBucket(itm.getVBucketId()); addBackfillItem() local
788 VBucketPtr vb = vbMap.getBucket(vbid); setVBucketState_UNLOCKED() local
903 VBucketPtr vb = getVBucket(vbid); scheduleVBStatePersist() local
918 VBucketPtr vb = vbMap.getBucket(vbid); deleteVBucket() local
947 VBucketPtr vb = vbMap.getBucket(db_file_id); checkForDBExistence() local
974 resetVBucket_UNLOCKED(LockedVBucketPtr& vb, std::unique_lock<std::mutex>& vbset) resetVBucket_UNLOCKED() argument
1292 VBucketPtr vb = getVBucket(vbucket); completeBGFetch() local
1316 VBucketPtr vb = getVBucket(vbId); completeBGFetchMulti() local
1354 VBucketPtr vb = getVBucket(vbucket); getInternal() local
1403 VBucketPtr vb = getVBucket(curr++); getRandomKey() local
1440 VBucketPtr vb = getVBucket(vbucket); getMetaData() local
1481 VBucketPtr vb = getVBucket(itm.getVBucketId()); setWithMeta() local
1538 VBucketPtr vb = getVBucket(vbucket); getAndUpdateTtl() local
1571 VBucketPtr vb = getVBucket(vbucket); getLocked() local
1598 VBucketPtr vb = getVBucket(vbucket); unlockKey() local
1649 VBucketPtr vb = getVBucket(vbucket); getKeyStats() local
1671 VBucketPtr vb = getVBucket(vbucket); validateKey() local
1709 VBucketPtr vb = getVBucket(vbucket); deleteItem() local
1755 VBucketPtr vb = getVBucket(vbucket); deleteWithMeta() local
1810 auto vb = getLockedVBucket(vbid); reset() local
2138 VBucketPtr vb = vbMap.getBucket(vbid); setAllBloomFilters() local
2152 VBucketPtr vb = vbMap.getBucket(vbid); visit() local
2175 VBucketPtr vb = vbMap.getBucket(vbid); pauseResumeVisit() local
2225 VBucketPtr vb = store->getVBucket(currentvb); run() local
2318 auto vb = getLockedVBucket(vbid, std::try_to_lock); rollback() local
2426 VBucketPtr vb = vbMap.getBucket(vbucket); forceMaxCas() local
2506 auto vb = getVBucket(vbid); collectionsEraseKey() local
[all...]
H A Dkvshard.cc83 void KVShard::setBucket(VBucketPtr vb) { in setBucket() argument
84 vbuckets[vb->getId()].lock().set(vb); in setBucket()
89 auto vb = vbuckets[id].lock(); in dropVBucketAndSetupDeferredDeletion() local
90 auto vbPtr = vb.get(); in dropVBucketAndSetupDeferredDeletion()
92 vb.reset(); in dropVBucketAndSetupDeferredDeletion()
101 auto vb = b.lock(); in getVBucketsSortedByState() local
102 auto vbPtr = vb.get(); in getVBucketsSortedByState()
114 auto vb = b.lock(); in getVBuckets() local
115 auto vbPtr = vb in getVBuckets()
123 callback(uint16_t &vb) callback() argument
[all...]
H A Dvb_visitors.cc27 bool PauseResumeVBAdapter::visit(VBucket& vb) { in visit() argument
31 if (resume_vbucket_id == vb.getId()) { in visit()
35 htVisitor->setCurrentVBucket(vb); in visit()
36 hashtable_position = vb.ht.pauseResumeVisit(*htVisitor, ht_start); in visit()
38 if (hashtable_position != vb.ht.endPosition()) { in visit()
41 resume_vbucket_id = vb.getId(); in visit()
H A Dcheckpoint_remover.cc49 void visitBucket(VBucketPtr &vb) override {
51 removed = vb->checkpointManager->removeClosedUnrefCheckpoints(
52 *vb, newCheckpointCreated);
57 vb->getId(), vb->checkpointManager->getHighSeqno());
64 removed, vb->getId());
146 VBucketPtr vb = kvBucket->getVBucket(vbid); in cursorDroppingIfNeeded() local
147 if (vb) { in cursorDroppingIfNeeded()
152 vb->checkpointManager->getListOfCursorsToDrop(); in cursorDroppingIfNeeded()
160 vb in cursorDroppingIfNeeded()
[all...]
H A Dvbucketmap.cc52 ENGINE_ERROR_CODE VBucketMap::addBucket(VBucketPtr vb) { in addBucket() argument
53 if (vb->getId() < size) { in addBucket()
54 getShardByVbId(vb->getId())->setBucket(vb); in addBucket()
55 ++vbStateCount[vb->getState()]; in addBucket()
58 vb->getId(), in addBucket()
59 VBucket::toString(vb->getState())); in addBucket()
63 "Cannot create vb %" PRIu16 ", max vbuckets is %" PRIu16, in addBucket()
64 vb->getId(), in addBucket()
166 auto vb in setHLCDriftAheadThreshold() local
175 auto vb = getBucket(id); setHLCDriftBehindThreshold() local
[all...]
/5.5.2/moxi/vbucket/
H A Dvbucket.c89 static void update_ketama_continuum(VBUCKET_CONFIG_HANDLE vb) in update_ketama_continuum() argument
97 new_continuum = calloc(160 * vb->num_servers, in update_ketama_continuum()
101 for (ss = 0, pp = 0; ss < vb->num_servers; ++ss) { in update_ketama_continuum()
105 vb->servers[ss].authority, hh); in update_ketama_continuum()
119 old_continuum = vb->continuum; in update_ketama_continuum()
120 vb->continuum = new_continuum; in update_ketama_continuum()
121 vb->num_continuum = pp; in update_ketama_continuum()
127 void vbucket_config_destroy(VBUCKET_CONFIG_HANDLE vb) { in vbucket_config_destroy() argument
129 for (i = 0; i < vb->num_servers; ++i) { in vbucket_config_destroy()
130 free(vb in vbucket_config_destroy()
145 substitute_localhost_marker(struct vbucket_config_st *vb, char *input) substitute_localhost_marker() argument
167 populate_servers(struct vbucket_config_st *vb, cJSON *c) populate_servers() argument
197 get_node_authority(struct vbucket_config_st *vb, cJSON *node, char **out, size_t nbuf) get_node_authority() argument
238 lookup_server_struct(struct vbucket_config_st *vb, cJSON *c) lookup_server_struct() argument
263 update_server_info(struct vbucket_config_st *vb, cJSON *config) update_server_info() argument
314 populate_buckets(struct vbucket_config_st *vb, cJSON *c, int is_forward) populate_buckets() argument
351 parse_vbucket_config(VBUCKET_CONFIG_HANDLE vb, cJSON *c) parse_vbucket_config() argument
434 parse_ketama_config(VBUCKET_CONFIG_HANDLE vb, cJSON *config) parse_ketama_config() argument
670 vbucket_map(VBUCKET_CONFIG_HANDLE vb, const void *key, size_t nkey, int *vbucket_id, int *server_idx) vbucket_map() argument
727 vbucket_config_get_num_replicas(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_replicas() argument
731 vbucket_config_get_num_vbuckets(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_vbuckets() argument
735 vbucket_config_get_num_servers(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_servers() argument
739 vbucket_config_get_couch_api_base(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_couch_api_base() argument
743 vbucket_config_get_rest_api_server(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_rest_api_server() argument
747 vbucket_config_is_config_node(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_is_config_node() argument
751 vbucket_config_get_distribution_type(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_distribution_type() argument
755 vbucket_config_get_server(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_server() argument
759 vbucket_config_get_user(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_user() argument
763 vbucket_config_get_password(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_password() argument
767 vbucket_get_vbucket_by_key(VBUCKET_CONFIG_HANDLE vb, const void *key, size_t nkey) vbucket_get_vbucket_by_key() argument
775 vbucket_get_master(VBUCKET_CONFIG_HANDLE vb, int vbucket) vbucket_get_master() argument
779 vbucket_get_replica(VBUCKET_CONFIG_HANDLE vb, int vbucket, int i) vbucket_get_replica() argument
788 vbucket_found_incorrect_master(VBUCKET_CONFIG_HANDLE vb, int vbucket, int wrongserver) vbucket_found_incorrect_master() argument
[all...]
H A Dvbuckettool.c24 VBUCKET_CONFIG_HANDLE vb = NULL; in main() local
48 vb = vbucket_config_parse_string(buf); in main()
50 vb = vbucket_config_parse_file(argv[1]); in main()
53 if (vb == NULL) { in main()
58 num_replicas = vbucket_config_get_num_replicas(vb); in main()
65 if (vbucket_map(vb, key, strlen(key), &v, &m) < -1) { in main()
69 master = vbucket_config_get_server(vb, m); in main()
70 couch_api_base = vbucket_config_get_couch_api_base(vb, m); in main()
72 if (vbucket_config_get_distribution_type(vb) == VBUCKET_DISTRIBUTION_VBUCKET) { in main()
78 int r = vbucket_get_replica(vb, in main()
[all...]
/5.5.2/moxi/tests/vbucket/
H A Dtestapp.c75 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); in testConfig() local
76 if (vb == NULL) { in testConfig()
83 int id = vbucket_get_vbucket_by_key(vb, k->key, strlen(k->key)); in testConfig()
95 cb_assert(vbucket_config_get_num_servers(vb) == 3 || vbucket_config_get_num_servers(vb) == 4); in testConfig()
96 cb_assert(vbucket_config_get_num_replicas(vb) == 2); in testConfig()
99 cb_assert(strcmp(vbucket_config_get_server(vb, i), servers[i]) == 0); in testConfig()
103 cb_assert(vbucket_get_master(vb, i) == vbuckets[i].master); in testConfig()
104 cb_assert(vbucket_get_replica(vb, i, 0) == vbuckets[i].replicas[0]); in testConfig()
105 cb_assert(vbucket_get_replica(vb, in testConfig()
116 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); testWrongServer() local
142 VBUCKET_CONFIG_HANDLE vb = vbucket_config_create(); testWrongNumVbuckets() local
151 VBUCKET_CONFIG_HANDLE vb = vbucket_config_create(); testZeroNumVbuckets() local
160 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); testWrongServerFFT() local
295 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath("config-couch-api-base")); testConfigCouchApiBase() local
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dataport/
H A Dprotobuf_test.go39 vb := common.NewVbKeyVersions("default", vbno, vbuuid, nMuts)
40 addKeyVersions(vb, []*common.KeyVersions{kv}, 1, nMuts)
41 testKeyVersions(t, vb)
47 vb := common.NewVbKeyVersions("default", vbno, vbuuid, nMuts)
48 addKeyVersions(vb, []*common.KeyVersions{kv}, 1, nMuts)
49 testKeyVersions(t, vb)
55 vb := common.NewVbKeyVersions("default", vbno, vbuuid, nMuts)
56 addKeyVersions(vb, []*common.KeyVersions{kv}, 1, nMuts)
57 testKeyVersions(t, vb)
66 vb
[all...]
/5.5.2/kv_engine/engines/ep/tests/module_tests/collections/
H A Devp_store_collections_eraser_test.cc30 vb = store->getVBucket(vbid);
34 vb.reset();
47 VBucketPtr vb; member in CollectionsEraserTest
53 vb->updateFromManifest({R"({"separator":":","uid":"0",)" in TEST_P()
65 EXPECT_EQ(2, vb->getNumItems()); in TEST_P()
71 vb->updateFromManifest( in TEST_P()
78 EXPECT_TRUE(vb->lockCollections().exists("dairy")); in TEST_P()
82 EXPECT_EQ(0, vb->getNumItems()); in TEST_P()
84 EXPECT_FALSE(vb->lockCollections().exists("dairy")); in TEST_P()
89 vb in TEST_P()
[all...]
H A Devp_store_collections_test.cc43 std::string getManifest(uint16_t vb) const { in getManifest()
44 return store->getVBucket(vb) in getManifest()
61 VBucketPtr vb = store->getVBucket(vbid); in TEST_F() local
63 vb->updateFromManifest({R"({"separator":":","uid":"0", in TEST_F()
95 VBucketPtr vb = store->getVBucket(vbid); in TEST_F() local
98 vb->updateFromManifest({R"({"separator":":","uid":"0", in TEST_F()
125 vb->updateFromManifest({R"({"separator":":","uid":"0", in TEST_F()
143 VBucketPtr vb = store->getVBucket(vbid); in TEST_F() local
145 vb->updateFromManifest({R"({"separator":":","uid":"0", in TEST_F()
162 vb in TEST_F()
265 VBucketPtr vb = store->getVBucket(vbid); TEST_F() local
379 VBucketPtr vb = store->getVBucket(vbid); createCollectionAndFlush() local
388 VBucketPtr vb = store->getVBucket(vbid); deleteCollectionAndFlush() local
397 VBucketPtr vb = store->getVBucket(vbid); completeDeletionAndFlush() local
530 auto vb = store->getVBucket(vbid); TEST_F() local
589 auto vb = store->getVBucket(vbid); TEST_F() local
618 auto vb = store->getVBucket(vbid); TEST_F() local
628 auto vb = store->getVBucket(vbid); TEST_F() local
666 auto vb = store->getVBucket(vbid); TEST_F() local
[all...]
H A Devp_store_collections_dcp_test.cc59 std::string getManifest(uint16_t vb) const { in getManifest()
60 return store->getVBucket(vb) in getManifest()
216 VBucketPtr vb = store->getVBucket(vbid); in TEST_F() local
218 EXPECT_FALSE(vb->lockCollections().doesKeyContainValidCollection( in TEST_F()
235 EXPECT_TRUE(vb->lockCollections().doesKeyContainValidCollection( in TEST_F()
237 EXPECT_TRUE(vb->lockCollections().isCollectionOpen("meat")); in TEST_F()
238 EXPECT_TRUE(vb->lockCollections().isCollectionOpen( in TEST_F()
240 EXPECT_EQ(0xcafef00d, vb->lockCollections().getManifestUid()); in TEST_F()
256 EXPECT_FALSE(vb->lockCollections().doesKeyContainValidCollection( in TEST_F()
271 VBucketPtr vb in TEST_F() local
353 VBucketPtr vb = store->getVBucket(vbid); TEST_F() local
402 VBucketPtr vb = store->getVBucket(vbid); TEST_F() local
447 VBucketPtr vb = store->getVBucket(vbid); TEST_F() local
484 VBucketPtr vb = store->getVBucket(vbid); TEST_F() local
526 auto vb = store->getVBucket(vbid); TEST_F() local
582 auto vb = store->getVBucket(vbid); TEST_F() local
[all...]
/5.5.2/kv_engine/engines/ep/tests/module_tests/
H A Dephemeral_bucket_test.cc30 void EphemeralBucketStatTest::addDocumentsForSeqListTesting(uint16_t vb) { in addDocumentsForSeqListTesting() argument
32 store_item(vb, makeStoredDocKey("deleted"), "value"); in addDocumentsForSeqListTesting()
33 delete_item(vb, makeStoredDocKey("deleted")); in addDocumentsForSeqListTesting()
34 store_item(vb, makeStoredDocKey("doc"), "value"); in addDocumentsForSeqListTesting()
35 store_item(vb, makeStoredDocKey("doc"), "value 2"); in addDocumentsForSeqListTesting()
62 auto vb = store->getVBucket(vbid); in TEST_F() local
64 auto lock = vb->ht.getLockedBucket(key); in TEST_F()
65 auto* value = vb->fetchValidValue( in TEST_F()
67 ASSERT_TRUE(vb->pageOut(lock, value)); in TEST_F()
90 auto vb in TEST_F() local
[all...]
H A Dcheckpoint_remover_test.cc27 size_t CheckpointRemoverTest::getMaxCheckpointItems(VBucket& vb) { in getMaxCheckpointItems() argument
28 return vb.checkpointManager->getCheckpointConfig().getCheckpointMaxItems(); in getMaxCheckpointItems()
71 auto vb = store->getVBuckets().getBucket(vbid); in TEST_F() local
72 auto& checkpointManager = vb->checkpointManager; in TEST_F()
101 auto vb = store->getVBuckets().getBucket(vbid); in TEST_F() local
102 auto& checkpointManager = vb->checkpointManager; in TEST_F()
124 for (size_t i = 0; i < getMaxCheckpointItems(*vb) + 10; i++) { in TEST_F()
134 flush_vbucket_to_disk(vbid, getMaxCheckpointItems(*vb) + 10); in TEST_F()
152 auto vb = store->getVBuckets().getBucket(vbid); in TEST_F() local
153 auto& checkpointManager = vb in TEST_F()
[all...]
/5.5.2/testrunner/lib/membase/helper/
H A Dcheckpoints.py19 vb = k[vb_pos_start + 1:vb_pos_end]
21 if vb not in result:
22 result[vb] = {}
23 result[vb][checkpoint_attribute] = v
29 for vb, attributes in per_node_result.items():
30 if vb not in total_results:
31 total_results[vb] = {}
32 total_results[vb][node] = attributes
68 for vb, checkpoints in merged.items():
72 alarms.append("active vbucket {0} num_checkpoints is {1}".format(vb,
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/common/
H A Dmutation.go74 func (p *Payload) AddVbKeyVersions(vb *VbKeyVersions) (err error) {
75 if vb == nil || p.Payltyp != PayloadKeyVersions {
78 p.Vbs = append(p.Vbs, vb)
143 vb := &VbKeyVersions{Bucket: bucket, Vbucket: vbno, Vbuuid: vbuuid, ProjVer: ProjVer_5_5_0}
144 vb.Kvs = make([]*KeyVersions, 0, maxMutations)
145 vb.Uuid = StreamID(bucket, vbno)
146 return vb
150 func (vb *VbKeyVersions) AddKeyVersions(kv *KeyVersions) error {
151 vb.Kvs = append(vb
[all...]
/5.5.2/godeps/src/github.com/couchbase/gomemcached/client/mocks/
H A DClientIface.go14 // Add provides a mock function with given fields: vb, key, flags, exp, body
15 func (_m *ClientIface) Add(vb uint16, key string, flags int, exp int, body []byte) (*gomemcached.MCResponse, error) {
16 ret := _m.Called(vb, key, flags, exp, body)
20 r0 = rf(vb, key, flags, exp, body)
29 r1 = rf(vb, key, flags, exp, body)
37 // Append provides a mock function with given fields: vb, key, data
38 func (_m *ClientIface) Append(vb uint16, key string, data []byte) (*gomemcached.MCResponse, error) {
39 ret := _m.Called(vb, key, data)
43 r0 = rf(vb, key, data)
52 r1 = rf(vb, ke
[all...]
/5.5.2/godeps/src/github.com/couchbase/go-couchbase/
H A Dobserve.go38 vb uint16
50 vb uint16
90 func (b *Bucket) ObserveAndPersistPoll(vb uint16, vbuuid uint64, seqNo uint64) (err error, failover bool) {
103 nodes := b.GetNodeList(vb)
114 opJob.vb = vb
130 opJob.vb = vb
207 errRes := &OPErrResponse{vb: job.vb, vbuui
[all...]
/5.5.2/kv_engine/engines/ep/src/collections/
H A Dmanager.cc58 auto vb = bucket.getVBuckets().getBucket(i); in update() local
60 if (vb && vb->getState() == vbucket_state_active) { in update()
61 vb->updateFromManifest(*current); in update()
78 void Collections::Manager::update(VBucket& vb) const { in update()
82 vb.updateFromManifest(*current); in update()
108 auto vb = bucket.getVBuckets().getBucket(i); in logAll() local
109 if (vb) { in logAll()
111 vbss << vb->lockCollections(); in logAll()
113 "vb in logAll()
[all...]
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/dcp/
H A Dupr.go50 for _, vb := range vBuckets {
51 if l := len(vbm.VBucketMap); int(vb) >= l {
53 logging.Errorf(fmsg, opaque, vb, l)
57 masterID := vbm.VBucketMap[vb][0]
61 logging.Errorf(fmsg, opaque, vb)
69 vbList = append(vbList, vb)
93 for vb, log := range failoverlogs {
94 failoverLogMap[vb] = *log
185 // DcpRequestStream starts a stream for a vb on a feed
190 vb uint1
[all...]
/5.5.2/godeps/src/github.com/couchbase/gomemcached/client/
H A Dmc.go21 Add(vb uint16, key string, flags int, exp int, body []byte) (*gomemcached.MCResponse, error)
22 Append(vb uint16, key string, data []byte) (*gomemcached.MCResponse, error)
27 CASNext(vb uint16, k string, exp int, state *CASState) bool
28 CAS(vb uint16, k string, f CasFunc, initexp int) (*gomemcached.MCResponse, error)
30 Decr(vb uint16, key string, amt, def uint64, exp int) (uint64, error)
31 Del(vb uint16, key string) (*gomemcached.MCResponse, error)
33 Get(vb uint16, key string) (*gomemcached.MCResponse, error)
34 GetSubdoc(vb uint16, key string, subPaths []string) (*gomemcached.MCResponse, error)
35 GetAndTouch(vb uint16, key string, exp int) (*gomemcached.MCResponse, error)
36 GetBulk(vb uint1
[all...]
/5.5.2/kv_engine/engines/ep/tests/mock/
H A Dmock_stream.h36 VBucket& vb, in MockActiveStream()
49 vb, in MockActiveStream()
59 vb.getManifest()) { in MockActiveStream()
63 std::vector<queued_item> public_getOutstandingItems(VBucket& vb) { in public_getOutstandingItems() argument
64 return getOutstandingItems(vb); in public_getOutstandingItems()
154 virtual std::vector<queued_item> getOutstandingItems(VBucket& vb) override {
156 return ActiveStream::getOutstandingItems(vb);
176 VBucket& vb, in MockActiveStreamWithOverloadedRegisterCursor()
188 vb, in MockActiveStreamWithOverloadedRegisterCursor()
244 uint16_t vb, in MockPassiveStream()
32 MockActiveStream(EventuallyPersistentEngine* e, std::shared_ptr<MockDcpProducer> p, uint32_t flags, uint32_t opaque, VBucket& vb, uint64_t st_seqno, uint64_t en_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, IncludeValue includeValue = IncludeValue::Yes, IncludeXattrs includeXattrs = IncludeXattrs::Yes) MockActiveStream() argument
171 MockActiveStreamWithOverloadedRegisterCursor( EventuallyPersistentEngine* e, std::shared_ptr<MockDcpProducer> p, uint32_t flags, uint32_t opaque, VBucket& vb, uint64_t st_seqno, uint64_t en_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, IncludeValue includeValue = IncludeValue::Yes, IncludeXattrs includeXattrs = IncludeXattrs::Yes) MockActiveStreamWithOverloadedRegisterCursor() argument
239 MockPassiveStream(EventuallyPersistentEngine& e, std::shared_ptr<DcpConsumer> consumer, const std::string& name, uint32_t flags, uint32_t opaque, uint16_t vb, uint64_t start_seqno, uint64_t end_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint64_t vb_high_seqno) MockPassiveStream() argument
[all...]
/5.5.2/testrunner/pytests/clitest/
H A Dvbuckettooltest.py28 for vb, items in self.keys_per_vbuckets_dict.iteritems():
32 self.assertEqual(str(result[item][0]), str(vb.id),
34 item, vb.id, result[item]))
47 for vb, items in self.keys_per_vbuckets_dict.iteritems():
51 self.assertTrue(result[item][1].startswith(bucket.vbuckets[vb].master),
53 item, bucket.vbuckets[vb].master, result[item]))
56 set(bucket.vbuckets[vb].replica),
58 item, bucket.vbuckets[vb].replica, result[item]))
70 for vb in bucket.vbuckets:
71 self.keys_per_vbuckets_dict[vb]
[all...]

Completed in 57 milliseconds

12345678