- leader.setSnapshot(Snapshot.create(bs.toByteArray(), Collections.<ReplicatedLogEntry>emptyList(),
- commitIndex, snapshotTerm, commitIndex, snapshotTerm));
- FollowerToSnapshot fts = leader.new FollowerToSnapshot(bs);
- leader.setFollowerSnapshot(FOLLOWER_ID, fts);
- while(!fts.isLastChunk(fts.getChunkIndex())) {
+ leader.setSnapshot(new SnapshotHolder(Snapshot.create(ByteState.of(bs.toByteArray()),
+ Collections.<ReplicatedLogEntry>emptyList(), commitIndex, snapshotTerm, commitIndex, snapshotTerm,
+ -1, null, null), ByteSource.wrap(bs.toByteArray())));
+ LeaderInstallSnapshotState fts = new LeaderInstallSnapshotState(
+ actorContext.getConfigParams().getSnapshotChunkSize(), leader.logName());
+ fts.setSnapshotBytes(ByteSource.wrap(bs.toByteArray()));
+ leader.getFollower(FOLLOWER_ID).setLeaderInstallSnapshotState(fts);
+ while (!fts.isLastChunk(fts.getChunkIndex())) {