int dim_dtq_init

(

int

thr_flag

)

Definition at line 91 of file dtq.c.

References alrm_sig_handler(), dll_init(), dummy_alrm_sig_handler(), Memory::malloc(), QUEUE_ENT::queue_head, SPECIAL_QUEUE, and WRITE_QUEUE.

Referenced by dim_dtq_thread(), dtq_create(), dtq_start_timer(), and dummy_alrm_sig_handler().

{
struct sigaction sig_info;
sigset_t set;
int ret = 0;

/*
        pid = getpid();
*/
        if( !sigvec_done) 
        {
            Inside_ast = 0;
            Alarm_runs = 0;
            DIM_last_time = 0;
/*
            for(i = 0; i < MAX_TIMER_QUEUES + 2; i++)
            {
                timer_queues[i].queue_head = 0;
                        timer_queues[i].remove_entries = 0;
            }
*/
                if( timer_queues[SPECIAL_QUEUE].queue_head == NULL ) {
                        timer_queues[SPECIAL_QUEUE].queue_head = (TIMR_ENT *)malloc(sizeof(TIMR_ENT));
                        memset(timer_queues[SPECIAL_QUEUE].queue_head, 0, sizeof(TIMR_ENT));
                        dll_init( (DLL *)timer_queues[SPECIAL_QUEUE].queue_head);
                }
                if( timer_queues[WRITE_QUEUE].queue_head == NULL ) {
                        timer_queues[WRITE_QUEUE].queue_head = (TIMR_ENT *)malloc(sizeof(TIMR_ENT));
                        memset(timer_queues[WRITE_QUEUE].queue_head, 0, sizeof(TIMR_ENT));
                        dll_init( (DLL *)timer_queues[WRITE_QUEUE].queue_head);
                }
            if(!thr_flag)
            {
                Threads_off = 1;
            }
                sigemptyset(&set);
          
                sigaddset(&set,SIGIO);
                
                if(thr_flag)
                        sig_info.sa_handler = dummy_alrm_sig_handler;
                else
                        sig_info.sa_handler = alrm_sig_handler;
                sig_info.sa_mask = set;
#ifndef LYNXOS
                sig_info.sa_flags = SA_RESTART;
#else
                sig_info.sa_flags = 0;
#endif
                if( sigaction(SIGALRM, &sig_info, 0) < 0 ) {
                        perror( "sigaction(SIGALRM)" );
                        exit(1);
                }
            
            sigvec_done = 1;
            ret = 1;
        }
        return(ret);
}

Here is the call graph for this function:

Here is the caller graph for this function: