int send_command	(	int	conn_id,
		DIC_SERVICE *	servp
	)

Definition at line 1956 of file dic.c.

References DIC_PACKET::buffer, COMMAND, copy_swap_buffer_out(), DIC_HEADER, dim_print_date_time(), dna_write_nowait(), do_cmnd_callback(), dtq_start_timer(), dic_serv::fill_address, dic_serv::fill_size, DIC_PACKET::format, dic_serv::format, dic_serv::format_data, Memory::free(), Memory::malloc(), MAX_NAME, Net_conns, dic_serv::pending, CMNDCB_ITEM::ret_code, dic_serv::serv_id, CMNDCB_ITEM::serv_id, dic_serv::serv_name, DIC_PACKET::service_id, DIC_PACKET::service_name, size, DIC_PACKET::size, DIC_PACKET::timeout, DIC_PACKET::type, dic_serv::user_routine, and WAITING_CMND_ANSWER.

Referenced by request_command(), and send_service_command().

{
        static DIC_PACKET *dic_packet;
        static int cmnd_packet_size = 0;
        register int size;
        int ret;
        CMNDCB_ITEM *itemp;

        size = servp->fill_size;

        if(size < 0)
                return(1);

        if( !cmnd_packet_size ) {
                dic_packet = (DIC_PACKET *)malloc((size_t)(DIC_HEADER + size));
                cmnd_packet_size = DIC_HEADER + size;
        }
        else
        {
                if( DIC_HEADER + size > cmnd_packet_size ) {
                        free( dic_packet );
                        dic_packet = (DIC_PACKET *)malloc((size_t)(DIC_HEADER + size));
                        cmnd_packet_size = DIC_HEADER + size;
                }
        }

        strncpy(dic_packet->service_name, servp->serv_name, (size_t)MAX_NAME); 
        dic_packet->type = htovl(COMMAND);
        dic_packet->timeout = htovl(0);
        dic_packet->format = htovl(MY_FORMAT);

        dic_packet->service_id = /*id_get((void *)servp)*/servp->serv_id;

        size = copy_swap_buffer_out(servp->format, servp->format_data, 
                                         dic_packet->buffer, servp->fill_address, 
                                         size);
        dic_packet->size = htovl( size + DIC_HEADER);
        if( servp->user_routine )
        {
                servp->pending = WAITING_CMND_ANSWER;
                ret = dna_write_nowait(conn_id, dic_packet, DIC_HEADER + size);
                itemp = (CMNDCB_ITEM *)malloc(sizeof(CMNDCB_ITEM));
                itemp->serv_id = servp->serv_id;
                itemp->ret_code = ret;
/*
                id = id_get((void *)itemp, SRC_DIC);
*/
                dtq_start_timer(0, do_cmnd_callback, (dim_long)itemp);
/*
                (servp->user_routine)( &servp->tag, &ret );
*/
        }
        else
        {
                ret = dna_write_nowait(conn_id, dic_packet, DIC_HEADER + size);
        }
/*
        if(!ret)
        {
                servp->pending = WAITING_DNS_UP;
                dic_release_service( (unsigned)servp->serv_id );
        }
*/
        /*
        ret = dna_write_nowait(conn_id, dic_packet, DIC_HEADER + size);
        if(!ret)
        {
                servp->pending = WAITING_DNS_UP;
                dic_release_service( (unsigned)servp->serv_id );
        }
        else
        {
                dim_usleep(5000);
                if( servp->user_routine )
                        (servp->user_routine)( &servp->tag, &ret );
        }
*/
        if(!ret)
        {
                dim_print_date_time();
                printf(" Client Sending Command: Couldn't write to Conn %3d : Server %s@%s\n",conn_id,
                        Net_conns[conn_id].task, Net_conns[conn_id].node);
                fflush(stdout);
        }
        return(ret);
}

Here is the call graph for this function:

Here is the caller graph for this function: