source: trunk/FACT++/dim/src/examples/test_server.c@ 12350

#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <dis.h>

char str[10][80];

typedef struct {
        int i;
        int j;
        int k;
        double d;
        short s;
        char c;
        short t;
        float f;
        char str[20];
}TT;

TT t;

/*
int big_buff[1024];
*/

void cmnd_rout(int *tag, TT *buf, int *size)
{

        if(tag){}
        printf("Command received, size = %d, TT size = %d:\n", *size,
               (int)sizeof(TT));
        printf("buf->i = %d, buf->d = %2.2f, buf->s = %d, buf->c = %c, buf->f = %2.2f, buf->str = %s\n",
                        buf->i,buf->d,buf->s,buf->c,buf->f,buf->str);
}

void client_exited(int *tag)
{
        char name[84];

        if(dis_get_client(name))
                printf("Client %s (%d) exited\n", name, *tag);
        else
                printf("Client %d exited\n", *tag);
}

void exit_cmnd(int *code)
{
        printf("Exit_cmnd %d\n", *code);
        exit(*code);
}

int NewData;
int NewIds[11];

int more_ids[1024];
int curr_more_index = 0;
char more_str[1024][80];

/*
int atlas_ids[210];
float atlas_arr[10];
*/
int main(int argc, char **argv)
{
        int i, id, *ptr;
        char aux[80];
        char name[84], name1[132];
        int on = 0;
        long dnsid = 0;
        char extra_dns[128];
        int new_dns = 0;
/*
        int buf_sz, buf_sz1;
*/
/*
dis_set_debug_on();
*/
/*
        int status;
        regex_t re;

        if(regcomp(&re, "abc*",REG_EXTENDED|REG_NOSUB) != 0)
                printf("regcomp error\n");
        status = regexec(&re,"abcdef", (size_t)0, NULL, 0);
        regfree(&re);
        printf("result = %d\n", status); 
*/
        if(argc){}
        new_dns = dim_get_env_var("EXTRA_DNS_NODE", extra_dns, sizeof(extra_dns));
        if(new_dns)
                dnsid = dis_add_dns(extra_dns,0);
/*
        buf_sz = dim_get_write_buffer_size();
        dim_set_write_buffer_size(10000000);
        buf_sz1 = dim_get_write_buffer_size();
printf("socket buffer size = %d, after = %d\n",buf_sz, buf_sz1);
*/
        dis_add_exit_handler(exit_cmnd);
        dis_add_client_exit_handler(client_exited);

        for(i = 0; i< 10; i++)
        {
                sprintf(str[i],"%s/Service_%03d",argv[1],i);
                dis_add_service( str[i], "C", str[i], strlen(str[i])+1, 
                        (void *)0, 0 );
        }
        t.i = 123;
        t.j = 456;
        t.k = 789;
        t.d = 56.78;
        t.s = 12;
        t.t = 12;
        t.c = 'a';
        t.f = (float)4.56;
        ptr = (int *)&t;
        strcpy(t.str,"hello world");

        sprintf(aux,"%s/TEST_SWAP",argv[1]);
        id = dis_add_service( aux, "l:3;d:1;s:1;c:1;s:1;f:1;c:20", &t, sizeof(t), 
                (void *)0, 0 );
        sprintf(aux,"%s/TEST_CMD",argv[1]);
        dis_add_cmnd(aux,"l:3;d:1;s:1;c:1;s:1;f:1;c:20",cmnd_rout, 0);

/*
        big_buff[0] = 1;
        for(i = 0; i < 20; i++)
        {
                sprintf(aux,"%s/TestMem_%d",argv[1], i);
                big_ids[i] = dis_add_service( aux, "I", big_buff, 1024*sizeof(int), 
                        (void *)0, 0 );
        }
*/
/*
        for(i = 1; i <= 200; i++)
        {
                sprintf(aux,"%s/ATLAS_Service%d",argv[1],i);
                atlas_ids[i] = dis_add_service( aux, "F", atlas_arr, 10*sizeof(float), 
                        (void *)0, 0 );
        }
*/
        dis_start_serving( argv[1] );

        if(dis_get_client(name))
        {
                printf("client %s\n",name);
        }
/*
        for(i = 0; i < 5; i++)
        {
                sleep(10);

        }
        dis_stop_serving();
        sleep(59);
*/
        while(1)
        {
/*
                for(i = 0; i < 20; i++)
                {
                        index++;
                        big_buff[0] = index;
                        dis_update_service(big_ids[i]);
                }
                sleep(1);
*/
/*
                pause();
                */
                sleep(10);
                dis_update_service(id);
/*              
                for(i = 1; i <= 200; i++)
                {
                        dis_update_service(atlas_ids[i]);
                }
*/
/*
                if(curr_more_index < 1000)
                {
                        for(i = 1; i <= 10; i++)
                        {
                                sprintf(more_str[curr_more_index],"%s/More_Service_%03d",argv[1],curr_more_index);
                                more_ids[curr_more_index] = dis_add_service( more_str[curr_more_index], "C", 
                                        more_str[curr_more_index], strlen(more_str[curr_more_index])+1, 
                                        (void *)0, 0 );
printf("Adding service %s\n",more_str[curr_more_index]);
                                curr_more_index++;
                                dis_start_serving(argv[1]);
                                dis_start_serving(argv[1]);
                        }
                }
*/
                /*
                if(new_dns)
                {
                        if(!on)
                        {
printf("Connecting New DNS \n");
                                for(i = 0; i < 10; i++)
                                {
                                        sprintf(name1,"NewService%d",i);
                                        NewIds[i] = dis_add_service_dns(dnsid, name1, "i", &NewData, sizeof(NewData), 
                                                (void *)0, 0 );
                                }
                                NewIds[10] = 0;
                                dis_start_serving_dns(dnsid, "xx_new");
                                on = 1;
                        }
                        else
                        {
printf("DisConnecting New DNS \n");
                                for(i = 0; i < 10; i++)
                                {
                                        dis_remove_service(NewIds[i]);
                                }
                                on = 0;
                        }
                }
                */
        }
        return 1;
}