void check_validity

(

int

conn_id

)

Definition at line 610 of file dns.c.

References node::conn_id, Debug, dim_print_date_time(), dna_write_nowait(), Dns_conns, DNS_DIS_HEADER, DNS_DIS_REGISTER, Net_conns, release_conn(), set_in_error(), DNS_DIS_PACKET::size, time, DNS_DIS_PACKET::type, DNS_CONNECTION::validity, and WATCHDOG_TMOUT_MAX.

Referenced by handle_registration().

{
        int time_diff;
        DNS_DIS_PACKET dis_packet;
        void set_in_error();

        if(Dns_conns[conn_id].validity < 0)
        {
                /* timeout reached kill all services and connection */
                if(Dns_conns[conn_id].n_services != -1)
                {
                        dim_print_date_time();
                        printf(" Server %s (%s@%s) has been set in error\n",
                                Dns_conns[conn_id].task_name, Net_conns[conn_id].task, Net_conns[conn_id].node);
                        fflush(stdout);
                        set_in_error(conn_id);
                        return;
                }
/*
                Dns_conns[conn_id].validity = -Dns_conns[conn_id].validity;
*/
        }
        time_diff = (int)time(NULL) - Dns_conns[conn_id].validity;
        if(time_diff > (int)(WATCHDOG_TMOUT_MAX*1.2))
        {
                /* send register signal */
                dis_packet.type = htovl(DNS_DIS_REGISTER);
                dis_packet.size = htovl(DNS_DIS_HEADER);
                if(Debug)
                {
                        dim_print_date_time();
                        printf(" Conn %3d : Server %s@%s Registration Requested\n",
                                conn_id, Net_conns[conn_id].task, Net_conns[conn_id].node);
                        fflush(stdout);
                }
/* moved from dna_write to dna_write_nowait in 14/10/2008 */
                if( !dna_write_nowait(conn_id, &dis_packet, DNS_DIS_HEADER) )
                {
                        dim_print_date_time();
                        printf(" Server Validity: Couldn't write, releasing Conn %3d : Server %s@%s\n",conn_id,
                                Net_conns[conn_id].task, Net_conns[conn_id].node);
                        fflush(stdout);
                        release_conn(conn_id);
                }
                else
                        Dns_conns[conn_id].validity = -Dns_conns[conn_id].validity;
        }
}               

Here is the call graph for this function:

Here is the caller graph for this function: