Subversion Repositories NedoOS

#include <stdio.h>
#include <string.h>
#include <oscalls.h>
#include <socket.h>
#include <stdlib.h>

extern unsigned char    buf_rx[4*1024];  
extern unsigned char *  ptr_in_rx;
extern unsigned char *  ptr_out_rx;
extern unsigned char    u32_intcount[4];
extern unsigned char    flag_int_change;
extern unsigned char    flag_syncrply;
extern unsigned char    msg_hello[9];
extern unsigned char    msg_framesync[5];
no_init union APP_PAGES app_pages;
no_init int                     len;

SOCKET                                  cmds = 0;
SOCKET                                  datasoc = 0;
char                                    grmod =0;

no_init struct sockaddr_in web_ia;


SOCKET                                  udps = 0;
no_init struct sockaddr_in udps_ia;
no_init struct sockaddr_in udpr_ia;
no_init unsigned char udp_buf[50];

no_init unsigned char * ptr;

void int_play(void);
void int_null(void);
void ptr_increment(int l);
void shutup(void);


unsigned char scrredraw(void){
        puts(msg_hello+2);
        return 0;
}

void exit(int e){
        shutup();
        if(cmds)closesocket(cmds,0);
        if(datasoc)closesocket(datasoc,0);
        if(udps)closesocket(udps,0);
        if(e!=0){      
                OS_SETGFX(6);
                puts((char*)e);
                puts("Press any key");
                getchar();
        }
        ((void(*)(int))0x0000)(e);
}

void initMCU(void){
        YIELD();
        app_pages.l = OS_GETMAINPAGES();
        //OS_SETMUSIC(int_play, app_pages.pgs.window_1);
        OS_SETGFX(6);
        puts(msg_hello+2);
}

void putserr(const char * s1,const char * s2){
        if(grmod == 0){
                OS_SETGFX(6);
                grmod = 1;
        }
        printf("Error: %s %s!",s1,s2);
}


C_task main (int argc, char *argv[])
{
        int l=1;
    initMCU();
        ptr_out_rx =  buf_rx;
        ptr_in_rx = buf_rx + sizeof(buf_rx);
        web_ia.sin_port=htons(16729); //'AY' chars
        udpr_ia.sin_port=htons(16729);
        while(l!=argc){
                char * p=argv[l];
                if(p[0]!='-') exit((int)"Wrong parameter");
                switch (p[1]&0xdf){
                        case 'P':
                                web_ia.sin_port=htons(strtoul(p+2,&ptr,10));
                                break;
                        default:
                                exit((int)"Wrong parameter");
                }
                l++;
        }
        cmds=socket(AF_INET,SOCK_STREAM,0);
        bind(cmds,&web_ia,sizeof(web_ia));
        listen(cmds,0);
        while(1){
                if(datasoc == 0){
                        if(udps == 0){
                                udps = socket(AF_INET,SOCK_DGRAM,0);
                                bind(udps,&udpr_ia, sizeof (udpr_ia));
                        }
                        l=recvfrom(udps,udp_buf,sizeof(udp_buf),0,&udps_ia,0);
                        if(l>0){
                                udp_buf[l] = 0x00;
                                puts(udp_buf);
                                sendto(udps,msg_hello+2,8,0,&udps_ia,0);
                        }              
                        if(cmds == 0){
                                cmds = socket(AF_INET,SOCK_STREAM,0);
                                bind(cmds, &web_ia, sizeof(web_ia));
                                listen(cmds, 0);
                        }
                        datasoc=accept(cmds, 0, 0);
                        if(datasoc < 0){
                                datasoc=0;
                                OS_SETMUSIC(int_null, app_pages.pgs.window_1);
                                if(errno != ERR_EAGAIN){
                                        closesocket(cmds, 0);
                                        cmds = 0;
                                }else{
                                        _low_level_get();
                                }
                                continue;
                        }else{//to do else
                                closesocket(cmds, 0);
                                cmds = 0;
                                closesocket(udps, 0);
                                udps = 0;
                                send(datasoc, msg_hello, 9, 0);
                                ptr_in_rx =  buf_rx;
                                ptr_out_rx = NULL;
                                OS_SETMUSIC(int_play, app_pages.pgs.window_1);
                        }
                }
                if(flag_int_change){
                        flag_int_change = 0;
                        if(flag_syncrply == 2){
                                send(datasoc, msg_framesync, 10, 0);
                        }else{
                                send(datasoc, msg_framesync, 5, 0);
                        }
                        flag_syncrply = 0;
                }
                if(ptr_out_rx < ptr_in_rx){
                        l=recv(datasoc, ptr_in_rx, buf_rx+sizeof(buf_rx)-ptr_in_rx, 0);
                }else if(ptr_out_rx > ptr_in_rx){
                        l=recv(datasoc, ptr_in_rx, ptr_out_rx - ptr_in_rx, 0);
                }else{
                        continue;
                }
                if(l < 0){
                        shutup();
                        closesocket(datasoc, 0);
                        OS_SETMUSIC(int_null, app_pages.pgs.window_1);
                        datasoc = 0;
                        continue;
                }else if(l == 0){
                        _low_level_get();
                        continue;
                }
                //╤В╤Г╤В ╤Б╨║╨╗╨░╨┤╤Л╨▓╨░╨╡╨╝ ╨┐╨░╨║╨╡╤В ╨▓ ╨▒╤Г╤Д╨╡╤А
                ptr_increment(l);
               
        }
}