summaryrefslogtreecommitdiff
path: root/src
Commit message (Expand)AuthorAgeFilesLines
* the queue index deletes transient msgs on initialisation. This is rather eleg...Matthew Sackman2009-10-141-6/+17
* Wire up the tx_commit callback. Note no coalescing because no sync on queue_i...Matthew Sackman2009-10-142-3/+10
* Be a bit more clever on starting the message store and look up durable queues...Matthew Sackman2009-10-134-37/+76
* most of the rewiring is done. Need to sort out how to delete non durable queu...Matthew Sackman2009-10-136-1538/+73
* added publish_delivered/2 which deals with adding a message, when the queue i...Matthew Sackman2009-10-131-1/+17
* publish/3 -> publish/2 because the IsDelivered bit is always false when calle...Matthew Sackman2009-10-131-14/+32
* it starts up againMatthew Sackman2009-10-133-5/+9
* Added ability to seed the msg_store. It's a bit hairy.Matthew Sackman2009-10-131-5/+57
* Maybe done. Maybe time to start hacking out mq and dq. Maybe.Matthew Sackman2009-10-132-22/+35
* factorisation and application of DeMorganMatthew Sackman2009-10-131-16/+14
* in preparation for commit, need to be able to indicate in a publish that pers...Matthew Sackman2009-10-121-22/+62
* cosmeticMatthew Sackman2009-10-121-5/+6
* tx_publish and tx_rollback done. Only tx_commit to go...Matthew Sackman2009-10-121-1/+12
* Requeue turns out to be vastly more elegant and predictable than in mq.Matthew Sackman2009-10-121-1/+11
* implemented delete. This is slightly less than pretty as, after doing the pur...Matthew Sackman2009-10-121-9/+38
* for queue delete I need to be able to discover the lowest and highest non-ack...Matthew Sackman2009-10-122-37/+38
* a couple of full list sorts were unnecessary and should only have been max or...Matthew Sackman2009-10-121-7/+8
* Well, it was beautiful, but it was also wrong. Firstly, purge needs to return...Matthew Sackman2009-10-121-20/+48
* given the way in which the vq works, the removed tests were unnecessary. For ...Matthew Sackman2009-10-121-7/+7
* merging in from bug 21368Matthew Sackman2009-10-122-80/+59
|\
| * rollback transactions on queue terminationMatthias Radestock2009-10-112-80/+59
* | Beautiful!Matthew Sackman2009-10-091-1/+40
* | cosmeticsMatthew Sackman2009-10-093-23/+31
* | Added ack to vq. Realised that ack no longer needs the msg itself, so there'v...Matthew Sackman2009-10-092-11/+25
* | gee, can you tell none of this has been run yet?Matthew Sackman2009-10-091-1/+2
* | tidying of the beloved msg_storeMatthew Sackman2009-10-092-27/+29
* | Prefetcher has priority over q1.Matthew Sackman2009-10-093-17/+43
* | switching back to lists:min and lists:max as erlang:min/max do not exist in R12Matthew Sackman2009-10-093-4/+4
* | altered the prefetcher to drive the msg_store directly, and wired into vqMatthew Sackman2009-10-093-104/+152
* | having discovered that erlang:min and erlang:max do exist, swap them in in pl...Matthew Sackman2009-10-092-3/+3
* | adding len and is_empty. Renaming in -> publish and out -> fetch. A bit of mo...Matthew Sackman2009-10-091-65/+86
* | on out/1, if the msg or its index are on disk and they don't need to be, take...Matthew Sackman2009-10-081-12/+32
* | And now actually make sure that on start up we load in the first segment from...Matthew Sackman2009-10-081-39/+45
* | The calculation of the highest seq id in the index queue was wrong - it was s...Matthew Sackman2009-10-082-42/+66
* | minor further corrections and modificationsMatthew Sackman2009-10-081-18/+21
* | merging in from bug 21368Matthew Sackman2009-10-081-1/+1
|\ \ | |/
| * fixing erroneous use of thunk(_) in spec to fun()Matthew Sackman2009-10-081-1/+1
* | Tidying and refactoring of the variable queue, some documentation, and the re...Matthew Sackman2009-10-082-174/+273
* | merging in from bug 21368Matthew Sackman2009-10-083-131/+149
|\ \ | |/
| * cosmeticMatthias Radestock2009-10-081-8/+5
| * make msg_store responsible for sync'ingMatthias Radestock2009-10-082-130/+148
| * merge default into bug21368Matthias Radestock2009-10-078-64/+133
| |\
| | * fix race condition in list_connections test when in a clusterMatthias Radestock2009-10-021-1/+4
* | | implemented out. This is getting pretty disgusting, needs some refactoring, m...Matthew Sackman2009-10-072-29/+164
* | | More work on variable queueMatthew Sackman2009-10-072-43/+174
* | | initial hacking on the variable queueMatthew Sackman2009-10-071-0/+182
* | | Make init include in its result the next sequence id to useMatthew Sackman2009-10-071-15/+33
* | | removing bogus and flawed fhc2Matthew Sackman2009-10-071-356/+0
* | | just some fixes as a result of dialyzer, but the module is actually about to ...Matthew Sackman2009-10-071-4/+4
* | | Well fixed a few bugs in the fhc2, but it's fundamentally flawed by the fact ...Matthew Sackman2009-10-061-25/+67