| /memcached-1.6.32/ |
| D | crc32c.c | 76 for (unsigned n = 0; n < 32; n++) in gf2_matrix_square() local 77 square[n] = gf2_matrix_times(mat, mat[n]); in gf2_matrix_square() 91 for (unsigned n = 1; n < 32; n++) { in crc32c_zeros_op() local 115 for (unsigned n = 0; n < 32; n++) in crc32c_zeros_op() local 116 even[n] = odd[n]; in crc32c_zeros_op() 125 for (unsigned n = 0; n < 256; n++) { in crc32c_zeros() local 126 zeros[0][n] = gf2_matrix_times(op, n); in crc32c_zeros() 370 for (unsigned n = 0; n < 256; n++) { in crc32c_init_sw_little() local 382 for (unsigned n = 0; n < 256; n++) { in crc32c_init_sw_little() local 443 for (unsigned n = 0; n < 256; n++) { in crc32c_init_sw_big() local [all …]
|
| D | slab_automove.c | 76 int n; in slab_automove_run() local 91 for (n = POWER_SMALLEST; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in slab_automove_run() 92 evicted_total += a->iam_after[n].evicted - a->iam_before[n].evicted; in slab_automove_run() 97 for (n = POWER_SMALLEST; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in slab_automove_run() 104 uint64_t evicted_delta = a->iam_after[n].evicted - a->iam_before[n].evicted; in slab_automove_run() 112 if (a->iam_after[n].outofmemory - a->iam_before[n].outofmemory > 0) { in slab_automove_run() 115 if (a->sam_after[n].total_pages - a->sam_before[n].total_pages > 0) { in slab_automove_run() 130 if (a->sam_after[n].free_chunks > a->sam_after[n].chunks_per_page * MIN_PAGES_FOR_RECLAIM) { in slab_automove_run() 132 *src = n; in slab_automove_run() 141 oldest = n; in slab_automove_run() [all …]
|
| D | slab_automove_extstore.c | 116 for (int n = 1; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in memcheck() local 135 int n; in slab_automove_extstore_run() local 152 for (n = POWER_SMALLEST; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in slab_automove_extstore_run() 162 if (a->iam_after[n].evicted - a->iam_before[n].evicted > 0 || in slab_automove_extstore_run() 163 a->iam_after[n].outofmemory - a->iam_before[n].outofmemory > 0) { in slab_automove_extstore_run() 167 if (a->sam_after[n].total_pages - a->sam_before[n].total_pages > 0) { in slab_automove_extstore_run() 177 wd->age = a->iam_after[n].age; in slab_automove_extstore_run() 189 if (a->sam_after[n].free_chunks > a->sam_after[n].chunks_per_page * MIN_PAGES_FOR_RECLAIM in slab_automove_extstore_run() 192 *src = n; in slab_automove_extstore_run() 198 *src = n; in slab_automove_extstore_run() [all …]
|
| D | proxy_tls.c | 102 int n = SSL_connect(be->ssl); in mcp_tls_connect() local 105 if (n == 1) { in mcp_tls_connect() 111 if (n == 0) { in mcp_tls_connect() 115 } else if (n < 0) { in mcp_tls_connect() 137 if (n == 1) { in mcp_tls_handshake() 167 if (n < 0 || n != len) { in mcp_tls_send_validate() 178 if (n < 0) { in mcp_tls_read() 190 be->rbufused += n; in mcp_tls_read() 191 return n; in mcp_tls_read() 235 if (n < 0) { in mcp_tls_writev() [all …]
|
| D | itoa_ljust.c | 87 --n; in digits() 89 return n; in digits() 92 static inline char* itoa(uint32_t u, char* p, int d, int n) { in itoa() argument 93 switch(n) { in itoa() 110 int d = 0,n; in itoa_u32() local 111 if (u >=100000000) n = digits(u, 100000000, &d, &p, 10); in itoa_u32() 112 else if (u < 100) n = digits(u, 1, &d, &p, 2); in itoa_u32() 113 else if (u < 10000) n = digits(u, 100, &d, &p, 4); in itoa_u32() 114 else if (u < 1000000) n = digits(u, 10000, &d, &p, 6); in itoa_u32() 115 else n = digits(u, 1000000, &d, &p, 8); in itoa_u32() [all …]
|
| D | proxy_ratelim.c | 19 #define TIMEVAL_TO_MILLIS(n) (n.tv_usec / 1000 + n.tv_sec * (uint64_t)1000) argument 55 lua_Integer n = 0; in _tbf_check() local 57 n = lua_tointeger(L, -1); in _tbf_check() 58 if (n < 0 || n > UINT_MAX-1) { in _tbf_check() 63 return n; in _tbf_check()
|
| D | items.c | 701 int n; in fill_item_stats_automove() local 702 for (n = 0; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in fill_item_stats_automove() 703 item_stats_automove *cur = &am[n]; in fill_item_stats_automove() 706 int i = n | HOT_LRU; in fill_item_stats_automove() 712 i = n | COLD_LRU; in fill_item_stats_automove() 734 int n; in item_stats_totals() local 735 for (n = 0; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in item_stats_totals() 739 i = n | lru_type_map[x]; in item_stats_totals() 792 int n; in item_stats() local 793 for (n = 0; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in item_stats() [all …]
|
| D | proxy_mutator.c | 64 mcp_mut_r n; // runtime length totaller member 96 mcp_mut_r n; // totaller function member 134 #define mut_step_c(n) static int mcp_mutator_##n##_c(lua_State *L, int tidx) argument 135 #define mut_step_i(n) static int mcp_mutator_##n##_i(lua_State *L, int tidx, int sc, struct mcp_mut… argument 136 #define mut_step_r(n) static int mcp_mutator_##n##_r(struct mcp_mut_run *run, struct mcp_mut_step *… argument 137 #define mut_step_n(n) static int mcp_mutator_##n##_n(struct mcp_mut_run *run, struct mcp_mut_step *… argument 160 static size_t _mut_check_strlen(lua_State *L, int tidx, const char *n) { in _mut_check_strlen() argument 163 if (lua_getfield(L, tidx, n) != LUA_TNIL) { in _mut_check_strlen() 166 proxy_lua_ferror(L, "mutator step %d: must provide '%s' argument", tidx, n); in _mut_check_strlen() 925 mut->steps[scount].n = mcp_mut_entries[st].n; in mcp_mutator_new() [all …]
|
| D | assoc.c | 34 #define hashsize(n) ((uint64_t)1<<(n)) argument 35 #define hashmask(n) (hashsize(n)-1) argument
|
| D | thread.c | 85 #define hashsize(n) ((unsigned long int)1<<(n)) argument 86 #define hashmask(n) (hashsize(n)-1) argument 340 if (write(t->n.notify_event_fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in notify_worker() 346 if (write(t->n.notify_send_fd, buf, 1) != 1) { in notify_worker() 437 setup_thread_notify(me, &me->n, thread_libevent_process); in setup_thread() 1136 memcached_thread_notify_init(&threads[i].n); in memcached_thread_init()
|
| D | proxy_request.c | 195 char *n = NULL; in _process_request_mset() local 196 int vlen = strtol(cur, &n, 10); in _process_request_mset() 197 if ((errno == ERANGE) || (cur == n)) { in _process_request_mset() 250 char *n = NULL; in _process_request_storage() local 253 int vlen = strtol(cur, &n, 10); in _process_request_storage() 254 if ((errno == ERANGE) || (cur == n)) { in _process_request_storage() 965 lua_Integer n = lua_tointegerx(L, idx, &isnum); in _mcp_request_check_flag_token() local 967 char *end = itoa_64(n, tostring); in _mcp_request_check_flag_token()
|
| D | md5.c | 197 #define ROTATE_LEFT(x, n) (((x) << (n)) | ((x) >> (32 - (n)))) in md5_process() argument
|
| D | slabs.c | 529 int n; in fill_slab_stats_automove() local 531 for (n = 0; n < MAX_NUMBER_OF_SLAB_CLASSES; n++) { in fill_slab_stats_automove() 532 slabclass_t *p = &slabclass[n]; in fill_slab_stats_automove() 533 slab_stats_automove *cur = &am[n]; in fill_slab_stats_automove()
|
| D | xxhash.h | 920 # define XXH_ALIGN(n) alignas(n) argument 922 # define XXH_ALIGN(n) __attribute__ ((aligned(n))) argument 924 # define XXH_ALIGN(n) __declspec(align(n)) argument 926 # define XXH_ALIGN(n) /* disabled */ argument 4208 size_t n; in XXH3_accumulate() local 4209 for (n = 0; n < nbStripes; n++ ) { in XXH3_accumulate() 4210 const xxh_u8* const in = input + n*XXH_STRIPE_LEN; in XXH3_accumulate() 4214 secret + n*XXH_SECRET_CONSUME_RATE); in XXH3_accumulate() 4229 size_t n; in XXH3_hashLong_internal_loop() local 4233 for (n = 0; n < nb_blocks; n++) { in XXH3_hashLong_internal_loop() [all …]
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 170 char *n = NULL; in _mcmc_parse_value_line() local 172 uint32_t flags = strtoul(p, &n, 10); in _mcmc_parse_value_line() 173 if ((errno == ERANGE) || (p == n) || (*n != ' ')) { in _mcmc_parse_value_line() 176 p = n; in _mcmc_parse_value_line() 179 uint32_t bytes = strtoul(p, &n, 10); in _mcmc_parse_value_line() 180 if ((errno == ERANGE) || (p == n)) { in _mcmc_parse_value_line() 183 p = n; in _mcmc_parse_value_line() 187 if (*n == ' ') { in _mcmc_parse_value_line() 189 cas = strtoull(p, &n, 10); in _mcmc_parse_value_line() 349 cur = n; in _mcmc_parse_response() [all …]
|
| /memcached-1.6.32/t/ |
| D | proxyrctxtimeout.lua | 21 fgen:ready({ n = "cond_timeout", f = function(rctx) function 51 fgen:ready({ n = "enqueue_timeout", f = function(rctx) function 80 fgen:ready({ n = "handle_timeout", f = function(rctx) function 107 fgen:ready({ n = "wait_more", f = function(rctx) function 128 fgen:ready({ n = "wait_double", f = function(rctx) function 151 fgen:ready({ n = "sleep", f = function(rctx) function
|
| D | stress-memcached.pl | 97 my $n = shift; 98 $_ = sprintf("%04d", $n); 99 if ($n % 2) { $_ .= "a"x20; }
|
| D | proxyins.lua | 40 n = "sepkey", f = function(rctx) function 93 n = "reshasflag", f = function(rctx) function 126 n = "reqkey", f = function(rctx) function 138 n = "intres", f = function(rctx) function
|
| D | proxymut.lua | 54 n = "mgtest", f = function(rctx) function 89 n = "mstest", f = function(rctx) function
|
| D | proxyfuncgen.lua | 73 fgen:ready({ f = func, a = o, n = arg.name}) 90 fgen:ready({ f = prefix_factory_gen, a = o, n = arg.name }) 115 fgen:ready({ f = direct_factory_gen, a = h, n = arg.name }) 131 fgen:ready({ f = locality_factory_gen, a = h, n = arg.name }) 312 fgen:ready({ f = blocker_factory_gen, a = o, n = arg.name }) 503 fgen:ready({ f = func, n = name }) 548 fgen:ready({ f = split_factory_gen, a = o, n = name })
|
| D | proxydepthlim.lua | 15 n = "depth", f = function(rctx) function
|
| D | proxymatch.lua | 13 n = "match", f = function(rctx) function
|
| D | proxyslotcache.lua | 15 fgen:ready({ n = "foo", f = function(rctx) function
|
| /memcached-1.6.32/doc/ |
| D | protocol.txt | 302 "END\r\n" 481 EN\r\n 537 EN\r\n 961 "mn\r\n" 965 "MN\r\n" 1225 byte, ie: "n%2Cfoo" for "n,foo". 1288 END\r\n 1546 END\r\n 1629 END\r\n 1680 END\r\n [all …]
|
| /memcached-1.6.32/scripts/ |
| D | memcached-tool | 263 foreach my $n (1..$max) { 264 my $it = $items{$n}; 271 $n, $size, $it->{age}, $it->{total_pages},
|