summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merging bug23445 into defaultMatthew Sackman2011-01-130-0/+0
|\
* | cosmetics and indentation onlyMatthew Sackman2011-01-133-120/+113
| |
* | Some refactoringsMatthew Sackman2011-01-134-47/+31
| |
* | Merging default into bug23445Matthew Sackman2011-01-1312-159/+237
|\ \ | |/ |/|
| * cosmetics and minor factoringsMatthew Sackman2011-01-115-27/+29
| |
| * Merging default into bug23445Matthew Sackman2011-01-1112-155/+231
| |\
| | * Only read inside an mnesia transactionEmile Joubert2011-01-101-3/+2
| | |
| | * One less thunkEmile Joubert2011-01-101-1/+1
| | |
| | * More frugal use of thunksEmile Joubert2011-01-102-4/+7
| | |
| | * Unconditionally return a fun() in execute mnesia txEmile Joubert2011-01-101-3/+7
| | |
| | * Transfer changes from rabbit_access_control to rabbit_vhostEmile Joubert2011-01-101-29/+27
| | |
| | * Merged default into bug23445Emile Joubert2011-01-1011-123/+195
| | |\
| | | * Merged default into bug23445Emile Joubert2010-12-2358-1771/+2193
| | | |\
| | | * | Changed exchange callback API for transactionsEmile Joubert2010-12-2313-163/+180
| | | | |
| | | * | Introduce some abstraction, reducing duplicate callsEmile Joubert2010-11-296-148/+154
| | | | |
| | | * | IndentationEmile Joubert2010-11-253-44/+46
| | | | |
| | | * | Offer tx and non-tx exchange hooksEmile Joubert2010-11-239-55/+100
| | | | |
* | | | | Merging bug23661 into defaultMatthew Sackman2011-01-131-2/+0
|\ \ \ \ \
| * | | | | ensure connections terminate when channel-related processes exit abnormallyMatthias Radestock2011-01-091-2/+0
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | When processes related to the channel, such as the writer and limiter, terminate abnormally, the channel_sup terminates the channel process with reason 'shutdown'. The reader musn't treat that as a controlled termination. The other path to a 'shutdown' termination of a channel process is the shutdown of the application. But the reader will be shut down first there since it is started after the channel_sup_sup. Hence it will never see a 'shutdown' termination from a channel in that scenario.
* | | | | | Fix bug. FTR, this mistake has been there since Sept 16th 2010Matthew Sackman2011-01-131-2/+1
| | | | | |
* | | | | | merge bug23678 into default (conditional on vq:needs_idle_timeout wrt ↵Alexandru Scvortov2011-01-131-29/+23
|\ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | confirms is too lax)
| * \ \ \ \ \ merge bug23684 into defaultMatthias Radestock2011-01-136-208/+210
| |\ \ \ \ \ \
| * | | | | | | remove redundant clauseMatthias Radestock2011-01-131-2/+0
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | confirm/3 is now only ever called once confirm mode has been enabled, and since we can't turn that mode off there is no point in checking.
| * | | | | | | generalise optimisationMatthias Radestock2011-01-131-6/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | there is never any point in trying to send a multi-ack when there is just one message to confirm
| * | | | | | | bug fix: don't send confirms when MsgSeqNo == undefinedMatthias Radestock2011-01-131-7/+13
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | also optimise unrouted message handling further - there is no point in going through all the logic of determining whether we can send a multi-ack since we know the MsgSeqNo will be the highest unconfirmed and it's just a single message we are confirming.
| * | | | | | | cosmeticMatthias Radestock2011-01-131-13/+10
| | | | | | | |
| * | | | | | | inline a functionAlexandru Scvortov2011-01-131-11/+3
| | | | | | | |
| * | | | | | | optimise confirms for unroutable messages; don't do any unnecessary set/dict ↵Alexandru Scvortov2011-01-131-12/+13
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | operations
* | | | | | | | merge from defaultAlexandru Scvortov2011-01-139-261/+275
|\ \ \ \ \ \ \ \ | | |/ / / / / / | |/| | | | | |
| * | | | | | | Backed out changeset b6d2a6e12e77Matthias Radestock2011-01-131-0/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Turns out this change is only valid on the bug23684 branch
| * | | | | | | remove redundant clauseMatthias Radestock2011-01-131-2/+0
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | confirm/3 is only ever called once confirm mode has been enabled, and since we can't turn that mode off there is no point in checking
| * | | | | | | tiny refactor: use dict:fetch instead of dict:findMatthias Radestock2011-01-131-2/+2
| | | | | | | |
| * | | | | | | Merging bug23643 into defaultMatthew Sackman2011-01-121-21/+31
| |\ \ \ \ \ \ \ | | |/ / / / / /
| | * | | | | | Merging bug23668 into defaultMatthew Sackman2011-01-121-21/+31
| | |\ \ \ \ \ \
| | | * | | | | | Refactoring and ensure that we don't issue confirms for messages that have ↵Matthew Sackman2011-01-121-24/+23
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | been masked from going to disk
| | | * | | | | | msg_store confirms messages that are written to disk, removed and then revivedAlexandru Scvortov2011-01-121-11/+22
| | | | | | | | |
| * | | | | | | | Eliminate unnecessary put/2, and cosmeticMatthew Sackman2011-01-121-5/+4
| | | | | | | | |
| * | | | | | | | typoMatthew Sackman2011-01-121-1/+1
| | | | | | | | |
| * | | | | | | | merge default into bug23643Matthias Radestock2011-01-1229-759/+1269
| |\ \ \ \ \ \ \ \ | | |/ / / / / / / | | | | / / / / / | | |_|/ / / / / | |/| | | | | |
| | * | | | | | merge headsMatthias Radestock2011-01-121-16/+16
| | |\ \ \ \ \ \
| | | * | | | | | cosmetic: fix indentationMatthias Radestock2011-01-121-16/+16
| | | | | | | | |
| | * | | | | | | Mandatory delivery only needs to know that it got to the queue. Not the ↵Matthew Sackman2011-01-121-4/+5
| | |/ / / / / / | | | | | | | | | | | | | | | | | | | | | | | | result of delivery
| | * | | | | | Prioritise both sync and async versions the sameMatthew Sackman2011-01-121-12/+13
| | |/ / / / /
| * | | | | | refactor: extract function to handle frame and pass to channelMatthias Radestock2011-01-061-23/+24
| | | | | | |
| * | | | | | cosmeticMatthias Radestock2011-01-061-7/+7
| | | | | | |
| * | | | | | cosmeticMatthias Radestock2011-01-031-2/+2
| | | | | | |
| * | | | | | better error handlingMatthias Radestock2011-01-031-5/+8
| | | | | | |
| * | | | | | add specs and move frame analysis from reader to command assemblerMatthias Radestock2011-01-032-22/+57
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The latter avoids a mutual dependency between the reader and command assembler.
| * | | | | | renamingMatthias Radestock2011-01-033-24/+24
| | | | | | |
| * | | | | | replace rabbit_framing_channel with tiny state machineMatthias Radestock2011-01-014-103/+66
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...which we store in the reader's process dict This simplifies the interactions between the channel and the reader. Note that the reader now monitors the channel processes rather than their sups. This makes more sense since it interacts with the former but never the latter.