Searched refs:DbWorker (Results 1 – 4 of 4) sorted by relevance
569 struct DbWorker;572 Tx(DbWorker* worker);574 DbWorker* const m_worker;612 struct DbWorker : Worker { struct in NdbImportImpl613 DbWorker(Team& team, uint n);614 virtual ~DbWorker() = 0;665 struct RelayOpWorker : DbWorker {726 struct ExecOpWorker : DbWorker {
2160 NdbImportImpl::Tx::Tx(DbWorker* w) : in Tx()2194 NdbImportImpl::DbWorker::DbWorker(Team& team, uint n) : in DbWorker() function in NdbImportImpl::DbWorker2204 NdbImportImpl::DbWorker::~DbWorker() in ~DbWorker()2211 NdbImportImpl::DbWorker::create_ndb(uint transcnt) in create_ndb()2236 NdbImportImpl::DbWorker::alloc_op() in alloc_op()2247 NdbImportImpl::DbWorker::free_op(Op* op) in free_op()2253 NdbImportImpl::DbWorker::start_trans() in start_trans()2278 NdbImportImpl::DbWorker::start_trans(const NdbRecord* keyrec, in start_trans()2331 NdbImportImpl::DbWorker::close_trans(Tx* tx) in close_trans()2400 DbWorker(team, n) in RelayOpWorker()[all …]
62 class DbWorker66 public DbWorker (ThreadFunc<void*> func)83 private ThreadPool<DbWorker> threads;143 threads = new ThreadPool<DbWorker>.with_owned_data ((worker) => {304 threads.add (new DbWorker (run));367 threads.add (new DbWorker (run));421 threads.add (new DbWorker (run));479 threads.add (new DbWorker (run));
1676 class DbWorker(DbAccess, threading.Thread): class1732 worker = DbWorker(self.taskqueue, daemon=True, db=dburi)