Lines Matching refs:g_thr_repository
1112 static struct thr_repository *g_thr_repository = NULL; variable
1463 struct thr_repository *rep = g_thr_repository; in thr_send_threads()
1826 thr_repository::send_buffer *sb = g_thr_repository->m_send_buffers+node; in trylock_send_node()
1834 thr_repository::send_buffer * sb = g_thr_repository->m_send_buffers+node; in perform_send()
2129 release_chunk(g_thr_repository->m_mm, RG_TRANSPORTER_BUFFERS); in run_send_thread()
2664 struct thr_repository* rep = g_thr_repository; in senddelay()
2876 Uint32 thr_count = g_thr_repository->m_thread_count; in flush_jbb_write_state()
2880 thr_data *thrptr = g_thr_repository->m_thread; in flush_jbb_write_state()
2993 const struct thr_repository* rep = g_thr_repository; in compute_min_free_out_buffers()
3036 const struct thr_repository* rep = g_thr_repository; in dumpJobQueues()
3091 sendlocal(g_thr_repository->m_send_buffers[nodeId].m_send_thread, in reportSendLen()
3110 struct thr_repository* rep = g_thr_repository; in lock_transporter()
3128 struct thr_repository* rep = g_thr_repository; in unlock_transporter()
3136 struct thr_repository* rep = g_thr_repository; in mt_checkDoJob()
3175 thr_send_queue *src = g_thr_repository->m_thread_send_buffers[node]; in link_thread_send_buffers()
3211 src = g_thr_repository->m_thread_send_buffers[node]; in link_thread_send_buffers()
3403 thr_repository::send_buffer *sb = g_thr_repository->m_send_buffers + node; in get_bytes_to_send_iovec()
3471 thr_data * thrptr = &g_thr_repository->m_thread[thr_no]; in get_bytes_to_send_iovec()
3595 thr_repository::send_buffer *sb = g_thr_repository->m_send_buffers+node; in bytes_sent()
3600 thr_data * thrptr = &g_thr_repository->m_thread[thr_no]; in bytes_sent()
3647 struct thr_repository *rep = g_thr_repository; in reset_send_buffer()
3711 thr_repository* rep = g_thr_repository; in try_pack_send_buffers()
3733 pool->release_global(g_thr_repository->m_mm, RG_TRANSPORTER_BUFFERS); in try_pack_send_buffers()
3746 thr_repository* rep = g_thr_repository; in flush_send_buffer()
3787 struct thr_repository *rep = g_thr_repository; in forceSend()
3832 struct thr_repository *rep = g_thr_repository; in try_send()
3959 struct thr_repository* rep = g_thr_repository; in do_send()
4075 if ((p = m_selfptr->m_send_buffer_pool.seize(g_thr_repository->m_mm, in getWritePtr()
4106 thr_repository *rep = g_thr_repository; in mt_get_send_buffer_bytes()
4117 thr_repository *rep = g_thr_repository; in mt_getSendBufferLevel()
4294 Uint32 thr_count = g_thr_repository->m_thread_count; in check_queues_empty()
4347 release_buffer(g_thr_repository, selfptr->m_thr_no, read_buffer); in execute_signals()
4432 Uint32 thr_count = g_thr_repository->m_thread_count; in run_job_buffers()
4591 struct thr_repository* rep = g_thr_repository; in add_thr_map()
4902 struct thr_repository* rep = g_thr_repository; in mt_receiver_thread_main()
5068 struct thr_repository* rep = g_thr_repository; in get_congested_job_queue()
5153 Uint32 perjb = (avail + g_thr_repository->m_thread_count - 1) / in update_sched_config()
5154 g_thr_repository->m_thread_count; in update_sched_config()
5265 if (!selfptr->m_send_buffer_pool.fill(g_thr_repository->m_mm, in mt_job_thread_main()
5418 struct thr_repository* rep = g_thr_repository; in mt_getSignalsInJBB()
5445 struct thr_repository* rep = g_thr_repository; in sendlocal()
5475 struct thr_repository* rep = g_thr_repository; in sendprioa()
5527 thr_repository *rep = g_thr_repository; in mt_send_remote()
5545 thr_repository *rep = g_thr_repository; in mt_send_remote()
5569 struct thr_repository* rep = g_thr_repository; in sendprioa_STOP_FOR_CRASH()
6053 g_thr_repository = new(cache_alligned_mem) thr_repository(); in ThreadConfig()
6058 g_thr_repository->~thr_repository(); in ~ThreadConfig()
6059 g_thr_repository = NULL; in ~ThreadConfig()
6081 ::rep_init(g_thr_repository, num_threads, in init()
6128 struct thr_repository* rep = g_thr_repository; in ipControlLoop()
6263 &g_thr_repository->m_thread[thr_no].m_jam; in traceDumpGetJam()
6295 NdbMutex_Lock(&g_thr_repository->stop_for_crash_mutex); in traceDumpPrepare()
6296 g_thr_repository->stopped_threads = 0; in traceDumpPrepare()
6313 while (g_thr_repository->stopped_threads < waitFor_count) in traceDumpPrepare()
6315 NdbCondition_WaitTimeout(&g_thr_repository->stop_for_crash_cond, in traceDumpPrepare()
6316 &g_thr_repository->stop_for_crash_mutex, in traceDumpPrepare()
6322 if (g_thr_repository->stopped_threads < waitFor_count) in traceDumpPrepare()
6329 waitFor_count - g_thr_repository->stopped_threads); in traceDumpPrepare()
6331 NdbMutex_Unlock(&g_thr_repository->stop_for_crash_mutex); in traceDumpPrepare()
6379 NdbMutex_Lock(&g_thr_repository->stop_for_crash_mutex); in prepare_to_crash()
6388 NdbMutex_Unlock(&g_thr_repository->stop_for_crash_mutex); in prepare_to_crash()
6405 NdbMutex_Unlock(&g_thr_repository->stop_for_crash_mutex); in prepare_to_crash()
6415 NdbMutex_Unlock(&g_thr_repository->stop_for_crash_mutex); in prepare_to_crash()
6425 NdbMutex_Lock(&g_thr_repository->stop_for_crash_mutex); in mt_execSTOP_FOR_CRASH()
6426 g_thr_repository->stopped_threads++; in mt_execSTOP_FOR_CRASH()
6427 NdbCondition_Signal(&g_thr_repository->stop_for_crash_cond); in mt_execSTOP_FOR_CRASH()
6428 NdbMutex_Unlock(&g_thr_repository->stop_for_crash_mutex); in mt_execSTOP_FOR_CRASH()
6441 const thr_repository *rep = g_thr_repository; in dumpSignalMemory()
6675 lock(&(g_thr_repository->m_section_lock)); in mt_section_lock()
6681 unlock(&(g_thr_repository->m_section_lock)); in mt_section_unlock()
6692 lock(&(g_thr_repository->m_mem_manager_lock)); in mt_mem_manager_lock()
6698 unlock(&(g_thr_repository->m_mem_manager_lock)); in mt_mem_manager_unlock()
6785 struct thr_data *thrptr = &g_thr_repository->m_thread[thr_no]; in mt_wakeup()
6794 struct thr_data *thrptr = &g_thr_repository->m_thread[thr_no]; in mt_assert_own_thread()
6810 struct thr_data *thr_ptr = &g_thr_repository->m_thread[thr_no]; in mt_get_blocklist()
6825 struct thr_data *selfptr = &g_thr_repository->m_thread[thr_no]; in mt_get_thr_stat()