summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Added tag rabbitmq_v1_5_1 for changeset 2e6e4090d44bBen Hood2009-01-190-0/+0
|
* Merged 19749 into defaultBen Hood2009-01-192-25/+25
|\
| * change a gen_server:call to a gen_server2:callMatthias Radestock2009-01-161-1/+1
| | | | | | | | for consistency with gen_server2:cast
| * merge default into bug19749Matthias Radestock2009-01-1618-231/+604
| |\
| * \ merge bug19759 into bug19749Matthias Radestock2009-01-084-23/+880
| |\ \ | | | | | | | | | | | | The former was the wrong bug number.
| | * | replace all cross-node gen_server:casts with gen_server2:castsMatthias Radestock2009-01-082-21/+21
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The latter is order-preserving, whereas the former isn't. Rather than just replacing the casts, I replaced all uses of gen_server with gen_server2 in the affected modules. That way we don't mix modules when talking to a given process.
| | * | merge bug20088 into bug19749Matthias Radestock2009-01-082-2/+859
| | |\ \ | |/ / /
* | | | Merged 20099 into defaultBen Hood2009-01-193-202/+89
|\ \ \ \
| * \ \ \ merge default into bug20099Matthias Radestock2009-01-1618-233/+603
| |\ \ \ \ | | | |_|/ | | |/| | | | | | | | | | | | | | | | | which involved a few conflict resolutions. The most complex of these was dealing with the termination of the limiter; we now unlink from it first so we don't get a spurious EXIT signal.
| * | | | fix bug in handling of writer exitMatthias Radestock2009-01-141-1/+1
| | | | |
| * | | | make the channel process hibernate after 1s of idlenessMatthias Radestock2009-01-141-7/+16
| | | | | | | | | | | | | | | | | | | | to conserve resources
| * | | | get rid of now-superfluous proxy_pid in channel stateMatthias Radestock2009-01-091-26/+18
| | | | |
| * | | | get rid of buffering_proxyMatthias Radestock2009-01-092-110/+1
| | | | |
| * | | | fix normal termination caseMatthias Radestock2009-01-091-5/+4
| | | | |
| * | | | first cut of turning rabbit_channel into a gen_server2Matthias Radestock2009-01-091-60/+59
| | | | |
| * | | | merge bug20088 into bug20099Matthias Radestock2009-01-092-2/+859
| |\ \ \ \ | | |_|/ / | |/| | / | | | |/ | | |/|
* | | | better documentation of message countsMatthias Radestock2009-01-181-7/+5
| | | |
* | | | cosmetic: correct indentationMatthias Radestock2009-01-181-2/+2
| |_|/ |/| |
* | | Merged 20071 into defaultBen Hood2009-01-161-5/+5
|\ \ \
| * | | turn queue processes into custom gen_serversMatthias Radestock2009-01-081-5/+5
| | | | | | | | | | | | | | | | to avoid long message queues that impact the performance of selective receive
| * | | merge bug20088 into bug20071Matthias Radestock2009-01-082-2/+859
| |\ \ \ | | |/ / | |/| / | | |/
* | | Merged 18557 into defaultBen Hood2009-01-164-89/+390
|\ \ \
| * | | add some commentsMatthias Radestock2009-01-152-2/+6
| | | |
| * | | Merged default into 18557Ben Hood2009-01-1521-163/+1021
| |\ \ \
| * | | | tidying up, refactoring and some cosmetic changesMatthias Radestock2008-12-264-61/+38
| | | | |
| * | | | cosmetic: rename 'in_use' to 'volume'Matthias Radestock2008-12-251-10/+10
| | | | |
| * | | | optimisation: only notify queues that have had can_send requests rejectedMatthias Radestock2008-12-251-18/+22
| | | | |
| * | | | destroy limiter when a channel becomes unlimitedMatthias Radestock2008-12-243-22/+38
| | | | | | | | | | | | | | | | | | | | which results in far more efficient handling of subsequent deliveries
| * | | | merge branch headsMatthias Radestock2008-12-240-0/+0
| |\ \ \ \
| | * | | | Remove unnecessary method name from protocol_errorTony Garnock-Jones2008-08-061-2/+1
| | | | | |
| | * | | | Special-case global=true: we don't implement itTony Garnock-Jones2008-08-061-0/+6
| | | | | |
| * | | | | don't leave the limiter behind when the channel terminatesMatthias Radestock2008-12-232-2/+13
| | | | | |
| * | | | | add type spec for start_linkMatthias Radestock2008-12-231-0/+1
| | | | | |
| * | | | | handle the "no limiter" case more obviouslyMatthias Radestock2008-12-231-10/+8
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is no semantic change since gen_server:cast(undefined, ...) returns 'ok'. However, it only does so because it catches the 'badarg' error thrown by erlang:send. It is probably more efficient to not attempt the send in the first place. Plus for documentation purposes, and to keep dialyzer happy, it is useful to state explicitly which functions are expected to be called on an 'undefined' limiter.
| * | | | | cosmeticMatthias Radestock2008-12-231-20/+20
| | | | | |
| * | | | | deal with limiting after consumer subscriptionMatthias Radestock2008-12-233-19/+43
| | | | | |
| * | | | | create limiter lazilyMatthias Radestock2008-12-232-5/+22
| | | | | | | | | | | | | | | | | | | | | | | | This makes an 'unlimited' channel as efficient as it used to be
| * | | | | make limiter keep track of all queues with subscriptionsMatthias Radestock2008-12-232-18/+52
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is more efficient since it avoids the repeated (de)monitoring and updates to the limiter state.
| * | | | | merge default into bug18557Matthias Radestock2008-12-231-0/+2
| |\ \ \ \ \
| * | | | | | cosmeticMatthias Radestock2008-12-232-12/+12
| | | | | | |
| * | | | | | merge default into bug18557Matthias Radestock2008-12-234-17/+37
| |\ \ \ \ \ \
| * | | | | | | ensure fairnessMatthias Radestock2008-12-231-4/+13
| | | | | | | |
| * | | | | | | saner state transition handlingMatthias Radestock2008-12-191-52/+39
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and assorted bug fixes
| * | | | | | | fix bug: make sure consumers blocked due to limit are dropped from StateMatthias Radestock2008-12-191-5/+5
| | | | | | | |
| * | | | | | | handle transactional acksMatthias Radestock2008-12-191-18/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | also: - simplify and optimise non-basic-get ack counting - don't talk to the limiter when there is nothing to tell, i.e. the non-basic-get ack count is zero
| * | | | | | | minor simplificationsMatthias Radestock2008-12-181-6/+4
| | | | | | | |
| * | | | | | | oopsMatthias Radestock2008-12-181-1/+1
| | | | | | | |
| * | | | | | | refactoringMatthias Radestock2008-12-181-18/+14
| | | | | | | |
| * | | | | | | tidy some more commentsMatthias Radestock2008-12-181-3/+3
| | | | | | | |
| * | | | | | | tidy commentsMatthias Radestock2008-12-181-11/+10
| | | | | | | |