int dis_start_serving_dns	(	dim_long	dnsid,
		char *	task
	)

Definition at line 1093 of file dis.c.

References ALL, create_dns(), Debug_on, Default_DNS, DIM_FATAL, dim_print_date_time(), DIMDNSUNDEF, Dis_conn_id, dis_dns_ent::dis_dns_packet, DIS_DNS_TMOUT_MAX, DIS_DNS_TMOUT_MIN, dis_find_dns(), dis_dns_ent::dis_first_time, Dis_first_time, dis_init(), dis_dns_ent::dis_service_id, Dis_timer_q, dll_init(), dna_open_server(), dis_dns_ent::dns_dis_conn_id, do_dis_add_cmnd_dns(), do_dis_add_service_dns(), do_update_service_list(), dtq_create(), dtq_start_timer(), error_handler(), id_get(), Memory::malloc(), MAX_NAME, MAX_TASK_NAME, MORE, more_ids, open_dns(), Port_number, Protocol, recv_dns_dis_rout(), register_services(), SEEK_PORT, dis_dns_ent::serving, Serving, sprintf(), SRC_DIS, dis_dns_ent::updating_service_list, and Version_number.

Referenced by dis_start_serving().

{
        char str0[MAX_NAME], str1[MAX_NAME],str2[MAX_NAME],
          str3[MAX_NAME],str4[MAX_NAME];
        char task_name_aux[MAX_TASK_NAME];
        extern int open_dns();
        extern DIS_DNS_CONN *dis_find_dns(dim_long);
        DIS_DNS_CONN *dnsp;
        unsigned int more_ids[10] = {0};

        dis_init();
        {
        DISABLE_AST
        if(Serving == -1)
        {
                ENABLE_AST
                return(0);
        }
          /*
#ifdef VxWorks
        taskDeleteHookAdd(remove_all_services);
        printf("Adding delete hook\n");
#endif
*/

        if(!Client_head) 
        {
                Client_head = (CLIENT *)malloc(sizeof(CLIENT));
                dll_init( (DLL *) Client_head );
        }
        if(dnsid == 0)
        {
                dnsp = Default_DNS;
        }
        else if(!(dnsp = dis_find_dns(dnsid)))
        {
                dnsp = create_dns(dnsid);
        }
        dnsp->serving = 1;
        Serving = 1;
        if(Dis_first_time)
        {
                strncpy( task_name_aux, task, (size_t)MAX_TASK_NAME );
                task_name_aux[MAX_TASK_NAME-1] = '\0';
                Port_number = SEEK_PORT;
if(Debug_on)
{
dim_print_date_time();
 printf("Opening Server Connection %s\n",task_name_aux);
}
                if( !(Dis_conn_id = dna_open_server( task_name_aux, dis_insert_request, 
                        &Protocol, &Port_number, error_handler) ))
                {
                        ENABLE_AST
                        return(0);
                }
                Dis_first_time = 0;
        }
        if(dnsp->dis_first_time)
        {
                dnsp->dis_first_time = 0;

                sprintf(str0, "%s/VERSION_NUMBER", task);
                sprintf(str1, "%s/CLIENT_LIST", task);
                sprintf(str2, "%s/SERVICE_LIST", task);
                sprintf(str3, "%s/SET_EXIT_HANDLER", task);
                sprintf(str4, "%s/EXIT", task);

                more_ids[0] = do_dis_add_service_dns( str0, "L", &Version_number,
                                                sizeof(Version_number), 0, 0, dnsid );

                more_ids[1] = do_dis_add_service_dns( str1, "C", 0, 0, client_info, (dim_long)dnsp, dnsid );
                dnsp->dis_client_id = more_ids[1];
                more_ids[2] = do_dis_add_service_dns( str2, "C", 0, 0, service_info, (dim_long)dnsp, dnsid );
                dnsp->dis_service_id = more_ids[2];
                more_ids[3] = do_dis_add_cmnd_dns( str3, "L:1", add_exit_handler, 0, dnsid );
                more_ids[4] = do_dis_add_cmnd_dns( str4, "L:1", exit_handler, 0, dnsid );
                more_ids[5] = 0;
                strcpy( dnsp->task_name, task );
if(Debug_on)
{
dim_print_date_time();
 printf("start serving %s\n",task);
}
        }
/*
        if(idlist)
        {
                for(i = 0; idlist[i]; i++)
                {
                        servp = (SERVICE *)id_get_ptr(idlist[i], SRC_DIS);
                        if(servp)
                        {
                                servp->dnsp = dnsp;
                                n_services++;
                        }
                }
        }
        if(dnsp != Default_DNS)
        {
                for(i = 0; more_ids[i]; i++)
                {
                        servp = (SERVICE *)id_get_ptr(more_ids[i], SRC_DIS);
                        if(servp)
                        {
                                servp->dnsp = dnsp;
                                n_services++;
                        }
                }
                dnsp->dis_n_services += n_services;
                Dis_n_services -= n_services;
        }
*/
        if(!Dis_timer_q)
                Dis_timer_q = dtq_create();
        if( !dnsp->dns_dis_conn_id )
        {
                if(!strcmp(task,"DIS_DNS"))
                {
                        register_services(dnsp, ALL, 1);
                        ENABLE_AST
                        return(id_get(&(dnsp->dis_dns_packet), SRC_DIS));
                }
                else
                {
                
                        dnsp->dns_dis_conn_id = open_dns(dnsid, recv_dns_dis_rout, error_handler,
                                        DIS_DNS_TMOUT_MIN, DIS_DNS_TMOUT_MAX, SRC_DIS );
                        if(dnsp->dns_dis_conn_id == -2)
                                error_handler(0, DIM_FATAL, DIMDNSUNDEF, "DIM_DNS_NODE undefined", -1);
                }
        }
        else
        {
                register_services(dnsp, MORE, 0);
                if(dnsp->dis_service_id)
                {
/*
                        dis_update_service(Dis_service_id);
*/
                        if(!dnsp->updating_service_list)
                        {
                                dtq_start_timer(1, do_update_service_list, dnsp);
                                dnsp->updating_service_list = 1;
                        }
                }
        }
        ENABLE_AST
        }
        return(1);
}

Here is the call graph for this function:

Here is the caller graph for this function: