-
Simon Morlat authored
Move license to GPLv3, update version number to 4.3.0.
2bc924c1
/*
* Copyright (c) 2010-2019 Belledonne Communications SARL.
*
* This file is part of Liblinphone.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#define _GNU_SOURCE
#include <fcntl.h>
#include <stdio.h>
#ifndef _WIN32
#include <poll.h>
#endif
#include "ortp/ortp.h"
static int running=1;
int main(int argc, char *argv[]){
char buf[32768];
ortp_pipe_t fd;
/* handle args */
if (argc < 2) {
ortp_error("Usage: %s pipename", argv[0]);
return 1;
}
ortp_init();
ortp_set_log_level_mask(NULL, ORTP_MESSAGE | ORTP_WARNING | ORTP_ERROR | ORTP_FATAL);
fd=ortp_client_pipe_connect(argv[1]);
if (fd==(ortp_pipe_t)-1){
ortp_error("Could not connect to control pipe: %s",strerror(errno));
return -1;
}
#ifdef _WIN32
DWORD fdwMode, fdwOldMode;
HANDLE hin = GetStdHandle(STD_INPUT_HANDLE);
HANDLE hout = GetStdHandle(STD_OUTPUT_HANDLE);
GetConsoleMode(hin, &fdwOldMode);
fdwMode = fdwOldMode ^ ENABLE_MOUSE_INPUT ^ ENABLE_WINDOW_INPUT;
SetConsoleMode(hin, fdwMode);
FlushConsoleInputBuffer(hin);
while (running) {
DWORD read = 0;
DWORD written = 0;
ReadFile(hin, buf, sizeof(buf), &read, NULL);
if (read > 2) {
buf[read - 2] = '\0'; // Remove ending '\r\n'
if (ortp_pipe_write(fd, (uint8_t *)buf, (int)strlen(buf)) < 0) {
running = 0;
} else {
read = ortp_pipe_read(fd, (uint8_t *)buf, sizeof(buf));
7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
if (read > 0) {
WriteFile(hout, buf, read, &written, NULL);
} else {
running = 0;
}
}
}
}
SetConsoleMode(hin, fdwOldMode);
#else
struct pollfd pfds[2] = { { 0 } };
ssize_t bytes;
pfds[0].fd=fd;
pfds[0].events=POLLIN;
pfds[1].fd=1;
pfds[1].events=POLLIN;
while (running){
int err;
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,(size_t)bytes)==-1){
ortp_error("Fail to write to stdout?");
break;
}
fprintf(stdout,"\n");
}else if (bytes==0){
break;
}
}
/*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,(size_t)bytes)==-1){
ortp_error("Fail to write to unix socket");
break;
}
}else if (bytes==0){
break;
}
}
}
}
#endif
return 0;
}