| 41 | |
| 42 | template<class DataType> |
| 43 | void |
| 44 | UpdateProcessor<DataType>::processSample( |
| 45 | const DataType* sample, |
| 46 | const DDS::SampleInfo* info) |
| 47 | { |
| 48 | if (OpenDDS::DCPS::DCPS_debug_level > 0) { |
| 49 | ACE_DEBUG((LM_DEBUG, |
| 50 | ACE_TEXT("(%P|%t) UpdateProcessor::processSample()\n"))); |
| 51 | } |
| 52 | |
| 53 | if (info->valid_data) { |
| 54 | switch (sample->action) { |
| 55 | case CreateEntity: |
| 56 | this->processCreate(sample, info); |
| 57 | break; |
| 58 | case UpdateQosValue1: |
| 59 | this->processUpdateQos1(sample, info); |
| 60 | break; |
| 61 | case UpdateQosValue2: |
| 62 | this->processUpdateQos2(sample, info); |
| 63 | break; |
| 64 | case UpdateFilterExpressionParams: |
| 65 | this->processUpdateFilterExpressionParams(sample, info); |
| 66 | break; |
| 67 | case DestroyEntity: |
| 68 | this->processDelete(sample, info); |
| 69 | break; |
| 70 | default: |
| 71 | ACE_ERROR((LM_ERROR, |
| 72 | ACE_TEXT("(%P|%t) ERROR: UpdateProcessor::processSample() - ") |
| 73 | ACE_TEXT("upsupported action type: %d.\n"), |
| 74 | sample->action)); |
| 75 | break; |
| 76 | } |
| 77 | |
| 78 | } else { |
| 79 | if (OpenDDS::DCPS::DCPS_debug_level > 0) { |
| 80 | ACE_DEBUG((LM_DEBUG, |
| 81 | ACE_TEXT("(%P|%t) UpdateProcessor::processSample() - ") |
| 82 | ACE_TEXT("sample not valid, declining to process.\n"))); |
| 83 | } |
| 84 | } |
| 85 | } |
| 86 | |
| 87 | template<class DataType> |
| 88 | void |
no test coverage detected