summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* flesh out vq API with funs useful for testingMatthias Radestock2010-07-191-5/+16
|
* merge default into bug21673Matthias Radestock2010-07-192-2/+13
|\
| * flesh out APIs somewhatMatthias Radestock2010-07-192-2/+13
| | | | | | | | useful in tests
* | More documentationMatthew Sackman2010-07-191-0/+30
| |
* | Improve documentation and document persistent vs transient msg store are forMatthew Sackman2010-07-191-10/+18
| |
* | refactor: simplify msg_store testsMatthias Radestock2010-07-191-19/+15
| |
* | refactor: simplify msg_store testsMatthias Radestock2010-07-191-14/+19
| |
* | refactor: simplify msg_store testsMatthias Radestock2010-07-191-12/+9
| |
* | tweakMatthias Radestock2010-07-191-3/+3
| |
* | refactor: take adantage of l/r symmetry in bpqueue testsMatthias Radestock2010-07-191-63/+43
| |
* | dict:find -> dict:fetch andalso lists:flatten -> lists:appendMatthew Sackman2010-07-191-8/+8
| |
* | Merging bug 22987 into bug 21673Matthew Sackman2010-07-191-29/+55
|\ \
| * | CosmeticsMatthew Sackman2010-07-191-13/+13
| | |
| * | optimise qi:sync call in tx commitMatthias Radestock2010-07-191-29/+55
|/ / | | | | | | call it with acks for persistent & durable messages only
* | refactor: 'cons_if' helper functionMatthias Radestock2010-07-191-20/+9
| |
* | merge default into bug21673Matthias Radestock2010-07-191-1/+1
|\ \ | |/
| * tweak to assist testingMatthias Radestock2010-07-191-1/+1
| | | | | | | | | | ...outside the context of the rabbit app cherry-picked from bug 21673.
| * 'sync' -> 'idle_timeout'Matthias Radestock2010-07-194-17/+18
| | | | | | | | cherry-picked from bug 21673.
| * Merged bug22140 into default.Simon MacMullen2010-07-161-1/+1
| |\
| | * replaced call bad:bad/0 with a call to exit/1Alexandru Scvortov2010-07-131-1/+1
| | |
* | | cosmeticMatthias Radestock2010-07-191-0/+1
| | |
* | | tweak msg_store API to make it saferMatthias Radestock2010-07-183-10/+12
| | | | | | | | | | | | ...by not allowing clients to be deleted w/o terminating them too
* | | tiny refactorMatthias Radestock2010-07-181-7/+6
| | |
* | | add a 'todo'Matthias Radestock2010-07-181-0/+5
| | |
* | | don't log warnings on clean startup of a msg_storeMatthias Radestock2010-07-183-25/+18
| | |
* | | don't forget to process transactional acksMatthias Radestock2010-07-161-2/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...when the tx doesn't involve any persistent messages, thus plugging a leak in pending_ack and qi. To reproduce: rr(amqp_connection). Conn = amqp_connection:start_network(), Ch = amqp_connection:open_channel(Conn), Q = <<"Q">>, amqp_channel:call(Ch, #'queue.declare'{queue = Q, durable = true, exclusive = true}), amqp_channel:call(Ch, #'basic.publish'{routing_key = Q}, #amqp_msg{}), amqp_channel:call(Ch, #'basic.get'{queue = Q}), amqp_channel:call(Ch, #'tx.select'{}), amqp_channel:call(Ch, #'basic.ack'{delivery_tag = 1}), amqp_channel:call(Ch, #'tx.commit'{}), ok. and then $ ./scripts/rabbitmqctl list_queues name messages_unacknowledged backing_queue_status Listing queues ... Q 0 [{q1,0},{q2,0},{delta,{delta,undefined,0,undefined}},{q3,0},{q4,0},{len,0},{pending_acks,1},{outstanding_txns,0},{target_ram_msg_count,infinity},{ram_msg_count,0},{ram_index_count,0},{avg_egress_rate,0.0},{avg_ingress_rate,0.0},{next_seq_id,1},{persistent_count,0}] ...done. Note the pending_acks of 1.
* | | add pending_acks to bq state reportMatthias Radestock2010-07-161-0/+2
| | | | | | | | | | | | it turns out to be useful
* | | refactor: invert some conditionals for better readabilityMatthias Radestock2010-07-161-22/+18
| | |
* | | refactor: trim args for msg_store_callbackMatthias Radestock2010-07-161-4/+3
| | | | | | | | | | | | we only ever need a msg_store_callback when we have persisted pubs
* | | another place were averages could end up being integers instead of floatsMatthias Radestock2010-07-151-3/+2
| | |
* | | rate averages are meant to be floatsMatthias Radestock2010-07-151-2/+2
| | |
* | | avoid >= between a number and an atomMatthias Radestock2010-07-151-1/+2
| | |
* | | improve type specsMatthias Radestock2010-07-151-5/+4
| | |
* | | cosmeticMatthias Radestock2010-07-151-5/+5
| | |
* | | merge default into bug21673Matthias Radestock2010-07-1512-81/+193
|\ \ \ | |/ /
| * | Merged headsEmile Joubert2010-07-142-0/+9
| |\ \
| | * | Changelog updates for release 1.8.1Emile Joubert2010-07-142-0/+9
| | | |
| | * | Added tag rabbitmq_v1_8_1 for changeset 5d9e3ff32dcbEmile Joubert2010-07-140-0/+0
| | | |
| * | | Merge bug22875 into defaultSimon MacMullen2010-07-142-5/+12
| |\ \ \ | | |/ / | |/| |
| | * | >80 lines fix.Simon MacMullen2010-07-141-1/+2
| | | |
| | * | added insightful commentAlexandru Scvortov2010-07-141-1/+1
| | | |
| | * | updated man pageAlexandru Scvortov2010-07-131-4/+6
| | | |
| | * | empty permissions are not printed as "" anymoreAlexandru Scvortov2010-07-131-2/+0
| | | |
| | * | "" is changed to "^$" when checking permissionsAlexandru Scvortov2010-07-131-9/+9
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | % rabbitmqctl set_permissions guest "" "" "" Setting permissions for user "guest" in vhost "/" ... ...done. % rabbitmqctl list_permissions Listing permissions in vhost "/" ... guest "" "" "" ...done.
| | * | empty strings are displayed as ""Alexandru Scvortov2010-07-131-0/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | % rabbitmqctl list_permissions Listing permissions in vhost "/" ... guest "" "" "" ...done.
| | * | corrected regexpAlexandru Scvortov2010-07-131-1/+1
| | | | | | | | | | | | | | | | | | | | Used character escaping because erlang-mode has problems correctly parsing "^$".
| | * | simplifying refactorMatthias Radestock2010-07-131-9/+8
| | | |
| | * | "" is transformed to "$^" in rabbitmqctl set_permissionsAlexandru Scvortov2010-07-121-1/+6
| | |/
| * | bug22914 merged into defaultrabbitmq_v1_8_1Marek Majkowski2010-07-142-2/+11
| |\ \ | | |/ | |/|
| | * Remove IFS setting on the su commandDavid Wragg2010-07-131-10/+8
| | | | | | | | | | | | | | | | | | | | | | | | | | | The script has lots of IFS vulnerabilities before it reaches the su command. If we really want to guard against IFS, we should set it at the top. But how many shell scripts have you ever seen that do that? If the user sets IFS, and breaks things, it seem reasonable to regard that as their problem. There is no security issue here because you should already be root or the rabbitmq user to run the script.