fdout
write(cl->fdout, &cc, 1);
int fdout;
cl.fdout = SHOUT;
if (setsockopt(fdin, SOL_SOCKET, SO_SPLICE, &fdout, sizeof(int)) == -1)
relay_copy(int fdin, int fdout)
nw = write(fdout, buf + off, nr);
relay_splice(int fdin, int fdout)
bus_space_write_1(iot, ioh, fdout, drive | FDO_FRST | FDO_MOEN(drive));
bus_space_write_1(iot, ioh, fdout, FDO_FRST);
bus_space_write_1(fdc->sc_iot, fdc->sc_ioh, fdout, status);
bus_space_write_1(iot, ioh, fdout, 0);
bus_space_write_1(iot, ioh, fdout, FDO_FRST);
if (write(fdout, &nfiles, sizeof(nfiles)) < 1) {
close(fdout);
if (write(fdout, h, headersize - sizeof(nfiles)) < 1) {
close(fdout);
close(fdout);
close(fdout);
close(fdout);
if (write(fdout, p, h[i].filesize) < 1) {
close(fdout);
close(fdout);
int fdout, fdin;
if ((fdout = open(FILENAME, O_CREAT|O_TRUNC|O_RDWR, 0644)) == -1)
int i, fdin, fdout, nfiles;
if ((fdout = open(h[i]->filename, O_CREAT|O_TRUNC|O_RDWR, 0644))
if (write(fdout, p, h[i]->filesize) < 1)
close(fdout);
write(t->fdout, &cc, 1);
int fdout;
tty.fdout = fileno(stdout);
flist_send(struct sess *sess, int fdin, int fdout, const struct flist *fl,
if (!io_write_byte(sess, fdout, flag)) {
} else if (!io_write_int(sess, fdout, sz)) {
} else if (!io_write_buf(sess, fdout, fn, sz)) {
} else if (!io_write_long(sess, fdout, f->st.size)) {
} else if (!io_write_uint(sess, fdout, (uint32_t)f->st.mtime)) {
} else if (!io_write_uint(sess, fdout, f->st.mode)) {
if (!io_write_uint(sess, fdout, f->st.uid)) {
if (!io_write_uint(sess, fdout, f->st.gid)) {
if (!io_write_int(sess, fdout, f->st.rdev)) {
if (!io_write_int(sess, fdout, sz)) {
if (!io_write_buf(sess, fdout, fn, sz)) {
if (!io_write_byte(sess, fdout, 0)) {
if (!idents_send(sess, fdout, uids, uidsz)) {
if (!idents_send(sess, fdout, gids, gidsz)) {
rsync_receiver(struct sess *sess, int fdin, int fdout, const char *root)
send_rules(sess, fdout);
pfd[PFD_SENDER_OUT].fd = fdout;
ul = upload_alloc(root, dfd, fdout, CSUM_LENGTH_PHASE1, fl, flsz,
if (!io_write_int(sess, fdout, -1)) {
if (!io_write_int(sess, fdout, -1)) {
int fdout, size_t argc, char **argv)
send_rules(sess, fdout);
if (!flist_send(sess, fdin, fdout, fl, flsz)) {
} else if (!io_write_int(sess, fdout, 0)) {
pfd[1].fd = fdout;
ssz = write(fdout, wbuf + wbufpos, wbufsz - wbufpos);
pfd[1].fd = fdout;
if (!sess_stats_send(sess, fdout)) {
if (!rsync_sender(&sess, fdin, fdout, argc, argv)) {
if (!rsync_receiver(&sess, fdin, fdout, argv[1])) {
fdout = STDOUT_FILENO, rc = 1;
!fcntl_nonblock(fdout)) {
} else if (!io_write_int(&sess, fdout, sess.lver)) {
} else if (!io_write_int(&sess, fdout, sess.seed)) {
*fileoutfd = u->fdout;
int fdout; /* write descriptor to sender */
if (!io_write_int(sess, p->fdout, p->idx)) {
upload_alloc(const char *root, int rootfd, int fdout,
p->fdout = fdout;
c = io_write_buf(sess, u->fdout,
if (!io_write_int(sess, u->fdout, -1)) {
copy_blocks(int fdout, int fdin, const char *sha, const char *endsha,
writeall(fdout, buffer, n, "stdout");
int fdin, fdout;
fdout = xopen(msgfile, O_CREAT|O_TRUNC|O_NOFOLLOW|O_WRONLY, 0666);
writeall(fdout, fake, sizeof fake, msgfile);
writeall(fdout, h.comment, len+1, msgfile);
copy_blocks(fdout, fdin, p, h.endcomment, bufsize, bufend);
close(fdout);
int fdin, fdout;
fdout = xopen(sigfile, O_CREAT|O_TRUNC|O_NOFOLLOW|O_WRONLY, 0666);
writeall(fdout, fake, sizeof fake, sigfile);
writeall(fdout, sighdr, strlen(sighdr), sigfile);
writeall(fdout, msg, p - msg + 1, sigfile);
writeall(fdout, buffer, n, sigfile);
close(fdout);
char *cmd, int *fdin, int *fdout, pid_t *pid)
*fdout = sv[1];
int fdin, int fdout)
if (dup2(fdout, 1) == -1)
int fdin, int fdout, int fderr, int ignore_fderr, int is_tty)
fdout, fdin, fderr,
int fdout, ptyfd, ttyfd, ptymaster;
if ((fdout = dup(ptyfd)) == -1) {
close(fdout);
close(fdout);
close(fdout);
session_set_fds(ssh, s, ptyfd, fdout, -1, 1, 1);
close(fdout[1]);
*fdoutptr = fdout[0];
close_pipe(fdout);
int fdout[] = { -1, -1 };
if(fdoutptr != NULL && pipe(fdout) == -1) {
if(dup2(fdout[1], 1) == -1) {
close_pipe(fdout);
int fdin, fderr, fdout, flags;
fdin = fdout = fderr = -1;
command, fdin == -2 ? &fdin : NULL, &fdout, &fderr);
flags = fcntl(fdout, F_GETFL, 0);
if(fcntl(fdout, F_SETFL, flags | O_NONBLOCK) == -1) {
verifier->output_stream.fd = fdout;
close(fdout);
int fdin = -1, fdout = -1, fd = -1;
if ((fdout = mktmpfile()) == -1)
if ((fd = dup(fdout)) == -1)
if ((ofp = fdopen(fdout, "w+")) == NULL)
if ((fdout = mktmpfile()) == -1)
if ((fd = dup(fdout)) == -1)
if ((ofp = fdopen(fdout, "w+")) == NULL)
if (fdout != -1)
close(fdout);