| /memcached-1.4.29/ |
| H A D | bipbuffer.c | 83 return (unsigned char *)me->data + me->b_end; in bipbuf_request()
87 return (unsigned char *)me->data + me->a_end; in bipbuf_request()
109 int bipbuf_offer(bipbuf_t* me, const unsigned char *data, const int size) in bipbuf_offer() argument
117 memcpy(me->data + me->b_end, data, size); in bipbuf_offer()
122 memcpy(me->data + me->a_end, data, size); in bipbuf_offer()
139 return (unsigned char *)me->data + me->a_start; in bipbuf_peek()
148 return (unsigned char*)me->data + me->a_start; in bipbuf_peek_all()
160 void *end = me->data + me->a_start; in bipbuf_poll()
|
| H A D | version.pl | 46 my $data = shift;
48 print $fh $data;
56 my $data = <$fh>;
58 return $data;
|
| H A D | logger.c | 327 unsigned char *data; in logger_thread_read() local
331 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
334 if (data == NULL) { in logger_thread_read()
343 e = (logentry *) (data + pos); in logger_thread_read()
356 data = bipbuf_poll(l->buf, size); in logger_thread_read()
362 if (data == NULL) { in logger_thread_read()
383 unsigned char *data; in logger_thread_poll_watchers() local
392 data = bipbuf_peek_all(w->buf, &data_size); in logger_thread_poll_watchers()
393 if (data != NULL) { in logger_thread_poll_watchers()
438 if ((data = bipbuf_peek_all(w->buf, &data_size)) != NULL) { in logger_thread_poll_watchers()
[all …]
|
| H A D | murmur3_hash.c | 73 const uint8_t * data = (const uint8_t*)key; in MurmurHash3_x86_32() local
84 const uint32_t * blocks = (const uint32_t *)(data + nblocks*4); in MurmurHash3_x86_32()
102 const uint8_t * tail = (const uint8_t*)(data + nblocks*4); in MurmurHash3_x86_32()
|
| H A D | bipbuffer.h | 17 unsigned char data[]; member
48 int bipbuf_offer(bipbuf_t *me, const unsigned char *data, const int size);
|
| H A D | memcached.h | 94 (i)->data->cas : (uint64_t)0)
98 (i)->data->cas = v; \
102 #define ITEM_key(item) (((char*)&((item)->data)) \
105 #define ITEM_suffix(item) ((char*) &((item)->data) + (item)->nkey + 1 \
108 #define ITEM_data(item) ((char*) &((item)->data) + (item)->nkey + 1 \
415 } data[]; member
449 char data[]; member
|
| H A D | logger.h | 79 } data[]; member
|
| H A D | memcached.c | 888 if (add_iov(c, ch->data, todo) != 0) { in add_chunked_item_iovs()
1030 buf[0] = ch->data[ch->used - 2]; in complete_nread_ascii()
1031 buf[1] = ch->data[ch->used - 1]; in complete_nread_ascii()
1035 buf[0] = ch->prev->data[ch->prev->used - 1]; in complete_nread_ascii()
1036 buf[1] = ch->data[ch->used - 1]; in complete_nread_ascii()
1366 ch->data[ch->used + 1] = '\r'; in complete_update_bin()
1367 ch->data[ch->used + 2] = '\n'; in complete_update_bin()
1370 ch->data[ch->used + 1] = '\r'; in complete_update_bin()
1371 ch->next->data[0] = '\n'; in complete_update_bin()
2498 memcpy(dch->data + dch->used, sch->data + copied, todo); in _store_item_copy_chunks()
[all …]
|
| H A D | ChangeLog | 92 * Don't leave stale data after failed set attempts (Dormando)
230 * Flesh out tests for unix domain sockets and binary data.
|
| /memcached-1.4.29/t/ |
| H A D | binary.t | 458 my $data = "";
459 $bytesread = sysread($mc2->{socket}, $data, 24),
480 if (length($data) > 2024) {
482 $mc->{socket}->send(substr($data, 0, $j));
485 $mc->{socket}->send(substr($data, $j));
489 $mc->{socket}->send($data);
679 my $header = substr $data, 0, 8, '';
714 $found_key = substr($data, 0, $keylen);
715 $found_val = substr($data, $keylen);
751 my $header = substr $data, 0, 4, '';
[all …]
|
| H A D | 64bit.t | 36 my $data = "a" x $size;
37 print $sock "set big$_ 0 0 $size\r\n$data\r\n";
|
| H A D | binary-sasl.t | 377 my ($ropaque, $status, $data) = $self->_handle_single_response;
455 my ($status, $data, undef) = $self->_do_command($cmd, $key, '',
458 my $header = substr $data, 0, 8, '';
486 my ($op, $status, $data, $cas, $keylen) = $self->_handle_single_response($opaque);
488 $found_key = substr($data, 0, $keylen);
489 $found_val = substr($data, $keylen);
523 my ($opaque, $status, $data) = $self->_handle_single_response;
526 my $header = substr $data, 0, 4, '';
529 $return{$keys[$opaque]} = [$flags, $data];
|
| H A D | chunked-items.t | 32 my $data = "x" x $size;
33 print $sock "set foo$_ 0 0 $size\r\n$data\r\n";
|
| H A D | getset.t | 60 my $data = scalar <$sock>; # grab data
|
| /memcached-1.4.29/doc/ |
| H A D | protocol.txt | 36 data from a server, it must use the length of the data block (which it
67 data block with the item's data; this continues until the server
134 "set" means "store this data".
137 hold data for this key".
140 already hold data for this key".
142 "append" means "add this data to an existing key after existing data".
144 "prepend" means "add this data to an existing key before existing data".
187 <data block>\r\n
189 - <data block> is a chunk of arbitrary 8-bit data of length <bytes>
229 <data block>\r\n
[all …]
|
| H A D | threads.txt | 9 global locks. Protocol parsing, data transfer happens in threads. Data lookups
|
| /memcached-1.4.29/m4/ |
| H A D | c99-backport.m4 | 51 double data[];
125 ia->data[i] = i * 1.234;
|