Lines Matching refs:p
19 #define META_SPACE(p) { \ argument
20 *p = ' '; \
21 p++; \
24 #define META_CHAR(p, c) { \ argument
25 *p = ' '; \
26 *(p+1) = c; \
27 p += 2; \
34 #define META_KEY(p, key, nkey, bin) { \ argument
35 META_CHAR(p, 'k'); \
37 memcpy(p, key, nkey); \
38 p += nkey; \
40 … p += base64_encode((unsigned char *) key, nkey, (unsigned char *)p, WRITE_BUFFER_SIZE / 2); \
41 *p = ' '; \
42 *(p+1) = 'b'; \
43 p += 2; \
58 char *p = resp->wbuf + resp->wbytes; in _finalize_mset() local
59 char *end = p; // end of the stashed data portion. in _finalize_mset()
63 memcpy(p, "HD", 2); in _finalize_mset()
70 memcpy(p, "EX", 2); in _finalize_mset()
73 memcpy(p, "NF", 2); in _finalize_mset()
76 memcpy(p, "NS", 2); in _finalize_mset()
83 p += 2; in _finalize_mset()
89 META_SPACE(p); in _finalize_mset()
91 *p = *fp; in _finalize_mset()
92 p++; in _finalize_mset()
98 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in _finalize_mset()
103 META_CHAR(p, 'c'); in _finalize_mset()
104 p = itoa_u64(cas, p); in _finalize_mset()
108 META_CHAR(p, 's'); in _finalize_mset()
111 p = itoa_u32(nbytes-2, p); in _finalize_mset()
113 p = itoa_u32(it->nbytes-2, p); in _finalize_mset()
121 memcpy(p, "\r\n", 2); in _finalize_mset()
122 p += 2; in _finalize_mset()
124 resp->wbytes = p - resp->wbuf; in _finalize_mset()
125 resp_add_iov(resp, end, p - end); in _finalize_mset()
523 char *p = suffix; in make_ascii_get_suffix() local
524 *p = ' '; in make_ascii_get_suffix()
525 p++; in make_ascii_get_suffix()
527 *p = '0'; in make_ascii_get_suffix()
528 p++; in make_ascii_get_suffix()
530 p = itoa_u64(*((client_flags_t *) ITEM_suffix(it)), p); in make_ascii_get_suffix()
532 *p = ' '; in make_ascii_get_suffix()
533 p = itoa_u32(nbytes-2, p+1); in make_ascii_get_suffix()
536 *p = ' '; in make_ascii_get_suffix()
537 p = itoa_u64(ITEM_get_cas(it), p+1); in make_ascii_get_suffix()
540 *p = '\r'; in make_ascii_get_suffix()
541 *(p+1) = '\n'; in make_ascii_get_suffix()
542 *(p+2) = '\0'; in make_ascii_get_suffix()
543 return (p - suffix) + 2; in make_ascii_get_suffix()
596 char *p = resp->wbuf; in process_get_command() local
597 memcpy(p, "VALUE ", 6); in process_get_command()
598 p += 6; in process_get_command()
599 memcpy(p, ITEM_key(it), it->nkey); in process_get_command()
600 p += it->nkey; in process_get_command()
601 p += make_ascii_get_suffix(p, it, return_cas, nbytes); in process_get_command()
602 resp_add_iov(resp, resp->wbuf, p - resp->wbuf); in process_get_command()
1089 char *p = resp->wbuf; in process_mget_command() local
1160 memcpy(p, "VA ", 3); in process_mget_command()
1161 p = itoa_u32(it->nbytes-2, p+3); in process_mget_command()
1163 memcpy(p, "HD", 2); in process_mget_command()
1164 p += 2; in process_mget_command()
1190 META_CHAR(p, 's'); in process_mget_command()
1191 p = itoa_u32(it->nbytes-2, p); in process_mget_command()
1196 META_CHAR(p, 't'); in process_mget_command()
1198 *p = '-'; in process_mget_command()
1199 *(p+1) = '1'; in process_mget_command()
1200 p += 2; in process_mget_command()
1202 p = itoa_u32(it->exptime - current_time, p); in process_mget_command()
1206 META_CHAR(p, 'c'); in process_mget_command()
1207 p = itoa_u64(ITEM_get_cas(it), p); in process_mget_command()
1210 META_CHAR(p, 'f'); in process_mget_command()
1212 *p = '0'; in process_mget_command()
1213 p++; in process_mget_command()
1215 p = itoa_u64(*((client_flags_t *) ITEM_suffix(it)), p); in process_mget_command()
1219 META_CHAR(p, 'l'); in process_mget_command()
1220 p = itoa_u32(current_time - it->time, p); in process_mget_command()
1223 META_CHAR(p, 'h'); in process_mget_command()
1225 *p = '1'; in process_mget_command()
1227 *p = '0'; in process_mget_command()
1229 p++; in process_mget_command()
1236 META_SPACE(p); in process_mget_command()
1237 memcpy(p, tokens[i].value, tokens[i].length); in process_mget_command()
1238 p += tokens[i].length; in process_mget_command()
1241 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in process_mget_command()
1250 META_CHAR(p, 'Z'); in process_mget_command()
1253 META_CHAR(p, 'X'); in process_mget_command()
1263 META_CHAR(p, 'W'); in process_mget_command()
1267 *p = '\r'; in process_mget_command()
1268 *(p+1) = '\n'; in process_mget_command()
1269 *(p+2) = '\0'; in process_mget_command()
1270 p += 2; in process_mget_command()
1272 resp_add_iov(resp, resp->wbuf, p - resp->wbuf); in process_mget_command()
1359 memcpy(p, "EN", 2); in process_mget_command()
1360 p += 2; in process_mget_command()
1369 META_SPACE(p); in process_mget_command()
1370 memcpy(p, tokens[i].value, tokens[i].length); in process_mget_command()
1371 p += tokens[i].length; in process_mget_command()
1374 META_KEY(p, key, nkey, of.key_binary); in process_mget_command()
1378 resp->wbytes = p - resp->wbuf; in process_mget_command()
1407 char *p = resp->wbuf; in process_mset_command() local
1430 p = resp->wbuf; in process_mset_command()
1469 META_SPACE(p); in process_mset_command()
1470 memcpy(p, tokens[i].value, tokens[i].length); in process_mset_command()
1471 p += tokens[i].length; in process_mset_command()
1474 META_CHAR(p, 'k'); in process_mset_command()
1478 META_CHAR(p, 'c'); in process_mset_command()
1482 META_CHAR(p, 's'); in process_mset_command()
1593 resp->wbytes = p - resp->wbuf; in process_mset_command()
1621 char *p = resp->wbuf + 2; in process_mdelete_command() local
1657 META_SPACE(p); in process_mdelete_command()
1658 memcpy(p, tokens[i].value, tokens[i].length); in process_mdelete_command()
1659 p += tokens[i].length; in process_mdelete_command()
1662 META_KEY(p, key, nkey, of.key_binary); in process_mdelete_command()
1747 resp->wbytes = p - resp->wbuf; in process_mdelete_command()
1771 char *p = resp->wbuf; in process_marithmetic_command() local
1882 memcpy(p, "NF", 2); in process_marithmetic_command()
1883 p += 2; in process_marithmetic_command()
1888 memcpy(p, "EX", 2); in process_marithmetic_command()
1889 p += 2; in process_marithmetic_command()
1899 memcpy(p, "VA ", 3); in process_marithmetic_command()
1900 p = itoa_u32(vlen, p+3); in process_marithmetic_command()
1902 memcpy(p, "HD", 2); in process_marithmetic_command()
1903 p += 2; in process_marithmetic_command()
1909 META_CHAR(p, 'c'); in process_marithmetic_command()
1910 p = itoa_u64(ITEM_get_cas(it), p); in process_marithmetic_command()
1913 META_CHAR(p, 't'); in process_marithmetic_command()
1915 *p = '-'; in process_marithmetic_command()
1916 *(p+1) = '1'; in process_marithmetic_command()
1917 p += 2; in process_marithmetic_command()
1919 p = itoa_u32(it->exptime - current_time, p); in process_marithmetic_command()
1936 META_SPACE(p); in process_marithmetic_command()
1937 memcpy(p, tokens[i].value, tokens[i].length); in process_marithmetic_command()
1938 p += tokens[i].length; in process_marithmetic_command()
1941 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()
1947 *p = '\r'; in process_marithmetic_command()
1948 *(p+1) = '\n'; in process_marithmetic_command()
1949 p += 2; in process_marithmetic_command()
1950 memcpy(p, tmpbuf, vlen); in process_marithmetic_command()
1951 p += vlen; in process_marithmetic_command()
1965 META_SPACE(p); in process_marithmetic_command()
1966 memcpy(p, tokens[i].value, tokens[i].length); in process_marithmetic_command()
1967 p += tokens[i].length; in process_marithmetic_command()
1970 META_KEY(p, key, nkey, of.key_binary); in process_marithmetic_command()
1978 resp->wbytes = p - resp->wbuf; in process_marithmetic_command()