static void release_conn ( int  conn_id )

static

Definition at line 1077 of file dns.c.

References node::client_prev, node::conn_id, serv::conn_id, Curr_n_servers, Curr_n_services, Debug, dim_print_date_time(), dll_empty(), dll_get_next(), dll_remove(), dna_close(), Dns_conns, do_update_did(), dtq_rem_entry(), Memory::free(), DNS_CONNECTION::n_services, Net_conns, node::next, serv::next, serv::node_head, red_serv::node_head, DNS_CONNECTION::node_head, serv::server_prev, DNS_CONNECTION::service_head, service_remove(), node::servp, SRC_DIC, SRC_DIS, SRC_NONE, DNS_CONNECTION::src_type, serv::state, Timer_q, and DNS_CONNECTION::timr_ent.

Referenced by check_validity(), handle_client_request(), handle_registration(), inform_clients(), kill_servers(), and recv_rout().

{
        DNS_SERVICE *servp, *old_servp;
        NODE *nodep, *old_nodep;
        void service_remove();

        servp = (DNS_SERVICE *)Dns_conns[conn_id].service_head;
        nodep = (NODE *)Dns_conns[conn_id].node_head;
        if(( Dns_conns[conn_id].src_type == SRC_DIS ) || (servp))
        {
                if( Debug )
                {
                        dim_print_date_time();
                        printf( " Conn %3d : Server %s@%s died\n",
                                conn_id, Dns_conns[conn_id].task_name,
                                Dns_conns[conn_id].node_name);
                        fflush(stdout);
                }
                else
                {
                        if(Dns_conns[conn_id].n_services == -1)
                        {
                                dim_print_date_time();
                                printf( " Conn %3d : Server %s@%s died\n",
                                        conn_id, Dns_conns[conn_id].task_name,
                                        Dns_conns[conn_id].node_name);
                                fflush(stdout);
                        }
                }
                Curr_n_servers--;
                if( Dns_conns[conn_id].timr_ent ) 
                {
                        dtq_rem_entry( Timer_q, Dns_conns[conn_id].timr_ent );
                        Dns_conns[conn_id].timr_ent = NULL;
                }
                servp = (DNS_SERVICE *)Dns_conns[conn_id].service_head;
                while( (servp = (DNS_SERVICE *) dll_get_next(
                                (DLL *) Dns_conns[conn_id].service_head,
                                (DLL *) servp)) )
                {
                        dll_remove((DLL *) servp);
                        if(dll_empty((DLL *) servp->node_head)) 
                        {
                                service_remove(&(servp->next));
                                Curr_n_services--;
                                old_servp = servp;
                                servp = servp->server_prev;
                                free(old_servp);
                        } 
                        else 
                        {
                                servp->state = 0;
                                servp->conn_id = 0;
                                servp = servp->server_prev;
                        }
                }
                if(Dns_conns[conn_id].n_services)
                {
                        Dns_conns[conn_id].n_services = 0;
                        
                        do_update_did(conn_id);
/*
                        Last_conn_id = conn_id;
                        dis_update_service(Server_new_info_id);
                    dis_update_service(Server_info_id);
*/                      
                }
                free((DNS_SERVICE *)Dns_conns[conn_id].service_head);
                Dns_conns[conn_id].service_head = 0;
                Dns_conns[conn_id].src_type = SRC_NONE;
                dna_close(conn_id);
        }
        else if((Dns_conns[conn_id].src_type == SRC_DIC) || (nodep))
        {
                if(Debug)
                {
                        dim_print_date_time();
                        printf(" Conn %3d : Client %s@%s died\n",
                                conn_id, Net_conns[conn_id].task, Net_conns[conn_id].node);
                        fflush(stdout);
                }
                if( (nodep = (NODE *)Dns_conns[conn_id].node_head) ) 
                {
                        while( (nodep = (NODE *) dll_get_next(
                                        (DLL *) Dns_conns[conn_id].node_head,
                                        (DLL *) nodep)) )
                        {
                                servp = nodep->servp;
                                dll_remove( (DLL *) nodep );
                                dll_remove( (DLL *) &(nodep->next) );
                                old_nodep = nodep;
                                nodep = nodep->client_prev;
                                free(old_nodep);
                                if( (dll_empty((DLL *) servp->node_head)) &&
                                    (!servp->conn_id) )
                                {
                                        service_remove(&(servp->next));
                                        Curr_n_services--;
                                        free( servp );
                                }
                        }
                        free(Dns_conns[conn_id].node_head);
                        Dns_conns[conn_id].node_head = 0;
                }
                Dns_conns[conn_id].src_type = SRC_NONE;
                dna_close(conn_id);
        } 
        else 
        {
                if(Debug)
                {
                        dim_print_date_time();
                        printf(" Conn %3d : Undefined Type %s@%s died\n",
                                conn_id, Net_conns[conn_id].task,
                                Net_conns[conn_id].node);
                        fflush(stdout);
                }
                dna_close(conn_id);
        }
}

Here is the call graph for this function:

Here is the caller graph for this function: