| 24 | |
| 25 | template<class DataType> |
| 26 | UpdateReceiver<DataType>::UpdateReceiver(UpdateProcessor<DataType>& processor) |
| 27 | : processor_(processor), |
| 28 | stop_(false), |
| 29 | workAvailable_(this->lock_) |
| 30 | { |
| 31 | if (OpenDDS::DCPS::DCPS_debug_level > 0) { |
| 32 | ACE_DEBUG((LM_DEBUG, |
| 33 | ACE_TEXT("(%P|%t) UpdateReceiver::UpdateReceiver()\n"))); |
| 34 | } |
| 35 | |
| 36 | // Always execute the thread. |
| 37 | this->open(0); |
| 38 | } |
| 39 | |
| 40 | template<class DataType> |
| 41 | UpdateReceiver<DataType>::~UpdateReceiver() |