-
Sandrine Avakian authoredd4ff86db
daemon-pipetest.c 2.03 KiB
/*
daemon-pipetest.c
Copyright (C) 2016 Belledonne Communications, Grenoble, France
This library is free software; you can redistribute it and/or modify it
under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation; either version 2.1 of the License, or (at
your option) any later version.
This library 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 Lesser General Public
License for more details.
You should have received a copy of the GNU Lesser General Public License
along with this library; if not, write to the Free Software Foundation,
Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
#define _GNU_SOURCE
#include <fcntl.h>
#include <poll.h>
#include "ortp/ortp.h"
static int running=1;
int main(int argc, char *argv[]){
struct pollfd pfds[2]={{0}};
char buf[4096];
int fd;
/* handle args */
if (argc < 2) {
ortp_error("Usage: %s pipename", argv[0]);
return 1;
}
fd=ortp_client_pipe_connect(argv[1]);
ortp_init();
ortp_set_log_level_mask(NULL,ORTP_MESSAGE|ORTP_WARNING|ORTP_ERROR|ORTP_FATAL);
if (fd==-1){
ortp_error("Could not connect to control pipe: %s",strerror(errno));
return -1;
}
pfds[0].fd=fd;
pfds[0].events=POLLIN;
pfds[1].fd=1;
pfds[1].events=POLLIN;
while (running){
int err;
int bytes;
err=poll(pfds,2,-1);
if (err>0){
/*splice to stdout*/
if (pfds[0].revents & POLLIN){
if ((bytes=read(pfds[0].fd,buf,sizeof(buf)))>0){
if (write(0,buf,bytes)==-1){
ortp_error("Fail to write to stdout?");
break;
}
fprintf(stdout,"\n");
}else if (bytes==0){
break;
}
}
7172737475767778798081828384858687
/*splice from stdin to pipe */
if (pfds[1].revents & POLLIN){
if ((bytes=read(pfds[1].fd,buf,sizeof(buf)))>0){
if (write(pfds[0].fd,buf,bytes)==-1){
ortp_error("Fail to write to unix socket");
break;
}
}else if (bytes==0){
break;
}
}
}
}
return 0;
}