Home
last modified time | relevance | path

Searched refs:mc (Results 1 - 25 of 39) sorted by relevance

12

/3.0.3-GA/moxi/t/
H A Dbinary.t54 my $mc = MC::Client->new;
58 $mc->stats('detail on');
62 my ($flags, $val, $cas) = $mc->get($key);
69 $mc->set($key, $orig_value, $orig_flags, $exp);
75 my $rv =()= eval { $mc->get($key) };
82 $mc->delete($key, $when);
87 my $v = $mc->version;
92 my %stats1 = $mc->stats('');
93 $mc->flush;
94 my %stats2 = $mc
[all...]
/3.0.3-GA/ep-engine/management/
H A Dcbstats24 mc = args[0]
37 mc.sasl_auth_plain(bucket, password)
43 buckets = mc.stats('bucket')
48 mc.bucket_select(bucket)
55 def stats_perform(mc, cmd=''):
57 return mc.stats(cmd)
117 def histograms(mc, raw_stats):
179 def stats_key(mc, key, vb):
182 vbs = mc.stats(cmd)
195 def stats_vkey(mc, ke
[all...]
H A Dcbepctl16 mc = args[0]
24 mc.sasl_auth_plain(bucket, password)
30 buckets = mc.stats('bucket')
35 mc.bucket_select(bucket)
43 def set_param(mc, type, key, val):
66 _quota_ = int(mc.stats()['ep_max_size'])
70 mc.set_param(key, val, engine_param)
78 def stop(mc):
80 mc.stop_persistence()
85 stats = mc
[all...]
H A Dcbvbucketctl5 def listvb(mc, username=None, password=""):
7 mc.sasl_auth_plain(username, password)
8 vbs = mc.stats('vbucket')
12 def setvb(mc, vbid, vbstate, username=None, password=""):
14 mc.sasl_auth_plain(username, password)
15 mc.set_vbucket_state(int(vbid), vbstate)
17 def rmvb(mc, vbid, username=None, password=""):
19 mc.sasl_auth_plain(username, password)
20 mc.delete_vbucket(int(vbid))
H A Dcbadm-tap-registration64 def readTap(mc):
68 cmd, vbucketId, opaque, cas, keylen, extlen, data = mc._recvMsg()
91 global mc
96 mc = mc_bin_client.MemcachedClient(host_port[0], int(host_port[1])) variable
111 mc._sendCmd(memcacheConstants.CMD_TAP_CONNECT, tap_name, val, 0, ext)
112 cmd, opaque, cas, vbucketId, key, ext, val = readTap(mc)
117 mc.deregister_tap_client(tap_name)
125 if mc:
126 mc.close()
H A Dcbvdiff36 mc = mc_bin_client.MemcachedClient(host, port)
45 mc.sasl_auth_plain(options.bucketName, password)
51 stats = mc.stats(stat_cmd)
H A Dclitool.py50 mc = mc_bin_client.MemcachedClient(host, port)
62 f[0](mc, *args[2:], **opts.__dict__)
64 getattr(mc, f[0])(*args[2:])
H A Dtap.py45 self.mc = mc_bin_client.MemcachedClient(self.server, self.port)
46 self.mc.sasl_auth_plain(self.user, self.pswd or "")
48 sock = self.mc.s
/3.0.3-GA/ep-engine/tests/module_tests/
H A Dexpiry_test.py17 def store(mc, kprefix):
20 mc.set(k, EXPIRY, 0, k)
23 mc.add(k, EXPIRY, 0, k)
25 def check(mc, kprefix):
30 mc.get(k)
36 mc = mc_bin_client.MemcachedClient() variable
41 store(mc, 'a1')
42 store(mc, 'a2')
45 check(mc, 'a2')
46 store(mc, 'a
[all...]
/3.0.3-GA/testrunner/scripts/
H A Dmb4461.py34 mc = MemcachedClient("127.0.0.1", 11211)
39 mc.set(k, 0, 0, str(uuid.uuid4())[0:16])
46 a, b, value = mc.get(k)
48 mc.delete(k)
50 mc.set(k, 0, 0, value[0:len(value) - 7])
52 mc.set(k, 0, 0, str(uuid.uuid4())[0:16])
57 mc.prepend(k, "two")
59 mc.set(k, 0, 0, str(uuid.uuid4())[0:16])
H A Dmixload-inlp.py40 mc = MemcachedClientHelper.proxy_client(server, bucket.name) variable
47 #mc = smart.memcached(key)
51 mc.delete(key)
52 mc.set(key, 0, 0, payload)
56 mc.set(key, 0, 0, payload)
57 mc.get(key)
68 mc = MemcachedClientHelper.proxy_client(server, bucket.name) variable
H A Dmixload-allset.py40 mc = MemcachedClientHelper.proxy_client(server, bucket.name) variable
45 #mc = smart.memcached(key)
47 mc.set(key, 0, 0, payload)
48 #mc.get(key)
55 mc = MemcachedClientHelper.proxy_client(server, bucket.name) variable
/3.0.3-GA/testrunner/pytests/
H A Dwarmupcluster.py136 mc = None
139 mc = MemcachedClientHelper.direct_client(server, "default")
140 stats = mc.stats()
149 if mc:
150 mc.close()
156 mc = MemcachedClientHelper.direct_client(server, "default")
169 stats = mc.stats()
195 if mc.stats()["curr_items_tot"] < expected_curr_items_tot:
196 self.log.info("still warming up .... curr_items_tot : {0}".format(mc.stats()["curr_items_tot"]))
197 while now_items == mc
[all...]
H A Dmemorysanitytests.py90 mc = MemcachedClientHelper.direct_client(self.master, self.default_bucket_name)
94 while (int(mc.stats()["vb_active_perc_mem_resident"]) == 0 or\
95 int(mc.stats()["vb_active_perc_mem_resident"]) > resident_ratio) and\
97 self.log.info("Resident ratio is %s" % mc.stats()["vb_active_perc_mem_resident"])
102 self.log.info("Resident ratio is %s" % mc.stats()["vb_active_perc_mem_resident"])
103 memory_mb = int(mc.stats("memory")["mem_used"]) / (1024 * 1024)
/3.0.3-GA/testrunner/pytests/regressions/
H A Dregressiontest.py14 mc = MemcachedClientHelper.direct_client(self.master, "default")
15 mc.set("hello", 0, 0, "world")
16 mc.getl("hello", 15)
18 ret = mc.replace("hello", 0, 0, "hello")
/3.0.3-GA/testrunner/pytests/memcachedops/
H A Dstats_ops.py70 mc = MemcachedClientHelper.direct_client(self.servers[0], self.bucket_name)
71 stats = mc.stats()
79 mem_used = int(mc.stats()["mem_used"])
80 if mem_used < threshold or int(mc.stats()["vb_active_perc_mem_resident"]) >= active_resident_threshold:
81 self.log.info("mem_used and vb_active_perc_mem_resident_ratio reached at %s/%s and %s " % (mem_used, threshold, mc.stats()["vb_active_perc_mem_resident"]))
/3.0.3-GA/testrunner/lib/membase/helper/
H A Dcluster_helper.py98 mc = None
104 mc = MemcachedClientHelper.direct_client(server, bucket_name)
105 stats = mc.stats()
129 if mc.stats()["ep_warmup_thread"] == "complete":
130 log.info("warmup completed, awesome!!! Warmed up. %s items " % (mc.stats()["curr_items_tot"]))
133 elif mc.stats()["ep_warmup_thread"] == "running":
135 "still warming up .... curr_items_tot : %s" % (mc.stats()["curr_items_tot"]))
139 mc.close()
339 mc = MemcachedClientHelper.direct_client(server, bucket)
345 rv = mc
[all...]
H A Dcheckpoints.py47 mc = MemcachedClientHelper.direct_client(server, bucket)
48 per_node_checkpoint = mc.stats("checkpoint")
51 mc.close()
/3.0.3-GA/testrunner/pytests/castest/
H A Dopschangecas.py113 mc = MemcachedClientHelper.proxy_client(self.servers[0], "default")
119 mc.set(key, 0, 0, payload)
125 if int(mc.stats()["vb_active_perc_mem_resident"]) >= active_resident_threshold:
126 self.log.info("vb_active_perc_mem_resident_ratio reached at %s " % (mc.stats()["vb_active_perc_mem_resident"]))
135 if time.time() > end_time and int(mc.stats()["vb_active_perc_mem_resident"]) >= active_resident_threshold:
144 mc.touch(key, 0)
/3.0.3-GA/testrunner/lib/membase/performance/
H A Dstats.py506 mc = MemcachedClientHelper.direct_client(node, bucket)
507 stats = mc.stats()
508 stats.update(mc.stats("warmup"))
526 mc = MemcachedClientHelper.direct_client(node, bucket)
527 mcs.append(mc)
534 for mc in mcs:
535 data[mc.host] = {"snapshots": [], "timings": [], "dispatcher": []}
540 for mc in mcs:
543 stats = mc.stats()
547 mc
[all...]
/3.0.3-GA/testrunner/unittests/
H A Dtapper.py67 #mc = MemcachedClientHelper.create_memcached_client("172.16.75.128","default",11210,"default")
68 mc = MemcachedClient("10.17.12.20", 11210) variable
74 # mc.set_vbucket_state(i, 'active')
83 mc.set(key, 10, 0, payload, vbucket=0)
86 # mc.set(key, 1, 0, payload, vbucket=0)
88 a,b,c = mc.get(key, vbucket=0)
99 # mc.set(key, 1, 0, payload, vbucket=0)
100 # mc.get(key, vbucket=0)
104 # mc.delete(key,vbucket=0)
/3.0.3-GA/couchbase-cli/t/
H A DMakefile8 test-restore-cb test-restore-mc
23 test-restore-mc:
/3.0.3-GA/couchbase-cli/
H A Dcollector.py152 def get_mc_stats_per_node(self, mc, stats):
157 node_stats = mc.stats(cmd)
192 mc = cb_bin_client.MemcachedClient(node_server, node['ports']['direct'])
194 mc.sasl_auth_cram_md5(bucket_name.encode("utf8"), bucket["saslPassword"].encode("utf8"))
195 self.get_mc_stats_per_node(mc, stats)
/3.0.3-GA/healthchecker/
H A Dcollector.py209 def get_mc_stats_per_node(self, mc, stats):
213 if mc:
214 node_stats = mc.stats(cmd)
220 if mc:
256 mc = cb_bin_client.MemcachedClient(node_server, node['ports']['direct'])
258 mc.sasl_auth_plain(bucket_name.encode("utf8"), bucket["saslPassword"].encode("utf8"))
259 self.get_mc_stats_per_node(mc, stats)
/3.0.3-GA/testrunner/lib/
H A Dtap.py45 self.mc = mc_bin_client.MemcachedClient(self.server, self.port)
46 self.mc.sasl_auth_plain(self.user, self.pswd or "")
48 sock = self.mc.s

Completed in 51 milliseconds

12