int request_command	(	char *	serv_name,
		void *	serv_address,
		int	serv_size,
		void(*)()	usr_routine,
		dim_long	tag,
		int	stamped
	)

Definition at line 736 of file dic.c.

References COMMAND, conn_arr_create(), dic_serv::conn_id, Dic_timer_q, dim_init_threads(), dll_init(), dtq_create(), dtq_start_timer(), end_command(), dic_serv::fill_address, dic_serv::fill_size, Memory::free(), insert_service(), locate_command(), locate_pending(), locate_service(), Memory::malloc(), send_command(), dic_serv::serv_id, SRC_DIC, dic_serv::tag, Threads_off, dic_serv::user_routine, and WAITING_DNS_UP.

Referenced by dic_cmnd_callback(), dic_cmnd_callback_stamped(), dic_cmnd_service(), dic_cmnd_service_stamped(), and send_data().

{
        int conn_id, ret;
        register DIC_SERVICE *servp, *testp;
        int *fillp;
        int send_command();
        int end_command();
        void dim_init_threads(void);
        int locate_service();

        if(!Threads_off)
        {
                dim_init_threads();
        }
        {
        DISABLE_AST
        /* create a timer queue for timeouts if not yet done */
        if( !Dic_timer_q ) {
                conn_arr_create( SRC_DIC );
                Dic_timer_q = dtq_create();
        }

        /* store_service */
        if( !Cmnd_head ) {
                Cmnd_head = (DIC_SERVICE *) malloc(sizeof(DIC_SERVICE) );
                dll_init( (DLL *) Cmnd_head );
                Cmnd_head->serv_id = 0;
        }
        if( (servp = locate_command(serv_name)) ) 
        {
                if(!(testp = locate_pending(serv_name)))
                {
                        if( (conn_id = servp->conn_id) ) 
                        {
                                if(servp->fill_size > 0)
                                        free( servp->fill_address );
                                fillp = serv_address;
                                if(serv_size > 0)
                                {
                                        fillp = (int *)malloc((size_t)serv_size);
                                        memcpy( (char *)fillp, (char *)serv_address, (size_t)serv_size );
                                }
                                servp->fill_address = fillp;
                                servp->fill_size = serv_size;
/*
                                servp->fill_address = (int *)serv_address;
                                servp->fill_size = serv_size;
*/
                                servp->user_routine = usr_routine;
                                servp->tag = tag;
                                ret = send_command(conn_id, servp);
                                end_command(servp, ret);
                                ENABLE_AST
                                return(1);
                        }
                }       
        }
        servp = insert_service( COMMAND, 0,
                                serv_name, 0, 0, usr_routine, tag, 
                                (int *)serv_address, serv_size,
                                WAITING_DNS_UP, stamped );      
        if( locate_service(servp) <= 0)
        {
/*
                service_tmout( servp->serv_id );
*/
                dtq_start_timer( 0, service_tmout, servp->serv_id);
        }
        ENABLE_AST
        }
        return(-1);
}

Here is the call graph for this function:

Here is the caller graph for this function: