hv_jpx_mergec.c

#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

static const char *socket_path = "/tmp/hv_jpx_merged_socket";

#define BUF_SIZE 1024

int main(int argc, char **argv)
{
    struct sockaddr_un addr;
    char buf[BUF_SIZE];
    int fd, rc;

    if (argc > 1)
        socket_path = argv[1];

    if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
        perror("socket error");
        exit(-1);
    }

    memset(&addr, 0, sizeof addr);
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, socket_path, sizeof addr.sun_path - 1);

    if (connect(fd, (struct sockaddr *) &addr, sizeof addr) == -1) {
        perror("connect error");
        exit(-1);
    }

    while ((rc = read(STDIN_FILENO, buf, sizeof buf)) > 0)
        if (write(fd, buf, rc) != rc) {
            if (rc > 0)
                fprintf(stderr, "partial write");
            else {
                perror("write error");
                exit(-1);
            }
        }

    return 0;
}