| /memcached-1.6.32/ |
| D | jenkins_hash.c | 126 uint32_t jenkins_hash( in jenkins_hash() 259 a += ((uint32_t)k[1])<<8; in jenkins_hash() 260 a += ((uint32_t)k[2])<<16; in jenkins_hash() 263 b += ((uint32_t)k[5])<<8; in jenkins_hash() 267 c += ((uint32_t)k[9])<<8; in jenkins_hash() 308 uint32_t a,b,c; in jenkins_hash() 391 a += ((uint32_t)k[2])<<8; in jenkins_hash() 392 a += ((uint32_t)k[3]); in jenkins_hash() 395 b += ((uint32_t)k[6])<<8; in jenkins_hash() 396 b += ((uint32_t)k[7]); in jenkins_hash() [all …]
|
| D | murmur3_hash.c | 33 static inline uint32_t rotl32 ( uint32_t x, int8_t r ) in rotl32() 48 static FORCE_INLINE uint32_t getblock32 ( const uint32_t * p, int i ) in getblock32() 56 static FORCE_INLINE uint32_t fmix32 ( uint32_t h ) in fmix32() 71 uint32_t MurmurHash3_x86_32 ( const void * key, size_t length) in MurmurHash3_x86_32() 76 uint32_t h1 = 0; in MurmurHash3_x86_32() 78 uint32_t c1 = 0xcc9e2d51; in MurmurHash3_x86_32() 79 uint32_t c2 = 0x1b873593; in MurmurHash3_x86_32() 84 const uint32_t * blocks = (const uint32_t *)(data + nblocks*4); in MurmurHash3_x86_32() 88 uint32_t k1 = getblock32(blocks,i); in MurmurHash3_x86_32() 104 uint32_t k1 = 0; in MurmurHash3_x86_32()
|
| D | crc32c.c | 52 uint32_t crc32c_sw_little(uint32_t crc, void const *buf, size_t len); 53 uint32_t crc32c_sw_big(uint32_t crc, void const *buf, size_t len); 62 static inline uint32_t gf2_matrix_times(uint32_t *mat, uint32_t vec) { in gf2_matrix_times() 63 uint32_t sum = 0; in gf2_matrix_times() 75 static inline void gf2_matrix_square(uint32_t *square, uint32_t *mat) { in gf2_matrix_square() 122 uint32_t op[32]; in crc32c_zeros() 134 static inline uint32_t crc32c_shift(uint32_t zeros[][256], uint32_t crc) { in crc32c_shift() 161 static uint32_t crc32c_hw(uint32_t crc, void const *buf, size_t len) { in crc32c_hw() 285 static inline uint32_t crc32cx(uint32_t crc, const uint64_t data) in crc32cx() 292 static inline uint32_t crc32cb(uint32_t crc, const uint8_t data) in crc32cb() [all …]
|
| D | items.h | 20 int do_item_link(item *it, const uint32_t hv, const uint64_t cas); /** may fail if transgresse… 21 void do_item_unlink(item *it, const uint32_t hv); 22 void do_item_unlink_nolock(item *it, const uint32_t hv); 26 int do_item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas); 30 unsigned int do_get_lru_size(uint32_t id); 44 uint32_t hv; 69 uint32_t age; 73 item *do_item_get(const char *key, const size_t nkey, const uint32_t hv, LIBEVENT_THREAD *t, const … 74 item *do_item_touch(const char *key, const size_t nkey, uint32_t exptime, const uint32_t hv, LIBEVE… 75 void do_item_bump(LIBEVENT_THREAD *t, item *it, const uint32_t hv);
|
| D | protocol_binary.h | 159 uint32_t bodylen; 160 uint32_t opaque; 178 uint32_t bodylen; 179 uint32_t opaque; 223 uint32_t flags; 255 uint32_t expiration; 275 uint32_t flags; 276 uint32_t expiration; 315 uint32_t expiration; 396 uint32_t expiration; [all …]
|
| D | crc32c.h | 15 typedef uint32_t (*crc_func)(uint32_t crc, const void *buf, size_t len); 21 uint32_t crc32c_sw(uint32_t crc, void const *buf, size_t len);
|
| D | itoa_ljust.c | 83 static inline int digits( uint32_t u, unsigned k, int* d, char** p, int n ) { in digits() 92 static inline char* itoa(uint32_t u, char* p, int d, int n) { in itoa() 109 char* itoa_u32(uint32_t u, char* p) { in itoa_u32() 120 uint32_t u = i; in itoa_32() 131 uint32_t lower = (uint32_t)u; in itoa_u64()
|
| D | memcached.h | 96 typedef uint32_t client_flags_t; 552 uint32_t sock_cookie_id; 930 uint32_t busy_items; 931 uint32_t rescues; 932 uint32_t evictions_nomem; 933 uint32_t inline_reclaim; 934 uint32_t chunk_rescues; 935 uint32_t busy_deletes; 936 uint32_t busy_loops; 1015 void item_lock(uint32_t hv); [all …]
|
| D | assoc.h | 4 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv); 5 int assoc_insert(item *item, const uint32_t hv); 6 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv);
|
| D | proxy_ratelim.c | 7 uint32_t bucket; 8 uint32_t limit; 9 uint32_t fill_rate; // tokens to add per tick rate 10 uint32_t tick_rate; // in milliseconds 106 uint32_t toadd = delta / lim->tick_rate; in _update_tbf()
|
| D | hash.c | 11 static uint32_t XXH3_hash(const void *key, size_t length) { in XXH3_hash() 12 return (uint32_t)XXH3_64bits(key, length); in XXH3_hash()
|
| D | slab_automove_extstore.c | 28 uint32_t window_size; 29 uint32_t window_cur; 30 uint32_t item_size; 42 uint32_t window_size = settings->slab_automove_window; in slab_automove_extstore_init() 75 uint32_t size) { in window_sum()
|
| D | crawler.c | 39 typedef void (*crawler_eval_func)(crawler_module_t *cm, item *it, uint32_t hv, int slab_cls); 64 static void crawler_expired_eval(crawler_module_t *cm, item *search, uint32_t hv, int i); 76 static void crawler_metadump_eval(crawler_module_t *cm, item *search, uint32_t hv, int i); 89 static void crawler_mgdump_eval(crawler_module_t *cm, item *search, uint32_t hv, int i); 270 static void crawler_metadump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_metadump_eval() 326 static void crawler_mgdump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_mgdump_eval() 570 uint32_t hv = hash(ITEM_key(search), search->nkey); in item_crawler_thread() 700 static int do_lru_crawler_start(uint32_t id, uint32_t remaining) { in do_lru_crawler_start() 701 uint32_t sid = id; in do_lru_crawler_start() 757 int lru_crawler_start(uint8_t *ids, uint32_t remaining, in lru_crawler_start() [all …]
|
| D | slab_automove.c | 25 uint32_t window_size; 26 uint32_t window_cur; 35 uint32_t window_size = settings->slab_automove_window; in slab_automove_init() 61 static void window_sum(struct window_data *wd, struct window_data *w, uint32_t size) { in window_sum()
|
| D | thread.c | 83 static uint32_t item_lock_count; 117 void item_lock(uint32_t hv) { in item_lock() 121 void *item_trylock(uint32_t hv) { in item_trylock() 133 void item_unlock(uint32_t hv) { in item_unlock() 880 uint32_t hv; in item_get() 899 item *item_touch(const char *key, size_t nkey, uint32_t exptime, LIBEVENT_THREAD *t) { in item_touch() 901 uint32_t hv; in item_touch() 914 uint32_t hv; in item_remove() 935 uint32_t hv; in item_unlink() 950 uint32_t hv; in add_delta() [all …]
|
| D | logger.h | 77 uint32_t latime; 86 uint32_t latime; 134 uint32_t reqlen;
|
| D | assoc.c | 70 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv) { in assoc_find() 103 static item** _hashitem_before (const char *key, const size_t nkey, const uint32_t hv) { in _hashitem_before() 153 int assoc_insert(item *it, const uint32_t hv) { in assoc_insert() 172 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv) { in assoc_delete()
|
| D | proxy.h | 219 uint32_t flap_backoff_max; // don't backoff longer than this. 296 typedef uint32_t (*hash_selector_func)(uint64_t hash, void *ctx); 335 uint32_t parsed; // how far into the request we parsed already 336 uint32_t reqlen; // full length of request buffer. 337 uint32_t endlen; // index to the start of \r\n or \n 339 uint32_t klen; // length of key. 358 uint32_t gen; 359 uint32_t next; 360 uint32_t every;
|
| D | murmur3_hash.h | 15 uint32_t MurmurHash3_x86_32(const void *key, size_t length);
|
| D | jenkins_hash.h | 8 uint32_t jenkins_hash(const void *key, size_t length);
|
| D | hash.h | 4 typedef uint32_t (*hash_func)(const void *key, size_t length);
|
| D | itoa_ljust.h | 23 char* itoa_u32(uint32_t u, char* buffer);
|
| D | storage.c | 157 uint32_t crc2; in _storage_get_item_cb() 158 uint32_t crc = (uint32_t) read_it->exptime; in _storage_get_item_cb() 194 uint32_t body_len = ntohl(header->response.bodylen); in _storage_get_item_cb() 429 uint32_t hv = (uint32_t)it->time; in recache_or_free() 769 uint32_t *page_id, uint64_t *page_version, in storage_compact_check() 904 uint32_t page_id, uint64_t page_version, uint32_t page_offset, uint64_t read_size) { in storage_compact_readback() 923 uint32_t hv = (uint32_t)it->time; in storage_compact_readback() 1061 uint32_t page_offset = 0; in storage_compact_thread() 1062 uint32_t page_id = 0; in storage_compact_thread()
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.h | 85 uint32_t flags; 143 int mcmc_token_get_u32(const char *l, mcmc_tokenizer_t *t, int idx, uint32_t *val); 150 int mcmc_token_get_flag_u32(const char *l, mcmc_tokenizer_t *t, char flag, uint32_t *val); 157 int mcmc_toktou32(const char *t, size_t len, uint32_t *out);
|
| D | mcmc.c | 39 uint32_t status_flags; // internal only flags. 172 uint32_t flags = strtoul(p, &n, 10); in _mcmc_parse_value_line() 179 uint32_t bytes = strtoul(p, &n, 10); in _mcmc_parse_value_line() 336 uint32_t vsize = strtoul(cur, &n, 10); in _mcmc_parse_response() 473 MCMC_STATIC int mcmc_toktou32(const char *t, size_t len, uint32_t *out) { in mcmc_toktou32() 474 uint32_t sum = 0; in mcmc_toktou32() 484 uint32_t lim = (UINT32_MAX - num) / 10; in mcmc_toktou32() 639 X(mcmc_token_get_u32, uint32_t, mcmc_toktou32) in X() argument 682 int mcmc_token_get_flag_u32(const char *l, mcmc_tokenizer_t *t, char flag, uint32_t *val) { in mcmc_token_get_flag_u32()
|