mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
HCOLL-134 ( release draft cut of the code so that I can test it across my network )
This commit is contained in:
@@ -279,7 +279,6 @@ class BytesExternalizableImpl implements BytesExternalizable {
|
||||
@Override
|
||||
public void writeExternalBytes(@NotNull Bytes destination) {
|
||||
|
||||
modificationsComplete.set(true);
|
||||
|
||||
if (bootstrapRequired.getAndSet(false)) {
|
||||
//destination.write(BOOTSTRAP_BYTES);
|
||||
@@ -307,8 +306,7 @@ class BytesExternalizableImpl implements BytesExternalizable {
|
||||
destination.writeUnsignedShort((int) bytes.remaining());
|
||||
destination.write(bytes);
|
||||
|
||||
if (!(modificationsComplete.get()))
|
||||
modificationNotifier.onChange();
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
@@ -357,8 +355,7 @@ class BytesExternalizableImpl implements BytesExternalizable {
|
||||
|
||||
}
|
||||
|
||||
private void onChange() {
|
||||
modificationsComplete.set(false);
|
||||
public void onChange() {
|
||||
modificationNotifier.onChange();
|
||||
}
|
||||
|
||||
@@ -424,18 +421,19 @@ class BytesExternalizableImpl implements BytesExternalizable {
|
||||
|
||||
public void sendBootStrap() {
|
||||
bootstrapRequired.set(true);
|
||||
onChange();
|
||||
|
||||
}
|
||||
|
||||
public void add(InetSocketAddress interfaceAddress) {
|
||||
allNodes.add(interfaceAddress);
|
||||
onChange();
|
||||
|
||||
}
|
||||
|
||||
|
||||
public void add(byte identifier) {
|
||||
allNodes.activeIdentifierBitSet().set(identifier);
|
||||
onChange();
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user