X-Git-Url: https://hackdaworld.org/gitweb/?p=my-code%2Fivac.git;a=blobdiff_plain;f=src%2Fivac.c;h=f6a11180a4e6b6e763944368da85ebeba08c83b9;hp=44e831c8b649ad08a996269ac48ec9a27907e639;hb=21a073b6e9d464f3f11dfb290d27341bb4a203b6;hpb=d525cc402e67386372745a4bc3c04a488ea264f7 diff --git a/src/ivac.c b/src/ivac.c index 44e831c..f6a1118 100644 --- a/src/ivac.c +++ b/src/ivac.c @@ -98,11 +98,18 @@ int main(int argc,char **argv) { ivac.event.timeout.tv_sec=IVAC_S_SEC; ivac.event.timeout.tv_usec=IVAC_S_USEC; /* event init */ - event_init(&(ivac.event)); + if(event_init(&(ivac.event))==E_ERROR) { + ivac_shutdown(&ivac); + return ERROR; + } /* input init */ ivac.input.mode=CONTENT_BUFFER; - input_init(&(ivac.input)); + ivac.input.c_count=0; + if(input_init(&(ivac.input))==I_ERROR) { + ivac_shutdown(&ivac); + return ERROR; + } /* network init */ if(network_init(&(ivac.net))==N_ERROR) { @@ -111,6 +118,8 @@ int main(int argc,char **argv) { ivac_shutdown(&ivac); return ERROR; } + + /* network udp init */ network_udp_listen_init(&(ivac.net)); /* add listening port(s) + stdin to (read) event system */ @@ -118,19 +127,22 @@ int main(int argc,char **argv) { event_math(ivac.net.l_udp_fd,&(ivac.event),READ,ADD); event_math(0,&(ivac.event),READ,ADD); - /* display init */ - display_init(&(ivac.display)); - /* use hardcoded audio settings by now */ ivac.audio.fmt=BIT_8; ivac.audio.channels=MONO; ivac.audio.speed=8000; /* audio init */ audio_init(&(ivac.audio)); + /* audio setup */ audio_setup(&(ivac.audio)); + /* display init */ + display_init(&(ivac.display)); + /* display */ - ivac_display(&(ivac.display)); + ivac_display(&ivac); + ivac_display_content(&ivac); + ivac_display_draw(&ivac); /* start event system - callbacks used: ivac_event_cb + ivac_regular_cb */ event_start(&(ivac.event),(void *)&ivac,ivac_event_cb,ivac_regular_cb); @@ -140,12 +152,12 @@ int main(int argc,char **argv) { int ivac_shutdown(t_ivac *ivac) { + display_shutdown(&(ivac->display)); network_shutdown(&(ivac->net)); network_udp_shutdown(&(ivac->net)); input_shutdown(&(ivac->input)); event_stop(&(ivac->event)); audio_shutdown(&(ivac->audio)); - display_shutdown(&(ivac->display)); return SUCCESS; } @@ -215,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: @@ -274,6 +286,7 @@ int ivac_event_cb(t_event *event,void *ptr) { ivac_send_info(channel,ivac); } ivac_display_content(ivac); + ivac_display_draw(ivac); } /* wait for user info */ @@ -288,6 +301,7 @@ int ivac_event_cb(t_event *event,void *ptr) { ivac_add_to_monitor(ivac,c_str); } ivac_display_content(ivac); + ivac_display_draw(ivac); } } } @@ -301,6 +315,10 @@ int ivac_event_cb(t_event *event,void *ptr) { int ivac_regular_cb(t_event *event,void *ptr) { + t_ivac *ivac; + + ivac=(t_ivac *)ptr; + /* usual jobs like audio & video transmit ... */ return SUCCESS; @@ -315,16 +333,25 @@ 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]; +#ifdef DEBUG + char debug_string[IVAC_CONSOLE_STRING_LEN]; +#endif 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); /* 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 + sprintf(debug_string,"got %02x",data[input->c_count-1]); + ivac_add_to_monitor(ivac,debug_string); +#endif /* delete console string + args */ memset(c_str,0,IVAC_CONSOLE_STRING_LEN); @@ -332,11 +359,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),channel); sprintf(c_str,"selected channel %d",channel); } - else if(arg[1][0]='*') { + else if(arg[1][0]=='*') { network_select(&(ivac->net),MAX_CONNECTIONS); strcpy(c_str,"selected all channels"); } @@ -436,7 +468,7 @@ int ivac_parse_command(t_input *input,void *ptr) { network_deselect(&(ivac->net),channel); sprintf(c_str,"deselected channel %d",channel); } - else if(arg[1][0]='*') { + else if(arg[1][0]=='*') { network_deselect(&(ivac->net),MAX_CONNECTIONS); strcpy(c_str,"deselected all channels"); } @@ -454,8 +486,9 @@ 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; @@ -464,16 +497,25 @@ int ivac_parse_command(t_input *input,void *ptr) { return SUCCESS; } -int ivac_display_head(t_display *display) { +int ivac_display_head(t_ivac *ivac) { - puts("#########################################################"); - puts("##### ivac - - Copyright (C) 2004 Frank Zirkelbach #####"); - puts("#########################################################"); + 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) { +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; } @@ -481,16 +523,38 @@ int ivac_display_box(t_display *display) { 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,""); + 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) { + 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)); + } + } + 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); return SUCCESS; } @@ -498,42 +562,48 @@ int ivac_display_console(t_display *display) { int ivac_display_console_content(t_ivac *ivac) { int i; + char string[IVAC_CONSOLE_STRING_LEN]; - for(i=0;iconsole[i]); - - return SUCCESS; -} - -int ivac_display_prompt(t_display *display) { + 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_content(t_ivac *ivac) { +int ivac_display_prompt(t_ivac *ivac) { - printf("%c",ivac->input.content[ivac->input.c_count-1]); - fflush(NULL); + display_string(&(ivac->display),0,ivac->display.max_y-1,"prompt: ",8); return SUCCESS; } -int ivac_display(t_display *display) { - - int x,y; - - /* display head */ - ivac_display_head(display); - - /* display box */ - ivac_display_box(display); - - /* display console */ - ivac_display_console(display); - - /* display command prompt */ - ivac_display_prompt(display); +int ivac_display_prompt_content(t_ivac *ivac) { + char string[IVAC_CONSOLE_STRING_LEN]; + int count; +#ifdef DEBUG + char debug_string[IVAC_CONSOLE_STRING_LEN]; +#endif + + for(count=0;countinput.c_count;count++) + string[count]=ivac->input.content[count]; + for(count=ivac->input.c_count;countdisplay),8,ivac->display.max_y-1, + string,ivac->display.max_x); + +#ifdef DEBUG + sprintf(debug_string,"%02x %02x %02x %02x ...",ivac->input.content[0], + ivac->input.content[1], + ivac->input.content[2], + ivac->input.content[3]); + ivac_add_to_monitor(ivac,debug_string); +#endif + return SUCCESS; } @@ -551,6 +621,32 @@ int ivac_display_content(t_ivac *ivac) { return SUCCESS; } +int ivac_display(t_ivac *ivac) { + + /* display static head */ + ivac_display_head(ivac); + + /* display static box */ + ivac_display_box(ivac); + + /* display static console */ + ivac_display_console(ivac); + + /* display command prompt */ + ivac_display_prompt(ivac); + + return SUCCESS; +} + +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; +} + int ivac_add_to_monitor(t_ivac *ivac,char *msg) { int i; @@ -559,5 +655,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; }