Home
last modified time | relevance | path

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

123

/3.0.3-GA/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
198 get_node_authority(struct vbucket_config_st *vb, cJSON *node, char **out, size_t nbuf) get_node_authority() argument
239 lookup_server_struct(struct vbucket_config_st *vb, cJSON *c) lookup_server_struct() argument
264 update_server_info(struct vbucket_config_st *vb, cJSON *config) update_server_info() argument
315 populate_buckets(struct vbucket_config_st *vb, cJSON *c, int is_forward) populate_buckets() argument
352 parse_vbucket_config(VBUCKET_CONFIG_HANDLE vb, cJSON *c) parse_vbucket_config() argument
435 parse_ketama_config(VBUCKET_CONFIG_HANDLE vb, cJSON *config) parse_ketama_config() argument
671 vbucket_map(VBUCKET_CONFIG_HANDLE vb, const void *key, size_t nkey, int *vbucket_id, int *server_idx) vbucket_map() argument
728 vbucket_config_get_num_replicas(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_replicas() argument
732 vbucket_config_get_num_vbuckets(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_vbuckets() argument
736 vbucket_config_get_num_servers(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_num_servers() argument
740 vbucket_config_get_couch_api_base(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_couch_api_base() argument
744 vbucket_config_get_rest_api_server(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_rest_api_server() argument
748 vbucket_config_is_config_node(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_is_config_node() argument
752 vbucket_config_get_distribution_type(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_distribution_type() argument
756 vbucket_config_get_server(VBUCKET_CONFIG_HANDLE vb, int i) vbucket_config_get_server() argument
760 vbucket_config_get_user(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_user() argument
764 vbucket_config_get_password(VBUCKET_CONFIG_HANDLE vb) vbucket_config_get_password() argument
768 vbucket_get_vbucket_by_key(VBUCKET_CONFIG_HANDLE vb, const void *key, size_t nkey) vbucket_get_vbucket_by_key() argument
776 vbucket_get_master(VBUCKET_CONFIG_HANDLE vb, int vbucket) vbucket_get_master() argument
780 vbucket_get_replica(VBUCKET_CONFIG_HANDLE vb, int vbucket, int i) vbucket_get_replica() argument
789 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...]
H A Dvbucketkeygen.c27 VBUCKET_CONFIG_HANDLE vb = NULL; in main() local
59 vb = vbucket_config_parse_string(buf); in main()
61 vb = vbucket_config_parse_file(argv[1]); in main()
64 if (vb == NULL) { in main()
72 num_vbuckets = vbucket_config_get_num_vbuckets(vb); in main()
89 v = vbucket_get_vbucket_by_key(vb, key, strlen(key)); in main()
116 vbucket_config_destroy(vb); in main()
/3.0.3-GA/moxi/tests/vbucket/
H A Dtestapp.c74 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); in testConfig() local
75 if (vb == NULL) { in testConfig()
82 int id = vbucket_get_vbucket_by_key(vb, k->key, strlen(k->key)); in testConfig()
94 assert(vbucket_config_get_num_servers(vb) == 3 || vbucket_config_get_num_servers(vb) == 4); in testConfig()
95 assert(vbucket_config_get_num_replicas(vb) == 2); in testConfig()
98 assert(strcmp(vbucket_config_get_server(vb, i), servers[i]) == 0); in testConfig()
102 assert(vbucket_get_master(vb, i) == vbuckets[i].master); in testConfig()
103 assert(vbucket_get_replica(vb, i, 0) == vbuckets[i].replicas[0]); in testConfig()
104 assert(vbucket_get_replica(vb, in testConfig()
115 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); testWrongServer() local
141 VBUCKET_CONFIG_HANDLE vb = vbucket_config_create(); testWrongNumVbuckets() local
150 VBUCKET_CONFIG_HANDLE vb = vbucket_config_create(); testZeroNumVbuckets() local
159 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); testWrongServerFFT() local
294 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath("config-couch-api-base")); testConfigCouchApiBase() local
[all...]
H A Dtestketama.c40 VBUCKET_CONFIG_HANDLE vb; in main() local
49 vb = vbucket_config_create(); in main()
50 assert(vbucket_config_parse(vb, LIBVBUCKET_SOURCE_FILE, buffer) == 0); in main()
59 vbucket_map(vb, key, len, NULL, &idx); in main()
60 host = vbucket_config_get_server(vb, idx); in main()
69 vbucket_config_destroy(vb); in main()
/3.0.3-GA/ep-engine/src/
H A Dep.cc142 RCPtr<VBucket> &vb, double delay) : in VBucketMemoryDeletionTask()
145 e(eng), vbucket(vb), vbid(vb->getId()) { } in VBucketMemoryDeletionTask()
168 PendingOpsNotification(EventuallyPersistentEngine &e, RCPtr<VBucket> &vb) : in PendingOpsNotification() argument
170 engine(e), vbucket(vb) { } in PendingOpsNotification()
471 RCPtr<VBucket> vb = vbMap.getBucket(vbid); in getVBucket() local
472 vbucket_state_t found_state(vb ? vb->getState() : vbucket_state_dead); in getVBucket()
474 return vb; in getVBucket()
485 RCPtr<VBucket> vb in deleteExpiredItem() local
141 VBucketMemoryDeletionTask(EventuallyPersistentEngine &eng, RCPtr<VBucket> &vb, double delay) VBucketMemoryDeletionTask() argument
530 fetchValidValue(RCPtr<VBucket> &vb, const std::string &key, int bucket_num, bool wantDeleted, bool trackReference, bool queueExpired) fetchValidValue() argument
561 RCPtr<VBucket> vb = getVBucket(vbucket); evictKey() local
599 addTempItemForBgFetch( LockHolder &lock, int bucket_num, const std::string &key, RCPtr<VBucket> &vb, const void *cookie, bool metadataOnly, bool isReplication) addTempItemForBgFetch() argument
632 RCPtr<VBucket> vb = getVBucket(itm.getVBucketId()); set() local
703 RCPtr<VBucket> vb = getVBucket(itm.getVBucketId()); add() local
748 RCPtr<VBucket> vb = getVBucket(itm.getVBucketId()); replace() local
824 RCPtr<VBucket> vb = getVBucket(itm.getVBucketId()); addTAPBackfillItem() local
878 RCPtr<VBucket> vb = epstore->getVBucket(ctx.vbucket); callback() local
896 visitBucket(RCPtr<VBucket> &vb) snapshotVBuckets() argument
969 RCPtr<VBucket> vb = getVBucket(vbid); persistVBState() local
1022 RCPtr<VBucket> vb = vbMap.getBucket(vbid); setVBucketState() local
1127 RCPtr<VBucket> vb = vbMap.getBucket(vbid); completeVBucketDeletion() local
1151 scheduleVBDeletion(RCPtr<VBucket> &vb, const void* cookie, double delay) scheduleVBDeletion() argument
1170 RCPtr<VBucket> vb = vbMap.getBucket(vbid); deleteVBucket() local
1188 RCPtr<VBucket> vb = vbMap.getBucket(vbid); compactDB() local
1243 RCPtr<VBucket> vb = vbMap.getBucket(vbid); compactVBucket() local
1301 RCPtr<VBucket> vb = vbMap.getBucket(vbid); resetVBucket() local
1407 RCPtr<VBucket> vb = getVBucket(vbucket); completeBGFetch() local
1484 RCPtr<VBucket> vb = getVBucket(vbId); completeBGFetchMulti() local
1587 RCPtr<VBucket> vb = getVBucket(vbucket); bgFetch() local
1626 RCPtr<VBucket> vb = getVBucket(vbucket); getInternal() local
1686 RCPtr<VBucket> vb = getVBucket(curr++); getRandomKey() local
1726 RCPtr<VBucket> vb = getVBucket(vbucket); getMetaData() local
1783 RCPtr<VBucket> vb = getVBucket(itm.getVBucketId()); setWithMeta() local
1865 RCPtr<VBucket> vb = getVBucket(vbucket); getAndUpdateTtl() local
1932 RCPtr<VBucket> vb = getVBucket(vbucket); statsVKey() local
1998 RCPtr<VBucket> vb = getVBucket(vbid); completeStatsVKey() local
2037 RCPtr<VBucket> vb = getVBucket(vbucket, vbucket_state_active); getLocked() local
2106 RCPtr<VBucket> vb = getVBucket(vbucket, vbucket_state_active); unlockKey() local
2152 RCPtr<VBucket> vb = getVBucket(vbucket); getKeyStats() local
2197 RCPtr<VBucket> vb = getVBucket(vbucket); validateKey() local
2231 RCPtr<VBucket> vb = getVBucket(vbucket); deleteItem() local
2343 RCPtr<VBucket> vb = getVBucket(vbucket); deleteWithMeta() local
2438 RCPtr<VBucket> vb = getVBucket(*it); reset() local
2467 PersistenceCallback(const queued_item &qi, RCPtr<VBucket> &vb, EventuallyPersistentStore *st, EPStats *s, uint64_t c) PersistenceCallback() argument
2620 RCPtr<VBucket> vb = getVBucket(i); flushOneDeleteAll() local
2650 RCPtr<VBucket> vb = vbMap.getBucket(vbid); flushVBucket() local
2774 flushOneDelOrSet(const queued_item &qi, RCPtr<VBucket> &vb) flushOneDelOrSet() argument
2823 queueDirty(RCPtr<VBucket> &vb, StoredValue* v, LockHolder *plh, bool tapBackfill, bool notifyReplicator, bool genBySeqno) queueDirty() argument
3075 RCPtr<VBucket> vb = vbMap.getBucket(vbid); visit() local
3098 RCPtr<VBucket> vb = store->vbMap.getBucket(vbid); VBCBAdaptor() local
3108 RCPtr<VBucket> vb = store->vbMap.getBucket(currentvb); run() local
3143 RCPtr<VBucket> vb = store->vbMap.getBucket(vbid); VBucketVisitorTask() local
3153 RCPtr<VBucket> vb = store->vbMap.getBucket(currentvb); run() local
3239 RCPtr<VBucket> vb = vbMap.getBucket(vbid); rollback() local
[all...]
H A Ddcp-stream.cc75 RCPtr<VBucket> vb = engine_->getEpStore()->getVBucket(lookup.getVBucketId()); in callback() local
76 if (!vb) { in callback()
82 LockHolder lh = vb->ht.getLockedBucket(lookup.getKey(), &bucket_num); in callback()
83 StoredValue *v = vb->ht.unlocked_find(lookup.getKey(), bucket_num, false, false); in callback()
172 LOG(EXTENSION_LOG_WARNING, "Backfill task (%llu to %llu) finished for vb %d" in run()
186 uint16_t vb, uint64_t start_seqno, uint64_t end_seqno, in Stream()
189 : name_(name), flags_(flags), opaque_(opaque), vb_(vb), in Stream()
236 uint32_t opaque, uint16_t vb, uint64_t st_seqno, in ActiveStream()
239 : Stream(n, flags, opaque, vb, st_seqno, en_seqno, vb_uuid, in ActiveStream()
260 LOG(EXTENSION_LOG_WARNING, "%s (vb in ActiveStream()
185 Stream(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) Stream() argument
234 ActiveStream(EventuallyPersistentEngine* e, DcpProducer* p, const std::string &n, uint32_t flags, uint32_t opaque, uint16_t vb, uint64_t st_seqno, uint64_t en_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno) ActiveStream() argument
318 RCPtr<VBucket> vb = engine->getVBucket(vb_); markDiskSnapshot() local
500 RCPtr<VBucket> vb = engine->getVBucket(vb_); addTakeoverStats() local
762 RCPtr<VBucket> vb = engine->getVBucket(vb_); transitionState() local
791 NotifierStream(EventuallyPersistentEngine* e, DcpProducer* p, const std::string &name, uint32_t flags, uint32_t opaque, uint16_t vb, uint64_t st_seqno, uint64_t en_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno) NotifierStream() argument
880 PassiveStream(EventuallyPersistentEngine* e, DcpConsumer* c, const std::string &name, uint32_t flags, uint32_t opaque, uint16_t vb, uint64_t st_seqno, uint64_t en_seqno, uint64_t vb_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno) PassiveStream() argument
935 reconnectStream(RCPtr<VBucket> &vb, uint32_t new_opaque, uint64_t start_seqno) reconnectStream() argument
1049 RCPtr<VBucket> vb = engine->getVBucket(vb_); processMutation() local
1097 RCPtr<VBucket> vb = engine->getVBucket(vb_); processDeletion() local
1146 RCPtr<VBucket> vb = engine->getVBucket(vb_); processMarker() local
1186 handleSnapshotEnd(RCPtr<VBucket>& vb, uint64_t byseqno) handleSnapshotEnd() argument
[all...]
H A Dcheckpoint_remover.cc39 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
40 currentBucket = vb; in visitBucket()
42 removed = vb->checkpointManager.removeClosedUnrefCheckpoints(vb, in visitBucket()
48 vb->getId()); in visitBucket()
50 vb->getId(), in visitBucket()
51 vb->checkpointManager.getHighSeqno()); in visitBucket()
H A Dwarmup.cc97 static bool warmupCallback(void *arg, uint16_t vb, in warmupCallback() argument
104 cookie->epstore->getROUnderlying(vb)->get(key, rowid, vb, cb); in warmupCallback()
112 "for vBucket = %d key = %s error = %X\n", vb, key.c_str(), in warmupCallback()
214 RCPtr<VBucket> vb = vbuckets.getBucket(i->getVBucketId()); in callback() local
215 if (!vb) { in callback()
222 switch (vb->ht.insert(*i, policy, shouldEject(), in callback()
243 if (vb->getShard()->getROUnderlying()->isKeyDumpSupported()) { in callback()
328 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); in purge() local
329 if (vb in purge()
339 RCPtr<VBucket> vb = vbuckets.getBucket(lookup.getVBucketId()); callback() local
456 RCPtr<VBucket> vb = store->getVBucket(vbid); createVBuckets() local
517 RCPtr<VBucket> vb = store->getVBucket(*it); estimateDatabaseItemCount() local
[all...]
H A Dbackfill.cc53 RCPtr<VBucket> vb = engine->getEpStore()->getVBucket(lookup.getVBucketId()); in callback() local
54 if (!vb) { in callback()
60 LockHolder lh = vb->ht.getLockedBucket(lookup.getKey(), &bucket_num); in callback()
61 StoredValue *v = vb->ht.unlocked_find(lookup.getKey(), bucket_num); in callback()
141 rv << "Loading TAP backfill from disk: vb " << vbucket; in getDescription()
145 bool BackFillVisitor::visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
146 if (VBucketVisitor::visitBucket(vb)) { in visitBucket()
149 double num_items = static_cast<double>(vb->getNumItems(policy)); in visitBucket()
156 getROUnderlying(vb->getId())); in visitBucket()
158 "Schedule a full backfill from disk for vbucket %d.", vb in visitBucket()
[all...]
H A Ditem_pager.cc94 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
98 size_t removed = vb->checkpointManager.removeClosedUnrefCheckpoints(vb, in visitBucket()
105 vb->getId()); in visitBucket()
107 vb->getId(), in visitBucket()
108 vb->checkpointManager.getHighSeqno()); in visitBucket()
113 return VBucketVisitor::visitBucket(vb); in visitBucket()
120 if (vb->getState() == vbucket_state_active && current < high && in visitBucket()
129 adjustPercent(p, vb->getState()); in visitBucket()
130 return VBucketVisitor::visitBucket(vb); in visitBucket()
[all...]
H A Dep.h65 * @param vb the vbucket we are beginning to visit
69 virtual bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
70 if (vBucketFilter(vb->getId())) { in visitBucket()
71 currentBucket = vb; in visitBucket()
125 rv << label << " on vb " << currentvb; in getDescription()
155 rv << label << " on vb " << currentvb; in getDescription()
470 uint64_t getLastPersistedCheckpointId(uint16_t vb) { in getLastPersistedCheckpointId() argument
471 return vbMap.getPersistenceCheckpointId(vb); in getLastPersistedCheckpointId()
474 uint64_t getLastPersistedSeqno(uint16_t vb) { in getLastPersistedSeqno() argument
475 return vbMap.getPersistenceSeqno(vb); in getLastPersistedSeqno()
648 incExpirationStat(RCPtr<VBucket> &vb, bool byPager = true) incExpirationStat() argument
793 RCPtr<VBucket> vb = getVBucket(vbid); invokeOnLockedStoredValue() local
[all...]
H A Dbgfetcher.cc79 "Warning: bgfetcher failed to fetch data for vb = %d " in doFetch()
115 RCPtr<VBucket> vb = store->getVBuckets().getBucket(vbId); in clearItems() local
116 cb_assert(vb); in clearItems()
119 "request for vb = %d key = %s retry = %d\n", in clearItems()
121 vb->queueBGFetchItem((*itr).first, *dItr, this); in clearItems()
154 RCPtr<VBucket> vb = shard->getBucket(vbId); in run() local
155 if (vb && vb->getBGFetchItems(items2fetch)) { in run()
181 RCPtr<VBucket> vb = shard->getBucket(vbIds[i]); in pendingJob() local
182 if (vb in pendingJob()
[all...]
H A Dkvstore.cc54 RCPtr<VBucket> vb = engine_.getVBucket(itm->getVBucketId()); in callback() local
67 LockHolder lh = vb->ht.getLockedBucket(it->getKey(), in callback()
69 bool ret = vb->ht.unlocked_del(it->getKey(), bucket_num); in callback()
76 mutation_type_t mtype = vb->ht.set(*it, it->getCas(), in callback()
87 LockHolder lh = vb->ht.getLockedBucket(itm->getKey(), &bucket_num); in callback()
88 bool ret = vb->ht.unlocked_del(itm->getKey(), bucket_num); in callback()
H A Dtapconnection.cc420 RCPtr<VBucket> vb = vbMap.getBucket(*it); in setVBucketFilter() local
421 if (vb) { in setVBucketFilter()
422 vb->checkpointManager.removeTAPCursor(getName()); in setVBucketFilter()
1030 void TapProducer::queueBGFetch_UNLOCKED(const std::string &key, uint64_t id, uint16_t vb) { in queueBGFetch_UNLOCKED() argument
1031 ExTask task = new BGFetchCallback(&engine(), getName(), key, vb, id, in queueBGFetch_UNLOCKED()
1036 std::map<uint16_t, CheckpointState>::iterator it = checkpointState_.find(vb); in queueBGFetch_UNLOCKED()
1221 RCPtr<VBucket> vb = vbuckets.getBucket(vbid);
1222 if (!vb || (vb->getState() == vbucket_state_dead && !doTakeOver)) {
1232 queued_item qi = vb
1324 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); getRemainingOnCheckpoints_UNLOCKED() local
1339 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); hasNextFromCheckpoints_UNLOCKED() local
1362 RCPtr<VBucket> vb = vbuckets.getBucket(*vbit); scheduleBackfill_UNLOCKED() local
1375 RCPtr<VBucket> vb = vbuckets.getBucket(*it); scheduleBackfill_UNLOCKED() local
1407 RCPtr<VBucket> vb = engine_.getVBucket(ev.vbucket); checkDumpOrTakeOverCompletion() local
1677 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); registerCursor() local
1966 RCPtr<VBucket> vb = vbuckets.getBucket(vbucket); setBackfillPhase() local
1990 RCPtr<VBucket> vb = vbuckets.getBucket(vbucket); isBackfillPhase() local
2088 RCPtr<VBucket> vb = vbuckets.getBucket(vbucket); checkVBOpenCheckpoint() local
2105 RCPtr<VBucket> vb = vbuckets.getBucket(vbucket); processCheckpointCommand() local
[all...]
H A Dmutation_log.cc855 uint16_t vb(*vit); in load()
859 for (copyit2 = loading[vb].begin(); in load()
860 copyit2 != loading[vb].end(); in load()
867 committed[vb][copyit2->first] = t.first; in load()
870 committed[vb].erase(copyit2->first); in load()
899 uint16_t vb(*it); in apply()
902 committed[vb].begin(); in apply()
903 it2 != committed[vb].end(); ++it2) { in apply()
906 if (!mlc(arg, vb, key, rowid)) { // Stop loading from an access log in apply()
918 uint16_t vb(*i in apply()
[all...]
H A Dhtresizer.cc34 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
35 vb->ht.resize(); in visitBucket()
H A Dep_engine.cc692 RCPtr<VBucket> vb = e->getVBucket(vbucket); in unlockKey() local
693 if (!vb) { in unlockKey()
773 RCPtr<VBucket> vb = e->getVBucket(vbucket); in getVBucket() local
774 if (!vb) { in getVBucket()
783 vbucket_state_t state = (vbucket_state_t)ntohl(vb->getState()); in getVBucket()
823 uint16_t vb = ntohs(req->message.header.request.vbucket); in setVBucket() local
824 if(e->setVBucketState(vb, state, false) == ENGINE_ERANGE) { in setVBucket()
2332 RCPtr<VBucket> vb = getVBucket(*vbucket); in doWalkTapQueue() local
2333 if (!vb) { in doWalkTapQueue()
2338 vb in doWalkTapQueue()
2607 RCPtr<VBucket> vb = getVBucket(vbucket); tapNotify() local
2870 visitBucket(RCPtr<VBucket> &vb) visitBucket() argument
2915 visitBucket(RCPtr<VBucket> &vb) visitBucket() argument
3488 visitBucket(RCPtr<VBucket> &vb) doVBucketStats() argument
3494 addVBStats(const void *cookie, ADD_STAT add_stat, RCPtr<VBucket> &vb, EventuallyPersistentStore *store, bool isPrevStateRequested, bool detailsRequested) doVBucketStats() argument
3528 RCPtr<VBucket> vb = getVBucket(vbucket_id); doVBucketStats() local
3552 visitBucket(RCPtr<VBucket> &vb) doHashStats() argument
3602 visitBucket(RCPtr<VBucket> &vb) visitBucket() argument
3607 addCheckpointStat(const void *cookie, ADD_STAT add_stat, EventuallyPersistentStore *eps, RCPtr<VBucket> &vb) addCheckpointStat() argument
3677 RCPtr<VBucket> vb = getVBucket(vbucket_id); doCheckpointStats() local
4028 RCPtr<VBucket> vb = getVBucket(vbid); doVbIdFailoverLogStats() local
4045 visitBucket(RCPtr<VBucket> &vb) doAllFailoverLogStats() argument
4212 RCPtr<VBucket> vb = getVBucket(vbucket); doSeqnoStats() local
4238 RCPtr<VBucket> vb = getVBucket(*itr); doSeqnoStats() local
4280 visitBucket(RCPtr<VBucket> &vb) doDiskStats() argument
4693 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); deregisterTapClient() local
4713 RCPtr<VBucket> vb = getVBucket(vbucket); handleCheckpointCmds() local
4813 RCPtr<VBucket> vb = getVBucket(vbucket); handleSeqnoCmds() local
5287 RCPtr<VBucket> vb = getVBucket(vbid); doDcpVbTakeoverStats() local
5324 RCPtr<VBucket> vb = getVBucket(vbid); doTapVbTakeoverStats() local
5576 RCPtr<VBucket> vb = getVBucket(vbucket); getAllKeys() local
[all...]
/3.0.3-GA/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...]
/3.0.3-GA/ep-engine/management/
H A Dcbstats179 def stats_key(mc, key, vb):
180 cmd = "key %s %s" % (key, str(vb))
195 def stats_vkey(mc, key, vb):
196 cmd = "vkey %s %s" % (key, str(vb))
211 def stats_tap_takeover(mc, vb, name):
212 cmd = "tap-vbtakeover %s %s" % (str(vb), name)
216 def stats_dcp_takeover(mc, vb, name):
217 cmd = "dcp-vbtakeover %s %s" % (str(vb), name)
250 def stats_checkpoint(mc, vb=-1):
252 vb
[all...]
/3.0.3-GA/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...]
/3.0.3-GA/ep-engine/tests/
H A Dep_test_apis.h109 uint16_t vb, uint32_t exp, bool quiet = false);
111 const char* key, uint16_t vb = 0);
114 void getl(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb,
117 uint16_t vb);
127 uint16_t vb, vbucket_state_t state);
133 uint64_t casIn = 0, uint16_t vb = 0,
139 uint16_t vb, uint32_t exp = 3600,
142 uint16_t vb, uint32_t exp);
144 uint16_t vb, uint64_t cas = 0);
148 uint16_t vb);
[all...]
H A Dep_test_apis.cc224 const uint32_t vb, ItemMetaData *itemMeta, in add_with_meta()
237 pkt = createPacket(PROTOCOL_BINARY_CMD_ADD_WITH_META, vb, 0, ext, blen, key, keylen, in add_with_meta()
252 uint16_t vb = htons(it->first); in changeVBFilter() local
254 value.write((char*) &vb, sizeof(uint16_t)); in changeVBFilter()
279 const size_t keylen, const uint32_t vb, in del_with_meta()
292 pkt = createPacket(PROTOCOL_BINARY_CMD_DEL_WITH_META, vb, cas_for_delete, ext, blen, key, in del_with_meta()
345 uint64_t checkpoint_id, uint16_t vb) { in checkpointPersistence()
348 request = createPacket(PROTOCOL_BINARY_CMD_CHECKPOINT_PERSISTENCE, vb, 0, NULL, 0, NULL, 0, in checkpointPersistence()
369 uint16_t vb, uint32_t exp, bool quiet) { in gat()
375 request = createPacket(opcode, vb, in gat()
222 add_with_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, ItemMetaData *itemMeta, bool skipConflictResolution) add_with_meta() argument
278 del_with_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const uint32_t vb, ItemMetaData *itemMeta, uint64_t cas_for_delete, bool skipConflictResolution) del_with_meta() argument
344 checkpointPersistence(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, uint64_t checkpoint_id, uint16_t vb) checkpointPersistence() argument
368 gat(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb, uint32_t exp, bool quiet) gat() argument
382 get_item_info(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, item_info *info, const char* key, uint16_t vb) get_item_info() argument
413 getl(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb, uint32_t lock_timeout) getl() argument
444 uint16_t vb = htons(it->second); observe() local
505 set_vbucket_state(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, uint16_t vb, vbucket_state_t state) set_vbucket_state() argument
521 set_with_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, ItemMetaData *itemMeta, uint64_t cas_for_set, bool skipConflictResolution, uint8_t datatype) set_with_meta() argument
544 return_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, const uint32_t type, uint8_t datatype) return_meta() argument
560 set_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, uint8_t datatype) set_ret_meta() argument
568 add_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const char *val, const size_t vallen, const uint32_t vb, const uint64_t cas, const uint32_t flags, const uint32_t exp, uint8_t datatype) add_ret_meta() argument
576 del_ret_meta(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char *key, const size_t keylen, const uint32_t vb, const uint64_t cas) del_ret_meta() argument
626 store(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const void *cookie, ENGINE_STORE_OPERATION op, const char *key, const char *value, item **outitem, uint64_t casIn, uint16_t vb, uint32_t exp, uint8_t datatype) store() argument
635 storeCasVb11(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const void *cookie, ENGINE_STORE_OPERATION op, const char *key, const char *value, size_t vlen, uint32_t flags, item **outitem, uint64_t casIn, uint16_t vb, uint32_t exp, uint8_t datatype) storeCasVb11() argument
670 touch(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb, uint32_t exp) touch() argument
683 unl(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, const char* key, uint16_t vb, uint64_t cas) unl() argument
715 vbucketDelete(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, uint16_t vb, const char* args) vbucketDelete() argument
735 verify_vbucket_missing(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, uint16_t vb) verify_vbucket_missing() argument
756 verify_vbucket_state(ENGINE_HANDLE *h, ENGINE_HANDLE_V1 *h1, uint16_t vb, vbucket_state_t expected, bool mute) verify_vbucket_state() argument
[all...]
/3.0.3-GA/ns_server/scripts/
H A Dvisualize-rebalance-2.rb39 vb = ev["vbucket"]
40 raise if $vbucket_to_move_start[vb]
41 $vbucket_to_move_start[vb] = ev
48 if (vb = ev["vbucket"])
49 arr = ($vbucket_to_events[vb] ||= [])
52 ev["vbuckets"].each do |vb|
53 arr = ($vbucket_to_events[vb] ||= [])
106 $vbucket_to_events.sort_by {|(_, evs)| evs[0]["ts"]}.each_with_index do |(vb, events), idx|
125 img.text(($width_per_vbucket + 1) * idx - 50, ts_to_y(start_at) + 2, vb.to_s, "font-size" => "20px")
171 # puts "seen takeover for vb #{v
[all...]
/3.0.3-GA/testrunner/lib/couchbase_helper/
H A Ddata_analysis_helper.py538 vb = tokens[0]
543 vb = tokens[0]
546 if vb in map_data.keys() and (num == num_map[vb] or num > num_map[vb]):
547 map_data[vb][key] = value[0]
548 num_map[vb] = num
549 elif vb in map_data.keys() and key == "num_entries":
550 map_data[vb][key] = value[0]
551 elif vb no
[all...]

Completed in 95 milliseconds

123