summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* source code file compressionMatthew Sackman2009-12-031-6/+5
|
* cosmeticMatthias Radestock2009-12-021-6/+7
|
* Up to 11kHz persistent on my home machine. Still a little way off the 13kHz ↵Matthew Sackman2009-12-022-30/+106
| | | | that I was getting before, but there were bugs in the previous QI (eg missing syncs) which could well have led to the old version being too fast. Added two functions to fhc: delete/1 which deletes without flushing any data at all. It will refuse to delete if the file isn't open; discard_write_buffer/1 which does what it says. We use the latter after scattering the journal as after we hit each segment, we sync the segment, so at that point there's no need at all to force out the data in the fhc for the journal prior to truncation.
* Allowed the journal to grow substantially bigger. This helps performance ↵Matthew Sackman2009-12-021-1/+1
| | | | substantially.
* New qi in place, tested and debugged. It works. It's not quite as fast as ↵Matthew Sackman2009-12-024-1460/+594
| | | | before because of use of nested dicts. This can be solved by using sets for publishes, deliveries and acks within each segment - we don't actually need what the dict provides and sets will go much faster. That change should be fairly straight forward to do - the code will get a little longer, but not much more complex.
* Finished. It might work - untested thoughMatthew Sackman2009-12-021-35/+217
|
* More good progress on qi3. The code still almost looks pretty in places. Its ↵Matthew Sackman2009-12-021-7/+175
| | | | prettiness is not diminishing.
* Lots of good progress on qi3. The code almost looks pretty in placesMatthew Sackman2009-12-021-36/+377
|
* Wrote two key combinators which will be used by the new queue index shortly. ↵Matthew Sackman2009-12-011-0/+159
| | | | qi3 is very temporary
* Only pull in one segment at a time from γ into q3Matthew Sackman2009-11-301-8/+9
|
* Remove the garbage_collect call as this doesn't seem to be necessary in R13B03Matthew Sackman2009-11-301-3/+1
|
* Garbage collect on memory reduction; remove delayed_write in queue index as ↵Matthew Sackman2009-11-303-4/+8
| | | | we're handling buffering ourselves; add a hack to get the raw vq status out of rabbitmqctl
* Removal of unnecessary clause in handle_info for queue process as prefetcher ↵Matthew Sackman2009-11-272-9/+4
| | | | has gone. Bump rabbit supervisor to allow all processes to take as long as necessary to exit. This should ensure cached data gets flushed out.
* Removed mnesia table and dq_msg_loc record that's no longer neededMatthew Sackman2009-11-272-12/+5
|
* There was a bug. Now it has gone away. It arose when γ has a partial ↵Matthew Sackman2009-11-273-39/+116
| | | | segment, and then memory is made available, and the next msg is persistent. It will go into the partial segment in qi, but will also be in q1 in vq. This lead to the msg being duplicated. Solution is to track the max seq id beyond the end of the γs, and thus drop anything being returned in the segment from qi with a seq_id above this max seq id.
* storage_mode is long goneMatthias Radestock2009-11-271-1/+1
|
* unintended variable captureMatthias Radestock2009-11-271-6/+7
|
* s/full_flush_journal/flush_journal and some refactoringMatthias Radestock2009-11-264-56/+41
|
* better const namesMatthias Radestock2009-11-261-17/+17
|
* cosmeticMatthias Radestock2009-11-261-33/+41
|
* cosmetic and inliningMatthias Radestock2009-11-261-33/+33
|
* use ?SERVER wherever possibleMatthias Radestock2009-11-261-1/+1
|
* Don't demonitor if we received a DOWN msg.Matthew Sackman2009-11-261-6/+10
|
* remove unnecessary commentMatthew Sackman2009-11-261-3/+0
|
* Added demonitoring, corrected counting on deregistering, and got fed up with ↵Matthew Sackman2009-11-261-43/+49
| | | | the lack of whitespace
* Don't need this variable anymoreMatthew Sackman2009-11-261-2/+1
|
* Remove the small_duration_threshold, and instead smooth the ram_msg_count ↵Matthew Sackman2009-11-262-38/+16
| | | | over the last two periods. This seems to work reasonably well.
* SMALL_INFINITY_OSCILLATION_DURATION => SMALL_DURATION_THRESHOLDMatthew Sackman2009-11-261-9/+8
|
* s/b(.)t/s\1m/Matthew Sackman2009-11-261-1/+1
|
* Improved documentation and code regarding fast moving mainly empty queues ↵Matthew Sackman2009-11-261-35/+59
| | | | and the SMALL_INFINITY_OSCILLATION_DURATION definition. Oh, and clamped zero.
* beautifulerMatthew Sackman2009-11-261-5/+2
|
* Improvements to documentation, further improvements to conditional and ↵Matthew Sackman2009-11-261-33/+32
| | | | refactorings. Removal of max queue duration because the rate calculated by the queue doesn't decay in the way necessary to make the max queue duration necessary
* Further correction to conditional; line lengths; extract all magic numbers ↵Matthew Sackman2009-11-261-17/+40
| | | | and -define them and document them.
* Lots of improvements: o) merge the dict and ets; use a record there; o) drop ↵Matthew Sackman2009-11-261-39/+44
| | | | record memory_ratio; o) corrected where we clamp to non-neg numbers; o) correct conditional in internal update
* Added deregister and stop to MMMatthew Sackman2009-11-262-20/+35
|
* merge default into bug21673Matthias Radestock2009-11-251-1/+2
|\
| * cosmeticMatthias Radestock2009-11-251-2/+3
| |
* | merge default into bug21673Matthias Radestock2009-11-251-45/+47
|\ \ | |/
| * put things in (the right) orderMatthias Radestock2009-11-251-22/+22
| |
| * merge bug22042 into defaultMatthias Radestock2009-11-251-22/+24
| |\
| | * don't use rabbit_log; use gen_server, not 2; correct long linesMatthew Sackman2009-11-251-14/+16
| | |
| | * remove trailing spacesMatthew Sackman2009-11-251-9/+9
| |/
* | (kinda bug 22042) inline rabbit_misc:cmd seeing as it's not used elsewhere ↵Matthew Sackman2009-11-252-12/+10
| | | | | | | | and we want to allow vm_memory_monitor to be used outside of rabbit
* | typeos to novelMatthew Sackman2009-11-251-20/+24
| |
* | merging headsMatthew Sackman2009-11-251-1/+2
|\ \
| * | cosmeticMatthias Radestock2009-11-251-1/+2
| | |
* | | A novelMatthew Sackman2009-11-251-0/+80
|/ /
* | merging headsMatthew Sackman2009-11-251-10/+9
|\ \
| * | use plain, old gen_server instead of gen_server2 - for better compatibilityMatthias Radestock2009-11-251-10/+9
| | |
* | | Stop using _misc:cmd and use os:cmd insteadMatthew Sackman2009-11-251-22/+23
|/ /