Home
last modified time | relevance | path

Searched refs:store (Results 1 - 25 of 72) sorted by relevance

123

/3.0.3-GA/couchstore/python/
H A Dcouchstore_test.py23 self.store = CouchStore("/tmp/test.couch", 'c')
26 self.store.close()
30 sequence = self.store.save("foo", "value of foo")
32 self.store.commit()
33 value = self.store.get("foo")
37 self.assertRaises(KeyError, self.store.get, "nonexistent")
40 self.assertRaises(TypeError, self.store.get, 0)
41 self.assertRaises(TypeError, self.store.get, None)
42 self.assertRaises(TypeError, self.store.get, [123])
46 sequence = self.store
[all...]
/3.0.3-GA/ep-engine/src/
H A Dwarmup.cc238 "Cannot store an item after emergency purge."); in callback()
312 EmergencyPurgeVisitor(EventuallyPersistentStore *store) : in purge() argument
313 epstore(store) {} in purge()
364 state(), store(st), startTime(0), metadata(0), warmup(0), in Warmup()
371 store->vbMap.numShards]; in Warmup()
372 shardVbIds = new std::vector<uint16_t>[store->vbMap.numShards]; in Warmup()
373 shardKeyDumpStatus = new bool[store->vbMap.numShards]; in Warmup()
374 for (size_t i = 0; i < store->vbMap.numShards; i++) { in Warmup()
411 ExTask task = new WarmupInitialize(*store, this, in scheduleInitialize()
419 allVbStates = store in initialize()
[all...]
H A Dstats.h167 maxDataSize.store(size); in setMaxDataSize()
277 //! Total memory overhead to store values for resident keys.
410 //! The number of basic store (add, set, arithmetic, touch, etc.) operations
471 //! Histogram of store commands.
531 tooYoung.store(0); in reset()
532 tooOld.store(0); in reset()
533 dirtyAge.store(0); in reset()
534 dirtyAgeHighWat.store(0); in reset()
535 commit_time.store(0); in reset()
536 pagerRuns.store( in reset()
[all...]
H A Ditem_pager.cc46 * @param s the store that will handle the bulk removal
58 : store(s), stats(st), percent(pcnt), in PagingVisitor()
104 store.getEPEngine().getTapConnMap().notifyVBConnections( in visitBucket()
106 store.getEPEngine().getDcpConnMap().notifyVBConnections( in visitBucket()
121 store.cachedResidentRatio.activeRatio < in visitBucket()
122 store.cachedResidentRatio.replicaRatio) in visitBucket()
138 store.deleteExpiredItems(expired); in update()
206 item_eviction_policy_t policy = store.getItemEvictionPolicy();
214 EventuallyPersistentStore &store; local
229 EventuallyPersistentStore *store in run() local
271 EventuallyPersistentStore *store = engine->getEpStore(); run() local
[all...]
H A Daccess_scanner.cc30 store(_store), stats(_stats), startTime(ep_real_time()), in ItemAccessVisitor()
33 Configuration &conf = store.getEPEngine().getConfiguration(); in ItemAccessVisitor()
87 if (++(as->completedCount) == store.getVBuckets().getNumShards()) { in complete()
99 stats.alogRuntime.store(ep_real_time() - startTime); in complete()
100 stats.alogNumItems.store(num_items); in complete()
129 EventuallyPersistentStore &store; member in ItemAccessVisitor
147 store.resetAccessScannerTasktime(); in run()
149 for (size_t i = 0; i < store.getVBuckets().getNumShards(); i++) { in run()
150 shared_ptr<ItemAccessVisitor> pv(new ItemAccessVisitor(store, in run()
153 ExTask task = new VBucketVisitorTask(&store, vb in run()
[all...]
H A Dcheckpoint_remover.cc36 : store(s), stats(st), removed(0), in CheckpointVisitor()
47 store->getEPEngine().getTapConnMap().notifyVBConnections( in visitBucket()
49 store->getEPEngine().getDcpConnMap().notifyVBConnections( in visitBucket()
74 EventuallyPersistentStore *store; member in CheckpointVisitor
83 EventuallyPersistentStore *store = engine->getEpStore(); in run() local
84 shared_ptr<CheckpointVisitor> pv(new CheckpointVisitor(store, stats, in run()
86 store->visit(pv, "Checkpoint Remover", NONIO_TASK_IDX, in run()
H A Dvbucketmap.cc27 EventuallyPersistentStore &store) : in VBucketMap()
35 WorkLoadPolicy &workload = store.getEPEngine().getWorkLoadPolicy(); in VBucketMap()
38 KVShard *shard = new KVShard(shardId, store); in VBucketMap()
43 bucketDeletion[i].store(false); in VBucketMap()
44 bucketCreation[i].store(true); in VBucketMap()
45 persistenceCheckpointIds[i].store(0); in VBucketMap()
148 persistenceCheckpointIds[id].store(checkpointId);
158 persistenceSeqnos[id].store(seqno);
26 VBucketMap(Configuration &config, EventuallyPersistentStore &store) VBucketMap() argument
H A Dkvshard.cc26 KVShard::KVShard(uint16_t id, EventuallyPersistentStore &store) : in KVShard() argument
30 EPStats &stats = store.getEPEngine().getEpStats(); in KVShard()
31 Configuration &config = store.getEPEngine().getConfiguration(); in KVShard()
39 flusher = new Flusher(&store, this); in KVShard()
40 bgFetcher = new BgFetcher(&store, this, stats); in KVShard()
H A Dvbucket.cc219 dirtyQueueMem.store(0); in doStatsForFlushing()
226 dirtyQueueAge.store(0); in doStatsForFlushing()
232 dirtyQueuePendingWrites.store(0); in doStatsForFlushing()
248 opsCreate.store(0); in resetStats()
249 opsUpdate.store(0); in resetStats()
250 opsDelete.store(0); in resetStats()
251 opsReject.store(0); in resetStats()
254 dirtyQueueSize.store(0); in resetStats()
255 dirtyQueueMem.store(0); in resetStats()
256 dirtyQueueFill.store( in resetStats()
[all...]
H A Dhtresizer.h38 store(s) {} in HashtableResizerTask()
47 EventuallyPersistentStore *store; member in HashtableResizerTask
H A Dbgfetcher.cc34 ExTask task = new BgFetcherTask(&(store->getEPEngine()), this, in start()
90 store->completeBGFetchMulti(vbId, fetchedItems, startTime); in doFetch()
115 RCPtr<VBucket> vb = store->getVBuckets().getBucket(vbId); in clearItems()
144 if (store->getVBuckets().isBucketCreation(vbId)) { in run()
165 double sleep = std::max(store->getBGFetchDelay(), sleepInterval); in run()
H A Dep.cc61 stats.mem_low_wat.store(low_wat); in sizeValueChanged()
62 stats.mem_high_wat.store(high_wat); in sizeValueChanged()
64 stats.mem_low_wat.store(value); in sizeValueChanged()
66 stats.mem_high_wat.store(value); in sizeValueChanged()
68 stats.tapThrottleThreshold.store( in sizeValueChanged()
71 stats.warmupMemUsedCap.store(static_cast<double>(value) / 100.0); in sizeValueChanged()
73 stats.warmupNumReadCap.store(static_cast<double>(value) / 100.0); in sizeValueChanged()
92 EPStoreValueChangeListener(EventuallyPersistentStore &st) : store(st) { in EPStoreValueChangeListener()
97 store.setBGFetchDelay(static_cast<uint32_t>(value)); in sizeValueChanged()
99 store in sizeValueChanged()
136 EventuallyPersistentStore &store; global() member in EPStoreValueChangeListener
874 KVStatsCallback(EventuallyPersistentStore *store) KVStatsCallback() argument
1219 ExpiredItemsCallback(EventuallyPersistentStore *store, uint16_t vbid) ExpiredItemsCallback() argument
2612 EventuallyPersistentStore *store; global() member in PersistenceCallback
[all...]
H A Daccess_scanner.h39 completedCount(0), store(_store), stats(st), sleepTime(sleeptime), in AccessScanner()
48 EventuallyPersistentStore &store; member in AccessScanner
H A Dtapthrottle.cc50 stats.tapThrottleWriteQueueCap.store(-1); in adjustWriteQueueCap()
58 stats.tapThrottleWriteQueueCap.store(throttleCap > qcap ? throttleCap : in adjustWriteQueueCap()
H A Dflusher.cc233 if (store->diskFlushAll && shard->getId() != EP_PRIMARY_SHARD) { in flushVB()
257 RCPtr<VBucket> vb = store->getVBucket(*itr); in flushVB()
274 if (store->flushVBucket(vbid) == RETRY_FLUSH_VBUCKET) { in flushVB()
283 if (store->flushVBucket(vbid) == RETRY_FLUSH_VBUCKET) { in flushVB()
/3.0.3-GA/testrunner/lib/perf_engines/libobserve/
H A Dobs_mcsoda.py22 store = None variable in McsodaObserver
33 def __init__(self, ctl, cfg, store, callback):
36 self.store = store
56 self.callback(self.store)
62 """build separate connections based on store"""
63 if not self.store:
64 print "<%s> failed to build connections, invalid store object"\
68 if self.store.__class__.__name__ == "StoreMemcachedBinary":
69 conn = MemcachedClient(self.store
[all...]
/3.0.3-GA/couchbase-cli/
H A Dpump_sfd.py84 store = couchstore.CouchStore(f, 'r')
86 doc_str = store.localDocs['_local/vbstate']
98 store.close()
117 rv, store, store_path = \
123 if rv != 0 or not store:
128 for doc_info in store.changesSince(0):
148 store.close()
199 store = None
236 store = couchstore.CouchStore(f, 'r')
242 store
[all...]
/3.0.3-GA/ep-engine/tests/module_tests/
H A Dexpiry_test.py17 def store(mc, kprefix): function
41 store(mc, 'a1')
42 store(mc, 'a2')
46 store(mc, 'a1')
47 store(mc, 'a2')
/3.0.3-GA/testrunner/lib/perf_engines/
H A Dmcsoda.py177 def obs_cb(store):
181 if not store:
185 log.info("obs_cb: clear obs_key_cas %s" % store.obs_key_cas)
186 store.obs_key_cas.clear()
189 def woq_worker(req_queue, stats_queue, ctl, cfg, store):
200 woq_observer = McsodaObserver(ctl, cfg, store, None)
222 result = store.rest.query_view(ddoc, view, bucket, query_params)
242 def cor_worker(stats_queue, ctl, cfg, cur, store):
251 store.cfg["cor"] = 1
252 store
[all...]
/3.0.3-GA/memcached/daemon/
H A Dtimings.cc52 timings[ii].ns.store(0); in initialize_timings()
54 timings[ii].usec[jj].store(0); in initialize_timings()
57 timings[ii].msec[jj].store(0); in initialize_timings()
60 timings[ii].halfsec[jj].store(0); in initialize_timings()
62 timings[ii].wayout.store(0); in initialize_timings()
/3.0.3-GA/ep-engine/tests/
H A Dep_testsuite.cc203 check(store(h, h1, NULL, OPERATION_SET, key, "{\"lock\":\"data\"}", in test_getl()
205 == ENGINE_SUCCESS, "Failed to store an item."); in test_getl()
229 check(store(h, h1, NULL, OPERATION_SET, key, "lockdata2", &i, 0, vbucketId) in test_getl()
230 != ENGINE_SUCCESS, "Should have failed to store an item."); in test_getl()
237 check(store(h, h1, NULL, OPERATION_SET, key, "lockdata", &i, 0, vbucketId) in test_getl()
238 == ENGINE_SUCCESS, "Failed to store an item."); in test_getl()
312 check(h1->store(h, NULL, it, &cas, OPERATION_SET, 0) == in test_getl()
327 /* but a simple store should succeed */ in test_getl()
328 check(store(h, h1, NULL, OPERATION_SET, ekey, edata, &i, 0, vbucketId) in test_getl()
329 == ENGINE_SUCCESS, "Failed to store a in test_getl()
[all...]
/3.0.3-GA/testrunner/scripts/
H A Dvbucketpop.py2 """Load data into memcached and an on disk key value store."""
68 store = {} variable
76 store = pickle.load(f)
85 for vbucketid, keys in store.items():
/3.0.3-GA/ep-engine/src/couch-kvstore/
H A Dcouch-kvstore.h57 docsCommitted.store(0); in reset()
58 numOpen.store(0); in reset()
59 numClose.store(0); in reset()
60 numLoadedVb.store(0); in reset()
61 numGetFailure.store(0); in reset()
62 numSetFailure.store(0); in reset()
63 numDelFailure.store(0); in reset()
64 numOpenFailure.store(0); in reset()
65 numVbSetFailure.store(0); in reset()
564 * Get all_docs API, to return the list of all keys in the store
[all...]
/3.0.3-GA/memcached/testsuite/
H A Dbasic_engine_testsuite.c76 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_SET,0) == ENGINE_SUCCESS); in set_test()
96 ENGINE_ERROR_CODE ret = h1->store(h, NULL, it, &cas, OPERATION_ADD, 0); in add_test()
131 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_REPLACE,0) == ENGINE_SUCCESS); in replace_test()
160 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_SET, 0) == ENGINE_SUCCESS); in append_test()
168 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_APPEND, 0) == ENGINE_SUCCESS); in append_test()
195 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_SET, 0) == ENGINE_SUCCESS); in prepend_test()
203 cb_assert(h1->store(h, NULL, it, &cas, OPERATION_PREPEND, 0) == ENGINE_SUCCESS); in prepend_test()
216 * Make sure when we can successfully store an item after it has been allocated
225 cb_assert(h1->store(h, NULL, test_item, &cas, OPERATION_SET,0) == ENGINE_SUCCESS); in store_test()
242 cb_assert(h1->store( in get_test()
[all...]
/3.0.3-GA/testrunner/pysystests/
H A Dcache.py15 def store(self, key, data, collectionKey): member in Cache
92 def store(self, cachekey, obj): member in ObjCacher
94 super(ObjCacher, self).store(id_, obj, cachekey)
186 Cache().store(key, value, CacheHelper.VARCACHEKEY)

Completed in 66 milliseconds

123