| 827 | } |
| 828 | |
| 829 | void File::uncompressedFileReadThread(File * file) { |
| 830 | try { |
| 831 | while (file->m_uncompressedFileThreadRunning) { |
| 832 | /* process */ |
| 833 | try { |
| 834 | file->uncompressedFile2ReadWriteQueue(); |
| 835 | } catch (Vector::BLF::Exception &) { |
| 836 | file->m_uncompressedFileThreadRunning = false; |
| 837 | } |
| 838 | |
| 839 | /* check for eof */ |
| 840 | if (!file->m_uncompressedFile.good()) |
| 841 | file->m_uncompressedFileThreadRunning = false; |
| 842 | } |
| 843 | |
| 844 | /* set end of file */ |
| 845 | file->m_readWriteQueue.setFileSize(file->m_readWriteQueue.tellp()); |
| 846 | } catch (...) { |
| 847 | file->m_uncompressedFileThreadException = std::current_exception(); |
| 848 | } |
| 849 | } |
| 850 | |
| 851 | void File::uncompressedFileWriteThread(File * file) { |
| 852 | try { |
nothing calls this directly
no test coverage detected