Lines Matching refs:fts_optimize_wq

42 ib_wqueue_t* fts_optimize_wq;  variable
2532 if (!fts_optimize_wq) { in fts_optimize_add_table()
2547 mutex_enter(&fts_optimize_wq->mutex); in fts_optimize_add_table()
2549 ib_wqueue_add(fts_optimize_wq, msg, msg->heap, true); in fts_optimize_add_table()
2553 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_add_table()
2569 if (!fts_optimize_wq) { in fts_optimize_remove_table()
2579 while (fts_optimize_wq) { in fts_optimize_remove_table()
2585 mutex_enter(&fts_optimize_wq->mutex); in fts_optimize_remove_table()
2588 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_remove_table()
2604 ib_wqueue_add(fts_optimize_wq, msg, msg->heap, true); in fts_optimize_remove_table()
2606 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_remove_table()
2614 mutex_enter(&fts_optimize_wq->mutex); in fts_optimize_remove_table()
2616 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_remove_table()
2628 if (!fts_optimize_wq) { in fts_optimize_request_sync_table()
2641 mutex_enter(&fts_optimize_wq->mutex); in fts_optimize_request_sync_table()
2643 ib_wqueue_add(fts_optimize_wq, msg, msg->heap, true); in fts_optimize_request_sync_table()
2646 DBUG_ASSERT(fts_optimize_wq->length <= 1000);); in fts_optimize_request_sync_table()
2648 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_request_sync_table()
2698 mutex_enter(&fts_optimize_wq->mutex); in fts_optimize_del_table()
2700 mutex_exit(&fts_optimize_wq->mutex); in fts_optimize_del_table()
2929 ut_a(!fts_optimize_wq); in fts_optimize_init()
2932 fts_optimize_wq = ib_wqueue_create(); in fts_optimize_init()
2933 ut_a(fts_optimize_wq != NULL); in fts_optimize_init()
2963 os_thread_create(fts_optimize_thread, fts_optimize_wq, NULL); in fts_optimize_init()
2990 ib_wqueue_add(fts_optimize_wq, msg, msg->heap); in fts_optimize_shutdown()
2996 ib_wqueue_free(fts_optimize_wq); in fts_optimize_shutdown()
2997 fts_optimize_wq = NULL; in fts_optimize_shutdown()