#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <string.h>
#include <time.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <fcntl.h>
#include <errno.h>
#include <ctype.h>
#include <pthread.h>

Include dependency graph for eagi_proxy.c:

Macros
#define	BUFSIZE 1024

#define	COMMAND_PORT 8417

#define	SEND_ENVIORNMENT /send the enviornment thru the socket/

#define	SIGNAL_PORT 8418

#define	WINBUF_NUM 2400 /* number of WINSIZE windows = 1 minute */

#define	WINSIZE 400 /* 25 ms @ 8 kHz and 16bit */

Functions
int	connect_to_host (char *host, int port)

void	finalize ()

int	main ()

void	read_full (int file, char *buffer, int num)

int	read_some (int file, char *buffer, int size)

void *	readSignal (void *ptr)

void *	readStdin (void *ptr)

void	setnonblocking (int desc)

int	write_amap (int file, char *buffer, int num)

void	write_buf (int file, char *buffer, int num)

Variables
char *	be

char *	bs

char	buf [BUFSIZE]

int	command_desc

pthread_mutex_t	command_mutex

char	connected =1

char *	end

pthread_t	signal_thread

int	speech_desc

pthread_t	stdin_thread

char *	winbuf

char	window [WINSIZE]

Macro Definition Documentation

◆ BUFSIZE

#define BUFSIZE 1024

Definition at line 65 of file eagi_proxy.c.

Referenced by main(), and readStdin().

◆ COMMAND_PORT

#define COMMAND_PORT 8417

Definition at line 60 of file eagi_proxy.c.

Referenced by main().

◆ SEND_ENVIORNMENT

#define SEND_ENVIORNMENT /*send the enviornment thru the socket*/

Definition at line 61 of file eagi_proxy.c.

◆ SIGNAL_PORT

#define SIGNAL_PORT 8418

Definition at line 59 of file eagi_proxy.c.

Referenced by main().

◆ WINBUF_NUM

#define WINBUF_NUM 2400 /* number of WINSIZE windows = 1 minute */

Definition at line 71 of file eagi_proxy.c.

Referenced by main().

◆ WINSIZE

#define WINSIZE 400 /* 25 ms @ 8 kHz and 16bit */

Definition at line 68 of file eagi_proxy.c.

Referenced by main(), and readSignal().

Function Documentation

◆ connect_to_host()

int connect_to_host	(	char *	host,
		int	port
	)

Definition at line 217 of file eagi_proxy.c.

References desc, EXIT_FAILURE, and gethostbyname.

Referenced by main().

 {
    int address;
    struct hostent* host_entity;
    int res,desc;
    int opts;
    struct sockaddr_in host;
 
 
    /* get address */
    if(!strcmp(name,"localhost"))
       address=htonl(2130706433); /*127.0.0.1*/
    else
    {
       address=inet_addr(name); /* check if it's an IP that's written in the string */
       if(address==(in_addr_t)-1)
       {
          host_entity = gethostbyname(name); /* search for the host under this name */
 
          if(!host_entity)
          {
             fprintf(stderr,"EAGI proxy: Wrong address!\n"); /* can't find anything*/
             return -1;
          }
          address=*((int*)host_entity->h_addr);
       }
    }
 
    desc=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    if(desc<0)
    {
       fprintf(stderr,"EAGI proxy: Cannot create socket!\n");
       return -1;
    }
 
    memset((void*)&host,0,sizeof(struct sockaddr_in));
 
    host.sin_family=AF_INET;
    host.sin_port=htons(port);
    host.sin_addr.s_addr=address;
 
    res=connect(desc,(struct sockaddr*)&host,sizeof(host));
    if(res<0)
    {
       fprintf(stderr,"EAGI proxy: Cannot connect!\n");
       return -1;
    }
 
    /* set to non-blocking mode */
    opts = fcntl(desc,F_GETFL);
    if (opts < 0) {
       perror("fcntl(F_GETFL)");
       exit(EXIT_FAILURE);
    }
    opts = (opts | O_NONBLOCK);
    if (fcntl(desc,F_SETFL,opts) < 0) {
       perror("fcntl(F_SETFL)");
       exit(EXIT_FAILURE);
    }
 
 
    return desc;
 }

