Home
last modified time | relevance | path

Searched refs:get (Results 1 - 25 of 238) sorted by relevance

12345678910

/3.0.3-GA/testrunner/lib/perf_engines/
H A Dmcsoda.py204 key, cas = req_queue.get(block=True)
215 if cfg.get("woq-verbose", 0):
230 if cfg.get("woq-verbose", 0):
250 key_num = OPAQUE_MAX - cur.get('cur-gets', 0)
253 persist = (int(cfg.get('cor-persist', 0)) == 1)
275 key_str = prepare_key(key_num, cfg.get('prefix', ''))
279 choose_entry(cfg.get('min-value-size', MIN_VALUE_SIZE), key_num)
318 store.stats_ops = cfg.get("stats_ops", 10000)
320 report = cfg.get('report', 0)
321 hot_shift = cfg.get('ho
[all...]
/3.0.3-GA/testrunner/pytests/view/
H A Dviewmergetests.py61 self.assertEquals(results.get(u'total_rows', None), 0)
62 self.assertEquals(len(results.get(u'rows', None)), 0)
81 self.assertEquals(results.get(u'total_rows', 0), self.num_docs)
82 self.assertEquals(len(results.get(u'rows', [])), self.num_docs)
105 for row in results.get(u'rows', []):
127 self.assertEquals(results.get(u'total_rows', None), self.num_docs)
128 self.assertEquals(len(results.get(u'rows', None)), self.num_docs)
133 self.assertEquals(results.get(u'total_rows', None), self.num_docs)
134 self.assertEquals(len(results.get(u'rows', None)), self.num_docs)
137 self.assertEquals(results.get(
[all...]
/3.0.3-GA/ns_server/priv/public/js/
H A Djquery.sparkline.js442 if (lookup.get) { // RangeMap
443 return lookups[lookupkey].get(fieldvalue) || fieldvalue;
449 if (options.get('numberFormatter')) {
450 fieldvalue = options.get('numberFormatter')(fieldvalue);
453 options.get('numberDigitGroupCount'),
454 options.get('numberDigitGroupSep'),
455 options.get('numberDecimalMark'));
643 get: function (value) {
677 this.displayTooltips = !options.get('disableTooltips');
678 this.highlightEnabled = !options.get('disableHighligh
[all...]
H A Dhooks.js458 var get = mkHTTPMethod("GET");
529 [get("sampleBuckets"), [{
545 [get("pools", "default", "serverGroups"), function () {
566 [get("settings", "autoCompaction"), {
580 [get("settings", "readOnlyAdminName"), function () {
585 [get("settings", "replications"), {}],
588 [get("internalSettings"), {
595 [get("logs"), {
630 [get("alerts"), {
658 [get("setting
[all...]
/3.0.3-GA/testrunner/lib/membase/performance/
H A Dstats.py147 histos = self._task["latency"].get(latency, [])
188 "buildinfo": self._task.get("buildstats", {}),
189 "machineinfo": self._task.get("machinestats", {}),
190 "membasestats": self._task.get("membasestats", []),
191 "systemstats": self._task.get("systemstats", []),
192 "iostats": self._task.get("iostats", []),
198 "ns_server_data": self._task.get("ns_server_stats", []),
199 "ns_server_data_system": self._task.get("ns_server_stats_system", []),
200 "view_info": self._task.get("view_info", []),
201 "indexer_info": self._task.get("indexer_inf
[all...]
/3.0.3-GA/couchbase-python-client/couchbase/tests/
H A Dtest_couchbaseclient.py44 self.assertTrue(self.client.get('key')[2] == 'value')
50 self.assertTrue(self.client.get('key')[2] == 'valueappended')
61 self.assertTrue(self.client.get('key')[2] == '3')
67 self.assertTrue(self.client.get('key')[2] == '2')
72 self.client.get('key')
78 self.assertTrue(self.client.get('key')[2] == 'value')
84 self.assertTrue(self.client.get('key')[2] == 'prependvalue')
90 self.assertTrue(self.client.get('key')[2] == 'replaced')
97 self.assertTrue(self.client.get('key')[2] == 'value')
106 self.client.get(
[all...]
/3.0.3-GA/ep-engine/src/
H A Dobjectregistry.cc71 EventuallyPersistentEngine *engine = th->get(); in onCreateBlob()
89 EventuallyPersistentEngine *engine = th->get(); in onDeleteBlob()
107 EventuallyPersistentEngine *engine = th->get(); in onCreateStoredValue()
124 EventuallyPersistentEngine *engine = th->get(); in onDeleteStoredValue()
142 EventuallyPersistentEngine *engine = th->get(); in onCreateItem()
153 EventuallyPersistentEngine *engine = th->get(); in onDeleteItem()
163 return th->get(); in getCurrentEngine()
172 old_engine = th->get(); in onSwitchThread()
183 EventuallyPersistentEngine *engine = th->get(); in memoryAllocated()
184 if (initial_track->get()) { in memoryAllocated()
[all...]
H A Dconnmap.cc52 TapProducer *tp = dynamic_cast<TapProducer*>(connection.get()); in run()
99 task = ExecutorPool::get()->schedule(connotifyTask, NONIO_TASK_IDX); in start()
106 ExecutorPool::get()->cancel(task); in stop()
113 ExecutorPool::get()->wake(task); in notifyMutationEvent()
118 ExecutorPool::get()->wake(task); in wake()
127 ExecutorPool::get()->snooze(task, DEFAULT_MIN_STIME); in notifyConnections()
131 ExecutorPool::get()->snooze(task, 0); in notifyConnections()
196 ExecutorPool::get()->schedule(connMgr, NONIO_TASK_IDX); in initialize()
226 Notifiable* tp = dynamic_cast<Notifiable*>(conn.get()); in notifyPausedConnection()
251 Notifiable *tp = dynamic_cast<Notifiable*>(conn.get()); in notifyAllPausedConnections()
[all...]
/3.0.3-GA/healthchecker/Cheetah/Tests/
H A DNameMapper.py120 get = VFN variable in NameMapperTest
123 got = self.get(name)
294 assert self.get('aDict.nestedFunc', False) == dummyFunc
299 assert self.get('aDict.nestedFunc', False) == dummyFunc
303 assert self.get('aMeth', False) == self.namespace()['aMeth']
308 assert self.get('aMeth', False) == self.namespace()['aMeth']
323 self.get('anObj.methX')
329 self.get('anObj.methX')
338 self.get('anObj.meth2')
344 self.get('anOb
457 def get(self, name, autocall=True): global() member in VFS
470 def get(self, name, autocall=True): global() member in VFF
517 def get(self, name, autocall=True): global() member in VFFSL
[all...]
/3.0.3-GA/testrunner/scripts/
H A Dactive_tasks.py20 tasks = requests.get(url=url, auth=auth).json()
39 tasks = requests.get(url=url, auth=auth).json()
43 get_id = lambda task: '_{0}_{1}_{2}_'.format(task.get('set', ''),
45 task.get('indexer_type', ''))
50 (server.ip + get_id(t) + metric, t.get(metric, None))
62 tasks = requests.get(url=url, auth=auth).json()
67 task.get('bucket', ''),
68 task.get('designDocument', ''))
73 (get_id(task) + metric, task.get(metric, None))
H A Dbucketloader.py40 def load_buckets(server, name, get, threads, moxi):
42 MemcachedClientHelper.load_bucket([server], name, -1, 10000000, distro, threads, -1, get, moxi)
51 get = True variable
72 if "get" in params:
73 if params["get"].lower() == "true":
74 get = True variable
90 t = Thread(target=load_buckets, args=(server, bucket.name, get, no_threads, moxi))
/3.0.3-GA/testrunner/unittests/
H A Dawareness.py23 vm.memcached(key).get(key)
35 cm.get(key)
42 cm1.get(key)
48 c1.get(key)
53 c2.get(key)
58 d1.get(key)
73 # vam.memcached(key).get(key)
/3.0.3-GA/testrunner/
H A DTestInput.py155 #now let's get the test specific parameters
198 #get global stuff and override for those unset
200 global_properties[option] = config.get(section, option)
272 ips.append(config.get(section, option))
282 server.ip = config.get(section, option)
284 server.port = config.get(section, option)
286 server.ssh_username = config.get(section, option)
288 server.ssh_password = config.get(section, option)
290 conf[option] = config.get(section, option)
301 ip = config.get(sectio
[all...]
/3.0.3-GA/moxi/t/
H A Drest_mock.rb12 get '/pools/default/buckets/default' do
16 get '/pools/default/bucketsStreaming/default' do
20 get '/pools/default/bucketsStreamingConfig/default' do
H A Dissue-MB-2649.sh37 echo get a | nc 127.0.0.1 11266 > /tmp/slow-node-0.out &
40 echo get a | nc 127.0.0.1 11266 > /tmp/slow-node-1.out &
43 echo get a | nc 127.0.0.1 11266 > /tmp/slow-node-2.out &
73 count=$(echo get a | nc 127.0.0.1 11266 | grep "VALUE" | wc -l)
/3.0.3-GA/testrunner/pysystests/app/
H A Dquery.py120 self.bucket = params.get("bucket")
121 self.password = params.get("password")
123 self.uniq_include_filters(params.get("include_filters"))
124 self.exclude_filters = params.get("exclude_filters")
125 self.startkey = params.get("startkey")
126 self.endkey = params.get("endkey")
127 self.startkey_docid = params.get("startkey_docid")
128 self.endkey_docid = params.get("endkey_docid")
129 self.limit = params.get("limit")
131 self.indexed_key = params.get("indexed_ke
[all...]
/3.0.3-GA/testrunner/pytests/sdk_client_tests/
H A Dsdk_client_tests.py26 val, flag, cas = client.get("1")
30 val, flag, cas = client.get("1")
35 val, flag, cas = client.get("key")
39 val, flag, cas = client.get("key")
43 val, flag, cas = client.get("key")
/3.0.3-GA/couchbase-cli/
H A Dpump_sfd.py89 state = doc.get('state', None)
143 doc['id'] = doc.get('id', doc_info.id)
144 doc['_rev'] = doc.get('_rev', doc_info.revSequence)
163 rv, batch = self.queue.get()
184 vbucket_states = source_nodes[0].get('vbucket_states', None)
190 vbuckets = vbucket_states.get(source_vbucket_state, None)
257 self.rehash = opts.extra.get("rehash", 0)
265 vbucket_states = self.source_node.get('vbucket_states', {})
324 vm = vbucket_states.get(destination_vbucket_state, None)
326 vi = vm.get(vbucket_i
[all...]
H A Dpump.py130 if not self.opts.extra.get("design_doc_only", 0):
137 if not self.opts.extra.get("data_only", 0):
188 if not source_map.get('spec_parts'):
193 source_map.get('spec_parts'))
197 logging.debug(" source_nodes: " + ",".join([n.get('hostname', NA)
212 key=lambda n: n.get('hostname', NA)):
214 source_node.get('hostname', NA))
265 self.queue.get()
266 hostname = source_node.get('hostname', NA)
291 self.cur[k] = self.cur.get(
[all...]
H A Dpump_cb.py21 self.rehash = opts.extra.get("rehash", 0)
142 couch_api_base = sink_nodes[0].get('couchApiBase')
159 doc = row.get('doc', None)
165 id = doc['meta'].get('id', None)
173 id = row.get('id', None)
217 conn = mconns.get(host_port, None)
/3.0.3-GA/testrunner/lib/tasks/
H A Dtaskmanager.py30 task = self.readyq.get()
33 s_task = self.sleepq.get()
43 task = self.sleepq.get()['task']
48 task = self.readyq.get()
/3.0.3-GA/testrunner/lib/
H A Dload_runner.py18 def get(self, key): member in FakeMemcachedClient
50 threads = int(load_info['operation_info'].get('threads', 0))
53 self.cache_data = load_info['operation_info'].get('cache_data', False)
58 self.bucket_name = load_info['memcached_info'].get('bucket_name', '')
59 self.bucket_password = load_info['memcached_info'].get('bucket_password', '')
74 self.max_operation_rate = int(load_info['operation_info'].get('operation_rate', 0) / threads)
81 self.limit_items = int(load_info['limit_info'].get('items', 0) / threads)
82 self.limit_operations = int(load_info['limit_info'].get('operations', 0) / threads)
83 self.limit_time = int(load_info['limit_info'].get('time', 0))
84 self.limit_size = int(load_info['limit_info'].get('siz
[all...]
/3.0.3-GA/testrunner/lib/perf_engines/libobserve/
H A Dobs_mcsoda.py40 self.backoff = self.cfg.get('obs-backoff', BACKOFF)
41 self.max_backoff = self.cfg.get('obs-max-backoff', MAX_BACKOFF)
57 self.backoff = self.cfg.get('obs-backoff', BACKOFF)
145 vbucketid = VbucketHelper.get_vbucket_id(obs.key, self.cfg.get("vbuckets", 0))
149 vals = self.obs_keys.get(persist_server, [])
167 vals = self.obs_keys.get(server, [])
225 vals = responses.get(server, [])
248 self.backoff = self.cfg.get('obs-backoff', BACKOFF)
292 VbucketHelper.get_vbucket_id(key, self.cfg.get("vbuckets", 0))
299 self.backoff = self.cfg.get('ob
[all...]
/3.0.3-GA/healthchecker/Cheetah/
H A DCacheStore.py12 get(key, val)
36 def get(self, key): member in AbstractCacheStore
59 def get(self, key): member in MemoryCacheStore
98 def get(self, key): member in MemcachedCacheStore
99 val = self._client.get(key)
/3.0.3-GA/ns_server/priv/ui_tests/deps/casperjs/modules/
H A Dcli.js92 get: function get(what, def) {
127 get: extract.get

Completed in 58 milliseconds

12345678910