| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Added tag rabbitmq_v1_5_1 for changeset 2e6e4090d44b | Ben Hood | 2009-01-19 | 0 | -0/+0 |
| | | |||||
| * | Merged 19749 into default | Ben Hood | 2009-01-19 | 2 | -25/+25 |
| |\ | |||||
| | * | change a gen_server:call to a gen_server2:call | Matthias Radestock | 2009-01-16 | 1 | -1/+1 |
| | | | | | | | | | for consistency with gen_server2:cast | ||||
| | * | merge default into bug19749 | Matthias Radestock | 2009-01-16 | 18 | -231/+604 |
| | |\ | |||||
| | * \ | merge bug19759 into bug19749 | Matthias Radestock | 2009-01-08 | 4 | -23/+880 |
| | |\ \ | | | | | | | | | | | | | The former was the wrong bug number. | ||||
| | | * | | replace all cross-node gen_server:casts with gen_server2:casts | Matthias Radestock | 2009-01-08 | 2 | -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 bug19749 | Matthias Radestock | 2009-01-08 | 2 | -2/+859 |
| | | |\ \ | |/ / / | |||||
| * | | | | Merged 20099 into default | Ben Hood | 2009-01-19 | 3 | -202/+89 |
| |\ \ \ \ | |||||
| | * \ \ \ | merge default into bug20099 | Matthias Radestock | 2009-01-16 | 18 | -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 exit | Matthias Radestock | 2009-01-14 | 1 | -1/+1 |
| | | | | | | |||||
| | * | | | | make the channel process hibernate after 1s of idleness | Matthias Radestock | 2009-01-14 | 1 | -7/+16 |
| | | | | | | | | | | | | | | | | | | | | | to conserve resources | ||||
| | * | | | | get rid of now-superfluous proxy_pid in channel state | Matthias Radestock | 2009-01-09 | 1 | -26/+18 |
| | | | | | | |||||
| | * | | | | get rid of buffering_proxy | Matthias Radestock | 2009-01-09 | 2 | -110/+1 |
| | | | | | | |||||
| | * | | | | fix normal termination case | Matthias Radestock | 2009-01-09 | 1 | -5/+4 |
| | | | | | | |||||
| | * | | | | first cut of turning rabbit_channel into a gen_server2 | Matthias Radestock | 2009-01-09 | 1 | -60/+59 |
| | | | | | | |||||
| | * | | | | merge bug20088 into bug20099 | Matthias Radestock | 2009-01-09 | 2 | -2/+859 |
| | |\ \ \ \ | | |_|/ / | |/| | / | | | |/ | | |/| | |||||
| * | | | | better documentation of message counts | Matthias Radestock | 2009-01-18 | 1 | -7/+5 |
| | | | | | |||||
| * | | | | cosmetic: correct indentation | Matthias Radestock | 2009-01-18 | 1 | -2/+2 |
| | |_|/ |/| | | |||||
| * | | | Merged 20071 into default | Ben Hood | 2009-01-16 | 1 | -5/+5 |
| |\ \ \ | |||||
| | * | | | turn queue processes into custom gen_servers | Matthias Radestock | 2009-01-08 | 1 | -5/+5 |
| | | | | | | | | | | | | | | | | | to avoid long message queues that impact the performance of selective receive | ||||
| | * | | | merge bug20088 into bug20071 | Matthias Radestock | 2009-01-08 | 2 | -2/+859 |
| | |\ \ \ | | |/ / | |/| / | | |/ | |||||
| * | | | Merged 18557 into default | Ben Hood | 2009-01-16 | 4 | -89/+390 |
| |\ \ \ | |||||
| | * | | | add some comments | Matthias Radestock | 2009-01-15 | 2 | -2/+6 |
| | | | | | |||||
| | * | | | Merged default into 18557 | Ben Hood | 2009-01-15 | 21 | -163/+1021 |
| | |\ \ \ | |||||
| | * | | | | tidying up, refactoring and some cosmetic changes | Matthias Radestock | 2008-12-26 | 4 | -61/+38 |
| | | | | | | |||||
| | * | | | | cosmetic: rename 'in_use' to 'volume' | Matthias Radestock | 2008-12-25 | 1 | -10/+10 |
| | | | | | | |||||
| | * | | | | optimisation: only notify queues that have had can_send requests rejected | Matthias Radestock | 2008-12-25 | 1 | -18/+22 |
| | | | | | | |||||
| | * | | | | destroy limiter when a channel becomes unlimited | Matthias Radestock | 2008-12-24 | 3 | -22/+38 |
| | | | | | | | | | | | | | | | | | | | | | which results in far more efficient handling of subsequent deliveries | ||||
| | * | | | | merge branch heads | Matthias Radestock | 2008-12-24 | 0 | -0/+0 |
| | |\ \ \ \ | |||||
| | | * | | | | Remove unnecessary method name from protocol_error | Tony Garnock-Jones | 2008-08-06 | 1 | -2/+1 |
| | | | | | | | |||||
| | | * | | | | Special-case global=true: we don't implement it | Tony Garnock-Jones | 2008-08-06 | 1 | -0/+6 |
| | | | | | | | |||||
| | * | | | | | don't leave the limiter behind when the channel terminates | Matthias Radestock | 2008-12-23 | 2 | -2/+13 |
| | | | | | | | |||||
| | * | | | | | add type spec for start_link | Matthias Radestock | 2008-12-23 | 1 | -0/+1 |
| | | | | | | | |||||
| | * | | | | | handle the "no limiter" case more obviously | Matthias Radestock | 2008-12-23 | 1 | -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. | ||||
| | * | | | | | cosmetic | Matthias Radestock | 2008-12-23 | 1 | -20/+20 |
| | | | | | | | |||||
| | * | | | | | deal with limiting after consumer subscription | Matthias Radestock | 2008-12-23 | 3 | -19/+43 |
| | | | | | | | |||||
| | * | | | | | create limiter lazily | Matthias Radestock | 2008-12-23 | 2 | -5/+22 |
| | | | | | | | | | | | | | | | | | | | | | | | | | This makes an 'unlimited' channel as efficient as it used to be | ||||
| | * | | | | | make limiter keep track of all queues with subscriptions | Matthias Radestock | 2008-12-23 | 2 | -18/+52 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This is more efficient since it avoids the repeated (de)monitoring and updates to the limiter state. | ||||
| | * | | | | | merge default into bug18557 | Matthias Radestock | 2008-12-23 | 1 | -0/+2 |
| | |\ \ \ \ \ | |||||
| | * | | | | | | cosmetic | Matthias Radestock | 2008-12-23 | 2 | -12/+12 |
| | | | | | | | | |||||
| | * | | | | | | merge default into bug18557 | Matthias Radestock | 2008-12-23 | 4 | -17/+37 |
| | |\ \ \ \ \ \ | |||||
| | * | | | | | | | ensure fairness | Matthias Radestock | 2008-12-23 | 1 | -4/+13 |
| | | | | | | | | | |||||
| | * | | | | | | | saner state transition handling | Matthias Radestock | 2008-12-19 | 1 | -52/+39 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and assorted bug fixes | ||||
| | * | | | | | | | fix bug: make sure consumers blocked due to limit are dropped from State | Matthias Radestock | 2008-12-19 | 1 | -5/+5 |
| | | | | | | | | | |||||
| | * | | | | | | | handle transactional acks | Matthias Radestock | 2008-12-19 | 1 | -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 simplifications | Matthias Radestock | 2008-12-18 | 1 | -6/+4 |
| | | | | | | | | | |||||
| | * | | | | | | | oops | Matthias Radestock | 2008-12-18 | 1 | -1/+1 |
| | | | | | | | | | |||||
| | * | | | | | | | refactoring | Matthias Radestock | 2008-12-18 | 1 | -18/+14 |
| | | | | | | | | | |||||
| | * | | | | | | | tidy some more comments | Matthias Radestock | 2008-12-18 | 1 | -3/+3 |
| | | | | | | | | | |||||
| | * | | | | | | | tidy comments | Matthias Radestock | 2008-12-18 | 1 | -11/+10 |
| | | | | | | | | | |||||
