| 156 | } |
| 157 | |
| 158 | void |
| 159 | SyncServer_i::way_point_reached (::Sync::Id id, |
| 160 | ::Sync::WayPoint way_point) |
| 161 | { |
| 162 | //ACE_DEBUG ((LM_DEBUG, "(%P|%t) SyncServer_i::way_point_reached\n")); |
| 163 | |
| 164 | // Check if entity is part of subscribe or publisher list |
| 165 | ClientInfos::iterator iter = subs_.find (id); |
| 166 | if (iter == subs_.end()) { |
| 167 | iter = pubs_.find (id); |
| 168 | if (iter == pubs_.end()) { |
| 169 | return; |
| 170 | } |
| 171 | } |
| 172 | |
| 173 | iter->second.way_point = way_point; |
| 174 | |
| 175 | if ((pubs_.size() == pub_count_) |
| 176 | && (subs_.size() == sub_count_) |
| 177 | && synched ()) { |
| 178 | notify (); |
| 179 | reset (); |
| 180 | } |
| 181 | } |
| 182 | |
| 183 | bool |
| 184 | SyncServer_i::synched (void) |