| | |
| | | private final InternalClientConnection conn = |
| | | InternalClientConnection.getRootConnection(); |
| | | private final ByteString asn1BaseDn; |
| | | private final short serverId; |
| | | private final int serverId; |
| | | |
| | | private final ServerState state; |
| | | |
| | |
| | | * @param baseDn The baseDN for which the ServerState is created |
| | | * @param serverId The serverId |
| | | */ |
| | | public PersistentServerState(DN baseDn, short serverId) |
| | | public PersistentServerState(DN baseDn, int serverId) |
| | | { |
| | | this.baseDn = baseDn; |
| | | this.serverId = serverId; |
| | |
| | | * @param serverId The serverId. |
| | | * @param state The serverState. |
| | | */ |
| | | public PersistentServerState(DN baseDn, short serverId, ServerState state) |
| | | public PersistentServerState(DN baseDn, int serverId, ServerState state) |
| | | { |
| | | this.baseDn = baseDn; |
| | | this.serverId = serverId; |
| | |
| | | Integer replicaId = Integer.parseInt(temp, 16); |
| | | |
| | | // No need to take into account the subSeqNum |
| | | ChangeNumber cn = new ChangeNumber(timeStamp*1000, seqNum, |
| | | replicaId.shortValue()); |
| | | ChangeNumber cn = |
| | | new ChangeNumber(timeStamp*1000, seqNum, replicaId); |
| | | |
| | | this.update(cn); |
| | | } |
| | |
| | | * |
| | | * @return The largest ChangeNumber seen. |
| | | */ |
| | | public ChangeNumber getMaxChangeNumber(short serverID) |
| | | public ChangeNumber getMaxChangeNumber(int serverID) |
| | | { |
| | | return state.getMaxChangeNumber(serverID); |
| | | } |