sockread: add support for reading data from a pipe

This commit is contained in:
Moritz Warning 2015-01-18 02:01:14 +01:00
parent e5c39cc999
commit 04a518498c
2 changed files with 15 additions and 7 deletions

View File

@ -18,7 +18,7 @@ define Package/sockread
endef endef
define Package/sockread/description define Package/sockread/description
sockread reads data from a Unix domain socket sockread writes and reads data from a Unix domain socket
represented as a special file on the file system. represented as a special file on the file system.
endef endef

View File

@ -3,15 +3,16 @@
#include <stdlib.h> #include <stdlib.h>
#include <errno.h> #include <errno.h>
#include <stddef.h> #include <stddef.h>
#include <stdio.h> #include <unistd.h>
#include <string.h>
#include <sys/socket.h> #include <sys/socket.h>
#include <sys/un.h> #include <sys/un.h>
int main(int argc, char *argv[]) { int main(int argc, char *argv[]) {
char buf[1024];
ssize_t r;
if (argc != 2) { if (argc != 2) {
fprintf(stderr, "Usage: %s <socket>\n", argv[0]); fprintf(stderr, "Write to and read from a Unix domain socket.\n\nUsage: %s <socket>\n", argv[0]);
return 1; return 1;
} }
@ -36,8 +37,15 @@ int main(int argc, char *argv[]) {
return 1; return 1;
} }
char buf[1024]; /* Check if stdin refers to a terminal */
ssize_t r; if (!isatty(fileno(stdin))) {
/* Read from stdin and write to socket */
while (0 < (r = fread(buf, 1, sizeof(buf), stdin))) {
send(fd, buf, r, 0);
}
}
/* Read from socket and write to stdout */
while (1) { while (1) {
r = recv(fd, buf, sizeof(buf), 0); r = recv(fd, buf, sizeof(buf), 0);
if (r < 0) { if (r < 0) {