Searched refs:replThread (Results 1 – 1 of 1) sorted by relevance
130 ReplicationThread replThread; in main() local131 replThread.db = db; in main()132 replThread.no_read = 0; in main()133 replThread.stop.store(false, std::memory_order_release); in main()135 env->StartThread(ReplicationThreadBody, &replThread); in main()136 while (replThread.no_read < FLAGS_num_inserts) in main()138 replThread.stop.store(true, std::memory_order_release); in main()139 if (replThread.no_read < dataPump.no_records) { in main()144 replThread.no_read, dataPump.no_records); in main()