From f05b97d3856bc37272be9f0b58ea0abbaac9a33e Mon Sep 17 00:00:00 2001 From: Keith Packard Date: Fri, 5 Oct 2012 11:59:35 -0700 Subject: [PATCH] Add simple multi-write example Signed-off-by: Keith Packard --- Makefile | 10 +++++-- twowrites.c | 77 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 85 insertions(+), 2 deletions(-) create mode 100644 twowrites.c diff --git a/Makefile b/Makefile index 81ea87d..e5ee716 100644 --- a/Makefile +++ b/Makefile @@ -1,6 +1,12 @@ CFLAGS=-O0 -g -all: fdpassing +all: fdpassing twowrites xreq fdpassing: fdpassing.o fdpass.o - $(CC) -o $@ fdpassing.o fdpass.o + $(CC) $(CFLAGS) -o $@ fdpassing.o fdpass.o + +twowrites: twowrites.o fdpass.o + $(CC) $(CFLAGS) -o $@ twowrites.o fdpass.o + +xreq: xreq.o fdpass.o + $(CC) $(CFLAGS) -o $@ xreq.o fdpass.o diff --git a/twowrites.c b/twowrites.c new file mode 100644 index 0000000..0529655 --- /dev/null +++ b/twowrites.c @@ -0,0 +1,77 @@ +/* + * Copyright © 2012 Keith Packard + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; version 2 of the License. + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. + */ + +#include "fdpass.h" + +void +child(int sock) +{ + int fd; + char buf[16]; + ssize_t size; + + for (;;) { + size = sock_fd_read(sock, buf, sizeof(buf), &fd); + if (size <= 0) + break; + printf ("read %d\n", size); + if (fd != -1) { + write(fd, "hello, world\n", 13); + close(fd); + } + } +} + +void +parent(int sock) +{ + ssize_t size; + int i; + int fd; + + fd = 1; + size = sock_fd_write(sock, "1", 1, -1); + printf ("wrote %d without fd\n", size); + size = sock_fd_write(sock, "1", 1, 1); + printf ("wrote %d with fd\n", size); +} + +int +main(int argc, char **argv) +{ + int sv[2]; + int pid; + + if (socketpair(AF_LOCAL, SOCK_STREAM, 0, sv) < 0) { + perror("socketpair"); + exit(1); + } + switch ((pid = fork())) { + case 0: + close(sv[0]); + child(sv[1]); + break; + case -1: + perror("fork"); + exit(1); + default: + close(sv[1]); + parent(sv[0]); + break; + } + return 0; +}