return;
}
-static uint32_t wreplsrv_calc_change_count(struct wreplsrv_partner *partner, uint64_t seqnumber)
+static uint32_t wreplsrv_calc_change_count(struct wreplsrv_partner *partner, uint64_t maxVersionID)
{
uint64_t tmp_diff = UINT32_MAX;
/* catch an overflow */
- if (partner->push.seqnumber > seqnumber) {
+ if (partner->push.maxVersionID > maxVersionID) {
goto done;
}
- tmp_diff = seqnumber - partner->push.seqnumber;
+ tmp_diff = maxVersionID - partner->push.maxVersionID;
if (tmp_diff > UINT32_MAX) {
tmp_diff = UINT32_MAX;
}
done:
- partner->push.seqnumber = seqnumber;
+ partner->push.maxVersionID = maxVersionID;
return (uint32_t)(tmp_diff & UINT32_MAX);
}
uint64_t seqnumber;
uint32_t change_count;
- seqnumber = winsdb_get_seqnumber(service->wins_db);
+ seqnumber = winsdb_get_maxVersion(service->wins_db);
for (partner = service->partners; partner; partner = partner->next) {
/* if it's not a push partner, go to the next partner */
/* change count till push notification */
uint32_t change_count;
- /* the last wins db seqnumber we know about */
- uint64_t seqnumber;
+ /* the last wins db maxVersion have reported to the partner */
+ uint64_t maxVersionID;
/* we should use WREPL_REPL_INFORM* messages to this partner */
BOOL use_inform;