| /memcached-1.6.32/ |
| D | extstore.c | 320 f->offset = 0; in extstore_init()
358 e->pages[i].offset = f->offset; in extstore_init()
360 f->offset += e->page_size; in extstore_init()
510 wbuf->offset = p->allocated; in _allocate_wbuf()
537 assert(p->written == w->offset); in _wbuf_cb()
573 io->offset = w->offset; in _submit_wbuf()
655 io->offset = p->wbuf->offset + (p->wbuf->size - p->wbuf->free); in extstore_write()
819 memcpy(io->buf, wbuf->buf + (io->offset - wbuf->offset), io->len); in _read_from_wbuf()
822 unsigned int off = io->offset - wbuf->offset; in _read_from_wbuf()
904 ret = lseek(p->fd, p->offset + cur_io->offset, SEEK_SET); in extstore_io_thread()
[all …]
|
| D | testapp.c | 786 off_t offset = 0; in send_ascii_command() local
791 ssize_t nw = con->write((void*)con, ptr + offset, len - offset); in send_ascii_command()
798 offset += nw; in send_ascii_command()
810 off_t offset = 0; in read_ascii_response() local
825 offset += nr; in read_ascii_response()
899 size_t offset = 5; in test_issue_102() local
901 offset += snprintf(buffer + offset, sizeof(buffer) - offset, in test_issue_102()
974 off_t offset = 0; in safe_send() local
1017 off_t offset = 0; in safe_recv() local
1019 ssize_t nr = con->read(con, ((char*)buf) + offset, len - offset); in safe_recv()
[all …]
|
| D | storage.c | 364 eio->offset = hdr.offset; in storage_get_item()
368 eio->offset = hdr->offset; in storage_get_item()
565 hdr->offset = io.offset; in storage_write()
905 uint64_t offset = 0; in storage_compact_readback() local
912 while (offset < read_size) { in storage_compact_readback()
915 item *it = (item *)(readback_buf+offset); in storage_compact_readback()
937 && hdr->offset == (int)offset + page_offset) { in storage_compact_readback()
976 hdr->offset = io.offset; in storage_compact_readback()
995 new_hdr->offset = io.offset; in storage_compact_readback()
1023 offset += ntotal; in storage_compact_readback()
[all …]
|
| D | md5.c | 327 int offset = (pms->count[0] >> 3) & 63; in md5_append() local
340 if (offset) { in md5_append()
341 int copy = (offset + nbytes > 64 ? 64 - offset : nbytes); in md5_append()
343 memcpy(pms->buf + offset, p, copy); in md5_append()
344 if (offset + copy < 64) in md5_append()
|
| D | extstore.h | 60 uint64_t offset; // internal usage member
86 unsigned int offset; /* for read mode */ member
|
| D | memcached.h | 654 int offset = it->nkey + 1 in ITEM_schunk() local
657 int remain = offset % 8; in ITEM_schunk()
659 offset += 8 - remain; in ITEM_schunk()
661 return ((char *) &(it->data)) + offset; in ITEM_schunk()
672 unsigned int offset; /* from IO header */ member
891 size_t offset; member
|
| D | slabs.c | 866 int offset = ((char*)slab_rebal.slab_pos-(char*)slab_rebal.slab_start)/(s_cls->size); in slab_rebalance_move() local
869 if (slab_rebal.completed[offset] == 0) { in slab_rebalance_move()
1038 slab_rebal.completed[offset] = 1; in slab_rebalance_move()
1050 slab_rebal.completed[offset] = 1; in slab_rebalance_move()
1068 slab_rebal.completed[offset] = 1; in slab_rebalance_move()
|
| D | proxy_internal.c | 185 eio->offset = hdr.offset; in proxy_storage_get()
189 eio->offset = hdr->offset; in proxy_storage_get()
|
| D | memcached.c | 1316 char *buf = c->stats.buffer + c->stats.offset; in append_bin_stats()
1339 c->stats.offset += sizeof(header.response) + bodylen; in append_bin_stats()
1345 char *pos = c->stats.buffer + c->stats.offset; in append_ascii_stats()
1347 int remaining = c->stats.size - c->stats.offset; in append_ascii_stats()
1358 c->stats.offset += nbytes; in append_ascii_stats()
1363 size_t available = nsize - c->stats.offset; in grow_stats_buf()
1369 available = c->stats.size = c->stats.offset = 0; in grow_stats_buf()
1375 available = nsize - c->stats.offset; in grow_stats_buf()
1419 assert(c->stats.offset <= c->stats.size); in append_stats()
|
| D | proxy_lua.c | 746 static void _mcplib_pool_make_be_loop(lua_State *L, mcp_pool_t *p, int offset, proxy_event_thread_t… in _mcplib_pool_make_be_loop() argument
749 mcp_pool_be_t *s = &p->pool[x-1 + (offset * p->pool_size)]; in _mcplib_pool_make_be_loop()
767 lua_pushinteger(L, offset); in _mcplib_pool_make_be_loop()
|
| D | proto_bin.c | 654 write_and_free(c, c->stats.buffer, c->stats.offset); in process_bin_stat()
669 write_and_free(c, c->stats.buffer, c->stats.offset); in process_bin_stat()
|
| D | xxhash.h | 4463 size_t offset = align - ((size_t)base & (align - 1)); /* base % align */ in XXH_alignedMalloc() local
4465 xxh_u8* ptr = base + offset; in XXH_alignedMalloc()
4470 ptr[-1] = (xxh_u8)offset; in XXH_alignedMalloc()
4485 xxh_u8 offset = ptr[-1]; in XXH_alignedFree() local
4487 xxh_u8* base = ptr - offset; in XXH_alignedFree()
|
| D | proto_text.c | 817 write_and_free(c, c->stats.buffer, c->stats.offset); in process_stat()
832 write_and_free(c, c->stats.buffer, c->stats.offset); in process_stat()
|
| /memcached-1.6.32/doc/ |
| D | protocol-binary.txt | 424 Field (offset) (value)
534 Field (offset) (value)
593 Field (offset) (value)
652 Field (offset) (value)
766 Field (offset) (value)
816 Field (offset) (value)
874 Field (offset) (value)
1045 Field (offset) (value)
1097 Field (offset) (value)
1149 Field (offset) (value)
[all …]
|
| D | protocol-binary-range.txt | 208 packet at the given byte offset.
|
| D | protocol.txt | 150 than an offset from current time.
245 items). If it's non-zero (either Unix time or offset in seconds from
|