40 #define reset_index_in_queue(alarm_data)  argument
42 #define reset_index_in_queue(alarm_data) alarm_data->index_in_queue= 0;  argument
172 my_bool thr_alarm(thr_alarm_t *alrm, uint sec, ALARM *alarm_data)  in thr_alarm()  argument
185     (*alrm)= &alarm_data->alarmed;  in thr_alarm()
186     alarm_data->alarmed= 1;                 /* Abort if interrupted */  in thr_alarm()
199   if (!alarm_data)  in thr_alarm()
201     if (!(alarm_data=(ALARM*) my_malloc(sizeof(ALARM),MYF(MY_WME))))  in thr_alarm()
203     alarm_data->malloced= 1;  in thr_alarm()
206     alarm_data->malloced= 0;  in thr_alarm()
208   alarm_data->expire_time= next;  in thr_alarm()
209   alarm_data->alarmed=   0;  in thr_alarm()
210   alarm_data->thread=    current_my_thread_var->pthread_self;  in thr_alarm()
211   alarm_data->thread_id= current_my_thread_var->id;  in thr_alarm()
220   queue_insert_safe(&alarm_queue, (uchar*) alarm_data);  in thr_alarm()
221   assert(alarm_data->index_in_queue > 0);  in thr_alarm()
237   (*alrm)= &alarm_data->alarmed;  in thr_alarm()
252   ALARM *alarm_data;  in thr_end_alarm()  local
261   alarm_data= (ALARM*) ((uchar*) *alarmed - offsetof(ALARM,alarmed));  in thr_end_alarm()
263   DBUG_ASSERT(alarm_data->index_in_queue != 0);  in thr_end_alarm()
265                                      alarm_data->index_in_queue) ==  in thr_end_alarm()
266               alarm_data);  in thr_end_alarm()
267   queue_remove(&alarm_queue, alarm_data->index_in_queue);  in thr_end_alarm()
270   reset_index_in_queue(alarm_data);  in thr_end_alarm()
326   ALARM *alarm_data;  in process_alarm_part2()  local
341 	alarm_data=(ALARM*) queue_element(&alarm_queue,i);  in process_alarm_part2()
342 	alarm_data->alarmed=1;			/* Info to thread */  in process_alarm_part2()
343 	if (pthread_equal(alarm_data->thread,alarm_thread) ||  in process_alarm_part2()
344 	    pthread_kill(alarm_data->thread, thr_client_alarm))  in process_alarm_part2()
350           reset_index_in_queue(alarm_data);  in process_alarm_part2()
364       while ((alarm_data=(ALARM*) queue_top(&alarm_queue))->expire_time <= now)  in process_alarm_part2()
366 	alarm_data->alarmed=1;			/* Info to thread */  in process_alarm_part2()
368 	if (pthread_equal(alarm_data->thread,alarm_thread) ||  in process_alarm_part2()
369 	    pthread_kill(alarm_data->thread, thr_client_alarm))  in process_alarm_part2()
375           reset_index_in_queue(alarm_data);  in process_alarm_part2()
381 	  alarm_data->expire_time=next;  in process_alarm_part2()
391 	alarm((uint) (alarm_data->expire_time-now));  in process_alarm_part2()
392         next_alarm_expire_time= alarm_data->expire_time;  in process_alarm_part2()
508     ALARM *alarm_data= (ALARM*) queue_top(&alarm_queue);  in thr_alarm_info()  local
509     time_diff= (long) (alarm_data->expire_time - now);  in thr_alarm_info()