Commit Graph
1096 Commits
Author SHA1 Message Date
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
leventov 600325d1e3 HCOLL-383 Fix TcpReplicator 2015-09-04 16:53:49 +03:00
Peter Lawrey e873899ff4 CE-145 Review exception handling in Wire 2015-09-02 10:18:51 +01:00
Peter Lawrey 5a4be810be code tidy. 2015-08-31 14:24:11 +01:00
leventov ca5caf27b4 Remove race condition in TcpReplicator.KeyInterestUpdater 2015-08-28 21:43:40 +03:00
leventov 5a16c8579d HCOLL-382 fixed added flag passing to MapEventListener 2015-08-26 23:22:19 +03:00
leventov 604c5f9e71 Rollback 9f9aaa9b9e 2015-08-26 22:56:44 +03:00
Rob Austin 72901c919d fixed possible issue with 'added' 2015-08-21 16:15:36 +01:00
Rob Austin ec3b92daf6 commented out test for now 2015-08-20 17:42:45 +01:00
Peter Lawrey bab67acf11 CHENT-49 performance enhancements of UTF8 string handling. lang 6.7.0, map 2.3.1 2015-08-20 15:38:34 +01:00
Rob Austin 0201606bbd HCOLL-382 add the UpdateResult field to net.openhft.chronicle.map.MapEventListener#onPut 2015-08-20 14:48:37 +01:00
Rob Austin a0ecb8fc6b HCOLL-382 add the UpdateResult field to net.openhft.chronicle.map.MapEventListener#onPut 2015-08-20 14:04:49 +01:00
Rob Austin f15d087234 CE-117 fixed put(K,V) to return true if present, even if put returns NULL 2015-08-18 09:57:46 +01:00
leventov bc24505e49 CE-134 Add ChronicleMap.update(K, V) method 2015-08-18 02:31:22 +03:00
leventov 2f32764082 Make replace() returns on absent entry consistent 2015-08-17 23:09:00 +03:00
leventov 7e9daf73f3 Add ChronicleMap.readKey() and readValue() for convenient work with BytesMapEventListener 2015-07-28 08:15:12 +03:00
rob 4b7c89ad04 rolled back peters change 2015-07-27 14:34:53 +01:00
Peter Lawrey 94cc3a3917 CHENT-49 performance tune repeated puts. 2015-07-24 19:49:40 +03:00
leventov 9d7017b3e2 Use different ports in different tests in StatelessClientDuplicateKeyTest 2015-07-19 18:27:11 +03:00
leventov a7a50b05cc Updated StatelessClientDuplicateKeyTest #33 2015-07-19 18:07:02 +03:00
leventov af48ed63c5 Add StatelessClientDuplicateKeyTest (see #33) 2015-07-19 06:13:45 +03:00
Peter Lawrey f4403738ab Add a wan simulator to reproduce timing sensitive issues. 2015-07-16 19:13:56 +01:00
Peter Lawrey b6426edbd2 CHENT-67 listeners in ChronicleMap should be transient. 2015-07-14 18:26:52 +01:00
Peter Lawrey 53eea261bd POC Tuning 2015-07-07 13:50:14 +01:00
Rob Austin 9b793bed6d added fix to this java.lang.AssertionError: Invalid address 1
at net.openhft.lang.io.NativeBytes.setStartPositionAddress(NativeBytes.java:77)
                 	at net.openhft.lang.io.NativeBytes.<init>(NativeBytes.java:67)
                 	at net.openhft.lang.io.NativeBytes.wrap(NativeBytes.java:83)
                 	at net.openhft.chronicle.map.ReplicatedChronicleMap$1$1.onEntry(ReplicatedChronicleMap.java:474)
                 	at net.openhft.chronicle.map.ReplicatedChronicleMap$ModificationIterator.nextEntry(ReplicatedChronicleMap.java:1759)
                 	at net.openhft.chronicle.map.ReplicatedChronicleMap$1.nextEntry(ReplicatedChronicleMap.java:460)
                 	at net.openhft.chronicle.engine.map.CMap2EngineReplicator$1.nextEntry(CMap2EngineReplicator.java:132)
                 	at net.openhft.chronicle.engine.map.CMap2EngineReplicator$1.forEach(CMap2EngineReplicator.java:120)
                 	at net.openhft.chronicle.engine.server.internal.ReplicationHandler$1$1.action(ReplicationHandler.java:124)
                 	at net.openhft.chronicle.threads.VanillaEventLoop.runOneTenthLowHandler(VanillaEventLoop.java:154)
                 	at net.openhft.chronicle.threads.VanillaEventLoop.run(VanillaEventLoop.java:108)
                 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
                 	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
                 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
                 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
                 	at java.lang.Thread.run(Thread.java:745)
                 sends:
2015-07-06 23:54:11 +01:00
Peter Lawrey eb68f098bd CHENT-52 Fixes to support Enterprise Journal 2015-06-29 19:37:45 +01:00
Peter Lawrey 9c8fea8367 Replace "throws Exception" with the specific Exception(s) thrown. 2015-06-28 18:52:05 +01:00
Peter Lawrey 9f9aaa9b9e Update event to include the previous value. 2015-06-27 16:17:00 +01:00
Peter Lawrey 9e2ff6b733 Fix test for replication 2015-06-26 15:01:24 +01:00
Peter Lawrey 3634d6d0b3 Fix test for replication 2015-06-26 14:58:35 +01:00
Peter Lawrey fa468d8e6f Fix tests for mit. 2015-06-26 13:49:41 +01:00
rob e0433a0922 changed the version of chronicle map back to 2.1 and added some fixes to replication 2015-06-24 13:11:34 +01:00
Rob Austin 1881c98778 move all subscription code into the SubscriptionHandlerProcessor 2015-06-22 12:57:18 +01:00
Rob Austin 87037c4abd added testConverMarshallableToTextName 2015-06-22 10:06:36 +01:00