Home
last modified time | relevance | path

Searched refs:thr_job_queue (Results 1 – 11 of 11) sorted by relevance

/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/
H A Dmt.cpp641 struct thr_job_queue struct
838 struct thr_job_queue m_jba;
872 struct thr_job_queue m_in_queue[MAX_THREADS];
1573 Uint32 minfree = thr_job_queue::SIZE; in compute_max_signals_to_execute()
1591 assert(free <= thr_job_queue::SIZE); in compute_max_signals_to_execute()
2342 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
2515 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
3152 thr_job_queue *q = dstptr->m_in_queue + self; in sendlocal()
3180 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
3278 thr_job_queue *q = &(dstptr->m_jba); in sendprioa_STOP_FOR_CRASH()
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/
H A Dmt.cpp641 struct thr_job_queue struct
838 struct thr_job_queue m_jba;
872 struct thr_job_queue m_in_queue[MAX_THREADS];
1573 Uint32 minfree = thr_job_queue::SIZE; in compute_max_signals_to_execute()
1591 assert(free <= thr_job_queue::SIZE); in compute_max_signals_to_execute()
2342 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
2515 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
3152 thr_job_queue *q = dstptr->m_in_queue + self; in sendlocal()
3180 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
3278 thr_job_queue *q = &(dstptr->m_jba); in sendprioa_STOP_FOR_CRASH()
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/kernel/vm/
H A Dmt.cpp641 struct thr_job_queue struct
838 struct thr_job_queue m_jba;
872 struct thr_job_queue m_in_queue[MAX_THREADS];
1573 Uint32 minfree = thr_job_queue::SIZE; in compute_max_signals_to_execute()
1591 assert(free <= thr_job_queue::SIZE); in compute_max_signals_to_execute()
2342 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
2515 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
3152 thr_job_queue *q = dstptr->m_in_queue + self; in sendlocal()
3180 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
3278 thr_job_queue *q = &(dstptr->m_jba); in sendprioa_STOP_FOR_CRASH()
[all …]
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/src/kernel/vm/
H A Dmt.cpp641 struct thr_job_queue struct
838 struct thr_job_queue m_jba;
872 struct thr_job_queue m_in_queue[MAX_THREADS];
1573 Uint32 minfree = thr_job_queue::SIZE; in compute_max_signals_to_execute()
1591 assert(free <= thr_job_queue::SIZE); in compute_max_signals_to_execute()
2342 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
2515 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
3152 thr_job_queue *q = dstptr->m_in_queue + self; in sendlocal()
3180 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
3278 thr_job_queue *q = &(dstptr->m_jba); in sendprioa_STOP_FOR_CRASH()
[all …]
/dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/src/kernel/vm/
H A Dmt.cpp641 struct thr_job_queue struct
838 struct thr_job_queue m_jba;
872 struct thr_job_queue m_in_queue[MAX_THREADS];
1573 Uint32 minfree = thr_job_queue::SIZE; in compute_max_signals_to_execute()
1591 assert(free <= thr_job_queue::SIZE); in compute_max_signals_to_execute()
2342 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
2515 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
3152 thr_job_queue *q = dstptr->m_in_queue + self; in sendlocal()
3180 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
3278 thr_job_queue *q = &(dstptr->m_jba); in sendprioa_STOP_FOR_CRASH()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/kernel/vm/
H A Dmt.cpp630 struct thr_job_queue struct
934 MY_ALIGNED(NDB_CL) struct thr_job_queue m_jba; in MY_ALIGNED()
2980 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
2982 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
2985 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
2992 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
4444 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
4499 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
5149 ? thr_job_queue::RESERVED in update_sched_config()
5485 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/src/kernel/vm/
H A Dmt.cpp630 struct thr_job_queue struct
934 MY_ALIGNED(NDB_CL) struct thr_job_queue m_jba; in MY_ALIGNED()
2980 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
2982 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
2985 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
2992 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
4444 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
4499 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
5149 ? thr_job_queue::RESERVED in update_sched_config()
5485 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/src/kernel/vm/
H A Dmt.cpp630 struct thr_job_queue struct
934 MY_ALIGNED(NDB_CL) struct thr_job_queue m_jba; in MY_ALIGNED()
2980 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
2982 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
2985 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
2992 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
4444 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
4499 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
5149 ? thr_job_queue::RESERVED in update_sched_config()
5485 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/src/kernel/vm/
H A Dmt.cpp630 struct thr_job_queue struct
934 MY_ALIGNED(NDB_CL) struct thr_job_queue m_jba; in MY_ALIGNED()
2980 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
2982 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
2985 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
2992 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
4444 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
4499 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
5149 ? thr_job_queue::RESERVED in update_sched_config()
5485 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/src/kernel/vm/
H A Dmt.cpp630 struct thr_job_queue struct
934 MY_ALIGNED(NDB_CL) struct thr_job_queue m_jba; in MY_ALIGNED()
2980 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
2982 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
2985 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
2992 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
4444 thr_job_queue *queue = selfptr->m_in_queue; in run_job_buffers()
4499 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
5149 ? thr_job_queue::RESERVED in update_sched_config()
5485 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/src/kernel/vm/
H A Dmt.cpp923 struct thr_job_queue struct
1283 alignas(NDB_CL) struct thr_job_queue m_jba;
4641 assert(free <= thr_job_queue::SIZE); in compute_free_buffers_in_queue()
4643 if (free <= (1 + thr_job_queue::SAFETY)) in compute_free_buffers_in_queue()
4646 return free - (1 + thr_job_queue::SAFETY); in compute_free_buffers_in_queue()
4653 Uint32 minfree = thr_job_queue::SIZE; in compute_min_free_out_buffers()
6274 const thr_job_queue *q = selfptr->m_in_queue; in read_jbb_state()
6674 if (free <= thr_job_queue::ALMOST_FULL) in run_job_buffers()
7515 ? thr_job_queue::RESERVED in update_sched_config()
8213 thr_job_queue *q = &(dstptr->m_jba); in sendprioa()
[all …]