void recv_dns_dis_rout	(	int	conn_id,
		DNS_DIS_PACKET *	packet,
		int	size,
		int	status
	)

Definition at line 641 of file dis.c.

References ALL, exit_ent::conn_id, DIM_FATAL, DIM_WARNING, DIMDNSDUPLC, DIMDNSEXIT, DIMDNSREFUS, DIMDNSTMOUT, DIMDNSUNDEF, DIS_DNS_TMOUT_MAX, DIS_DNS_TMOUT_MIN, Dis_timer_q, dna_close(), dis_dns_ent::dns_dis_conn_id, DNS_DIS_EXIT, DNS_DIS_HEADER, DNS_DIS_KILL, DNS_DIS_REGISTER, DNS_DIS_SOFT_EXIT, DNS_DIS_STOP, dis_dns_ent::dns_timr_ent, dis_dns_ent::dnsid, do_dis_stop_serving_dns(), do_register_services(), dtq_add_entry(), dtq_rem_entry(), error_handler(), find_dns_by_conn_id(), open_dns(), rand_tmout(), register_services(), dis_dns_ent::serving, Serving, DNS_DIS_PACKET::size, sprintf(), SRC_DIS, STA_CONN, STA_DISC, str, dis_dns_ent::task_name, type, DNS_DIS_PACKET::type, WATCHDOG_TMOUT_MAX, and WATCHDOG_TMOUT_MIN.

Referenced by dis_start_serving_dns(), and release_conn().

{
        char str[128];
        int dns_timr_time;
        extern int rand_tmout(int, int);
        extern int open_dns(dim_long, void (*)(), void (*)(), int, int, int);
        extern DIS_DNS_CONN *find_dns_by_conn_id(int);
        extern void do_register_services(DIS_DNS_CONN *);
        extern void do_dis_stop_serving_dns(DIS_DNS_CONN *);
        DIS_DNS_CONN *dnsp;
        int type, exit_code;

        if(size){}
        dnsp = find_dns_by_conn_id(conn_id);
        if(!dnsp)
        {
                return;
        }
        switch(status)
        {
        case STA_DISC:     /* connection broken */
                if( dnsp->dns_timr_ent ) {
                        dtq_rem_entry( Dis_timer_q, dnsp->dns_timr_ent );
                        dnsp->dns_timr_ent = NULL;
                }

                if(dnsp->dns_dis_conn_id > 0)
                        dna_close(dnsp->dns_dis_conn_id);
                if(Serving == -1)
                        return;
                if(dnsp->serving)
                {
                        dnsp->dns_dis_conn_id = open_dns(dnsp->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);
                }
                break;
        case STA_CONN:          /* connection received */
                if(dnsp->serving)
                {
                        dnsp->dns_dis_conn_id = conn_id;
                        register_services(dnsp, ALL, 0);
                        dns_timr_time = rand_tmout(WATCHDOG_TMOUT_MIN, 
                                                         WATCHDOG_TMOUT_MAX);
                        dnsp->dns_timr_ent = dtq_add_entry( Dis_timer_q,
                                                  dns_timr_time,
                                                  do_register_services, dnsp ); 
                }
                else
                {
                        dna_close(conn_id);
                }
                break;
        default :          /* normal packet */
                if(vtohl(packet->size) != DNS_DIS_HEADER)
                        break;
                type = vtohl(packet->type);
                exit_code = (type >> 16) & 0xFFFF;
                type &= 0xFFFF;
                switch(type)
                {
                case DNS_DIS_REGISTER :
                        sprintf(str, 
                                "%s: Watchdog Timeout, DNS requests registration",
                                dnsp->task_name);
                        error_handler(0, DIM_WARNING, DIMDNSTMOUT, str, -1);
                        register_services(dnsp, ALL, 0);
                        break;
                case DNS_DIS_KILL :
                        sprintf(str,
                                "%s: Some Services already known to DNS",
                                dnsp->task_name);
                        /*
                        exit(2);
                        */
                        Serving = -1;
                        error_handler(0, DIM_FATAL, DIMDNSDUPLC, str, -1);
                        /*
                        do_dis_stop_serving_dns(dnsp);
                        dis_stop_serving();
                        */
/*
                        exit_tag = 0;
                        exit_code = 2;
                        exit_size = sizeof(int);
                        exit_handler(&exit_tag, &exit_code, &exit_size);
*/
                        break;
                case DNS_DIS_STOP :
                        sprintf(str, 
                                "%s: DNS refuses connection",dnsp->task_name);
/*
                        exit(2);
*/
                        Serving = -1;
                        error_handler(0, DIM_FATAL, DIMDNSREFUS, str, -1);
                        /*
                        do_dis_stop_serving_dns(dnsp);
                        dis_stop_serving();
                        */
/*
                        exit_tag = 0;
                        exit_code = 2;
                        exit_size = sizeof(int);
                        exit_handler(&exit_tag, &exit_code, &exit_size);
*/
                        break;
                case DNS_DIS_EXIT :
                        sprintf(str, 
                                "%s: DNS requests Exit",dnsp->task_name);
/*
                        Serving = -1;
*/
                        error_handler(0, DIM_FATAL, DIMDNSEXIT, str, -1);
                        break;
                case DNS_DIS_SOFT_EXIT :
                        sprintf(str, 
                                "%s: DNS requests Exit(%d)",dnsp->task_name, exit_code);
/*
                        Serving = -1;
*/
                        error_handler(0, DIM_FATAL, DIMDNSEXIT, str, exit_code);
                        break;
                }
                break;
        }
}

Here is the call graph for this function:

Here is the caller graph for this function: