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