Commit Graph
1129 Commits
Author SHA1 Message Date
Rob Austin dbed8e7d73 fixed merge issues 2015-12-14 11:27:45 +00:00
Rob Austin 58c8d94f11 remvoed boolean hasValueChanged = false; 2015-12-14 11:24:45 +00:00
Rob Austin 1c772eea22 Merge remote-tracking branch 'origin/2.1' into 2.1
Conflicts:
	src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
	src/main/java/net/openhft/chronicle/map/VanillaChronicleMap.java
2015-12-14 11:21:53 +00:00
Rob Austin d1513a4ba9 added further fields to ByteEventListener such as byte replacedIdentifier, long timeStamp, long replacedTimeStamp 2015-12-14 11:17:37 +00:00
leventov d0dc667717 Improve startsWith() implementations 2015-12-14 13:56:55 +03:00
leventov e2ba8b3f5a HCOLL-410 2015-12-14 13:54:04 +03:00
Rob Austin 81b2079b74 addded size back in 2015-12-13 21:30:39 +00:00
Rob Austin d713589bd2 added hasValueChanged to ByteMapEventListener 2015-12-13 21:29:55 +00:00
Rob Austin 342b7fc546 added @Ignore("JIRA - HCOLL-411") 2015-12-13 17:14:16 +00:00
Rob Austin d496cf30fe fixed some minor bugs with chronicle-map around the update to an entry 2015-12-13 16:54:35 +00:00
Rob Austin 14e57121c3 Merge remote-tracking branch 'origin/2.1' into 2.1
Conflicts:
	src/main/java/net/openhft/chronicle/map/VanillaChronicleMap.java
2015-12-13 16:49:21 +00:00
Rob Austin ca05142928 fixed some minor bugs with chronicle-engine 2015-12-13 16:43:41 +00:00
leventov 5eda4c44b3 HCOLL-410 2015-12-13 18:41:29 +03:00
Rob Austin c2224da389 fixed build issue 2015-12-12 15:35:53 +00:00
Rob Austin adb309185c added identifier etc for remove events. 2015-12-12 15:12:42 +00:00
Rob Austin 37ba02935f added javadoc to the event listener 2015-12-11 22:45:39 +00:00
Rob Austin 3647c0a555 HCOLL-410 map event listener expose the identifer, timestamp and hasValueChanged 2015-12-11 17:20:22 +00:00
Rob Austin 6d869e2f86 added a replicaiton test case 2015-12-08 09:45:43 +00:00
Rob Austin 64aaa6c54e added missing
final InetSocketAddress serverInetSocketAddress =
                new InetSocketAddress(replicationConfig.serverPort());
        final Details serverDetails = new Details(serverInetSocketAddress, localIdentifier);

        attached.connector = new ServerConnector(serverDetails);
2015-12-04 10:22:10 +00:00
leventov 5da0e4041b Remove buggy optimization #58 2015-11-17 14:57:25 +03:00
Rob Austin 1f219376ed removed unwanted NPE catch 2015-10-23 13:35:36 +01:00
Rob Austin a2e4320923 removed assignment at definition 2015-10-23 13:27:33 +01:00
Rob Austin 0d4f3c2aef added missing fields to init transients 2015-10-23 12:38:24 +01:00
Rob Austin 386e1828ef HCOLL-403 When the following setting is set on chronicle map "bootstrapOnlyLocalEntries==false", it is not sending all the entries. - this is the same issue but it was affecting chronicle engine replication 2015-10-23 11:42:42 +01:00
leventov fb1a54f266 Allow ReplicatedChronicleMap to be accessed without configuring replicators 2015-10-22 00:28:15 +03:00
rob 429ff80edd changed ports 2015-10-14 11:02:30 +01:00
rob 0082a6e860 HCOLL-403 corrected test name 2015-10-14 10:49:08 +01:00
rob d1d1d2daff HCOLL-403 removed another filter that was preventing all the message to be sent ( from all the nodes on bootstrap ) 2015-10-14 10:46:58 +01:00
Rob Austin dd16bf6cde Merge remote-tracking branch 'origin/2.1' into 2.1 2015-10-14 08:21:26 +01:00
Rob Austin afee88dc37 HCOLL-403 added Ozan's test case 2015-10-14 08:21:12 +01:00
leventov 253de0f870 Fix a bug in ChannelProvider.ChronicleChannel.close(), props to @maxime-leur #51 2015-10-13 14:44:31 +03:00
Rob Austin 99258b23ac HCOLL-403 When the following setting is set on chronicle map "bootstrapOnlyLocalEntries==false", it is not sending all the entries. 2015-10-12 17:56:14 +01:00
leventov 69e38fc52c Fix a bug in TcpReplicator -- didn't schedule to connect to an endpoint later, when channel.socket().setTcpNoDelay(true) throws an exception 2015-10-09 15:15:35 +03:00
rob 04db0ad7df added example 2015-09-18 21:25:47 +09:00
leventov 3c296823e6 Fix ModificationIterator.hasNext() condition 2015-09-16 19:26:20 +03:00
Rob Austin 2519b3619e corrected - if (attached.isServer && attached.isHandShakingComplete()) 2015-09-15 21:39:58 +01:00
Rob Austin f094733294 corrected - if (attached.isServer && attached.isHandShakingComplete()) 2015-09-15 19:46:34 +01:00
Rob Austin 522f0503b3 corrected if (!attached.isServer || !attached.isHandShakingComplete())
return;
2015-09-15 19:44:24 +01:00
Rob Austin ef39df5a59 improved the connection listener 2015-09-14 15:37:38 +01:00
Rob Austin 996c9868f3 fixed issue with 2015-09-14 15:16:37 +01:00
Rob Austin a0507f4f31 added connection listener check 2015-09-14 13:25:32 +01:00
Rob Austin 5c1f89ac9d removed system.out 2015-09-14 13:22:26 +01:00
Rob Austin 82a22fd331 Merge remote-tracking branch 'origin/2.1' into 2.1
Conflicts:
	src/main/java/net/openhft/chronicle/map/TcpReplicator.java
2015-09-14 13:18:06 +01:00
Rob Austin 2403f7d4c1 added connection listener 2015-09-14 13:14:50 +01:00
Peter Lawrey 8a816054d3 Reduce line padding. 2015-09-11 15:26:02 +01:00
Peter Lawrey 2839bde340 Reduce blank lines 2015-09-11 10:29:10 +01:00
leventov 608d88917a HCOLL-384 add a test for issue #37 2015-09-10 17:01:20 +03:00
leventov aa3f3ad7d7 HCOLL-384 #37 protect from double close() 2015-09-10 16:46:29 +03:00
leventov c292c7d657 HCOLL-384 #37 Optimize channels management in ChannelProvider 2015-09-10 16:39:24 +03:00
xfeep 86a35a5d7e Fix NoClassDefFoundError when run without xstream 2015-09-10 11:35:16 +08:00