| 118 | } |
| 119 | |
| 120 | bool AFClassCallBackManager::OnNodeCallBack( |
| 121 | const AFGUID& self, AFINode* pNode, const AFIData& old_data, const AFIData& new_data) |
| 122 | { |
| 123 | auto index = pNode->GetIndex(); |
| 124 | auto& name = pNode->GetName(); |
| 125 | |
| 126 | // sync call back |
| 127 | if (pNode->HaveMask(ArkDataMask::PF_REAL_TIME)) |
| 128 | { |
| 129 | for (auto& iter : node_sync_call_back_list_) |
| 130 | { |
| 131 | auto mask_value = iter.first; |
| 132 | if (!pNode->HaveMask(mask_value)) |
| 133 | { |
| 134 | continue; |
| 135 | } |
| 136 | |
| 137 | iter.second(self, index, mask_value, new_data); |
| 138 | } |
| 139 | } |
| 140 | else |
| 141 | { |
| 142 | UpdateDelayNodeList(self, pNode); |
| 143 | } |
| 144 | |
| 145 | // common call back |
| 146 | auto iter_call_backs = data_call_backs_list_.find(index); |
| 147 | if (iter_call_backs != data_call_backs_list_.end()) |
| 148 | { |
| 149 | for (auto& iter : iter_call_backs->second) |
| 150 | { |
| 151 | iter.second(self, name, index, old_data, new_data); |
| 152 | } |
| 153 | } |
| 154 | |
| 155 | return true; |
| 156 | } |
| 157 | |
| 158 | bool AFClassCallBackManager::OnTableCallBack(const AFGUID& self, const ArkMaskType mask, AFINode* pNode, |
| 159 | const TABLE_EVENT_DATA& event_data, const AFIData& old_data, const AFIData& new_data) |
no test coverage detected