◆ finalize()

void finalize ( )

Definition at line 154 of file eagi_proxy.c.

References command_desc, free(), speech_desc, and winbuf.

Referenced by main().

 {
    close(command_desc);
    close(speech_desc);
    free(winbuf);
 }

◆ main()

int main ( )

Definition at line 107 of file eagi_proxy.c.

References be, bs, buf, BUFSIZE, command_desc, command_mutex, COMMAND_PORT, connect_to_host(), connected, end, finalize(), malloc(), NULL, pthread_create, pthread_mutex_init, pthread_mutex_lock, pthread_mutex_unlock, read_some(), readSignal(), readStdin(), SIGNAL_PORT, signal_thread, speech_desc, stdin_thread, winbuf, WINBUF_NUM, and WINSIZE.

 {
    int ret;
 
    atexit(finalize);
 
    setlinebuf(stdin);
    setlinebuf(stdout);
 
    winbuf=(char*)malloc(WINSIZE*WINBUF_NUM);
    end=winbuf+WINSIZE*WINBUF_NUM;
    bs=be=winbuf;
 
    speech_desc=connect_to_host("localhost",SIGNAL_PORT);
    if(speech_desc<0)
    {
       perror("signal socket");
       return -1;
    }
 
 
    command_desc=connect_to_host("localhost",COMMAND_PORT);
    if(command_desc<0)
    {
       perror("command socket");
       return -1;
    }
 
    pthread_mutex_init(&command_mutex,NULL);
    pthread_create(&stdin_thread,NULL,readStdin,NULL);
    pthread_create(&signal_thread,NULL,readSignal,NULL);
 
    while(connected)
    {
       pthread_mutex_lock(&command_mutex);
       ret=read_some(command_desc,buf,BUFSIZE);
       pthread_mutex_unlock(&command_mutex);
       if(ret>0)
       {
          buf[ret]=0;
          printf("%s",buf);
       }
    }
 
    return 0;
 }

◆ read_full()

void read_full	(	int	file,
		char *	buffer,
		int	num
	)

Definition at line 200 of file eagi_proxy.c.

References connected, and errno.

Referenced by readSignal().

 {
    int count,pos=0;
 
    while(num)
    {
       count=read(file,buffer+pos,num);
       if(count==0 || (count<0 && errno!=EAGAIN))
       {
          connected=0;
          return;
       }
       num-=count;
       pos+=count;
    }
 }

◆ read_some()

int read_some	(	int	file,
		char *	buffer,
		int	size
	)

Definition at line 281 of file eagi_proxy.c.

References c, connected, and errno.

Referenced by main().

 {
    unsigned char c;
    int res,i=0;
 
    for(;;)
    {
       res=read(desc,&c,1);
       if(res<1)
       {
          if(errno!=EAGAIN)
          {
             perror("Error reading");
             connected=0;
          }
          break;
       }
       if(res==0)
       {
          connected=0;
          break;
       }
 
       buffer[i]=c;
       i++;
    }
 
    return i;
 }

◆ readSignal()

void * readSignal ( void * ptr )

Definition at line 188 of file eagi_proxy.c.

References connected, NULL, read_full(), speech_desc, window, WINSIZE, and write_buf().

Referenced by main().

 {
    while(connected)
    {
       read_full(3,window,WINSIZE);
       write_buf(speech_desc,window,WINSIZE);
    }
 
    pthread_exit(NULL);
 }

◆ readStdin()

void * readStdin ( void * ptr )

Definition at line 161 of file eagi_proxy.c.

References buf, BUFSIZE, command_desc, command_mutex, connected, NULL, pthread_mutex_lock, pthread_mutex_unlock, and write_buf().

