Home
last modified time | relevance | path

Searched refs:len (Results 1 – 25 of 46) sorted by relevance

12

/memcached-1.6.32/t/
Dchunked-items.t55 my $len = 1024 * 200;
56 while ($len < 1024 * 1024) {
57 my $val = "B" x $len;
58 print $sock "set foo_$len 0 0 $len\r\n$val\r\n";
60 $len += 2048;
68 my $len = length($str);
76 my $len = length($todo);
87 $len = length($str);
97 my $len = length($str);
105 my $len = length($part);
[all …]
Dgetset.t83 my $len = 1024;
84 while ($len < 1024*1028) {
85 my $val = "B"x$len;
86 if ($len > (1024*1024)) {
88 print $sock "set foo_$len 0 0 3\r\nMOO\r\n";
90 print $sock "set foo_$len 0 0 $len\r\n$val\r\n";
92 mem_get_is($sock, "foo_$len");
94 print $sock "set foo_$len 0 0 $len\r\n$val\r\n";
97 $len += 2048;
105 my $len = 1024 * 128;
[all …]
Dlru.t22 my $len = length($too_big);
23 print $sock "set too_big 0 0 $len\r\n$too_big\r\n";
27 my $len = length($big);
28 print $sock "set big 0 0 $len\r\n$big\r\n";
38 print $sock "set item_$i 0 0 $len\r\n$big\r\n";
Dbinary-get.t16 my $len = length($blob);
17 print "len is $len\n";
18 print $sock "set $key 0 0 $len\r\n$blob\r\n";
Dissue_260.t29 my $len = length($big);
30 print $sock "set big 0 0 $len\r\n$big\r\n";
40 print $sock "set item_$i 0 0 $len\r\n$big\r\n";
/memcached-1.6.32/
Dcrc32c.c107 len >>= 1; in crc32c_zeros_op()
111 len >>= 1; in crc32c_zeros_op()
112 } while (len); in crc32c_zeros_op()
177 len--; in crc32c_hw()
241 len--; in crc32c_hw()
306 len--; in crc32c_hw()
332 len--; in crc32c_hw()
400 len--; in crc32c_sw_little()
421 len--; in crc32c_sw_little()
474 len--; in crc32c_sw_big()
[all …]
Dproxy_mutator.c170 return len; in _mut_check_strlen()
221 return len; in mut_step_c()
232 c->len = len; in mut_step_i()
348 return len; in mut_step_c()
360 c->len = len; in mut_step_i()
367 return len; in mut_step_i()
400 c->len = len; in mut_step_i()
545 c->len = len; in mut_step_i()
566 int len = c->len; in mut_step_r() local
600 c->str.len = len; in mut_step_i()
[all …]
Dxxhash.h1928 len=0; in XXH32_endian_align()
3305 XXH_ASSERT(1 <= len && len <= 3); in XXH3_len_1to3_64b()
3328 XXH_ASSERT(4 <= len && len <= 8); in XXH3_len_4to8_64b()
3344 XXH_ASSERT(8 <= len && len <= 16); in XXH3_len_9to16_64b()
3432 XXH_ASSERT(16 < len && len <= 128); in XXH3_len_17to128_64b()
3462 XXH_ASSERT(128 < len && len <= XXH3_MIDSIZE_MAX); in XXH3_len_129to240_64b()
4801 XXH_ASSERT(1 <= len && len <= 3); in XXH3_len_1to3_128b()
4830 XXH_ASSERT(4 <= len && len <= 8); in XXH3_len_4to8_128b()
4857 XXH_ASSERT(9 <= len && len <= 16); in XXH3_len_9to16_128b()
4964 XXH_ASSERT(16 < len && len <= 128); in XXH3_len_17to128_128b()
[all …]
Dproxy_inspector.c32 unsigned int len; member
45 unsigned int len; member
110 size_t len = 0; in mcp_inspector_string_c_g() local
122 return len; in mcp_inspector_string_c_g()
128 size_t len = 0; in mcp_inspector_string_i_g() local
134 c->len = len; in mcp_inspector_string_i_g()
141 return len; in mcp_inspector_string_i_g()
274 if (c->len < klen && strncmp(key, str, c->len) == 0) { in mcp_inspector_keybegin_r()
291 if (c->len == klen && strncmp(key, str, c->len) == 0) { in mcp_inspector_keyis_r()
424 c->len = len; in mcp_inspector_flagstr_i()
[all …]
Dtestapp.c800 } while (offset < len); in send_ascii_command()
1010 } while (offset < len); in safe_send()
1014 if (len == 0) { in safe_recv()
1032 } while (offset < len); in safe_recv()
1050 ptr += len; in safe_recv_packet()
1603 len = 0; in test_binary_get_impl()
1614 len += l; in test_binary_get_impl()
1667 len += len2; in test_binary_getq_impl()
1673 len += len2; in test_binary_getq_impl()
2037 size_t len; in test_binary_pipeline_hickup_chunk() local
[all …]
Dbase64.c93 size_t base64_encode(const unsigned char *src, size_t len, in base64_encode() argument
100 olen = len * 4 / 3 + 4; /* 3-byte blocks to 4-byte */ in base64_encode()
103 if (olen < len) { in base64_encode()
113 end = src + len; in base64_encode()
150 size_t base64_decode(const unsigned char *src, size_t len, in base64_decode() argument
158 for (i = 0; i < len; i++) { in base64_decode()
176 for (i = 0; i < len; i++) { in base64_decode()
Dproxy_request.c12 int len = pr->endlen; in _process_tokenize() local
513 p += len; in mcp_request_render()
572 p += len; in mcp_request_append()
616 size_t len = 0; in mcplib_request() local
813 size_t len = 0; in mcplib_request_has_flag() local
815 if (len != 1) { in mcplib_request_has_flag()
837 size_t len = 0; in mcplib_request_flag_token() local
840 if (len != 1) { in mcplib_request_flag_token()
893 size_t len = 0; in mcplib_request_flag_token_int() local
895 if (len != 1) { in mcplib_request_flag_token_int()
[all …]
Dproxy_tls.c160 const size_t len = strlen(str); in mcp_tls_send_validate() local
164 int n = SSL_write(be->ssl, str, len); in mcp_tls_send_validate()
167 if (n < 0 || n != len) { in mcp_tls_send_validate()
224 size_t len = be->write_iovs[i].iov_len; in mcp_tls_writev() local
225 size_t to_copy = len < remain ? len : remain; in mcp_tls_writev()
Dbase64.h12 size_t base64_encode(const unsigned char *src, size_t len,
14 size_t base64_decode(const unsigned char *src, size_t len,
Dcrc32c.h15 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);
Dbipbuffer.h55 unsigned char *bipbuf_peek(const bipbuf_t* me, const unsigned int len);
62 unsigned char *bipbuf_peek_all(const bipbuf_t* me, unsigned int *len);
Dproxy_luafgen.c702 size_t len = 0; in mcplib_funcgen_ready() local
805 unsigned int len = lua_rawlen(L, 3); in mcplib_rcontext_enqueue() local
806 for (int x = 0; x < len; x++) { in mcplib_rcontext_enqueue()
1437 int len = 0; in mcplib_rcontext_tls_peer_cn() local
1502 *len = end - key; in _mcp_router_shortsep()
1528 *len = end - key; in _mcp_router_longsep()
1694 if (*len == 0) { in _mcplib_router_new_check()
1750 size_t len = 0; in _mcplib_router_new_mode() local
1760 } else if (len == 1) { in _mcplib_router_new_mode()
1782 } else if (len == 1 && elen == 1) { in _mcplib_router_new_mode()
[all …]
Dtls.c23 static void print_ssl_error(char *buff, size_t len);
125 const unsigned char *ssl_get_peer_cn(conn *c, int *len) { in ssl_get_peer_cn() argument
152 *len = ASN1_STRING_length(asn1); in ssl_get_peer_cn()
253 size_t len = msg->msg_iov[i].iov_len; in ssl_sendmsg() local
254 to_copy = len < buf_remain ? len : buf_remain; in ssl_sendmsg()
271 static void print_ssl_error(char *buff, size_t len) { in print_ssl_error() argument
274 ERR_error_string_n(err, buff, len); in print_ssl_error()
Dproxy_result.c78 size_t len = 0; in mcplib_response_flag_blank() local
79 const char *flagstr = luaL_checklstring(L, 2, &len); in mcplib_response_flag_blank()
81 if (len != 1) { in mcplib_response_flag_blank()
Dproxy_ring_hash.c48 static uint64_t ketama_key_hasher(const void *key, size_t len, uint64_t seed);
70 static uint64_t ketama_key_hasher(const void *key, size_t len, uint64_t seed) { in ketama_key_hasher() argument
77 md5_append(&md5state, (unsigned char *)key, len); in ketama_key_hasher()
135 size_t len = snprintf(hashstring, hashstring_size, "%s:%s-%d", parts[0], parts[1], k); in _add_server_default() local
136 kt->continuum[*cont].point = (unsigned int) XXH3_64bits(hashstring, len); in _add_server_default()
Dproxy_lua.c864 size_t len = 0; in mcplib_pool() local
866 memcpy(p->beprefix, bepfx, len); in mcplib_pool()
867 p->beprefix[len+1] = '\0'; in mcplib_pool()
908 size_t len = 0; in mcplib_pool() local
910 if (len < 2 || len > KEY_HASH_FILTER_MAX) { in mcplib_pool()
914 memcpy(p->key_filter_conf, conf, len); in mcplib_pool()
915 p->key_filter_conf[len+1] = '\0'; in mcplib_pool()
974 key = p->key_filter(p->key_filter_conf, key, len, &len); in mcplib_pool_proxy_call_helper()
1268 size_t len; in mcplib_attach() local
1270 if (len < 1 || len > 8) { in mcplib_attach()
[all …]
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c70 len -= 2; in _mcmc_tokenize_meta()
72 len -= 1; in _mcmc_tokenize_meta()
142 if (len != NULL) { in _mcmc_token()
147 *len = e - s; in _mcmc_token()
481 while (len--) { in mcmc_toktou32()
504 while (len--) { in mcmc_toktou64()
538 len--; in mcmc_tokto32()
542 while (len--) { in mcmc_tokto32()
576 len--; in mcmc_tokto64()
580 while (len--) { in mcmc_tokto64()
[all …]
Dmcmc.h128 int mcmc_send_request(void *c, const char *request, int len, int count);
140 int mcmc_tokenize_res(const char *l, size_t len, mcmc_tokenizer_t *t);
142 const char *mcmc_token_get(const char *l, mcmc_tokenizer_t *t, int idx, int *len);
149 const char *mcmc_token_get_flag(const char *l, mcmc_tokenizer_t *t, char flag, int *len);
157 int mcmc_toktou32(const char *t, size_t len, uint32_t *out);
158 int mcmc_toktou64(const char *t, size_t len, uint64_t *out);
159 int mcmc_tokto32(const char *t, size_t len, int32_t *out);
160 int mcmc_tokto64(const char *t, size_t len, int64_t *out);
161 int _mcmc_tokenize_meta(mcmc_tokenizer_t *t, const char *line, size_t len, const int mstart, const …
163 const char *_mcmc_token(const char *line, mcmc_tokenizer_t *t, size_t token, int *len);
/memcached-1.6.32/scripts/
Dmemcached-tool148 my $len = $3;
150 read $sock, $val, $len;
151 print "add $k $flags $keyexp{$k} $len\r\n$val\r\n";
Dmemcached-automove-extstore72 if (len(history['w']) > args.window):
110 age = window_check(history, sid, 'age') / len(history['w'])
121 and excess >= len(history['w']):
131 and window_check(history, sid, 'excess_free') < len(history['w']) \
159 if (len(history['w']) >= args.window):

12