search for: total_written

.../ }/ /- rprintf(FINFO,"Total bytes sent: %s\n",/ /+ rprintf(FERROR,"Total bytes sent: %s\n",/ / human_num(total_written));/ /- rprintf(FINFO,"Total bytes received: %s\n",/ /+ rprintf(FERROR,"Total bytes received: %s\n",/ / human_num(total_read));/...

...-06-30 13:17:26.000000000 -0300 +++ io.c-MOSER 2011-08-12 22:29:41.000000000 -0300 @@ -1402,7 +1402,7 @@ if (prior_tv.tv_sec) { elapsed_usec = (start_tv.tv_sec - prior_tv.tv_sec) * ONE_SEC + (start_tv.tv_usec - prior_tv.tv_usec); - total_written -= elapsed_usec * bwlimit / (ONE_SEC/1024); + total_written -= ((long long)((long long)elapsed_usec * bwlimit) / (ONE_SEC/1024)); if (total_written < 0) total_written = 0; } Thank you. Francisco Moser -- Configure bugmail: https:/...

...y process */ show_malloc_stats(); show_flist_stats(); @@ -139,12 +139,12 @@ rprintf(FINFO,"File list size: %d\n", stats.flist_size); rprintf(FINFO,"Total bytes written: %.0f\n", (double)stats.total_written); - rprintf(FINFO,"Total bytes read: %.0f\n\n", + rprintf(FINFO,"Total bytes read: %.0f\n", (double)stats.total_read); } if (verbose || do_stats) { - rprintf(FINFO,"wrote %.0f bytes...

...f -ru rsync-2.6.3pre1/flist.c rsync-2.6.3pre1+tykhe/flist.c --- rsync-2.6.3pre1/flist.c 2004-08-12 14:20:07.000000000 -0400 +++ rsync-2.6.3pre1+tykhe/flist.c 2004-09-03 10:17:31.259895000 -0400 @@ -1056,6 +1056,7 @@ start_filelist_progress("building file list"); start_write = stats.total_written; + stats.flist_buildtime = time(NULL); flist = flist_new(f == -1 ? WITHOUT_HLINK : WITH_HLINK, "send_file_list"); @@ -1202,6 +1203,9 @@ } } + stats.flist_buildtime = time(NULL) - stats.flist_buildtime; + stats.flist_xfertime = time(NULL); + if (f !=...

...27 06:10:44 2002 +++ rsync-2.5.5/main.c Tue May 14 16:38:06 2002 @@ -118,7 +118,7 @@ (double)stats.total_read); } - if (verbose || do_stats) { + if (verbose > 1 || do_stats) { rprintf(FINFO,"wrote %.0f bytes read %.0f bytes %.2f bytes/sec\n", (double)stats.total_written, (double)stats.total_read, --- rsync-2.5.5/generator.c.orig Mon Mar 25 06:54:31 2002 +++ rsync-2.5.5/generator.c Tue May 14 16:40:28 2002 @@ -417,7 +417,7 @@ } if (update_only && cmp_modtime(st.st_mtime,file->modtime)>0 && fnamecmp == fname) { - if (verbose &...

...27 00:10:44 2002 +++ rsync-2.5.5/main.c Wed Jul 31 09:13:10 2002 @@ -118,7 +118,7 @@ (double)stats.total_read); } - if (verbose || do_stats) { + if (verbose > 1 || do_stats) { rprintf(FINFO,"wrote %.0f bytes read %.0f bytes %.2f bytes/sec\n", (double)stats.total_written, (double)stats.total_read, diff -r -X /home/roderick/.diff-exclude -u rsync-2.5.5.debian/rsync.1 rsync-2.5.5/rsync.1 --- rsync-2.5.5.debian/rsync.1 Wed Feb 6 16:21:19 2002 +++ rsync-2.5.5/rsync.1 Wed Jul 31 09:13:10 2002 @@ -338,9 +338,9 @@ This option increases the amount of informatio...

...*fmt = '%'; @@ -483,6 +483,20 @@ snprintf(buf2, sizeof buf2, fmt, (double)b); n = buf2; break; + case 's': + if (!am_sender) { + b = stats.total_written - + initial_stats->total_written; + } else { + b = stats.total_read - + initial_stats->total_read; + } + strlcat(fmt, &qu...

...truct vsock_sock *vsk, + struct sockaddr_vm *remote_addr, + struct iovec *iov, + size_t dgram_len) +{ + struct virtio_transport *trans = vsk->trans; + struct virtio_vsock_pkt_info info = { + .op = VIRTIO_VSOCK_OP_RW, + .type = SOCK_DGRAM, + .iov = iov, + }; + size_t total_written = 0, pkt_off = 0, written; + u16 dgram_id; + + /* The max size of a single dgram we support is 64KB */ + if (dgram_len > VIRTIO_VSOCK_MAX_DGRAM_SIZE) + return -EMSGSIZE; + + info.dgram_len = dgram_len; + vsk->remote_addr = *remote_addr; + + dgram_id = trans->dgram_id++; + + /* TODO: To op...

...vsock_sk(sk); + transport = vsk->transport; switch (optname) { case SO_VM_SOCKETS_BUFFER_SIZE: @@ -1501,6 +1517,7 @@ static int vsock_stream_sendmsg(struct socket *sock, struct msghdr *msg, { struct sock *sk; struct vsock_sock *vsk; + const struct vsock_transport *transport; ssize_t total_written; long timeout; int err; @@ -1509,6 +1526,7 @@ static int vsock_stream_sendmsg(struct socket *sock, struct msghdr *msg, sk = sock->sk; vsk = vsock_sk(sk); + transport = vsk->transport; total_written = 0; err = 0; @@ -1640,6 +1658,7 @@ vsock_stream_recvmsg(struct socket *sock, s...

...vsock_sk(sk); + transport = vsk->transport; switch (optname) { case SO_VM_SOCKETS_BUFFER_SIZE: @@ -1509,6 +1525,7 @@ static int vsock_stream_sendmsg(struct socket *sock, struct msghdr *msg, { struct sock *sk; struct vsock_sock *vsk; + const struct vsock_transport *transport; ssize_t total_written; long timeout; int err; @@ -1517,6 +1534,7 @@ static int vsock_stream_sendmsg(struct socket *sock, struct msghdr *msg, sk = sock->sk; vsk = vsock_sk(sk); + transport = vsk->transport; total_written = 0; err = 0; @@ -1648,6 +1666,7 @@ vsock_stream_recvmsg(struct socket *sock, s...

...gt;diff --git a/net/vmw_vsock/af_vsock.c b/net/vmw_vsock/af_vsock.c >index 020cf17ab7e4..013b65241b65 100644 >--- a/net/vmw_vsock/af_vsock.c >+++ b/net/vmw_vsock/af_vsock.c >@@ -1921,6 +1921,9 @@ static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg, > err = total_written; > } > out: >+ if (sk->sk_type == SOCK_STREAM) >+ err = sk_stream_error(sk, msg->msg_flags, err); >+ > release_sock(sk); > return err; > } >-- >2.25.1 >

...sfer time: 0.000 seconds Total bytes sent: 69219 Total bytes received: 184 sent 69219 bytes received 184 bytes 138806.00 bytes/sec total size is 327945064379 speedup is 4725228.94 BTW, why aren't these fields struct stats { int64 total_size; int64 total_transferred_size; int64 total_written; int64 total_read; int64 literal_data; int64 matched_data; of type size_t?

...ock/af_vsock.c >>> index 020cf17ab7e4..013b65241b65 100644 >>> --- a/net/vmw_vsock/af_vsock.c >>> +++ b/net/vmw_vsock/af_vsock.c >>> @@ -1921,6 +1921,9 @@ static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg, >>> ??????????? err = total_written; >>> ????} >>> out: >>> +??? if (sk->sk_type == SOCK_STREAM) >>> +??????? err = sk_stream_error(sk, msg->msg_flags, err); >> >> Do you know why we don't need this for SOCK_SEQPACKET and SOCK_DGRAM? > >Yes, here is my explanation: >...

...x 020cf17ab7e4..013b65241b65 100644 >>>>> --- a/net/vmw_vsock/af_vsock.c >>>>> +++ b/net/vmw_vsock/af_vsock.c >>>>> @@ -1921,6 +1921,9 @@ static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg, >>>>> ??????????? err = total_written; >>>>> ????} >>>>> out: >>>>> +??? if (sk->sk_type == SOCK_STREAM) >>>>> +??????? err = sk_stream_error(sk, msg->msg_flags, err); >>>> >>>> Do you know why we don't need this for SOCK_SEQPACKET and SOCK_DG...

Hi guys: First post for me on this list. THE PROBLEM =========== I have several linux servers (ranging from Redhat 7.3 to FC3) that use Rsync (version 2.6.8 and 2.6.7, read on for reasons) to backup their data. A typical rsync backup script looks like this: ------------------------------------------------------------------------------------------ #!/bin/sh RSYNC_PASSWORD=<PASSWORD> rsync

...x 020cf17ab7e4..013b65241b65 100644 >>>>> --- a/net/vmw_vsock/af_vsock.c >>>>> +++ b/net/vmw_vsock/af_vsock.c >>>>> @@ -1921,6 +1921,9 @@ static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg, >>>>> ??????????? err = total_written; >>>>> ????} >>>>> out: >>>>> +??? if (sk->sk_type == SOCK_STREAM) >>>>> +??????? err = sk_stream_error(sk, msg->msg_flags, err); >>>> >>>> Do you know why we don't need this for SOCK_SEQPACKET and SOCK_DG...

...644 >>>>>>> --- a/net/vmw_vsock/af_vsock.c >>>>>>> +++ b/net/vmw_vsock/af_vsock.c >>>>>>> @@ -1921,6 +1921,9 @@ static int vsock_connectible_sendmsg(struct socket *sock, struct msghdr *msg, >>>>>>> ??????????? err = total_written; >>>>>>> ????} >>>>>>> out: >>>>>>> +??? if (sk->sk_type == SOCK_STREAM) >>>>>>> +??????? err = sk_stream_error(sk, msg->msg_flags, err); >>>>>> >>>>>> Do you know why we do...

...ck *vsk, - struct sockaddr_vm *remote_addr, - struct msghdr *msg, - size_t dgram_len) -{ - struct virtio_transport *trans = vsk->trans; - struct virtio_vsock_pkt_info info = { - .op = VIRTIO_VSOCK_OP_RW, - .type = VIRTIO_VSOCK_TYPE_DGRAM, - .msg = msg, - }; - size_t total_written = 0, pkt_off = 0, written; - u16 dgram_id; - - /* The max size of a single dgram we support is 64KB */ - if (dgram_len > VIRTIO_VSOCK_MAX_DGRAM_SIZE) - return -EMSGSIZE; - - info.dgram_len = dgram_len; - vsk->remote_addr = *remote_addr; - - dgram_id = trans->dgram_id++; - - /* TODO: To op...

...ck *vsk, - struct sockaddr_vm *remote_addr, - struct msghdr *msg, - size_t dgram_len) -{ - struct virtio_transport *trans = vsk->trans; - struct virtio_vsock_pkt_info info = { - .op = VIRTIO_VSOCK_OP_RW, - .type = VIRTIO_VSOCK_TYPE_DGRAM, - .msg = msg, - }; - size_t total_written = 0, pkt_off = 0, written; - u16 dgram_id; - - /* The max size of a single dgram we support is 64KB */ - if (dgram_len > VIRTIO_VSOCK_MAX_DGRAM_SIZE) - return -EMSGSIZE; - - info.dgram_len = dgram_len; - vsk->remote_addr = *remote_addr; - - dgram_id = trans->dgram_id++; - - /* TODO: To op...

...*)buf1; SIVAL(buffer, 0, ((MPLEX_BASE + (int)code)<<24) + len); @@ -533,8 +546,10 @@ } } -static void writefd(int fd,char *buf,int len) +static void writefd(int fd, const void * buf1,int len) { +unsigned char * buf; + buf = (unsigned char *)buf1; stats.total_written += len; err_list_push(); @@ -560,7 +575,7 @@ void write_int(int f,int32 x) { - char b[4]; + unsigned char b[4]; SIVAL(b,0,x); writefd(f,b,4); } @@ -573,7 +588,7 @@ void write_longint(int f, int64 x) { extern int remote_version; - cha...