summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* don't include TimeoutState in status formattingMatthias Radestock2009-07-241-10/+3
| | | | | ordinary timeouts are not shown as part of the status, so it doesn't make sense to show the special ones. Also, the code was incorrect.
* remove R13B-1ismMatthias Radestock2009-07-241-4/+0
|
* *idiot*.Matthew Sackman2009-07-091-12/+11
|
* a) reverted the change to do_send which had come in when I updated ↵Matthew Sackman2009-07-061-7/+8
| | | | | | gen_server2 to R13B1 - this was a change originally made by matthias to ensure that messages cast to remote nodes are done so in order b) Add guards and slightly relax name/1 so that it works in R11B5. All tests pass in R11B5 and manual testing of the binary backoff hibernation shows that too works.
* All cosmetic (line length)Matthew Sackman2009-07-061-28/+49
|
* Pushed the binary exponential timeout / hibernate system into gen_server2. ↵Matthew Sackman2009-07-062-92/+117
| | | | Adjusted amqqueue_process to use it. Added documentation. Tested thoroughly with explicit test module (not added), and full test suite, which all passed. Existing tests further up in this bug similarly pass and demonstrate code is functioning correctly.
* updating gen_server2 with latest from R13B01 in order to ensure this doesn't ↵Matthew Sackman2009-07-063-28/+71
| | | | slip badly behind the shipped version.
* Done. In order to keep the code simple, the detection of naptime is done in ↵Matthew Sackman2009-07-021-6/+45
| | | | | | | | | | | | | | | | | | | reply and noreply functions. This means that the now() value there includes computation relating to the last message in. This is maybe not desirable, but the alternative is to wrap all of handle_cast, handle_call and handle_info. Nevertheless, testing shows this works: in the erlang client: Conn = amqp_connection:start("guest", "guest", "localhost"), Chan = lib_amqp:start_channel(Conn), [begin Q = list_to_binary(integer_to_list(R)), Q = lib_amqp:declare_queue(Chan, Q) end || R <- lists:seq(1,1000)], Props = (amqp_util:basic_properties()). [begin Q = list_to_binary(integer_to_list(R)), ok = lib_amqp:publish(Chan, <<"">>, Q, <<0:(8*1024)>>, Props) end || _ <- lists:seq(1,1500), R <- lists:seq(1,1000)]. Then, after that lot's gone in, in a shell do: watch -n 2 "time ./scripts/rabbitmqctl list_queues | tail" The times for me start off at about 2.3 seconds, then drop rapidly to 1.4 and then 0.2 seconds and stay there.
* merge bug21060 into defaultMatthias Radestock2009-07-012-13/+54
|\
| * better exception tagMatthias Radestock2009-07-011-1/+1
| |
| * fix another off-by-one errorMatthias Radestock2009-07-011-1/+1
| |
| * foldMatthias Radestock2009-07-011-9/+6
| |
| * Fix off-by-one error (discovered by Matthias)Tony Garnock-Jones2009-07-011-1/+1
| |
| * cosmeticMatthias Radestock2009-07-011-23/+19
| |
| * Convenience rabbit_basic functions.Tony Garnock-Jones2009-06-222-11/+59
|/
* Updated portfile for 1.6.0 releaseTim Clark2009-06-181-4/+4
|
* tabs -> spacesMatthias Radestock2009-06-186-25/+25
|
* TMPDIR should be honoured by MakefileMatthew Sackman2009-06-181-2/+6
|
* Added tag rabbitmq_v1_6_0 for changeset 1588df06f913Matthias Radestock2009-06-160-0/+0
|
* add package changelog entries for 1.6.0 releaserabbitmq_v1_6_0Matthias Radestock2009-06-162-0/+9
|
* merge bug20961 into defaultMatthias Radestock2009-06-161-8/+8
|\
| * Fixing up escaping of commandline argumentsTim Clark2009-06-141-11/+1
| |
| * Attempt to fix regexp in PortfileTim Clark2009-06-121-4/+4
| |
| * Changes to version and checksumsTim Clark2009-06-121-4/+4
| |
* | emergency merge of bug20958 into defaultMatthias Radestock2009-06-161-11/+1
|\ \ | | | | | | | | | further qa is still required
| * | FIx for escaping of argumentsTim Clark2009-06-141-11/+1
| | |
* | | merge bug20979 into defaultMatthias Radestock2009-06-162-2/+2
|\ \ \
| * | | cleandb is now an rm -rf and build depends not on mnesiaMatthew Sackman2009-06-122-2/+2
| | |/ | |/|
* | | merge bug20976 into defaultMatthias Radestock2009-06-162-2/+4
|\ \ \ | |/ / |/| |
| * | Altered dependencies and added comment to the appMatthew Sackman2009-06-122-2/+4
|/ /
* | merging in bug20943Matthew Sackman2009-06-111-129/+120
|\ \
| * | refactoring: rename "round robin" to "active consumers"Matthias Radestock2009-06-101-27/+31
| | |
| * | proper round-robining even when blockingMatthias Radestock2009-06-101-124/+111
|/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This involved some substantial changes to the queue internal data structures - mostly by choice; the new design is cleaner: - We no longer keep a list of consumers in the channel records. Now the channel records just contain a consumer count instead, and that's only there for efficiency so we can more easily tell when we need to register/unregister with the limiter. - We now keep *two* consumer queues - one of active consumers (that's the one we've always had) and one of blocked consumers. We round-robin on the first one as before, and move things between the two queues when blocking/unblocking channels. When doing so the relative order of a channel's consumers is preserved, so the effects of any round-robining the active consumers get carried through to the blocked consumers when they get blocked and then back to the active consumers when they get unblocked.
* | emergency merge of bug20958 into defaultMatthias Radestock2009-06-102-2/+2
|\ \ | |/ | | | | | | | | We point to the macports files of the default branch from our web site and they got broken with the merge of bug20333. This hopefully fixes that, but further qa is required.
| * Removed default shell, changed wrapper to work without default shelltimc@afallen.home2009-06-102-2/+2
| |
| * Creates rabbitmq user with a default shell and uses correct arguments to the ↵timc@afallen.home2009-06-102-3/+3
| | | | | | | | os x su command
* | merge in bug20955Matthew Sackman2009-06-101-4/+11
|\ \
| * | respect channel blocking when adding consumersMatthias Radestock2009-06-101-4/+11
|/ /
* | Merge bug20801 into defaultHubert Plociniczak2009-06-102-5/+3
|\ \
| * | Use dist macro for building correct distribution versions.Hubert Plociniczak2009-06-102-5/+3
| |/
* | Merge two default branches into one.Hubert Plociniczak2009-06-103-23/+50
|\ \ | |/
| * Merge from bug20333 post verificationtimc@afallen.home2009-06-103-23/+50
| |\
| | * remove/add files missed on previous commitMatthias Radestock2009-04-062-2/+23
| | |
| | * use wrapper scripts in macportsMatthias Radestock2009-04-061-21/+27
| | |
* | | fix off-by-one errorMatthias Radestock2009-06-101-1/+1
| | | | | | | | | | | | not that it really matters much
* | | cosmeticMatthias Radestock2009-06-101-7/+9
|/ /
* | merge bug20940 into defaultMatthias Radestock2009-06-102-9/+12
|\ \
| * | cosmeticMatthias Radestock2009-06-101-6/+7
| | |
| * | Made can_send/2 into can_send/3.Matthew Sackman2009-06-092-9/+11
|/ /
* | merging in bug20782Matthew Sackman2009-06-088-81/+103
|\ \
View Lorry Controller Status