ref -lsocket -lnsl
hdr,sys poll,socket,netinet/in
lib select,poll,socket
typ fd_set sys/socket.h sys/select.h
typ socklen_t unistd.h sys/socket.h = unsigned int
tst pipe_socketpair note{ use socketpair() for peekable pipe() }end execute{
#include <ast.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/socket.h>
#ifndef SHUT_RD
#define SHUT_RD 0
#endif
#ifndef SHUT_WR
#define SHUT_WR 1
#endif
static void handler(sig)
int sig;
{
_exit(0);
}
int main()
{
int n;
int pfd[2];
int sfd[2];
char buf[256];
pid_t pid;
static char msg[] = "hello world\n";
close(0);
if (pipe(pfd) < 0 ||
socketpair(AF_UNIX, SOCK_STREAM, 0, sfd) < 0 ||
shutdown(sfd[1], SHUT_RD) < 0 ||
shutdown(sfd[0], SHUT_WR) < 0)
return(1);
if ((pid = fork()) < 0)
return(1);
if (pid)
{
close(pfd[1]);
close(sfd[1]);
wait(&n);
if (sfpkrd(pfd[0], buf, sizeof(buf), '\n', -1, 1) >= 0 ||
sfpkrd(sfd[0], buf, sizeof(buf), '\n', -1, 1) < 0)
return(1);
}
else
{
close(pfd[0]);
close(sfd[0]);
write(pfd[1], msg, sizeof(msg) - 1);
write(sfd[1], msg, sizeof(msg) - 1);
return(0);
}
close(pfd[0]);
close(sfd[0]);
signal(SIGPIPE, handler);
if (socketpair(AF_UNIX, SOCK_STREAM, 0, sfd) < 0 ||
shutdown(sfd[1], SHUT_RD) < 0 ||
shutdown(sfd[0], SHUT_WR) < 0)
return(1);
close(sfd[0]);
write(sfd[1], msg, sizeof(msg) - 1);
return(1);
}
}end
tst socketpair_devfd note{ /dev/fd/N handles socketpair() }end execute{
#include <ast.h>
#include <fs3d.h>
#include <sys/types.h>
#include <sys/socket.h>
int main()
{
int devfd;
int n;
int sfd[2];
fs3d(FS3D_OFF);
close(0);
open("/dev/null", O_RDONLY);
if ((n = open("/dev/fd/0", O_RDONLY)) < 0)
return(1);
close(n);
if (socketpair(AF_UNIX, SOCK_STREAM, 0, sfd) < 0 ||
shutdown(sfd[0], 1) < 0 ||
shutdown(sfd[1], 0) < 0)
return(1);
close(0);
dup(sfd[0]);
close(sfd[0]);
if ((n = open("/dev/fd/0", O_RDONLY)) < 0)
return(1);
return(0);
}
}end
tst socketpair_shutdown_mode note{ fchmod() after socketpair() shutdown() }end execute{
#include <ast.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
int main()
{
int sfd[2];
struct stat st0;
struct stat st1;
if (socketpair(AF_UNIX, SOCK_STREAM, 0, sfd) < 0 ||
shutdown(sfd[0], 1) < 0 ||
shutdown(sfd[1], 0) < 0)
return(1);
if (fstat(sfd[0], &st0) < 0 || fstat(sfd[1], &st1) < 0)
return(1);
if ((st0.st_mode & (S_IRUSR|S_IWUSR)) == S_IRUSR &&
(st1.st_mode & (S_IRUSR|S_IWUSR)) == S_IWUSR)
return(1);
if (fchmod(sfd[0], S_IRUSR) < 0 ||
fstat(sfd[0], &st0) < 0 ||
(st0.st_mode & (S_IRUSR|S_IWUSR)) != S_IRUSR)
return(1);
if (fchmod(sfd[1], S_IWUSR) < 0 ||
fstat(sfd[1], &st1) < 0 ||
(st1.st_mode & (S_IRUSR|S_IWUSR)) != S_IWUSR)
return(1);
return(0);
}
}end
cat{
#pragma prototyped
#ifdef _lib_poll
# define poll _SYS_poll
#else
# undef _hdr_poll
# undef _sys_poll
#endif /* _lib_poll */
#ifdef _hdr_poll
# include <poll.h>
#else
# ifdef _sys_poll
# include <sys/poll.h>
# endif /* _sys_poll */
#endif /* _hdr_poll */
#ifdef _lib_poll
# undef poll
extern int poll(struct pollfd*,unsigned long,int);
#endif /* _lib_poll */
#ifdef _lib_select
# ifndef FD_ZERO
# define FD_ZERO(x) (*(x)=0)
# endif /* FD_ZERO */
# ifndef FD_SET
# define FD_SET(n,x) (*(x)|=(1L<<(n)))
# endif /* FD_SET */
# ifndef _typ_fd_set
typedef long fd_set;
# endif /*_typ_fd_set */
#endif /* _lib_select */
}end