28 #define USE_SOCKETPAIR 1 30 #if (USE_SOCKETPAIR == 1) && !defined (HAVE_SOCKETPAIR) 43 return (socketpair(AF_UNIX, SOCK_STREAM, 0, p));
64 if ((val = fcntl(p[chan], F_GETFL, 0)) < 0)
70 if ((val != O_WRONLY) && (val != O_RDWR))
76 if (write(p[chan], &
msg,
sizeof (
msg)) !=
sizeof (
msg))
100 if ((val = fcntl(p[chan], F_GETFL, 0)) < 0)
106 if (val != O_RDONLY && val != O_RDWR)
112 if (read(p[chan],
msg,
sizeof (*
msg)) !=
sizeof (*
msg))
132 if ((val = fcntl(fd, F_GETFL, 0)) < 0)
138 if ((val != O_WRONLY) && (val != O_RDWR))
144 if (write(fd, &
msg,
sizeof (
msg)) !=
sizeof (
msg))
164 if ((val = fcntl(fd, F_GETFL, 0)) < 0)
170 if (val != O_RDONLY && val != O_RDWR)
176 if (read(fd,
msg,
sizeof (*
msg)) !=
sizeof (*
msg))
int recv_msg_channel(p, int *msg, int who)
#define ZE_LogSysWarning(...)
#define ZE_LogMsgWarning(level,...)
bool send_message_pipe(int fd, int msg)
int send_msg_channel(p, int msg, int who)
bool recv_message_pipe(int fd, int *msg)