| 315 | |
| 316 | template <typename T> |
| 317 | void PrivateQueueDataFeed<T>::ReadThread() { |
| 318 | #ifdef _LINUX |
| 319 | VLOG(4) << "entering PrivateQueueDataFeed<T>::ReadThread()"; |
| 320 | std::string filename; |
| 321 | while (PickOneFile(&filename)) { |
| 322 | int err_no = 0; |
| 323 | fp_ = fs_open_read(filename, &err_no, pipe_command_, true); |
| 324 | __fsetlocking(&*fp_, FSETLOCKING_BYCALLER); |
| 325 | T instance; |
| 326 | while (ParseOneInstanceFromPipe(&instance)) { |
| 327 | queue_->Put(instance); |
| 328 | } |
| 329 | } |
| 330 | queue_->Close(); |
| 331 | #endif |
| 332 | } |
| 333 | |
| 334 | template <typename T> |
| 335 | int PrivateQueueDataFeed<T>::Next() { |
nothing calls this directly
no test coverage detected