Home
last modified time | relevance | path

Searched defs:vb (Results 1 - 25 of 36) sorted by relevance

12

/3.0.3-GA/ep-engine/src/
H A Dhtresizer.cc34 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
H A Dcheckpoint_remover.cc39 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
H A Dkvstore.cc54 RCPtr<VBucket> vb = engine_.getVBucket(itm->getVBucketId()); in callback() local
H A Dkvshard.cc78 void KVShard::setBucket(const RCPtr<VBucket> &vb) { in setBucket() argument
H A Daccess_scanner.cc73 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
H A Dbackfill.cc53 RCPtr<VBucket> vb = engine->getEpStore()->getVBucket(lookup.getVBucketId()); in callback() local
145 bool BackFillVisitor::visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
[all...]
H A Dbgfetcher.cc115 RCPtr<VBucket> vb = store->getVBuckets().getBucket(vbId); in clearItems() local
154 RCPtr<VBucket> vb = shard->getBucket(vbId); in run() local
181 RCPtr<VBucket> vb = shard->getBucket(vbIds[i]); in pendingJob() local
[all...]
H A Dflusher.cc257 RCPtr<VBucket> vb = store->getVBucket(*itr); in flushVB() local
H A Dcallbacks.h49 CacheLookup(std::string k, int64_t s, uint16_t vb) : in CacheLookup() argument
H A Dconnmap.h86 CompletedBGFetchTapOperation(hrtime_t token, uint16_t vb, bool ie=false) : in CompletedBGFetchTapOperation() argument
H A Ditem_pager.cc94 bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
[all...]
H A Dkvstore.h238 virtual void getMulti(uint16_t vb, vb_bgfetch_queue_t &itms) { in getMulti() argument
H A Ddcp-consumer.cc105 RCPtr<VBucket> vb = engine_.getVBucket(vbucket); in addStream() local
520 RCPtr<VBucket> vb = engine_.getVBucket(vbid); doRollback() local
642 RCPtr<VBucket> vb = engine_.getVBucket(vbucket); streamAccepted() local
[all...]
H A Ddcp-producer.cc104 RCPtr<VBucket> vb = engine_.getVBucket(vbucket); in streamRequest() local
215 RCPtr<VBucket> vb = engine_.getVBucket(vbucket); getFailoverLog() local
[all...]
H A Ditem.h339 Item(const std::string &k, const uint16_t vb, in Item() argument
H A Dconnmap.cc872 RCPtr<VBucket> vb = vbuckets.getBucket(vbid); in removeTapCursors_UNLOCKED() local
H A Ddcp-stream.cc75 RCPtr<VBucket> vb = engine_->getEpStore()->getVBucket(lookup.getVBucketId()); in callback() local
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 Dep.h69 virtual bool visitBucket(RCPtr<VBucket> &vb) { in visitBucket() argument
470 uint64_t getLastPersistedCheckpointId(uint16_t vb) { in getLastPersistedCheckpointId() argument
474 uint64_t getLastPersistedSeqno(uint16_t vb) { in getLastPersistedSeqno() argument
648 incExpirationStat(RCPtr<VBucket> &vb, bool byPager = true) incExpirationStat() argument
793 RCPtr<VBucket> vb = getVBucket(vbid); invokeOnLockedStoredValue() local
[all...]
H A Dmutation_log.h570 void setVBucket(uint16_t vb) { in setVBucket() argument
206 newEntry(uint8_t *buf, uint64_t r, mutation_log_type_t t, uint16_t vb, const std::string &k) newEntry() argument
279 MutationLogEntry(uint64_t r, mutation_log_type_t t, uint16_t vb, const std::string &k) MutationLogEntry() argument
/3.0.3-GA/moxi/vbucket/
H A Dvbuckettool.c24 VBUCKET_CONFIG_HANDLE vb = NULL; in main() local
[all...]
H A Dvbucketkeygen.c27 VBUCKET_CONFIG_HANDLE vb = NULL; in main() local
/3.0.3-GA/ep-engine/tests/module_tests/
H A Dmutation_log_test.cc116 static void loaderFun(void *arg, uint16_t vb, in loaderFun() argument
H A Dtiming_tests.cc88 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) storeCasVb11() argument
/3.0.3-GA/moxi/tests/vbucket/
H A Dtestketama.c40 VBUCKET_CONFIG_HANDLE vb; in main() local
H A Dtestapp.c74 VBUCKET_CONFIG_HANDLE vb = vbucket_config_parse_file(configPath(fname)); in testConfig() local
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...]

Completed in 59 milliseconds

12