Home
last modified time | relevance | path

Searched refs:sent (Results 1 – 12 of 12) sorted by relevance

/memcached-1.6.32/
Dproxy_network.c958 if (sent >= io->iovbytes) { in _post_pending_write()
960 sent -= io->iovbytes; in _post_pending_write()
962 io->iovbytes -= sent; in _post_pending_write()
971 sent = 0; in _post_pending_write()
982 if (sent <= 0) { in _post_pending_write()
984 assert(sent >= 0); in _post_pending_write()
1017 if (sent > 0) { in _flush_pending_write()
1018 _post_pending_write(be, sent); in _flush_pending_write()
1024 } else if (sent == -1) { in _flush_pending_write()
1046 if (sent > 0) { in _flush_pending_tls_write()
[all …]
Dcrawler.c376 unsigned int sent = 0; in lru_crawler_write() local
384 while (sent < data_size) { in lru_crawler_write()
411 int total = ((conn*)c->c)->write(c->c, c->buf + sent, data_size - sent); in lru_crawler_write()
421 sent += total; in lru_crawler_write()
DChangeLog146 * Final fixes for all 1.2.4 features are in, -rc2 sent out.
478 * pidfile saving support from Lisa Seelye <[email protected]>, sent
/memcached-1.6.32/t/
Dbinary-extstore.t301 my $sent = 0;
303 while ($sent < $data_len) {
305 $data_len - $sent > MemcachedTest::MAX_READ_WRITE_SIZE ?
306 MemcachedTest::MAX_READ_WRITE_SIZE : ($data_len - $sent),
307 $sent);
309 $sent += $sent_bytes;
313 if($sent != length($full_msg)) {
314 die("only sent $sent of " . length($full_msg) . " bytes");
Dbinary.t581 my $sent = 0;
583 while ($sent < $data_len) {
585 $data_len - $sent > MemcachedTest::MAX_READ_WRITE_SIZE ?
586 MemcachedTest::MAX_READ_WRITE_SIZE : ($data_len - $sent),
587 $sent);
589 $sent += $sent_bytes;
592 if($sent != $data_len) {
593 die("only sent $sent of " . length($full_msg) . " bytes");
Dbinary-sasl.t371 my $sent = $self->{socket}->send($full_msg);
372 die("Send failed: $!") unless $sent;
373 if($sent != length($full_msg)) {
374 die("only sent $sent of " . length($full_msg) . " bytes");
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c898 int sent = send(ctx->fd, r, l, 0); in mcmc_send_request() local
899 if (sent == -1) { in mcmc_send_request()
908 if (sent < len) { in mcmc_send_request()
910 ctx->sent_bytes_partial += sent; in mcmc_send_request()
922 int mcmc_request_writev(void *c, const struct iovec *iov, int iovcnt, ssize_t *sent, int count) { in mcmc_request_writev() argument
930 *sent = writev(ctx->fd, iov, iovcnt); in mcmc_request_writev()
931 if (*sent == -1) { in mcmc_request_writev()
940 if (*sent < tosend) { in mcmc_request_writev()
Dmcmc.h129 int mcmc_request_writev(void *c, const struct iovec *iov, int iovcnt, ssize_t *sent, int count);
DREADME.md7 sent to memcached. It has no 3rd party dependencies and is designed to
/memcached-1.6.32/doc/
Dprotocol.txt164 means the client sent a nonexistent command name.
306 Each item sent by the server looks like this:
311 - <key> is the key for the item being sent
446 Each item sent by the server looks like this:
451 - <key> is the key for the item being sent
517 An item sent by the server looks like:
525 They are added in order specified by the flags sent.
565 - Z: item has already sent a winning flag
573 are sent to memcached in base64 encoding.
678 - Z: item has already sent a winning flag
[all …]
Dprotocol-binary-range.txt150 counted), a Get Range response packet MUST be sent instead of the Get
/memcached-1.6.32/t/lib/
DMemcachedTest.pm578 my $sent = $be->send("VERSION 1.0.0-mock\r\n");
579 Test::More::cmp_ok($sent, '>', 0, "wrote VERSION back to backend");