int execute_service

(

int

req_id

)

Definition at line 1275 of file dis_old.c.

References serv::address, COMMAND, req_ent::conn_id, copy_swap_buffer_out(), Curr_conn_id, serv::def, req_ent::delay_delete, DIS_HEADER, DIS_STAMPED_HEADER, dna_write_nowait(), req_ent::first_time, req_ent::format, serv::format_data, Memory::free(), id_get_ptr(), Memory::malloc(), MAX_NAME, serv::quality, DIS_STAMPED_PACKET::quality, DIS_STAMPED_PACKET::reserved, req_ent::service_id, DIS_STAMPED_PACKET::service_id, req_ent::service_ptr, size, serv::size, DIS_STAMPED_PACKET::size, sprintf(), SRC_DIS, STAMPED, str, serv::tag, DIS_STAMPED_PACKET::time_stamp, req_ent::to_delete, req_ent::type, serv::type, serv::user_millisecs, serv::user_routine, and serv::user_secs.

Referenced by dis_insert_request(), dis_report_service(), and do_update_service().

{
        int *buffp, size;
        register REQUEST *reqp;
        register SERVICE *servp;
        char str[80], def[MAX_NAME];
        register char *ptr;
        int last_conn_id;
        int *pkt_buffer, header_size, aux;
#ifdef WIN32
        struct timeb timebuf;
#else
        struct timeval tv;
        struct timezone *tz;
#endif
        FORMAT_STR format_data_cp[MAX_NAME/4];

        reqp = (REQUEST *)id_get_ptr(req_id, SRC_DIS);
        if(!reqp)
                return(0);
        if(reqp->to_delete)
                return(0);
        reqp->delay_delete++;
        servp = reqp->service_ptr;
        last_conn_id = Curr_conn_id;
        Curr_conn_id = reqp->conn_id;
        ptr = servp->def;
        if(servp->type == COMMAND)
        {
                sprintf(str,"This is a COMMAND Service");
                buffp = (int *)str;
                size = 26;
                sprintf(def,"c:26");
                ptr = def;
        }
        else if( servp->user_routine != 0 ) 
        {
                (servp->user_routine)( &servp->tag, &buffp, &size,
                                        &reqp->first_time );
                reqp->first_time = 0;
                
        } 
        else 
        {
                buffp = servp->address;
                size = servp->size;
        }
        Curr_conn_id = last_conn_id;
/* send even if no data but not if negative */
        if( size  < 0)
        {
                reqp->delay_delete--;
                return(0);
        }
        if( DIS_STAMPED_HEADER + size > Dis_packet_size ) 
        {
                if( Dis_packet_size )
                        free( Dis_packet );
                Dis_packet = (DIS_STAMPED_PACKET *)malloc(DIS_STAMPED_HEADER + size);
                if(!Dis_packet)
                {
                        reqp->delay_delete--;
                        return(0);
                }
                Dis_packet_size = DIS_STAMPED_HEADER + size;
        }
        Dis_packet->service_id = htovl(reqp->service_id);
        if((reqp->type & 0xFF000) == STAMPED)
        {
                pkt_buffer = ((DIS_STAMPED_PACKET *)Dis_packet)->buffer;
                header_size = DIS_STAMPED_HEADER;
                if(!servp->user_secs)
                {
#ifdef WIN32
                        ftime(&timebuf);
                        aux = timebuf.millitm;
                        Dis_packet->time_stamp[0] = htovl(aux);
                        Dis_packet->time_stamp[1] = htovl((int)timebuf.time);
#else
                        tz = 0;
                        gettimeofday(&tv, tz);
                        aux = tv.tv_usec / 1000;
                        Dis_packet->time_stamp[0] = htovl(aux);
                        Dis_packet->time_stamp[1] = htovl(tv.tv_sec);
#endif
                }
                else
                {
                        aux = /*0xc0de0000 |*/ servp->user_millisecs;
                        Dis_packet->time_stamp[0] = htovl(aux);
                        Dis_packet->time_stamp[1] = htovl(servp->user_secs);
                }
                Dis_packet->reserved[0] = htovl(0xc0dec0de);
                Dis_packet->quality = htovl(servp->quality);
        }
        else
        {
                pkt_buffer = ((DIS_PACKET *)Dis_packet)->buffer;
                header_size = DIS_HEADER;
        }
        memcpy(format_data_cp, servp->format_data, sizeof(format_data_cp));
        size = copy_swap_buffer_out(reqp->format, format_data_cp, 
                pkt_buffer,
                buffp, size);
        Dis_packet->size = htovl(header_size + size);
        if( !dna_write_nowait(reqp->conn_id, Dis_packet, header_size + size) ) 
        {
                reqp->to_delete = 1;
        }
/*
        else
        {
                if((reqp->type & 0xFFF) == MONITORED)
                {
                        if(reqp->timr_ent)
                                dtq_clear_entry(reqp->timr_ent);
                }
        }
*/
        reqp->delay_delete--;
        return(1);
}

Here is the call graph for this function:

Here is the caller graph for this function: