Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

HCOLL-124 fixed - Issue preventing the Replication in chronicle map from working

Browse Source
This commit is contained in:
Rob Austin
2014-08-07 19:14:45 +01:00
parent ca66c00d33
commit 039de2d07f
1 changed files with 18 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/collections/SharedHashMapBuilder.java
+18 -20
View File
@@ -73,7 +73,7 @@ public class SharedHashMapBuilder<K, V> implements Cloneable {
private boolean canReplicate;
byte identifier = Byte.MIN_VALUE;
TcpReplicatorBuilder tcpReplicatorBuilder;
// ExternalReplicatorBuilder externalReplicatorBuilder;
// ExternalReplicatorBuilder externalReplicatorBuilder;
private TimeProvider timeProvider = TimeProvider.SYSTEM;
UdpReplicatorBuilder udpReplicatorBuilder;
@@ -285,10 +285,6 @@ public class SharedHashMapBuilder<K, V> implements Cloneable {
if (vClass == null)
throw new IllegalArgumentException("missing mandatory parameter vClass");
if (file == null)
throw new IllegalArgumentException("missing mandatory parameter file");
SharedHashMapBuilder<K, V> builder = toBuilder();
if (!canReplicate())
@@ -334,23 +330,25 @@ public class SharedHashMapBuilder<K, V> implements Cloneable {
SharedHashMapBuilder<K, V> toBuilder() throws IOException {
SharedHashMapBuilder builder = clone();
for (int i = 0; i < 10; i++) {
if (file.exists() && file.length() > 0) {
readFile(file, builder);
break;
}
if (file.createNewFile() || file.length() == 0) {
newFile(file);
break;
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
throw new IOException(e);
if (file != null) {
for (int i = 0; i < 10; i++) {
if (file.exists() && file.length() > 0) {
readFile(file, builder);
break;
}
if (file.createNewFile() || file.length() == 0) {
newFile(file);
break;
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
throw new IOException(e);
}
}
if (builder == null || !file.exists())
throw new FileNotFoundException("Unable to create " + file);
}
if (builder == null || !file.exists())
throw new FileNotFoundException("Unable to create " + file);
return builder;
}