Referenced by main().

 {
    while(1)/*read enviornment*/
    {
       fgets(buf,BUFSIZE,stdin);
       #ifdef SEND_ENVIORNMENT
          pthread_mutex_lock(&command_mutex);
          write_buf(command_desc,buf,strlen(buf));
          pthread_mutex_unlock(&command_mutex);
       #endif
       if(feof(stdin) || buf[0]=='\n')
       {
          break;
       }
    }
 
    while(connected)
    {
       fgets(buf,BUFSIZE,stdin);
       pthread_mutex_lock(&command_mutex);
       write_buf(command_desc,buf,strlen(buf));
       pthread_mutex_unlock(&command_mutex);
    }
 
    pthread_exit(NULL);
 }

◆ setnonblocking()

void setnonblocking ( int desc )

Definition at line 402 of file eagi_proxy.c.

 {
    int opts;
 
    opts = fcntl(desc,F_GETFL);
    if(opts < 0)
    {
       perror("fcntl(F_GETFL)");
       exit(-1);
    }
 
    opts = (opts | O_NONBLOCK );
    if(fcntl(desc,F_SETFL,opts) < 0)
    {
       perror("fcntl(F_SETFL)");
       exit(-1);
    }
 }

◆ write_amap()

int write_amap	(	int	file,
		char *	buffer,
		int	num
	)

Definition at line 382 of file eagi_proxy.c.

References connected, and errno.

Referenced by write_buf().

 {
    int ret;
    ret=write(desc,buf,size);
    if(ret<0)
    {
       if(errno!=EAGAIN)
       {
          perror("Error writing");
          connected=0;
       }
       return 0;
    }
    if(ret==0)
       connected=0;
 
    return ret;
 }

◆ write_buf()

void write_buf	(	int	file,
		char *	buffer,
		int	num
	)

Definition at line 312 of file eagi_proxy.c.

References be, bs, end, winbuf, and write_amap().

Referenced by AST_TEST_DEFINE(), audiohook_read_frame_both(), readSignal(), and readStdin().

 {
    int ret;
 
    /*NOTE: AMAP -> as much as possible */
 
    if(be!=bs)/* if data left in buffer */
    {
       if(be>bs)/* if buffer not split */
       {
          ret=write_amap(desc,bs,be-bs);/* write AMAP */
          bs+=ret;/* shift the start of the buffer */
       }
       else/* if buffer is split */
       {
          ret=write_amap(desc,bs,end-bs);/* write higher part first */
          if(ret==end-bs)/* if wrote whole of the higher part */
          {
             ret=write_amap(desc,winbuf,be-winbuf);/* write lower part */
             bs=winbuf+ret;/* shift start to new position */
          }
          else bs+=ret;/* if not wrote whole of higher part, only shift start */
       }
    }
 
    if(be==bs)/* if buffer is empty now */
    {
       ret=write_amap(desc,buf,size);/* write AMAP of the new data */
       buf+=ret;/* shift start of new data */
       size-=ret;/* lower size of new data */
    }
 
    if(size)/* if new data still remains unsent */
    {
       if(be>=bs)/* if data not split */
       {
          if(size>end-be)/* if new data size doesn't fit higher end */
          {
             size-=end-be;/* reduce new data size by the higher end size */
             memcpy(be,buf,end-be);/* copy to higher end */
             be=winbuf;/* shift end to begining of buffer */
             buf+=end-be;/* shift start of new data */
          }
          else/* if new data fits the higher end */
          {
             memcpy(be,buf,size);/* copy to higher end */
             be+=size;/* shift end by size */
             if(be>=end)/* if end goes beyond the buffer */
                be=winbuf;/* restart */
             size=0;/* everything copied */
          }
       }
 
       if(size)/* if new data still remains */
       {
          if(size>=bs-be)/* if new data doesn't fit between end and start */
          {
             fprintf(stderr,"Buffer overflow!\n");
             size=bs-be-1;/* reduce the size that we can copy */
          }
 
          if(size)/* if we can copy anything */
          {
             memcpy(be,buf,size);/* copy the new data between end and start */
             be+=size;/* shift end by size */
          }
       }
    }
 }