/3.0.3-GA/testrunner/lib/memcached/helper/ |
H A D | kvstore.py | 19 def acquire_partition(self, key): 20 partition = self.cache[self._hash(key)] 26 for key in keys: 27 partition = self.cache[self._hash(key)] 32 part_obj_keys[partition_obj].append(key) 40 def release_partition(self, key): 41 if isinstance(key, str): 42 self.cache[self._hash(key)]["lock"].release() 43 elif isinstance(key, int): 44 self.cache[key]["loc [all...] |
/3.0.3-GA/couchdb/share/www/script/test/ |
H A D | multiple_rows.js | 35 T(rows[0].key == "Boston, MA"); 36 T(rows[1].key == "Cambridge, MA"); 37 T(rows[2].key == "Charlotte, NC"); 38 T(rows[3].key == "Lowell, MA"); 39 T(rows[4].key == "Miami, FL"); 40 T(rows[5].key == "Orlando, FL"); 41 T(rows[6].key == "Raleigh, NC"); 42 T(rows[7].key == "Springfield, FL"); 43 T(rows[8].key == "Springfield, MA"); 44 T(rows[9].key [all...] |
/3.0.3-GA/healthchecker/Cheetah/ |
H A D | CacheStore.py | 6 set(key, val, time=0) 8 add(key, val, time=0) 9 set only if the server doesn't already have this key 10 replace(key, val, time=0) 11 set only if the server already have this key 12 get(key, val) 14 delete(key) 24 def set(self, key, val, time=None): 27 def add(self, key, val, time=None): 30 def replace(self, key, va [all...] |
/3.0.3-GA/moxi/libmemcached/libhashkit/ |
H A D | algorithm.c | 11 uint32_t libhashkit_one_at_a_time(const char *key, size_t key_length) in libhashkit_one_at_a_time() argument 13 return hashkit_one_at_a_time(key, key_length, NULL); in libhashkit_one_at_a_time() 16 uint32_t libhashkit_fnv1_64(const char *key, size_t key_length) in libhashkit_fnv1_64() argument 18 return hashkit_fnv1_64(key, key_length, NULL); in libhashkit_fnv1_64() 21 uint32_t libhashkit_fnv1a_64(const char *key, size_t key_length) in libhashkit_fnv1a_64() argument 23 return hashkit_fnv1a_64(key, key_length, NULL); in libhashkit_fnv1a_64() 26 uint32_t libhashkit_fnv1_32(const char *key, size_t key_length) in libhashkit_fnv1_32() argument 28 return hashkit_fnv1_32(key, key_length, NULL); in libhashkit_fnv1_32() 31 uint32_t libhashkit_fnv1a_32(const char *key, size_t key_length) in libhashkit_fnv1a_32() argument 33 return hashkit_fnv1a_32(key, key_lengt in libhashkit_fnv1a_32() 36 libhashkit_crc32(const char *key, size_t key_length) libhashkit_crc32() argument 42 libhashkit_hsieh(const char *key, size_t key_length) libhashkit_hsieh() argument 49 libhashkit_murmur(const char *key, size_t key_length) libhashkit_murmur() argument 55 libhashkit_jenkins(const char *key, size_t key_length) libhashkit_jenkins() argument 60 libhashkit_md5(const char *key, size_t key_length) libhashkit_md5() argument 65 libhashkit_md5_signature(const unsigned char *key, size_t length, unsigned char *result) libhashkit_md5_signature() argument [all...] |
H A D | algorithm.h | 22 uint32_t libhashkit_one_at_a_time(const char *key, size_t key_length); 25 uint32_t libhashkit_fnv1_64(const char *key, size_t key_length); 28 uint32_t libhashkit_fnv1a_64(const char *key, size_t key_length); 31 uint32_t libhashkit_fnv1_32(const char *key, size_t key_length); 34 uint32_t libhashkit_fnv1a_32(const char *key, size_t key_length); 37 uint32_t libhashkit_crc32(const char *key, size_t key_length); 40 uint32_t libhashkit_jenkins(const char *key, size_t key_length); 43 uint32_t libhashkit_md5(const char *key, size_t key_length); 46 uint32_t hashkit_one_at_a_time(const char *key, size_t key_length, void *context); 49 uint32_t hashkit_fnv1_64(const char *key, size_ [all...] |
H A D | digest.c | 11 uint32_t hashkit_digest(const hashkit_st *self, const char *key, size_t key_length) in hashkit_digest() argument 13 return self->base_hash.function(key, key_length, self->base_hash.context); in hashkit_digest() 16 uint32_t libhashkit_digest(const char *key, size_t key_length, hashkit_hash_algorithm_t hash_algorithm) in libhashkit_digest() argument 21 return libhashkit_one_at_a_time(key, key_length); in libhashkit_digest() 23 return libhashkit_md5(key, key_length); in libhashkit_digest() 25 return libhashkit_crc32(key, key_length); in libhashkit_digest() 27 return libhashkit_fnv1_64(key, key_length); in libhashkit_digest() 29 return libhashkit_fnv1a_64(key, key_length); in libhashkit_digest() 31 return libhashkit_fnv1_32(key, key_length); in libhashkit_digest() 33 return libhashkit_fnv1a_32(key, key_lengt in libhashkit_digest() [all...] |
/3.0.3-GA/ep-engine/src/ |
H A D | configuration.h | 46 * @param key the key who changed 47 * @param value the new value for the key 49 virtual void booleanValueChanged(const std::string &key, bool) { in booleanValueChanged() argument 51 " a boolean value", key.c_str()); in booleanValueChanged() 56 * @param key the key who changed 57 * @param value the new value for the key 59 virtual void sizeValueChanged(const std::string &key, size_t) { in sizeValueChanged() argument 61 " a size value", key in sizeValueChanged() 69 ssizeValueChanged(const std::string &key, ssize_t) ssizeValueChanged() argument 79 floatValueChanged(const std::string &key, float) floatValueChanged() argument 88 stringValueChanged(const std::string &key, const char *) stringValueChanged() argument 109 validateBool(const std::string &key, bool) validateBool() argument 121 validateSize(const std::string &key, size_t) validateSize() argument 133 validateSSize(const std::string &key, ssize_t) validateSSize() argument 145 validateFloat(const std::string &key, float) validateFloat() argument 157 validateString(const std::string &key, const char *) validateString() argument 184 validateSize(const std::string &key, size_t value) validateSize() argument 189 validateSSize(const std::string &key, ssize_t value) validateSSize() argument 218 validateFloat(const std::string &key, float value) validateFloat() argument 240 validateString(const std::string &key, const char *value) validateString() argument [all...] |
H A D | configuration.cc | 40 std::string Configuration::getString(const std::string &key) const { in getString() 45 if ((iter = attributes.find(key)) == attributes.end()) { in getString() 55 bool Configuration::getBool(const std::string &key) const { in getBool() 60 if ((iter = attributes.find(key)) == attributes.end()) { in getBool() 67 float Configuration::getFloat(const std::string &key) const { in getFloat() 72 if ((iter = attributes.find(key)) == attributes.end()) { in getFloat() 79 size_t Configuration::getInteger(const std::string &key) const { in getInteger() 84 if ((iter = attributes.find(key)) == attributes.end()) { in getInteger() 91 ssize_t Configuration::getSignedInteger(const std::string &key) const { in getSignedInteger() 96 if ((iter = attributes.find(key)) in getSignedInteger() 144 setParameter(const std::string &key, bool value) setParameter() argument 164 setParameter(const std::string &key, size_t value) setParameter() argument 189 setParameter(const std::string &key, ssize_t value) setParameter() argument 214 setParameter(const std::string &key, float value) setParameter() argument 236 setParameter(const std::string &key, const std::string &value) setParameter() argument 245 setParameter(const std::string &key, const char *value) setParameter() argument 274 addValueChangedListener(const std::string &key, ValueChangedListener *val) addValueChangedListener() argument 282 setValueValidator(const std::string &key, ValueChangedValidator *validator) setValueValidator() argument 321 std::stringstream key; addStats() local [all...] |
/3.0.3-GA/ep-engine/management/ |
H A D | mc_bin_server.py | 59 format, the key, and the data. 61 Return (hdrTuple, key, data)""" 66 key=data[hdrSize:keylen+hdrSize] 67 assert len(key) == keylen, "len(%s) == %d, expected %d" \ 68 % (key, len(key), keylen) 70 return hdr, key, val 84 hdrs, key, val=self._splitKeys(EXTRA_HDR_FMTS.get(cmd, ''), 87 return self.handlers.get(cmd, self.handle_unknown)(cmd, hdrs, key, 90 def handle_noop(self, cmd, hdrs, key, ca [all...] |
/3.0.3-GA/testrunner/lib/ |
H A D | mc_bin_server.py | 60 format, the key, and the data. 62 Return (hdrTuple, key, data)""" 67 key = data[hdrSize:keylen + hdrSize] 68 assert len(key) == keylen, "len(%s) == %d, expected %d" \ 69 % (key, len(key), keylen) 71 return hdr, key, val 85 hdrs, key, val = self._splitKeys(EXTRA_HDR_FMTS.get(cmd, ''), 88 return self.handlers.get(cmd, self.handle_unknown)(cmd, hdrs, key, 91 def handle_noop(self, cmd, hdrs, key, ca [all...] |
H A D | mc_bin_client.py | 65 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 66 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 69 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 73 cmd, len(key), len(extraHeader), dtype, vbucketId, 74 len(key) + len(extraHeader) + len(val), opaque, cas) 77 self.s.send(msg + extraHeader + key + val) 124 def _doCmd(self, cmd, key, val, extraHeader='', cas=0): 127 self._sendCmd(cmd, key, val, opaque, extraHeader, cas) 130 def _mutate(self, cmd, key, exp, flags, cas, val): 131 return self._doCmd(cmd, key, va [all...] |
/3.0.3-GA/moxi/libmemcached/libmemcached/ |
H A D | stats.c | 40 static memcached_return_t set_data(memcached_stat_st *memc_stat, char *key, char *value) in set_data() argument 43 if (strlen(key) < 1) in set_data() 45 WATCHPOINT_STRING(key); in set_data() 48 else if (!strcmp("pid", key)) in set_data() 52 else if (!strcmp("uptime", key)) in set_data() 56 else if (!strcmp("time", key)) in set_data() 60 else if (!strcmp("version", key)) in set_data() 65 else if (!strcmp("pointer_size", key)) in set_data() 69 else if (!strcmp("rusage_user", key)) in set_data() 78 else if (!strcmp("rusage_system", key)) in set_data() 172 memcached_stat_get_value(const memcached_st *ptr, memcached_stat_st *memc_stat, const char *key, memcached_return_t *error) memcached_stat_get_value() argument 364 char *key, *value; ascii_stats_fetch() local [all...] |
H A D | memcached.hpp | 226 * @param[in] key key of object to fetch 230 memcached_return_t fetch(std::string &key, in fetch() argument 244 key.assign(ret_key); in fetch() 258 * @param[in] key key of object whose value to get 263 bool get(const std::string &key, in get() argument 270 if (key.empty()) in get() 272 throw(Error("the key supplied is empty!", false)); in get() 274 char *value= memcached_get(&memc, key in get() 298 getByKey(const std::string &master_key, const std::string &key, std::vector<char> &ret_val) getByKey() argument 378 set(const std::string &key, const std::vector<char> &value, time_t expiration, uint32_t flags) set() argument 405 setByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value, time_t expiration, uint32_t flags) setByKey() argument 505 increment(const std::string &key, uint32_t offset, uint64_t *value) increment() argument 526 decrement(const std::string &key, uint32_t offset, uint64_t *value) decrement() argument 548 add(const std::string &key, const std::vector<char> &value) add() argument 570 addByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value) addByKey() argument 599 replace(const std::string &key, const std::vector<char> &value) replace() argument 622 replaceByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value) replaceByKey() argument 650 prepend(const std::string &key, const std::vector<char> &value) prepend() argument 672 prependByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value) prependByKey() argument 702 append(const std::string &key, const std::vector<char> &value) append() argument 728 appendByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value) appendByKey() argument 758 cas(const std::string &key, const std::vector<char> &value, uint64_t cas_arg) cas() argument 782 casByKey(const std::string &master_key, const std::string &key, const std::vector<char> &value, uint64_t cas_arg) casByKey() argument 810 remove(const std::string &key) remove() argument 827 remove(const std::string &key, time_t expiration) remove() argument 848 removeByKey(const std::string &master_key, const std::string &key) removeByKey() argument 872 removeByKey(const std::string &master_key, const std::string &key, time_t expiration) removeByKey() argument [all...] |
/3.0.3-GA/moxi/t/ |
H A D | binary.t | 61 my ($key, $orig_flags, $orig_val) = @_; 62 my ($flags, $val, $cas) = $mc->get($key); 68 my ($key, $exp, $orig_flags, $orig_value) = @_; 69 $mc->set($key, $orig_value, $orig_flags, $exp); 70 $check->($key, $orig_flags, $orig_value); 74 my $key = shift; 75 my $rv =()= eval { $mc->get($key) }; 81 my ($key, $when) = @_; 82 $mc->delete($key, $when); 83 $empty->($key); [all...] |
H A D | stress-memcached.pl | 61 my $key = key($i); 62 my $set = $memc->set($key, $key); 68 my $key = key($rand); 74 $memc->add($key, $key, $exp); 77 $memc->delete($key); 80 $memc->set($key, 96 sub key { global() subroutine [all...] |
H A D | mc_bin_client.py | 51 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 54 cmd, len(key), len(extraHeader), dtype, self.vbucketId, 55 len(key) + len(extraHeader) + len(val), opaque, cas) 56 self.s.send(msg + extraHeader + key + val) 83 def _doCmd(self, cmd, key, val, extraHeader='', cas=0): 86 self._sendCmd(cmd, key, val, opaque, extraHeader, cas) 89 def _mutate(self, cmd, key, exp, flags, cas, val): 90 return self._doCmd(cmd, key, val, struct.pack(SET_PKT_FMT, flags, exp), 93 def _cat(self, cmd, key, cas, val): 94 return self._doCmd(cmd, key, va [all...] |
/3.0.3-GA/testrunner/unittests/ |
H A D | awareness.py | 21 key = str(uuid.uuid4()) variable 22 vm.memcached(key).set(key, 0, 0, "hi") 23 vm.memcached(key).get(key) 33 key = str(uuid.uuid4()) variable 34 cm.set(key, 0, 0, "hi") 35 cm.get(key) 40 key = str(uuid.uuid4()) variable 41 cm1.set(key, 46 key = str(uuid.uuid4()) global() variable 51 key = str(uuid.uuid4()) global() variable 56 key = str(uuid.uuid4()) global() variable [all...] |
/3.0.3-GA/couchstore/src/views/ |
H A D | keys.c | 15 view_btree_key_t **key) in decode_view_btree_key() 57 *key = k; in decode_view_btree_key() 67 couchstore_error_t encode_view_btree_key(const view_btree_key_t *key, in encode_view_btree_key() argument 75 sz += key->json_key.size; in encode_view_btree_key() 76 sz += key->doc_id.size; in encode_view_btree_key() 83 enc_uint16(key->json_key.size, &b); in encode_view_btree_key() 85 memcpy(b, key->json_key.buf, key->json_key.size); in encode_view_btree_key() 86 b += key->json_key.size; in encode_view_btree_key() 88 memcpy(b, key in encode_view_btree_key() 13 decode_view_btree_key(const char *bytes, size_t len, view_btree_key_t **key) decode_view_btree_key() argument 103 free_view_btree_key(view_btree_key_t *key) free_view_btree_key() argument 115 decode_view_id_btree_key(const char *bytes, size_t len, view_id_btree_key_t **key) decode_view_id_btree_key() argument 153 encode_view_id_btree_key(const view_id_btree_key_t *key, char **buffer, size_t *buffer_size) encode_view_id_btree_key() argument 186 free_view_id_btree_key(view_id_btree_key_t *key) free_view_id_btree_key() argument [all...] |
/3.0.3-GA/couchdbx-app/Couchbase Server/ |
H A D | dictionary.c | 35 /** Invalid key token */ 84 @brief Compute the hash key for a string. 85 @param key Character string to use for key. 90 The key is stored anyway in the struct so that collision can be avoided 91 by comparing the key itself in last resort. 94 unsigned dictionary_hash(const char * key) in dictionary_hash() argument 100 len = strlen(key); in dictionary_hash() 102 hash += (unsigned)key[i] ; in dictionary_hash() 135 d->key in dictionary_new() 181 dictionary_get(dictionary * d, char * key, char * def) dictionary_get() argument 227 dictionary_set(dictionary * d, const char * key, const char * val) dictionary_set() argument 295 dictionary_unset(dictionary * d, char * key) dictionary_unset() argument [all...] |
H A D | iniparser.c | 109 dictionary: a section name is given as "section" whereas a key is 110 stored as "section:key", thus the test looks for entries that do not 127 if (d->key[i]==NULL) in iniparser_getnsec() 129 if (strchr(d->key[i], ':')==NULL) { in iniparser_getnsec() 158 if (d->key[i]==NULL) in iniparser_getsecname() 160 if (strchr(d->key[i], ':')==NULL) { in iniparser_getsecname() 169 return d->key[i] ; in iniparser_getsecname() 191 if (d->key[i]==NULL) in iniparser_dump() 194 fprintf(f, "[%s]=[%s]\n", d->key[i], d->val[i]); in iniparser_dump() 196 fprintf(f, "[%s]=UNDEF\n", d->key[ in iniparser_dump() 268 iniparser_getstring(dictionary * d, char * key, char * def) iniparser_getstring() argument 308 iniparser_getint(dictionary * d, char * key, int notfound) iniparser_getint() argument 330 iniparser_getdouble(dictionary * d, char * key, double notfound) iniparser_getdouble() argument 371 iniparser_getboolean(dictionary * d, char * key, int notfound) iniparser_getboolean() argument 455 iniparser_line( char * input_line, char * section, char * key, char * value) iniparser_line() argument 535 char key [ASCIILINESZ+1] ; iniparser_load() local [all...] |
/3.0.3-GA/couchdb/test/python/set_view/ |
H A D | replica_index.py | 150 all_keys[row["key"]] = row["value"] 151 for key in xrange(5, doc_count, self._params["nparts"]): 152 self.assertFalse(key in all_keys, "Key from partition 4 not in view result") 153 for key in xrange(6, doc_count, self._params["nparts"]): 154 self.assertFalse(key in all_keys, "Key from partition 5 not in view result") 155 for key in xrange(7, doc_count, self._params["nparts"]): 156 self.assertFalse(key in all_keys, "Key from partition 6 not in view result") 157 for key in xrange(8, doc_count, self._params["nparts"]): 158 self.assertFalse(key in all_keys, "Key from partition 7 not in view result") 165 self.assertTrue(red_view_result_nogroup["rows"][0]["key"] i [all...] |
H A D | update_cleanup.py | 92 all_keys[r["key"]] = True 94 for key in xrange(1, self._params["ndocs"], self._params["nparts"]): 95 self.assertFalse(key in all_keys, "Key %d (partition 1) not in query result after update+cleanup" % key) 96 for key in xrange(2, self._params["ndocs"], self._params["nparts"]): 97 self.assertTrue(key in all_keys, "Key %d (partition 2) in query result after update+cleanup" % key) 98 for key in xrange(3, self._params["ndocs"], self._params["nparts"]): 99 self.assertTrue(key in all_keys, "Key %d (partition 3) in query result after update+cleanup" % key) [all...] |
/3.0.3-GA/couchstore/tests/ |
H A D | localdoc.lua | 5 local key = "a_local_key" 11 testlib.assert_no_local_doc(key) 13 db:save_local(key, value) 16 testlib.assert_no_doc(key) 22 testlib.check_local_doc(db, key, value) 24 db:save_local(key, value2) 25 testlib.check_local_doc(db, key, value2) 27 testlib.check_local_doc(db, key, value2) 32 testlib.check_local_doc(db, key, value2) 37 db:save(key, "no [all...] |
/3.0.3-GA/couchbase-cli/ |
H A D | cb_bin_client.py | 54 def _sendCmd(self, cmd, key, val, opaque, extraHeader='', cas=0): 55 self._sendMsg(cmd, key, val, opaque, extraHeader=extraHeader, cas=cas, 58 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, 62 cmd, len(key), len(extraHeader), dtype, vbucketId, 63 len(key) + len(extraHeader) + len(val), opaque, cas) 64 self.s.send(msg + extraHeader + key + val) 100 def _doCmd(self, cmd, key, val, extraHeader='', cas=0): 103 self._sendCmd(cmd, key, val, opaque, extraHeader, cas) 106 def _mutate(self, cmd, key, exp, flags, cas, val): 107 return self._doCmd(cmd, key, va [all...] |
/3.0.3-GA/memcached/testsuite/ |
H A D | basic_engine_testsuite.c | 53 void *key = "akey"; in allocate_test() local 54 cb_assert(h1->allocate(h, NULL, &test_item, key, strlen(key), 1,1,1, in allocate_test() 66 void *key = "key"; in set_test() local 70 cb_assert(h1->allocate(h, NULL, &it, key, in set_test() 71 strlen(key), 1, 1, 0, in set_test() 88 void *key = "key"; in add_test() local 91 cb_assert(h1->allocate(h, NULL, &it, key, in add_test() 113 void *key = "key"; replace_test() local 150 void *key = "key"; append_test() local 185 void *key = "key"; prepend_test() local 221 void *key = "bkey"; store_test() local 238 void *key = "get_test_key"; get_test() local 252 void *key = "get_test_key"; expiry_test() local 270 void *key = "release_test_key"; release_test() local 285 void *key = "remove_test_key"; remove_test() local 306 void *key = "incr_test_key"; incr_test() local 324 void *key = "incr_test_key"; incr_test_main() local 346 void *key = "incr_test_key"; mt_incr_test() local 380 void *key = "decr_test_key"; decr_test() local 401 void *key = "flush_test_key"; flush_test() local 423 char *key = "get_item_info_test_key"; get_item_info_test() local 446 char *key = "item_set_cas_test_key"; item_set_cas_test() local 465 eviction_stats_handler(const char *key, const uint16_t klen, const char *val, const uint32_t vlen, const void *cookie) eviction_stats_handler() argument 491 char key[1024]; lru_test() local 513 char key[1024]; lru_test() local 551 response_handler(const void *key, uint16_t keylen, const void *ext, uint8_t extlen, const void *body, uint32_t bodylen, uint8_t datatype, uint16_t status, uint64_t cas, const void *cookie) response_handler() argument 592 void *key = "get_test_key"; touch_test() local 666 void *key = "get_test_key"; gat_test() local 742 void *key = "get_test_key"; gatq_test() local 807 void *key = "{foo:1}"; test_datatype() local [all...] |