void dis_send_service	(	unsigned	service_id,
		int *	buffer,
		int	size
	)

Definition at line 2053 of file dis.c.

References DIS_PACKET::buffer, req_ent::conn_id, DIM_ERROR, dim_print_date_time(), DIMSVCINVAL, DIS_HEADER, dll_get_next(), dna_write_nowait(), error_handler(), Memory::free(), id_get_ptr(), Memory::malloc(), Net_conns, release_conn(), serv::request_head, req_ent::service_id, DIS_PACKET::service_id, size, DIS_PACKET::size, sprintf(), SRC_DIS, and str.

Referenced by dis_hash_print().

{
        register REQUEST *reqp, *prevp;
        register SERVICE *servp;
        static DIS_PACKET *dis_packet;
        static int packet_size = 0;
        int conn_id;
        char str[128];

        DISABLE_AST
        if( !service_id ) {
                sprintf(str,"Send Service - Invalid service id");
                error_handler(0, DIM_ERROR, DIMSVCINVAL, str, -1);
                ENABLE_AST
                return;
        }
        servp = (SERVICE *)id_get_ptr(service_id, SRC_DIS);
        if(!servp)
        {
                ENABLE_AST
                return;
        }
        if(!packet_size)
        {
                dis_packet = (DIS_PACKET *)malloc((size_t)(DIS_HEADER+size));
                packet_size = DIS_HEADER + size;
        } 
        else 
        {
                if( DIS_HEADER+size > packet_size ) 
                {
                        free(dis_packet);
                        dis_packet = (DIS_PACKET *)malloc((size_t)(DIS_HEADER+size));
                        packet_size = DIS_HEADER+size;
                }
        }
        prevp = servp->request_head;
        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                (DLL *) prevp)) ) 
        {
                dis_packet->service_id = htovl(reqp->service_id);
                memcpy(dis_packet->buffer, buffer, (size_t)size);
                dis_packet->size = htovl(DIS_HEADER + size);

                conn_id = reqp->conn_id;
                if( !dna_write_nowait(conn_id, dis_packet, size + DIS_HEADER) )
                {
                        dim_print_date_time();
                        printf(" Server Sending Service: Couldn't write to Conn %3d : Client %s@%s\n",conn_id,
                                Net_conns[conn_id].task, Net_conns[conn_id].node);
                        fflush(stdout);
                        release_conn(conn_id, 1, 0);
                }
                else
                        prevp = reqp;
        }
        ENABLE_AST
}

Here is the call graph for this function:

Here is the caller graph for this function: