X-Git-Url: https://hackdaworld.org/gitweb/?p=my-code%2Fivac.git;a=blobdiff_plain;f=src%2Fivac.c;h=e959ef8ba6f4e0dc7bec8b8b4dc2322167d9feb7;hp=9645c33f59444e0e74b66b9b85814c61e657cf9f;hb=40031b2d692a7b83e437535045ece6c58f8bf31e;hpb=5f7a9e08cad9caa3aa593eba18e6a22f763ecc37 diff --git a/src/ivac.c b/src/ivac.c index 9645c33..e959ef8 100644 --- a/src/ivac.c +++ b/src/ivac.c @@ -21,10 +21,25 @@ * */ -// #define USE_NCURSES - #include "ivac.h" +int usage(void) { + + puts(""); + puts("usage: ivac "); + puts(""); + puts("options:"); + puts("-h \t\t show this help"); + puts("-n \t specify your name"); + puts("-p \t specify port to listen for incoming connections"); + puts("-u \t specify udp data port"); + puts("-d \t specify audio device"); + puts("-i \t specify network interface"); + puts(""); + + return SUCCESS; +} + int main(int argc,char **argv) { /* TESTING BY NOW */ @@ -32,13 +47,42 @@ int main(int argc,char **argv) { t_ivac ivac; int i; - if(argc!=2) { - printf("\nusage: %s \n\n",argv[0]); - return ERROR; + /* default values */ + strcpy(ivac.username,"ivac"); + ivac.net.l_port=IVAC_LISTEN_PORT; + ivac.net.l_udp_port=IVAC_UDP_PORT; + strcpy(ivac.audio.dsp_dev,SOUND_DEVICE); + strcpy(ivac.net.nic,"eth0"); + + /* parse argv and change default values */ + for(i=1;idisplay)); network_shutdown(&(ivac->net)); + network_udp_shutdown(&(ivac->net)); input_shutdown(&(ivac->input)); event_stop(&(ivac->event)); - // display_shutdown(&(ivac->display)); + audio_shutdown(&(ivac->audio)); return SUCCESS; } @@ -129,9 +193,26 @@ int ivac_send_info(int channel,t_ivac *ivac) { return SUCCESS; } +int ivac_send_quit(int channel,t_ivac *ivac) { + + char data[7]; /* one more for \0 */ + + data[0]=IVAC_SEND_QUIT; + data[1]=4; + strcpy(data+2,"quit"); + + if(network_send(ivac->net.connection[channel].fd,data,6)==N_ERROR) { + puts("[ivac] ivac_send_quit failed"); + return ERROR; + } + + return SUCCESS; +} + int ivac_receive_info(int channel,t_ivac *ivac) { char data[SEND_N_MAX]; + char c_str[IVAC_CONSOLE_STRING_LEN]; int count,length; count=0; @@ -146,7 +227,7 @@ int ivac_receive_info(int channel,t_ivac *ivac) { switch(data[count]) { case IVAC_SEND_NAME: strncpy(ivac->challenger[channel].name,data+count+2,data[count+1]); - ivac->challenger[channel].name[data[count+1]]='\0'; + ivac->challenger[channel].name[(int)data[count+1]]='\0'; count+=(data[count+1]+2); break; case IVAC_SEND_G_CAP: @@ -158,49 +239,88 @@ int ivac_receive_info(int channel,t_ivac *ivac) { ivac->challenger[channel].av_cap|=data[count+3]; count+=4; break; + case IVAC_SEND_QUIT: + if(!(strncmp(data+count+2,"quit",data[1]))) + sprintf(c_str,"channel %02d: connection closed by remote host", + channel); + event_math(ivac->net.connection[channel].fd,&(ivac->event), + READ,REMOVE); + network_close(&(ivac->net),channel); + memset(&(ivac->challenger[channel]),0,sizeof(t_challenger)); + ivac_add_to_monitor(ivac,c_str); + count+=6; + break; default: - puts("[ivac] ivac_receive_info, unknown character"); + sprintf(c_str,"ivac_receive_info, unknown character: 0x%02x\n", + data[count]); + ivac_add_to_monitor(ivac,c_str); return ERROR; break; } } - return SUCCESS; + return length; } int ivac_event_cb(t_event *event,void *ptr) { t_ivac *ivac; int channel; + char c_str[IVAC_CONSOLE_STRING_LEN]; ivac=(t_ivac *)ptr; + /* incoming connection -- first contact => send info */ if(FD_ISSET(ivac->net.l_fd,&(event->rfds))) { - /* manage incoming + send info */ - if((channel=network_manage_incoming(&(ivac->net)))!=N_ERROR) { + channel=network_manage_incoming(&(ivac->net)); + if(channel==N_E_ACCEPT) + sprintf(c_str,"accept failed"); + else if(channel==N_E_MAXC) + sprintf(c_str,"maximum connections reached"); + else { + sprintf(c_str,"connection from %s port %d on channel %d", + ivac->net.connection[channel].ip, + ivac->net.connection[channel].port,channel); + ivac_add_to_monitor(ivac,c_str); event_math(ivac->net.connection[channel].fd,event,READ,ADD); ivac_send_info(channel,ivac); } + ivac_display_content(ivac); + ivac_display_draw(ivac); } - /* receive info */ - for(channel=0;channelnet.connection[channel].status&C_ESTABL) - if(FD_ISSET(ivac->net.connection[channel].fd,&(event->rfds))) - ivac_receive_info(channel,ivac); + /* wait for user info */ + for(channel=0;channelnet.connection[channel].status&C_ESTABL) { + /* remote is sending info */ + if(FD_ISSET(ivac->net.connection[channel].fd,&(event->rfds))) { + if(ivac_receive_info(channel,ivac)==0) { + event_math(ivac->net.connection[channel].fd,event,READ,REMOVE); + network_close(&(ivac->net),channel); + sprintf(c_str,"channel %02d: broken pipe - disconnected",channel); + ivac_add_to_monitor(ivac,c_str); + } + ivac_display_content(ivac); + ivac_display_draw(ivac); + } + } + } /* user interaction */ if(FD_ISSET(0,&(event->rfds))) input_get_event(&(ivac->input),ivac_parse_command,ivac); - /* display ivac gui */ - // ivac_display_content(ivac); - return SUCCESS; } int ivac_regular_cb(t_event *event,void *ptr) { + t_ivac *ivac; + + ivac=(t_ivac *)ptr; + + ivac_add_to_monitor(ivac,"event HUGH"); + /* usual jobs like audio & video transmit ... */ return SUCCESS; @@ -215,16 +335,26 @@ int ivac_parse_command(t_input *input,void *ptr) { char *data,valid; char c_str[IVAC_CONSOLE_STRING_LEN]; char arg[IVAC_ARG_COUNT][IVAC_ARG_LEN]; + char debug_string[128]; ivac=(t_ivac *)ptr; data=input->content; valid=0; - /* refresh prompt content only! */ + /* refresh prompt content only */ ivac_display_prompt_content(ivac); + ivac_display_draw(ivac); + +#ifdef DEBUG + ivac_add_to_monitor(ivac,"nach display refresh"); +#endif /* parse command routines */ - if(data[input->c_count-1]=='\n') { + if(data[input->c_count-1]=='\n'||data[input->c_count-1]=='\r') { + +#ifdef DEBUG + ivac_add_to_monitor(ivac,"got newline or carriage return!"); +#endif /* delete console string + args */ memset(c_str,0,IVAC_CONSOLE_STRING_LEN); @@ -232,11 +362,11 @@ int ivac_parse_command(t_input *input,void *ptr) { /* get args */ len=0; - while(data[len]!='\n') len++; + while(data[len]!='\n'||data[len]!='\r') len++; i=0; j=0; while((inet.connection[i].status&C_ESTABL) { + ivac_send_quit(i,ivac); + network_close(&(ivac->net),i); + } + } ivac_shutdown(ivac); } if(!(strncmp(arg[0],"set",3))) { @@ -262,15 +399,11 @@ int ivac_parse_command(t_input *input,void *ptr) { sprintf(c_str,"changed username to %s",ivac->username); } else if((channel>=0)&&(channelnet.connection[channel].status&C_IN_USE) { + i=network_set_connection_info(&(ivac->net),channel,arg[2],atoi(arg[3])); + if(i==N_E_IN_USE) sprintf(c_str,"channel %02d: connection in use",channel); - } - else { - strncpy(ivac->net.connection[channel].ip,arg[2],IP_DIGITS); - ivac->net.connection[channel].port=atoi(arg[3]); + if(i==N_SUCCESS) sprintf(c_str,"channel %02d: set connection info",channel); - ivac->net.connection[channel].status|=C_INFO_A; - } } else snprintf(c_str,IVAC_CONSOLE_STRING_LEN,"unknown argument: '%s'", arg[1]); } @@ -279,17 +412,17 @@ int ivac_parse_command(t_input *input,void *ptr) { if((arg[1][0]>='0')&&(arg[1][0]<='9')) channel=atoi(arg[1]); else channel=-1; if((channel>=0)&&(channelnet.connection[channel].status&C_INFO_A)) + i=network_connect(&(ivac->net),channel); + if(i==N_E_IN_USE) + sprintf(c_str,"channel %02d: connection in use",channel); + else if(i==N_E_NO_INFO) sprintf(c_str,"channel %02d: channel not configured",channel); else { - if(ivac->net.connection[channel].status&C_IN_USE) - sprintf(c_str,"channel %02d: connection in use",channel); - else { - sprintf(c_str,"channel %02d: trying to connect to %s:%d",channel, - ivac->net.connection[channel].ip, - ivac->net.connection[channel].port); - ivac->net.connection[channel].status|=C_IN_USE; - } + sprintf(c_str,"channel %02d: connected to %s:%d",channel, + ivac->net.connection[channel].ip, + ivac->net.connection[channel].port); + event_math(ivac->net.connection[channel].fd,&(ivac->event),READ,ADD); + ivac_send_info(channel,ivac); } } else sprintf(c_str,"invalid argument: '%s'",arg[1]); @@ -299,12 +432,16 @@ int ivac_parse_command(t_input *input,void *ptr) { if((arg[1][0]>='0')&&(arg[1][0]<='9')) channel=atoi(arg[1]); else channel=-1; if((channel>=0)&&(channelnet.connection[channel].status&C_ESTABL)) - sprintf(c_str,"channel %02d: no active connection",channel); - else { - ivac->net.connection[channel].status|=C_HANGUP; + if(ivac->net.connection[channel].status&C_ESTABL) { + ivac_send_quit(channel,ivac); + event_math(ivac->net.connection[channel].fd,&(ivac->event), + READ,REMOVE); + network_close(&(ivac->net),channel); sprintf(c_str,"channel %02d: connection closed",channel); + memset(&(ivac->challenger[channel]),0,sizeof(t_challenger)); } + else + sprintf(c_str,"channel %02d: no active connection",channel); } else sprintf(c_str,"invalid argument: '%s'",arg[1]); } @@ -313,11 +450,11 @@ int ivac_parse_command(t_input *input,void *ptr) { if((arg[1][0]>='0')&&(arg[1][0]<='9')) channel=atoi(arg[1]); else channel=-1; if((channel>=0)&&(channelnet.sendmask|=(1<net),channel); sprintf(c_str,"selected channel %d",channel); } - else if(arg[1][0]='*') { - ivac->net.sendmask=0xff; + else if(arg[1][0]=='*') { + network_select(&(ivac->net),MAX_CONNECTIONS); strcpy(c_str,"selected all channels"); } else sprintf(c_str,"invalid argument: '%s'",arg[1]); @@ -327,11 +464,11 @@ int ivac_parse_command(t_input *input,void *ptr) { if((arg[1][0]>='0')&&(arg[1][0]<='9')) channel=atoi(arg[1]); else channel=-1; if((channel>=0)&&(channelnet.sendmask&=(~(1<net),channel); sprintf(c_str,"deselected channel %d",channel); } - else if(arg[1][0]='*') { - ivac->net.sendmask=0; + else if(arg[1][0]=='*') { + network_deselect(&(ivac->net),MAX_CONNECTIONS); strcpy(c_str,"deselected all channels"); } else sprintf(c_str,"invalid argument: '%s'",arg[1]); @@ -348,181 +485,153 @@ int ivac_parse_command(t_input *input,void *ptr) { /* refresh whole display content */ ivac_display_content(ivac); + ivac_display_draw(ivac); - /* delete content buffer + reset counter */ + /* delete input content buffer + reset counter */ memset(input->content,0,input->c_count-1); input->c_count=0; } + ivac_add_to_monitor(ivac,"debug: end of parse function"); + return SUCCESS; } -int ivac_display_head(t_display *display) { - -#ifdef USE_NCURSES - int x,y; - - move(0,0); - for(x=0;xmax_x;x++) addch('#'); - mvaddstr(1,0,"##"); - mvaddstr(1,(display->max_x-4)/2-4,"- ivac -"); - mvaddstr(1,(display->max_x-2),"##"); - move(2,0); - for(x=0;xmax_x;x++) addch('#'); - refresh(); -#else - puts("#########################################################"); - puts("##### ivac - - Copyright (C) 2004 Frank Zirkelbach #####"); - puts("#########################################################"); -#endif +int ivac_display_head(t_ivac *ivac) { + + display_line(&(ivac->display),0,0,ivac->display.max_x,0,'#'); + display_string(&(ivac->display),(ivac->display.max_x-strlen(PROG_NAME))/2,1, + PROG_NAME,strlen(PROG_NAME)); + display_line(&(ivac->display),0,2,ivac->display.max_x,2,'#'); return SUCCESS; } -int ivac_display_box(t_display *display) { - -#ifdef USE_NCURSES - int x,y; - - for(y=IVAC_PROMPT_LEN;ymax_y-IVAC_PROMPT_LEN;y++) { - mvaddch(y,0,'#'); - mvaddch(y,display->max_x-1,'#'); - } -#endif +int ivac_display_box(t_ivac *ivac) { + display_line(&(ivac->display),0,3,ivac->display.max_x,3,'-'); + display_line(&(ivac->display),0,5,ivac->display.max_x,5,'-'); + display_string(&(ivac->display),0,6,"connections:",12); + display_line(&(ivac->display), + 0,ivac->display.max_y-IVAC_PROMPT_LEN-IVAC_CONSOLE_LEN-1, + ivac->display.max_x, + ivac->display.max_y-IVAC_PROMPT_LEN-IVAC_CONSOLE_LEN-1,'-'); + return SUCCESS; } int ivac_display_box_content(t_ivac *ivac) { int channel; + char string[MAX_BOX_CHARS]; /* prepare challenger names */ for(channel=0;channelchallenger[channel].name[0]==0) strcpy(ivac->challenger[channel].name,""); -#ifdef USE_NCURSES -#else + sprintf(string,"username: %s, capabilities: %02x|%04x", + ivac->username,ivac->g_cap,ivac->av_cap); + display_string(&(ivac->display),0,4,string,strlen(string)); + for(channel=0;channelnet.connection[channel].status&C_INFO_A) - printf("channel %02d: ip:%s port:%d status: %02x - name: %s\n",channel, - ivac->net.connection[channel].ip, - ivac->net.connection[channel].port, - ivac->net.connection[channel].status, - ivac->challenger[channel].name); + if(ivac->net.connection[channel].status&C_INFO_A) { + snprintf(string,MAX_BOX_CHARS, + "channel %02d: %s:%d, status: %02x, name: %s\n",channel, + ivac->net.connection[channel].ip, + ivac->net.connection[channel].port, + ivac->net.connection[channel].status, + ivac->challenger[channel].name); + display_string(&(ivac->display),0,IVAC_HEAD_LEN+4+channel, + string,strlen(string)); + } } -#endif return SUCCESS; } -int ivac_display_console(t_display *display) { +int ivac_display_console(t_ivac *ivac) { + + display_string(&(ivac->display), + 0,ivac->display.max_y-IVAC_PROMPT_LEN-IVAC_CONSOLE_LEN, + "console messages:",17); -#ifdef USE_NCURSES - int x,y; - - move(display->max_y-IVAC_CONSOLE_LEN-IVAC_PROMPT_LEN-1,0); - for(x=0;xmax_x;x++) addch('#'); -#endif - return SUCCESS; } int ivac_display_console_content(t_ivac *ivac) { -#ifdef USE_NCURSES - int x,y; - int len; - - for(y=0;yconsole[y]); - move(ivac->display.max_y-IVAC_CONSOLE_LEN-IVAC_PROMPT_LEN+y,2); - for(x=0;xconsole[y][x]>' ')||(ivac->console[y][x]<='~')) - ?ivac->console[y][x]:' '); - for(x=len;xconsole[i]); -#endif + for(i=0;iconsole[i]); + display_string(&(ivac->display), + 0,ivac->display.max_y-IVAC_PROMPT_LEN-IVAC_CONSOLE_LEN+1+i, + string,strlen(string)); + } return SUCCESS; } -int ivac_display_prompt(t_display *display) { +int ivac_display_prompt(t_ivac *ivac) { -#ifdef USE_NCURSES - int x,y; - - move(display->max_y-3,0); - for(x=0;xmax_x;x++) addch('#'); - mvaddstr(display->max_y-2,0,"## command: "); - mvaddstr(display->max_y-2,display->max_x-2,"##"); - move(display->max_y-1,0); - for(x=0;xmax_x;x++) addch('#'); - refresh(); -#endif + display_string(&(ivac->display),0,ivac->display.max_y-1,"prompt: ",8); return SUCCESS; } int ivac_display_prompt_content(t_ivac *ivac) { -#ifdef USE_NCURSES - int x,y; + char string[IVAC_CONSOLE_STRING_LEN]; + int count; - /* delete old command */ - if(ivac->input.c_count==0) { - move(ivac->display.max_y-2,12); - for(x=12;xdisplay.max_x-1;x++) addch(' '); - } + for(count=0;countinput.c_count;count++) + string[count]=ivac->input.content[count]; + for(;countdisplay.max_x-8;count++) string[count]=' '; + display_string(&(ivac->display),8,ivac->display.max_y-1, + string,ivac->display.max_x); + + return SUCCESS; +} - for(x=0;xinput.c_count;x++) - mvaddch(ivac->display.max_y-2,x+12,ivac->input.content[x]); - refresh(); -#else - printf("%c",ivac->input.content[ivac->input.c_count-1]); - fflush(NULL); -#endif +int ivac_display_content(t_ivac *ivac) { + + /* display box content */ + ivac_display_box_content(ivac); + + /* display console content */ + ivac_display_console_content(ivac); + + /* display prompt content */ + ivac_display_prompt_content(ivac); return SUCCESS; } -int ivac_display(t_display *display) { +int ivac_display(t_ivac *ivac) { - int x,y; + /* display static head */ + ivac_display_head(ivac); - /* display head */ - ivac_display_head(display); + /* display static box */ + ivac_display_box(ivac); - /* display box */ - ivac_display_box(display); - - /* display console */ - ivac_display_console(display); + /* display static console */ + ivac_display_console(ivac); /* display command prompt */ - ivac_display_prompt(display); + ivac_display_prompt(ivac); return SUCCESS; } -int ivac_display_content(t_ivac *ivac) { - - /* display box content */ - ivac_display_box_content(ivac); - - /* display console content */ - ivac_display_console_content(ivac); - - /* display prompt content */ - ivac_display_prompt_content(ivac); +int ivac_display_draw(t_ivac *ivac) { + + display_draw(&(ivac->display)); + display_set_cursor(&(ivac->display),ivac->input.c_count+8, + ivac->display.max_y-1); return SUCCESS; } @@ -535,5 +644,8 @@ int ivac_add_to_monitor(t_ivac *ivac,char *msg) { memcpy(ivac->console[i],ivac->console[i+1],IVAC_CONSOLE_STRING_LEN); memcpy(ivac->console[IVAC_CONSOLE_LEN-1],msg,IVAC_CONSOLE_STRING_LEN); + ivac_display_console_content(ivac); + ivac_display_draw(ivac); + return SUCCESS; }