| 2826 | |
| 2827 | |
| 2828 | void |
| 2829 | DataReaderImpl::coherent_change_received(const GUID_t& publisher_id, Coherent_State& result) |
| 2830 | { |
| 2831 | ACE_READ_GUARD(ACE_RW_Thread_Mutex, read_guard, this->writers_lock_); |
| 2832 | |
| 2833 | result = COMPLETED; |
| 2834 | for (WriterMapType::iterator iter = writers_.begin(); |
| 2835 | iter != writers_.end(); |
| 2836 | ++iter) { |
| 2837 | |
| 2838 | if (iter->second->publisher_id() == publisher_id) { |
| 2839 | const Coherent_State state = iter->second->coherent_change_received(); |
| 2840 | if (state == NOT_COMPLETED_YET) { |
| 2841 | result = NOT_COMPLETED_YET; |
| 2842 | break; |
| 2843 | } |
| 2844 | else if (state == REJECTED) { |
| 2845 | result = REJECTED; |
| 2846 | } |
| 2847 | } |
| 2848 | } |
| 2849 | } |
| 2850 | |
| 2851 | |
| 2852 | void |
no test coverage detected