summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* 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 ↵Matthew Sackman2009-10-092-3/+3
| | | | place of lists:min and lists:max where appropriate
* adding len and is_empty. Renaming in -> publish and out -> fetch. A bit of ↵Matthew Sackman2009-10-091-65/+86
| | | | moving around. Generally trying to work towards the mq API so that it can be dropped in
* on out/1, if the msg or its index are on disk and they don't need to be, ↵Matthew Sackman2009-10-081-12/+32
| | | | take them off disk
* And now actually make sure that on start up we load in the first segment ↵Matthew Sackman2009-10-081-39/+45
| | | | from gamma to q3 if possible. Hence a refactoring here.
* The calculation of the highest seq id in the index queue was wrong - it was ↵Matthew Sackman2009-10-082-42/+66
| | | | simply returning the highest unacked seq id, instead of looking for the highest seq id ever encountered. This could have led to reuse of seq ids. We also need to know the total message count in the queue index which is the number of unacked msgs recorded in the index, and we also need the seq id of the segment boundary of the segment containing the first msg in the queue. This is so that we can form the inital gamma correctly.
* 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 ↵Matthew Sackman2009-10-082-174/+273
| | | | | | | | removal of a lot of algorithmic bugs. No real new features, but code in much better state.
* | merging in from bug 21368Matthew Sackman2009-10-085-131/+158
|\ \ | |/
| * cosmeticMatthias Radestock2009-10-081-8/+5
| |
| * make msg_store responsible for sync'ingMatthias Radestock2009-10-082-130/+148
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The API to the msg_store has changed: now instead of asking whether a sync is needed for a set of msg ids, and subsequently requesting a sync, we request a sync for a set of msg ids and supply a callback that is invoked when that sync is done. That way the msg_store can make its own decisions on when to sync, and less logic is required by callers. During queue deletion we must remove *all* queue messages from the store, including those that are part of committed transactions for which the disk_queue has not yet received the sync callback. To do that we keep a record of these messages in a dict in the state. The dict also ensures that we do not act on a sync callback involving a queue which has since been deleted and perhaps recreated.
| * merge default into bug21368Matthias Radestock2009-10-0717-92/+194
| |\
| | * Added tag rabbitmq_v1_7_0 for changeset b1089fcc31b7David Wragg2009-10-070-0/+0
| | |
| | * Bump version to 1.7.0rabbitmq_v1_7_0David Wragg2009-10-072-0/+9
| | |
| | * Merge QAd bug21738 into defaultMichael Bridgen2009-10-051-1/+4
| | |\
| | | * 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, ↵Matthew Sackman2009-10-072-29/+164
| | | | | | | | | | | | | | | | marginally more useful variable names, and more API, in particular proper support for the prefetcher. Also, totally untested.
* | | | 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
| | | | | | | | | | | | | | | | be deleted
* | | | Well fixed a few bugs in the fhc2, but it's fundamentally flawed by the fact ↵Matthew Sackman2009-10-061-25/+67
| | | | | | | | | | | | | | | | that raw files can only be manipulated by the process that opens it. Thus the whole design is wrong because the server process can't be responsible for holding on to released but unclosed fhs.
* | | | mainly cosmeticsMatthew Sackman2009-10-051-11/+11
| | | |
* | | | more work on file handle cache. However, untested, and liable to extreme changeMatthew Sackman2009-10-051-22/+116
| | | |
* | | | initial work on new file handle cache. Public API not done yet.Matthew Sackman2009-10-051-0/+220
| | | |
* | | | merging in from defaultMatthew Sackman2009-10-0514-91/+181
|\ \ \ \ | | |/ / | |/| |
| * | | Merge bug21222 into defaultDavid Wragg2009-10-041-5/+6
| |\ \ \ | | |_|/ | |/| |
| | * | setting log dir for startup/shutdown messagesMarek Majkowski2009-10-011-5/+6
| | | |
| * | | Merged bug 21294 into default.Marek Majkowski2009-10-022-1/+15
| |\ \ \ | | |/ / | |/| |
| | * | Shuffled the config file element declaration so the debian defaults file ↵Paul Jones2009-10-011-1/+2
| | | | | | | | | | | | | | | | will be able to override it
| | * | Changed location of the configuration file on windowsPaul Jones2009-10-011-3/+6
| | | |
| | * | Added ability to provide configuration file to windows server startup tooPaul Jones2009-09-211-1/+7
| | | |
| | * | Added facility to provide a configuration file to rabbit startup for Unix ↵Paul Jones2009-09-211-0/+4
| | | | | | | | | | | | | | | | systems
| * | | Merged bug 21682 into defaultMarek Majkowski2009-10-011-13/+14
| |\ \ \
| | * | | Introduced realsbin directoryPaul Jones2009-09-301-13/+14
| | | | |
| | * | | Changed target of reinplace calls to prevent macports converting symlinks to ↵Paul Jones2009-09-241-13/+13
| | | | | | | | | | | | | | | | | | | | files
| * | | | Merged bug 21273 into defaultMarek Majkowski2009-10-012-20/+37
| |\ \ \ \
| | * \ \ \ Default merged into bug21273Marek Majkowski2009-10-019-52/+109
| | |\ \ \ \ | | |/ / / / | |/| | | |
| * | | | | merge bug21669 into defaultMatthias Radestock2009-09-303-22/+66
| |\ \ \ \ \
| | * | | | | leave error reporting in rabbit:prepare to contextMatthias Radestock2009-09-302-55/+54
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | also: - tabs->spaces - a few cosmetic changes - extract error handling & termination in rabbit_plugin_activator
| | * | | | | Reverted rabbit:boot to rabbit_misc:start_applicationsPaul Jones2009-09-301-1/+1
| | | | | | |
| | * | | | | Removed application starting changes, since these were causing a number of ↵Paul Jones2009-09-302-24/+8
| | | | | | | | | | | | | | | | | | | | | | | | | | | | problems
| | * | | | | Updated boot modification code to support catching errorsPaul Jones2009-09-283-31/+53
| | | | | | |
| | * | | | | Added rabbit:prepare to the generated boot file; removed call to ↵Paul Jones2009-09-243-4/+43
| | | | | | | | | | | | | | | | | | | | | | | | | | | | rabbit:start when using a boot file
| * | | | | | Merged bug 20399 into default.Marek Majkowski2009-09-302-21/+24
| |\ \ \ \ \ \
| | * | | | | | cosmeticMatthias Radestock2009-09-301-1/+1
| | | | | | | |
| | * | | | | | fix handling of precondition_failedMatthias Radestock2009-09-302-21/+24
| | | | | | | |
View Lorry Controller Status