| 2765 | */ |
| 2766 | |
| 2767 | static |
| 2768 | Delayed_insert *find_handler(THD *thd, TABLE_LIST *table_list) |
| 2769 | { |
| 2770 | THD_STAGE_INFO(thd, stage_waiting_for_delay_list); |
| 2771 | mysql_mutex_lock(&LOCK_delayed_insert); // Protect master list |
| 2772 | I_List_iterator<Delayed_insert> it(delayed_threads); |
| 2773 | Delayed_insert *di; |
| 2774 | while ((di= it++)) |
| 2775 | { |
| 2776 | if (!cmp(&table_list->db, &di->table_list.db) && |
| 2777 | !cmp(&table_list->table_name, &di->table_list.table_name)) |
| 2778 | { |
| 2779 | di->lock(); |
| 2780 | break; |
| 2781 | } |
| 2782 | } |
| 2783 | mysql_mutex_unlock(&LOCK_delayed_insert); // For unlink from list |
| 2784 | return di; |
| 2785 | } |
| 2786 | |
| 2787 | |
| 2788 | /** |
no test coverage detected