| | |
| | | * |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions copyright 2011 ForgeRock AS |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | |
| | |
| | | */ |
| | | public long getEligibleCount(ServerState startState, ChangeNumber endCN) |
| | | { |
| | | long sidRes = 0; |
| | | long res = 0; |
| | | |
| | | // Parses the dbState of the domain , server by server |
| | |
| | | ChangeNumber startCN = null; |
| | | if (startState.getMaxChangeNumber(sid) != null) |
| | | startCN = startState.getMaxChangeNumber(sid); |
| | | sidRes += getCount(sid, startCN, endCN); |
| | | long sidRes = getCount(sid, startCN, endCN); |
| | | |
| | | // The startPoint is excluded when counting the ECL eligible changes |
| | | if ((startCN!=null)&&(sidRes>0)) |
| | |
| | | */ |
| | | public long getEligibleCount(ChangeNumber startCN, ChangeNumber endCN) |
| | | { |
| | | long sidRes = 0; |
| | | long res = 0; |
| | | |
| | | // Parses the dbState of the domain , server by server |
| | |
| | | int sid = serverIDIterator.next(); |
| | | ChangeNumber lStartCN = |
| | | new ChangeNumber(startCN.getTime(), startCN.getSeqnum(), sid); |
| | | sidRes += getCount(sid, lStartCN, endCN); |
| | | res+=sidRes; |
| | | res+=getCount(sid, lStartCN, endCN); |
| | | } |
| | | return res; |
| | | } |