| 598 | |
| 599 | template<typename TDatum, typename TDatums, typename TDatumsSP, typename TWorker> |
| 600 | bool WrapperT<TDatum, TDatums, TDatumsSP, TWorker>::waitAndPush(const TDatumsSP& tDatums) |
| 601 | { |
| 602 | try |
| 603 | { |
| 604 | if (!mUserWs[int(WorkerType::Input)].empty()) |
| 605 | error("Push cannot be called if an input worker was already selected.", |
| 606 | __LINE__, __FUNCTION__, __FILE__); |
| 607 | return mThreadManager.waitAndPush(tDatums); |
| 608 | } |
| 609 | catch (const std::exception& e) |
| 610 | { |
| 611 | error(e.what(), __LINE__, __FUNCTION__, __FILE__); |
| 612 | return false; |
| 613 | } |
| 614 | } |
| 615 | |
| 616 | template<typename TDatum, typename TDatums, typename TDatumsSP, typename TWorker> |
| 617 | bool WrapperT<TDatum, TDatums, TDatumsSP, TWorker>::waitAndPush(const Matrix& matrix) |