Home
last modified time | relevance | path

Searched defs:vbucket (Results 1 - 25 of 45) sorted by relevance

12

/3.0.3-GA/testrunner/lib/perf_engines/libobserve/
H A Dobs_req.py9 vbucket = 0x0000 variable in ObserveRequestKey
43 vbucket = 0x0000 variable in ObserveRequest
[all...]
/3.0.3-GA/ep-engine/src/
H A Dbackfill.cc141 rv << "Loading TAP backfill from disk: vb " << vbucket; in getDescription() local
H A Dbackfill.h72 uint16_t vbucket; member in BackfillDiskLoad
H A Ddcp-response.h70 StreamRequest(uint16_t vbucket, uint32_t opaque, uint32_t flags, in StreamRequest() argument
191 StreamEndResponse(uint32_t opaque, uint32_t flags, uint16_t vbucket) in StreamEndResponse() argument
216 SetVBucketState(uint32_t opaque, uint16_t vbucket, vbucket_state_t state) in SetVBucketState() argument
241 SnapshotMarker(uint32_t opaque, uint16_t vbucket, uint64_t start_seqno, in SnapshotMarker() argument
H A Dtasks.h237 VBStatePersistTask(EventuallyPersistentEngine *e, const Priority &p, uint16_t vbucket, bool completeBeforeShutdown = true) VBStatePersistTask() argument
287 CompactVBucketTask(EventuallyPersistentEngine *e, const Priority &p, uint16_t vbucket, compaction_ctx c, const void *ck, bool completeBeforeShutdown = true) CompactVBucketTask() argument
369 <<vbucket; getDescription() local
375 uint16_t vbucket; global() member in VKeyStatBGFetchTask
395 ss << "Fetching item from disk: " << key<<" vbucket "<<vbucket; getDescription() local
401 uint16_t vbucket; global() member in BGFetchTask
[all...]
H A Dcheckpoint.h335 CheckpointManager(EPStats &st, uint16_t vbucket, CheckpointConfig &config, in CheckpointManager() argument
[all...]
H A Ddcp-consumer.cc98 ENGINE_ERROR_CODE DcpConsumer::addStream(uint32_t opaque, uint16_t vbucket, in addStream() argument
145 closeStream(uint32_t opaque, uint16_t vbucket) closeStream() argument
168 streamEnd(uint32_t opaque, uint16_t vbucket, uint32_t flags) streamEnd() argument
199 mutation(uint32_t opaque, const void* key, uint16_t nkey, const void* value, uint32_t nvalue, uint64_t cas, uint16_t vbucket, uint32_t flags, uint8_t datatype, uint32_t locktime, uint64_t bySeqno, uint64_t revSeqno, uint32_t exptime, uint8_t nru, const void* meta, uint16_t nmeta) mutation() argument
238 deletion(uint32_t opaque, const void* key, uint16_t nkey, uint64_t cas, uint16_t vbucket, uint64_t bySeqno, uint64_t revSeqno, const void* meta, uint16_t nmeta) deletion() argument
271 expiration(uint32_t opaque, const void* key, uint16_t nkey, uint64_t cas, uint16_t vbucket, uint64_t bySeqno, uint64_t revSeqno, const void* meta, uint16_t nmeta) expiration() argument
280 snapshotMarker(uint32_t opaque, uint16_t vbucket, uint64_t start_seqno, uint64_t end_seqno, uint32_t flags) snapshotMarker() argument
316 flush(uint32_t opaque, uint16_t vbucket) flush() argument
324 setVBucketState(uint32_t opaque, uint16_t vbucket, vbucket_state_t state) setVBucketState() argument
585 uint16_t vbucket = ready.front(); getNextItem() local
617 notifyStreamReady(uint16_t vbucket) notifyStreamReady() argument
636 uint16_t vbucket = oitr->second.second; streamAccepted() local
664 isValidOpaque(uint32_t opaque, uint16_t vbucket) isValidOpaque() argument
[all...]
H A Ddcp-producer.cc89 streamRequest(uint32_t flags, uint32_t opaque, uint16_t vbucket, uint64_t start_seqno, uint64_t end_seqno, uint64_t vbucket_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint64_t *rollback_seqno, dcp_add_failover_log callback) streamRequest() argument
208 getFailoverLog(uint32_t opaque, uint16_t vbucket, dcp_add_failover_log callback) getFailoverLog() argument
326 bufferAcknowledgement(uint32_t opaque, uint16_t vbucket, uint32_t buffer_bytes) bufferAcknowledgement() argument
443 closeStream(uint32_t opaque, uint16_t vbucket) closeStream() argument
531 notifySeqnoAvailable(uint16_t vbucket, uint64_t seqno) notifySeqnoAvailable() argument
541 vbucketStateChanged(uint16_t vbucket, vbucket_state_t state) vbucketStateChanged() argument
589 uint16_t vbucket = ready.front(); getNextItem() local
645 notifyStreamReady(uint16_t vbucket, bool schedule) notifyStreamReady() argument
[all...]
H A Dmutation_log.cc296 void MutationLog::newItem(uint16_t vbucket, const std::string &key, in newItem() argument
306 void MutationLog::delItem(uint16_t vbucket, const std::string &key) { in delItem() argument
315 void MutationLog::deleteAll(uint16_t vbucket) { in deleteAll() argument
919 RCPtr<VBucket> vbucket = engine->getEpStore()->getVBucket(vb); apply() local
[all...]
H A Dvbucket.h110 bool addVBucket(uint16_t vbucket) { in addVBucket() argument
115 void removeVBucket(uint16_t vbucket) { in removeVBucket() argument
143 uint16_t vbucket; member
[all...]
H A Dconnmap.cc1012 void DcpConnMap::vbucketStateChanged(uint16_t vbucket, vbucket_state_t state) { in vbucketStateChanged() argument
H A Ddcp-stream.cc386 RCPtr<VBucket> vbucket = engine->getVBucket(vb_); in setVBucketStateAckRecieved() local
559 RCPtr<VBucket> vbucket = engine->getVBucket(vb_); in nextCheckpointItem() local
670 RCPtr<VBucket> vbucket in scheduleBackfill() local
770 RCPtr<VBucket> vbucket = engine->getVBucket(vb_); getItemsRemaining() local
801 RCPtr<VBucket> vbucket = e->getVBucket(vb_); NotifierStream() local
[all...]
H A Dep.h239 GetValue get(const std::string &key, uint16_t vbucket, in get() argument
258 getReplica(const std::string &key, uint16_t vbucket, const void *cookie, bool queueBG=true) getReplica() argument
[all...]
H A Dmutation_log.h263 uint16_t vbucket() const { in vbucket() function in MutationLogEntry
551 uint16_t vbucket; member
/3.0.3-GA/memcached/engines/default_engine/
H A Ditems.h200 uint16_t vbucket; member
/3.0.3-GA/memcached/extensions/protocol/
H A Dfragment_rw.c94 uint16_t vbucket; in handle_fragment_rw() local
44 create_object(ENGINE_HANDLE_V1 *v1, ENGINE_HANDLE *v, const void *cookie, const item_info *org, uint16_t vbucket, const void *data, uint64_t offset, uint64_t len, uint64_t *cas, uint8_t datatype) create_object() argument
/3.0.3-GA/moxi/src/
H A Dcproxy_multiget.c175 int vbucket = -1; in multiget_ascii_downstream() local
81 multiget_ascii_downstream(downstream *d, conn *uc, int (*emit_start)(conn *c, char *cmd, int cmd_len), int (*emit_skey)(conn *c, char *skey, int skey_len, int vbucket, int key_index), int (*emit_end)(conn *c), mcache *front_cache) multiget_ascii_downstream() argument
H A Dcproxy_protocol_b2b.c145 int vbucket = -1; in b2b_forward_item() local
201 b2b_forward_item_vbucket(conn *uc, downstream *d, item *it, conn *c, int vbucket) b2b_forward_item_vbucket() argument
502 int vbucket; cproxy_process_b2b_downstream_nread() local
[all...]
H A Dcproxy_protocol_a2a.c428 int a2a_multiget_skey(conn *c, char *skey, int skey_length, int vbucket, int key_index) { in a2a_multiget_skey() argument
H A Dcproxy_protocol_a2b.c1163 int vbucket = -1; in cproxy_forward_a2b_simple_downstream() local
1438 int a2b_multiget_skey(conn *c, char *skey, int skey_length, int vbucket, in argument
1604 int vbucket = -1; cproxy_forward_a2b_item_downstream() local
1809 int vbucket; a2b_not_my_vbucket() local
1861 int vbucket = -1; a2b_not_my_vbucket() local
[all...]
H A Dmcs.c136 mcs_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) mcs_key_hash() argument
147 mcs_server_invalid_vbucket(mcs_st *ptr, int server_index, int vbucket) mcs_server_invalid_vbucket() argument
285 lvb_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) lvb_key_hash() argument
303 lvb_server_invalid_vbucket(mcs_st *ptr, int server_index, int vbucket) lvb_server_invalid_vbucket() argument
414 lmc_key_hash(mcs_st *ptr, const char *key, size_t key_length, int *vbucket) lmc_key_hash() argument
[all...]
/3.0.3-GA/moxi/tests/vbucket/
H A Dtestapp.c14 int vbucket; member
/3.0.3-GA/ep-engine/tests/module_tests/
H A Dcheckpoint_test.cc53 RCPtr<VBucket> vbucket; member
[all...]
/3.0.3-GA/ep-engine/tests/mock/
H A Dmock_dcp.cc71 mock_get_failover_log(const void *cookie, uint32_t opaque, uint16_t vbucket) mock_get_failover_log() argument
81 mock_stream_req(const void *cookie, uint32_t opaque, uint16_t vbucket, uint32_t flags, uint64_t start_seqno, uint64_t end_seqno, uint64_t vbucket_uuid, uint64_t snap_start_seqno, uint64_t snap_end_seqno) mock_stream_req() argument
131 mock_stream_end(const void *cookie, uint32_t opaque, uint16_t vbucket, uint32_t flags) mock_stream_end() argument
145 mock_marker(const void *cookie, uint32_t opaque, uint16_t vbucket, uint64_t snap_start_seqno, uint64_t snap_end_seqno, uint32_t flags) mock_marker() argument
163 mock_mutation(const void* cookie, uint32_t opaque, item *itm, uint16_t vbucket, uint64_t by_seqno, uint64_t rev_seqno, uint32_t lock_time, const void *meta, uint16_t nmeta, uint8_t nru) mock_mutation() argument
190 mock_deletion(const void* cookie, uint32_t opaque, const void *key, uint16_t nkey, uint64_t cas, uint16_t vbucket, uint64_t by_seqno, uint64_t rev_seqno, const void *meta, uint16_t nmeta) mock_deletion() argument
215 mock_expiration(const void* cookie, uint32_t opaque, const void *key, uint16_t nkey, uint64_t cas, uint16_t vbucket, uint64_t by_seqno, uint64_t rev_seqno, const void *meta, uint16_t nmeta) mock_expiration() argument
239 mock_flush(const void* cookie, uint32_t opaque, uint16_t vbucket) mock_flush() argument
249 mock_set_vbucket_state(const void* cookie, uint32_t opaque, uint16_t vbucket, vbucket_state_t state) mock_set_vbucket_state() argument
272 mock_buffer_acknowledgement(const void* cookie, uint32_t opaque, uint16_t vbucket, uint32_t buffer_bytes) mock_buffer_acknowledgement() argument
[all...]
/3.0.3-GA/memcached/engines/bucket_engine/
H A Dmock_engine.c135 mock_tap_iterator(ENGINE_HANDLE* handle, const void *cookie, item **it, void **engine_specific, uint16_t *nengine_specific, uint8_t *ttl, uint16_t *flags, uint32_t *seqno, uint16_t *vbucket) mock_tap_iterator() argument
172 mock_tap_notify(ENGINE_HANDLE* handle, const void *cookie, void *engine_specific, uint16_t nengine, uint8_t ttl, uint16_t tap_flags, tap_event_t tap_event, uint32_t tap_seqno, const void *key, size_t nkey, uint32_t flags, uint32_t exptime, uint64_t cas, uint8_t datatype, const void *data, size_t ndata, uint16_t vbucket) mock_tap_notify() argument
367 mock_item_delete(ENGINE_HANDLE* handle, const void* cookie, const void* key, const size_t nkey, uint64_t* cas, uint16_t vbucket) mock_item_delete() argument
387 mock_get(ENGINE_HANDLE* handle, const void* cookie, item** itm, const void* key, const int nkey, uint16_t vbucket) mock_get() argument
415 mock_store(ENGINE_HANDLE* handle, const void *cookie, item* itm, uint64_t *cas, ENGINE_STORE_OPERATION operation, uint16_t vbucket) mock_store() argument
430 mock_arithmetic(ENGINE_HANDLE* handle, const void* cookie, const void* key, const int nkey, const bool increment, const bool create, const uint64_t delta, const uint64_t initial, const rel_time_t exptime, uint64_t *cas, uint8_t datatype, uint64_t *result, uint16_t vbucket) mock_arithmetic() argument
[all...]

Completed in 77 milliseconds

12