Home
last modified time | relevance | path

Searched refs:vlen (Results 1 – 20 of 20) sorted by relevance

/memcached-1.6.32/
Dproxy_request.c201 if (vlen < 0 || vlen > (INT_MAX - 2)) { in _process_request_mset()
206 pr->vlen = vlen; in _process_request_mset()
258 if (vlen < 0 || vlen > (INT_MAX - 2)) { in _process_request_storage()
263 pr->vlen = vlen; in _process_request_storage()
541 int vlen = pr->vlen; in mcp_request_render() local
549 pr->vlen = vlen; in mcp_request_render()
580 int vlen = pr->vlen; in mcp_request_append() local
588 pr->vlen = vlen; in mcp_request_append()
639 vlen = rq->pr.vlen; in mcplib_request()
653 rq->pr.vlen = vlen; in mcplib_request()
[all …]
Dproto_bin.c763 c->rlbytes = vlen; in process_bin_sasl_auth()
794 if (vlen > ((item*) c->item)->nbytes) { in process_bin_complete_sasl_auth()
818 challenge, vlen, in process_bin_complete_sasl_auth()
1083 int vlen; in process_bin_update() local
1130 c->sbytes = vlen; in process_bin_update()
1184 c->rlbytes = vlen; in process_bin_update()
1192 int vlen; in process_bin_append_prepend() local
1209 it = item_alloc(key, nkey, 0, 0, vlen+2); in process_bin_append_prepend()
1212 if (! item_size_ok(nkey, 0, vlen + 2)) { in process_bin_append_prepend()
1217 c->sbytes = vlen; in process_bin_append_prepend()
[all …]
Dproxy_mutator.c131 size_t vlen; // length of the actual value buffer. member
791 run->vlen = srq->pr.vlen; in mut_step_n()
811 run->vbuf = lua_tolstring(L, idx, &run->vlen); in mut_step_n()
829 const char *e = itoa_u64(run->vlen, temp); in mut_step_n()
837 run->d_pos = itoa_u64(run->vlen-2, run->d_pos); in mut_step_r()
1022 rq->pr.vbuf = malloc(run->vlen); in mcp_mut_run()
1027 t->proxy_buffer_memory_used += rq->pr.vlen; in mcp_mut_run()
1030 rq->pr.vlen = run->vlen; in mcp_mut_run()
1031 memcpy(rq->pr.vbuf, run->vbuf, run->vlen); in mcp_mut_run()
1056 memcpy(run->d_pos, run->vbuf, run->vlen); in mcp_mut_run()
[all …]
Dproto_text.c1437 if (vlen < 0 || vlen > (INT_MAX - 2)) { in process_mset_command()
1441 vlen += 2; in process_mset_command()
1601 c->sbytes = vlen; in process_mset_command()
1897 size_t vlen = strlen(tmpbuf); in process_marithmetic_command() local
1900 p = itoa_u32(vlen, p+3); in process_marithmetic_command()
1950 memcpy(p, tmpbuf, vlen); in process_marithmetic_command()
1951 p += vlen; in process_marithmetic_command()
1999 int vlen; in process_update_command() local
2032 if (vlen < 0 || vlen > (INT_MAX - 2)) { in process_update_command()
2036 vlen += 2; in process_update_command()
[all …]
Dproxy_result.c44 if (r->resp.vlen >= 2) { in mcplib_response_vlen()
45 lua_pushinteger(L, r->resp.vlen-2); in mcplib_response_vlen()
Dproxy_internal.c351 it = item_alloc(key, nkey, flags, exptime, pr->vlen); in process_update_cmd()
355 if (! item_size_ok(nkey, flags, pr->vlen)) { in process_update_cmd()
1065 int vlen = pr->vlen; // value from data line. in process_mset_cmd() local
1502 int vlen = strlen(tmpbuf); in process_marithmetic_cmd() local
1504 it = item_alloc(key, nkey, 0, 0, vlen+2); in process_marithmetic_cmd()
1506 memcpy(ITEM_data(it), tmpbuf, vlen); in process_marithmetic_cmd()
1507 memcpy(ITEM_data(it) + vlen, "\r\n", 2); in process_marithmetic_cmd()
1543 size_t vlen = strlen(tmpbuf); in process_marithmetic_cmd() local
1546 p = itoa_u32(vlen, p+3); in process_marithmetic_cmd()
1596 memcpy(p, tmpbuf, vlen); in process_marithmetic_cmd()
[all …]
Dproto_proxy.c720 if (strncmp((char *)c->item + rq->pr.vlen - 2, "\r\n", 2) != 0) { in complete_nread_proxy()
738 thr->proxy_buffer_memory_used += rq->pr.vlen; in complete_nread_proxy()
1162 if (pr.vlen != 0) { in proxy_process_command()
1163 c->sbytes = pr.vlen; in proxy_process_command()
1173 if (pr.vlen != 0) { in proxy_process_command()
1174 c->sbytes = pr.vlen; in proxy_process_command()
1195 if (pr.vlen != 0) { in proxy_process_command()
1203 c->item = malloc(pr.vlen); in proxy_process_command()
1212 c->sbytes = pr.vlen; in proxy_process_command()
1218 c->rlbytes = pr.vlen; in proxy_process_command()
Drestart.c274 int vlen = vsnprintf(valbuf, SET_VAL_MAX-1, fmt, ap); in restart_set_kv() local
279 if (vlen >= SET_VAL_MAX) { in restart_set_kv()
Dmemcached.h164 vlen = snprintf(val_str, STAT_VAL_LEN, fmt, val); \
165 add_stats(key_str, klen, val_str, vlen, c);
192 const char *val, const uint32_t vlen,
1068 const char *val, const uint32_t vlen,
Dmemcached.c1317 uint32_t bodylen = klen + vlen; in append_bin_stats()
1334 if (vlen > 0) { in append_bin_stats()
1335 memcpy(buf, val, vlen); in append_bin_stats()
1350 if (klen == 0 && vlen == 0) { in append_ascii_stats()
1352 } else if (vlen == 0) { in append_ascii_stats()
1399 if (klen == 0 && vlen > 0) { in append_stats()
1410 append_bin_stats(key, klen, val, vlen, c); in append_stats()
1416 append_ascii_stats(key, klen, val, vlen, c); in append_stats()
1754 int vlen; in append_stat() local
1766 add_stats(name, strlen(name), val_str, vlen, c); in append_stat()
[all …]
Dproxy_network.c527 assert(r->resp.vlen == 0); in proxy_backend_drive_machine()
571 r->blen = r->resp.reslen + r->resp.vlen; in proxy_backend_drive_machine()
596 …UG("%s: r->status: %d, r->bread: %d, r->vlen: %lu\n", __func__, r->status, r->bread, r->resp.vlen); in proxy_backend_drive_machine()
597 if (r->resp.vlen != r->resp.vlen_read) { in proxy_backend_drive_machine()
665 P_DEBUG("%s: [want_read] r->bread: %d vlen: %lu\n", __func__, r->bread, r->resp.vlen); in proxy_backend_drive_machine()
Dproxy_lua.c17 const char *val, const uint32_t vlen, in _mcplib_append_stats() argument
29 lua_pushlstring(L, val, vlen); in _mcplib_append_stats()
34 const char *val, const uint32_t vlen, in _mcplib_append_section_stats() argument
65 lua_pushlstring(L, val, vlen); in _mcplib_append_section_stats()
71 lua_pushlstring(L, val, vlen); in _mcplib_append_section_stats()
Dproxy.h338 int vlen; member
Dslabs.c572 int klen = 0, vlen = 0; in do_slabs_stats() local
Dstorage.c81 int klen = 0, vlen = 0; in process_extstore_stats() local
Ditems.c805 int klen = 0, vlen = 0; in item_stats() local
/memcached-1.6.32/vendor/mcmc/
Dexample.c38 if (resp.vlen != resp.vlen_read) { in show_response_buffer()
41 val = malloc(resp.vlen); in show_response_buffer()
43 size_t toread = resp.vlen - resp.vlen_read; in show_response_buffer()
Dmcmc.c197 r->vlen = bytes + 2; // add in the \r\n in _mcmc_parse_value_line()
199 if (buffer_remain >= r->vlen) { in _mcmc_parse_value_line()
200 r->vlen_read = r->vlen; in _mcmc_parse_value_line()
341 r->vlen = vsize + 2; // tag in the \r\n. in _mcmc_parse_response()
344 if (buffer_remain >= r->vlen) { in _mcmc_parse_response()
345 r->vlen_read = r->vlen; in _mcmc_parse_response()
Dmcmc.h74 size_t vlen; // reslen + vlen is the full length of the response. member
119 int32_t vlen; // length of the value if there is one member
/memcached-1.6.32/t/
Dproxyunits.lua197 local newReq = mcp.request("ms /request/a " .. res:vlen() .. "\r\n", res)
261 local vlen = res:vlen()
262 if vlen == 1 then