Home
last modified time | relevance | path

Searched refs:rows_reject (Results 1 – 3 of 3) sorted by relevance

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/tools/
H A DNdbImportCsv.cpp426 RowList& rows_reject, in Input() argument
436 m_rows_reject(rows_reject), in Input()
529 RowList& rows_reject = m_rows_reject; in reject_line() local
530 rows_reject.lock(); in reject_line()
544 require(rows_reject.push_back(rejectrow)); in reject_line()
546 if (rows_reject.totcnt() > opt.m_rejects) in reject_line()
551 rows_reject.unlock(); in reject_line()
3019 UtilRowList rows_reject; in testinput1() local
3027 rows_reject, in testinput1()
3106 UtilRowList rows_reject; in testinput2() local
[all …]
H A DNdbImportImpl.cpp1732 rows_reject, in do_init()
2774 rows_reject.lock(); in reject_row()
2787 if (rows_reject.totcnt() > opt.m_rejects) in reject_row()
2793 rows_reject.unlock(); in reject_row()
3408 RowList rows_reject; in read_old_diags() local
3421 rows_reject, in read_old_diags()
3479 require(rows_reject.cnt() == 0); in read_old_diags()
4036 rows_reject.lock(); in write_reject()
4039 Row* row = rows_reject.pop_front(); in write_reject()
4040 require(!rows_reject.m_eof); in write_reject()
[all …]
H A DNdbImportCsv.hpp294 RowList& rows_reject,