Lines Matching refs:wr

926 …qmem_to_tempfile_partial(chunkqueue * const dest, chunk * const c, ssize_t wr, log_error_st * cons…  in chunkqueue_append_cqmem_to_tempfile_partial()  argument
932 dest->bytes_in -= wr; /*(avoid double count in dest cq)*/ in chunkqueue_append_cqmem_to_tempfile_partial()
933 dest->bytes_out -= wr; in chunkqueue_append_cqmem_to_tempfile_partial()
934 chunkqueue_mark_written(dest, wr);/*(remove MEM_CHUNK written to tempfile)*/ in chunkqueue_append_cqmem_to_tempfile_partial()
992 ssize_t wr = pwritev(c->file.fd, iov, (int)iovcnt, c->file.length); in chunkqueue_append_cqmem_to_tempfile() local
999 if (wr >= 0) { in chunkqueue_append_cqmem_to_tempfile()
1000 c->file.length += wr; in chunkqueue_append_cqmem_to_tempfile()
1001 dest->bytes_in += wr; in chunkqueue_append_cqmem_to_tempfile()
1003 if (__builtin_expect( (wr < dlen), 0)) in chunkqueue_append_cqmem_to_tempfile()
1005 chunkqueue_append_cqmem_to_tempfile_partial(dest,c,wr,errh); in chunkqueue_append_cqmem_to_tempfile()
1006 wr -= (ssize_t)dlen; in chunkqueue_append_cqmem_to_tempfile()
1013 wr = 0; /*(to trigger continue/retry in caller rather than error)*/ in chunkqueue_append_cqmem_to_tempfile()
1015 return wr; in chunkqueue_append_cqmem_to_tempfile()
1069 ssize_t wr = splice(fd, NULL, c->file.fd, &off, len, in chunkqueue_append_splice_pipe_tempfile() local
1072 if (__builtin_expect(((size_t)wr == len), 1)) { in chunkqueue_append_splice_pipe_tempfile()
1077 else if (wr >= 0) { in chunkqueue_append_splice_pipe_tempfile()
1080 cq->bytes_in += wr; in chunkqueue_append_splice_pipe_tempfile()
1081 total += wr; in chunkqueue_append_splice_pipe_tempfile()
1082 len -= (size_t)wr; in chunkqueue_append_splice_pipe_tempfile()
1083 c->file.length += (size_t)wr; in chunkqueue_append_splice_pipe_tempfile()
1101 wr = chunkqueue_append_drain_pipe_tempfile(cq, fd, len, errh); in chunkqueue_append_splice_pipe_tempfile()
1102 return (0 == wr) ? total + (ssize_t)len : wr; in chunkqueue_append_splice_pipe_tempfile()
1153 ssize_t wr = splice(fd, NULL, pipes[1], NULL, len, in chunkqueue_append_splice_sock_tempfile() local
1155 if (__builtin_expect( (wr <= 0), 0)) in chunkqueue_append_splice_sock_tempfile()
1157 len = (unsigned int)wr; in chunkqueue_append_splice_sock_tempfile()
1160 wr = chunkqueue_append_splice_pipe_tempfile(cq, pipes[0], len, errh); in chunkqueue_append_splice_sock_tempfile()
1161 if (wr < 0) /* expect (wr == (ssize_t)len) or (wr == -1) */ in chunkqueue_append_splice_sock_tempfile()
1163 return wr; in chunkqueue_append_splice_sock_tempfile()
1369 ssize_t wr = 0; in chunkqueue_write_data() local
1371 do { wr = write(fd, buf, len); } while (-1 == wr && errno == EINTR); in chunkqueue_write_data()
1372 return wr; in chunkqueue_write_data()
1417 const ssize_t wr = in chunkqueue_write_chunk_file() local
1419 if (__builtin_expect( (wr >= 0), 1) || (errno != EINVAL && errno != ENOSYS)) in chunkqueue_write_chunk_file()
1420 return wr; in chunkqueue_write_chunk_file()