/5.5.2/kv_engine/engines/ep/src/ |
H A D | vb_count_visitor.cc | 22 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 D | ep_bucket.cc | 41 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 D | kv_bucket.cc | 205 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 D | kvshard.cc | 83 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 D | vb_visitors.cc | 27 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 D | checkpoint_remover.cc | 49 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 D | vbucketmap.cc | 52 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 D | vbucket.c | 89 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 D | vbuckettool.c | 24 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 D | testapp.c | 75 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 D | protobuf_test.go | 39 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 D | evp_store_collections_eraser_test.cc | 30 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 D | evp_store_collections_test.cc | 43 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 D | evp_store_collections_dcp_test.cc | 59 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 D | ephemeral_bucket_test.cc | 30 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 D | checkpoint_remover_test.cc | 27 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 D | checkpoints.py | 19 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 D | mutation.go | 74 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 D | ClientIface.go | 14 // 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 D | observe.go | 38 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 D | manager.cc | 58 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 D | upr.go | 50 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 D | mc.go | 21 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 D | mock_stream.h | 36 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 D | vbuckettooltest.py | 28 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...] |