void inform_clients

(

DNS_SERVICE *

servp

)

Definition at line 984 of file dns.c.

References node::conn_id, red_node::conn_id, serv::conn_id, Curr_N_Conns, Debug, dim_print_date_time(), dll_get_next(), dll_remove(), dna_write_nowait(), Dns_conns, DNS_DIC_HEADER, DNS_DIC_PACKET::format, Memory::free(), i, Net_conns, NET_CONNECTION::node, DNS_DIC_PACKET::node_addr, DNS_CONNECTION::node_addr, serv::node_head, DNS_DIC_PACKET::node_name, DNS_CONNECTION::node_name, DNS_DIC_PACKET::pid, DNS_CONNECTION::pid, DNS_DIC_PACKET::port, DNS_CONNECTION::port, red_node::prev, DNS_DIC_PACKET::protocol, DNS_CONNECTION::protocol, release_conn(), serv::serv_def, serv::server_format, DNS_DIC_PACKET::service_def, red_node::service_id, DNS_DIC_PACKET::service_id, DNS_DIC_PACKET::size, SRC_DIC, NET_CONNECTION::task, DNS_DIC_PACKET::task_name, and DNS_CONNECTION::task_name.

Referenced by do_inform_clients(), and handle_registration().

{
        RED_NODE *nodep, *prevp; 
        NODE *full_nodep; 
        DNS_DIC_PACKET packet;
        char *ptr;
        int i, to_release = 0;

        nodep = servp->node_head;
        prevp = nodep;
        while( (nodep = (RED_NODE *) dll_get_next((DLL *) servp->node_head,
                                                 (DLL *) prevp)) )
        {
                packet.service_id = htovl(nodep->service_id);
                strcpy(packet.node_name, Dns_conns[servp->conn_id].node_name);
                strcpy(packet.task_name, Dns_conns[servp->conn_id].task_name);
                for(i = 0; i < 4; i++)
                        packet.node_addr[i] = Dns_conns[servp->conn_id].node_addr[i];
                packet.port = htovl(Dns_conns[servp->conn_id].port);
                packet.pid = htovl(Dns_conns[servp->conn_id].pid);
                packet.protocol = htovl(Dns_conns[servp->conn_id].protocol);
                packet.size = htovl(DNS_DIC_HEADER);
                packet.format = htovl(servp->server_format);
                strcpy( packet.service_def, servp->serv_def );
/* Should it be dna_write_nowait? 16/9/2008 */
/* moved from dna_write to dna_write_nowait in 14/10/2008 */
/*
                dna_write_nowait(nodep->conn_id, &packet, DNS_DIC_HEADER);
*/
                if( !dna_write_nowait(nodep->conn_id, &packet, DNS_DIC_HEADER) )
                {
                        dim_print_date_time();
                        printf(" Inform Client: Couldn't write, releasing Conn %3d : Client %s@%s\n",nodep->conn_id,
                                        Net_conns[nodep->conn_id].task,
                                        Net_conns[nodep->conn_id].node);
                        fflush(stdout);
                        to_release = nodep->conn_id;
/*
release_conn(nodep->conn_id);
*/
                }
/*
                if(dna_write_nowait(nodep->conn_id, &packet, DNS_DIC_HEADER))
                {
*/
                        dll_remove( (DLL *) nodep );
                        ptr = (char *)nodep - (2 * sizeof(void *));
                        full_nodep = (NODE *)ptr;
                        dll_remove( (DLL *) full_nodep );
                        nodep = nodep->prev;
                        free( full_nodep );
                        prevp = nodep;
/*
                }
*/
        }
        if(to_release)
                release_conn(to_release);
}

Here is the call graph for this function:

Here is the caller graph for this function: