| /memcached-1.6.32/ |
| D | logger.h | 76 int nbytes; member
98 int nbytes; member
109 int nbytes; member
115 int nbytes; member
|
| D | proxy_internal.c | 173 resp_add_iov(resp, "", it->nbytes); in proxy_storage_get()
215 p = itoa_u32(nbytes-2, p+1); in make_ascii_get_suffix()
241 int nbytes = it->nbytes;; in process_get_cmd() local
242 nbytes = it->nbytes; in process_get_cmd()
265 resp_add_chunked_iov(resp, it, it->nbytes); in process_get_cmd()
823 p = itoa_u32(it->nbytes-2, p+3); in process_mget_cmd()
853 p = itoa_u32(it->nbytes-2, p); in process_mget_cmd()
1189 int nbytes = 0; in process_mset_cmd() local
1238 if (nbytes != 0) { in process_mset_cmd()
1239 p = itoa_u32(nbytes-2, p); in process_mset_cmd()
[all …]
|
| D | logger.c | 71 le->nbytes = it->nbytes; in _logger_log_evictions()
100 int nbytes = va_arg(ap, int); in _logger_log_item_get() local
107 le->nbytes = nbytes; in _logger_log_item_get()
119 int nbytes = va_arg(ap, int); in _logger_log_item_store() local
128 le->nbytes = nbytes; in _logger_log_item_store()
146 le->nbytes = it->nbytes; in _logger_log_item_deleted()
231 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ise()
247 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ige()
261 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ee()
282 le->nbytes > 0 ? le->nbytes - 2 : 0); // CLRF in _logger_parse_ide()
|
| D | items.c | 164 return sizeof(item) + nkey + *nsuffix + nbytes; in item_make_header()
260 if (nbytes < 2) in do_item_alloc()
332 it->nbytes = nbytes; in do_item_alloc()
376 if (nbytes < 2) in item_size_ok()
379 size_t ntotal = item_make_header(nkey + 1, flags, nbytes, in item_size_ok()
492 MEMCACHED_ITEM_LINK(ITEM_key(it), it->nkey, it->nbytes); in do_item_link()
514 MEMCACHED_ITEM_UNLINK(ITEM_key(it), it->nkey, it->nbytes); in do_item_unlink()
530 MEMCACHED_ITEM_UNLINK(ITEM_key(it), it->nkey, it->nbytes); in do_item_unlink_nolock()
678 key_temp, it->nbytes - 2, in item_cachedump()
1754 assert(it->nbytes == 0); in do_item_linktail_q()
[all …]
|
| D | md5.c | 323 md5_append(md5_state_t *pms, const md5_byte_t *data, int nbytes) in md5_append() argument
326 int left = nbytes; in md5_append()
328 md5_word_t nbits = (md5_word_t)(nbytes << 3); in md5_append()
330 if (nbytes <= 0) in md5_append()
334 pms->count[1] += nbytes >> 29; in md5_append()
341 int copy = (offset + nbytes > 64 ? 64 - offset : nbytes); in md5_append()
|
| D | proto_text.c | 110 if (nbytes != 0) { in _finalize_mset()
111 p = itoa_u32(nbytes-2, p); in _finalize_mset()
113 p = itoa_u32(it->nbytes-2, p); in _finalize_mset()
139 int nbytes = 0; in complete_nread_ascii() local
215 _finalize_mset(c, nbytes, ret, cas); in complete_nread_ascii()
533 p = itoa_u32(nbytes-2, p+1); in make_ascii_get_suffix()
595 int nbytes = it->nbytes; in process_get_command() local
1161 p = itoa_u32(it->nbytes-2, p+3); in process_mget_command()
1191 p = itoa_u32(it->nbytes-2, p); in process_mget_command()
1582 c->rlbytes = it->nbytes; in process_mset_command()
[all …]
|
| D | proto_bin.c | 371 *(ITEM_data(it) + it->nbytes - 2) = '\r'; in complete_update_bin()
372 *(ITEM_data(it) + it->nbytes - 1) = '\n'; in complete_update_bin()
393 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
502 it->nbytes, ITEM_get_cas(it)); in process_bin_get_or_touch()
505 it->nbytes, ITEM_get_cas(it)); in process_bin_get_or_touch()
509 bodylen -= it->nbytes - 2; in process_bin_get_or_touch()
539 resp_add_iov(c->resp, ITEM_data(it), it->nbytes - 2); in process_bin_get_or_touch()
542 resp_add_chunked_iov(c->resp, it, it->nbytes - 2); in process_bin_get_or_touch()
546 resp_add_iov(c->resp, ITEM_data(it), it->nbytes - 2); in process_bin_get_or_touch()
548 resp_add_chunked_iov(c->resp, it, it->nbytes - 2); in process_bin_get_or_touch()
[all …]
|
| D | items.h | 14 …r *key, const size_t nkey, const client_flags_t flags, const rel_time_t exptime, const int nbytes);
18 bool item_size_ok(const size_t nkey, const client_flags_t flags, const int nbytes);
|
| D | md5.h | 89 void md5_append(md5_state_t *pms, const md5_byte_t *data, int nbytes);
|
| D | memcached.h | 146 + (item)->nbytes \
598 int nbytes; /* size of data */ member
626 int nbytes; /* size of data */ member
644 int nbytes; /* used. */ member
955 …e_item(item *item, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *nbytes, uint64_t *cas, co…
1004 item *item_alloc(const char *key, size_t nkey, client_flags_t flags, rel_time_t exptime, int nbytes…
1038 enum store_item_type store_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *ca…
|
| D | storage.h | 39 #define STORE_OFFSET offsetof(item, nbytes)
|
| D | storage.c | 265 new_it = item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, it->nbytes); in storage_get_item()
296 size_t remain = new_it->nbytes; in storage_get_item()
311 eio->iov[0].iov_len = ITEM_ntotal(new_it) - new_it->nbytes; in storage_get_item()
337 int iovtotal = (c->protocol == binary_prot) ? it->nbytes - 2 : it->nbytes; in storage_get_item()
543 int hdrtotal = ITEM_ntotal(it) - it->nbytes; in storage_write()
567 hdr_it->nbytes = it->nbytes; in storage_write()
989 new_it->nbytes = hdr_it->nbytes; in storage_compact_readback()
|
| D | memcached.c | 1346 uint32_t nbytes = 0; in append_ascii_stats() local
1351 nbytes = snprintf(pos, room, "END\r\n"); in append_ascii_stats()
1353 nbytes = snprintf(pos, room, "STAT %s\r\n", key); in append_ascii_stats()
1355 nbytes = snprintf(pos, room, "STAT %s %s\r\n", key, val); in append_ascii_stats()
1358 c->stats.offset += nbytes; in append_ascii_stats()
1547 … memcpy(ITEM_data(new_it) + old_it->nbytes - 2 /* CRLF */, ITEM_data(add_it), add_it->nbytes); in _store_item_copy_data()
1558 … memcpy(ITEM_data(new_it) + add_it->nbytes - 2 /* CRLF */, ITEM_data(old_it), old_it->nbytes); in _store_item_copy_data()
1658 …ew_it = do_item_alloc(key, it->nkey, flags, old_it->exptime, it->nbytes + old_it->nbytes - 2 /* CR… in do_store_item()
1673 if (nbytes != NULL) { in do_store_item()
1674 *nbytes = it->nbytes; in do_store_item()
[all …]
|
| D | thread.c | 867 item *item_alloc(const char *key, size_t nkey, client_flags_t flags, rel_time_t exptime, int nbytes… in item_alloc() argument
870 it = do_item_alloc(key, nkey, flags, exptime, nbytes); in item_alloc()
962 enum store_item_type store_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *ca… in store_item() argument
968 ret = do_store_item(item, comm, t, hv, nbytes, cas, cas_in, cas_stale); in store_item()
|
| D | crawler.c | 708 crawlers[sid].nbytes = 0; in do_lru_crawler_start()
|
| D | slabs.c | 968 ntotal = (ntotal - it->nbytes) + sizeof(item_hdr); in slab_rebalance_move()
|