Gary Tully
d458a5d17f
fix org.apache.kahadb.journal.JournalTest.testBatchWriteCompleteAfterClose() after changes for AMQ-2143, the file and offset in a location are set after an enqueue to a write batch, so doing the inflight add just overwrote the same entry, -1:-1. Which fixed the leak but broke inflights, proper fix is to do the inflight addition in enqueue, just after the location details are known and with a lock on appender enqueue
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@748475 13f79535-47bb-0310-9956-ffa450edef68
2009-02-27 10:22:50 +00:00
Gary Tully
d98ea376ba
resolve mem leak in kahadb - AMQ-2143
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@748218 13f79535-47bb-0310-9956-ffa450edef68
2009-02-26 17:32:37 +00:00
Hiram R. Chirino
f73b622a60
Change the way journal records are validated on recovery to be consistent. We now use a checksum to provide better consistency.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741741 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 21:35:39 +00:00
Hiram R. Chirino
d761e80ae4
- added some handy generic visitors to the BTreeVisitor class.
...
- Updated the recovery process so it now rollsback changes applied to the index which did not get synced to the journal.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741659 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 18:19:31 +00:00
Hiram R. Chirino
789ea7cab9
Making the removeDataFile a little smarter to avoid removing data files that are still being worked on
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741600 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 15:54:19 +00:00
Gary Tully
deea2d11a8
expose relevant index attributes for configuration from kahadb
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741528 13f79535-47bb-0310-9956-ffa450edef68
2009-02-06 10:59:47 +00:00
Hiram R. Chirino
180b0ec4ab
- Implemented the setBatch API call in KahaDBStore.
...
- fixed bug: When a async thread was used for writing in KahaDBStore you could run in a Memory leak due to an unbound enqueue buffer type problem.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741327 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 22:41:01 +00:00
Gary Tully
f0af62f64d
add a little more info to flush
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741293 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 21:15:13 +00:00
Hiram R. Chirino
8262ef7903
Changed the cleanup algorithm used in the KahaDB.. It should now be much faster.
...
Fixed bug in the BTreeNode.visit() which was making us load most of the pages instead of letting us filter down to just a few.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741212 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 18:07:57 +00:00
Hiram R. Chirino
c0594251e2
Bettter property names.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741169 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 16:33:23 +00:00
Hiram R. Chirino
19c4316a1c
Added the ability to customize thw write batch size in the PageFile.
...
Added some diagnostic logging to see when store updates take too long and why.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741137 13f79535-47bb-0310-9956-ffa450edef68
2009-02-05 15:29:48 +00:00
Hiram R. Chirino
ba706d134d
Added a handy little rotateTo method to be able to quickly rotate to a specific node.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@740329 13f79535-47bb-0310-9956-ffa450edef68
2009-02-03 16:02:01 +00:00
Hiram R. Chirino
c01e182cfd
Avoid NPE
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@740087 13f79535-47bb-0310-9956-ffa450edef68
2009-02-02 19:38:04 +00:00
Hiram R. Chirino
42824ffc55
Adding a handy getList() method to the LinkedNode impl
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@738946 13f79535-47bb-0310-9956-ffa450edef68
2009-01-29 18:10:03 +00:00
Gary Tully
2deea18cc2
applied patch from https://issues.apache.org/activemq/browse/AMQ-2068 with thanks
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@734981 13f79535-47bb-0310-9956-ffa450edef68
2009-01-16 11:47:02 +00:00
Hiram R. Chirino
47e6d0482b
Fixing 2 bugs and adding a nice to have toArrayList() method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@733888 13f79535-47bb-0310-9956-ffa450edef68
2009-01-12 20:17:48 +00:00
Hiram R. Chirino
050436d72c
Fixing rotate() method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@733849 13f79535-47bb-0310-9956-ffa450edef68
2009-01-12 17:51:08 +00:00
Bosanac Dejan
3967b81cc7
name and description for kaha db module
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@732985 13f79535-47bb-0310-9956-ffa450edef68
2009-01-09 09:48:35 +00:00
Hiram R. Chirino
f62737be7c
Moving stuff around so that activemq-core can depend on kahadb instead of kahadb depending on activemq-core. This step allows kahadb to be used as the default
...
store implementation if desired. Will do that next.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@731704 13f79535-47bb-0310-9956-ffa450edef68
2009-01-05 20:48:38 +00:00
Robert Davies
30f41b9811
Fix for https://issues.apache.org/activemq/browse/AMQ-1842
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@729942 13f79535-47bb-0310-9956-ffa450edef68
2008-12-29 16:50:53 +00:00
Robert Davies
04bb24b05e
Add activeBlaze replication cluster state manager
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@722615 13f79535-47bb-0310-9956-ffa450edef68
2008-12-02 20:54:32 +00:00
Hiram R. Chirino
7c70973de3
Fixing build.. breaks on java 1.6
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@721260 13f79535-47bb-0310-9956-ffa450edef68
2008-11-27 18:53:25 +00:00
Hiram R. Chirino
2996cf31e8
- Switched to using camel case in the xml emlement names to make things consistent.
...
- Replaced the asyncReplication property in the ReplicationService with a minimumReplicas properties. When set to 0, async replication will be in effect.
- Also removed the use of a map to track replication requests since at most, only 1 sync requrest is issued at a time.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@720234 13f79535-47bb-0310-9956-ffa450edef68
2008-11-24 17:44:12 +00:00
Hiram R. Chirino
a85ca4a186
Updated assembly so that kahadb is included and also added an example HA configuration which uses it.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@719763 13f79535-47bb-0310-9956-ffa450edef68
2008-11-22 00:36:43 +00:00
Hiram R. Chirino
456a2ba5cf
Moving the kahadb work from the sandbox into trunk now that 5.2 has been released.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@719665 13f79535-47bb-0310-9956-ffa450edef68
2008-11-21 18:19:50 +00:00