summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--source4/wrepl_server/wrepl_out_push.c10
-rw-r--r--source4/wrepl_server/wrepl_server.h4
2 files changed, 7 insertions, 7 deletions
diff --git a/source4/wrepl_server/wrepl_out_push.c b/source4/wrepl_server/wrepl_out_push.c
index a9a7826f00..9c8c9fad8d 100644
--- a/source4/wrepl_server/wrepl_out_push.c
+++ b/source4/wrepl_server/wrepl_out_push.c
@@ -96,16 +96,16 @@ nomem:
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;
@@ -113,7 +113,7 @@ static uint32_t wreplsrv_calc_change_count(struct wreplsrv_partner *partner, uin
}
done:
- partner->push.seqnumber = seqnumber;
+ partner->push.maxVersionID = maxVersionID;
return (uint32_t)(tmp_diff & UINT32_MAX);
}
@@ -123,7 +123,7 @@ NTSTATUS wreplsrv_out_push_run(struct wreplsrv_service *service)
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 */
diff --git a/source4/wrepl_server/wrepl_server.h b/source4/wrepl_server/wrepl_server.h
index bcf6f8ac48..c8dfcc64bd 100644
--- a/source4/wrepl_server/wrepl_server.h
+++ b/source4/wrepl_server/wrepl_server.h
@@ -165,8 +165,8 @@ struct wreplsrv_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;