This commit is contained in:
rogersimmons
2019-10-03 15:18:27 +01:00
parent f10edcf1c8
commit ce3e4ab4b1
2 changed files with 5 additions and 2 deletions
@@ -189,6 +189,7 @@ public interface Replica extends Closeable {
* operation and add zeroBytes, if the identifier in the entry did not
* match the maps local
* @param chronicleId is the channel id used to identify the canonical map or queue
* @param keys list of keys corresponding to given ReplicableEntry (added to during the call)
*/
void writeExternalEntry(ReplicableEntry entry, Bytes payload, @NotNull Bytes destination, int chronicleId, ArrayList<String> keys );
@@ -177,6 +177,7 @@ public class BasicReplicationTest {
private final Bytes<ByteBuffer> buffer = Bytes.elasticByteBuffer(4096);
private final ExecutorService delayedExecutor = Executors.newSingleThreadExecutor();
private final AtomicInteger messagesInflight = new AtomicInteger(0);
private final ArrayList<String> keys = new ArrayList<>();
IteratorAndDestinationMap(final ReplicatedChronicleMap<K, V, ?>.ModificationIterator modificationIterator,
final ReplicatedChronicleMap<K, V, ?> sourceMap,
@@ -190,7 +191,8 @@ public class BasicReplicationTest {
public void onEntry(final ReplicableEntry entry, final int chronicleId) {
try {
buffer.clear();
sourceMap.writeExternalEntry(entry, null, buffer, chronicleId);
keys.clear();
sourceMap.writeExternalEntry(entry, null, buffer, chronicleId,keys);
buffer.readPosition(0);
buffer.readLimit(buffer.writePosition());
@@ -221,4 +223,4 @@ public class BasicReplicationTest {
destinationMap.setRemoteNodeCouldBootstrapFrom((byte) chronicleId, bootstrapTime);
}
}
}
}