Mercurialrabbitmq-server / summary
summary | shortlog | changelog | tags | files | bz2 | zip | gz
 
descriptionRabbitMQ AMQP Server
ownertonyg@lshift.net
last changeFri, 03 Jul 2009 17:43:52 +0100
changes
13 hours agoMatthew SackmanReworked. Because the disk->mixed transition doesn't eat up any ram, there is no need for the emergency tokens, nor any need for the weird doubling. So it's basically got much simpler. bug20980 tip changeset | files
20 hours agoMatthew Sackmanreport memory: bug20980 changeset | files
37 hours agoMatthew Sackmanwip, dnc. bug20980 changeset | files
37 hours agoMatthew Sackmancosmetic bug20980 changeset | files
37 hours agoMatthew Sackmanwell if we're going to not actually pull messages off disk when going to mixed mode, we may as well do it really lazily and not bother with any communication with the disk_queue. We just have a token in the queue which indicates how many messages we are expecting to get from the disk queue. This makes disk -> mixed almost instantaneous. This also means that performance is not initially brilliant. Maybe we need some way of the queue knowing that both it and the disk_queue are idle and deciding to prefetch. Even batching could work well. It's an endless trade off between getting operations to happen quickly and being able to get good performance. Dunno what the third thing is, probably not necessary, as you can't even have both of those, let alone pick 2 from 3! bug20980 changeset | files
38 hours agoMatthew SackmanSorted out the timer versus hibernate binary backoff. The trick is to use apply_after, not apply interval, and then after reporting memory use, don't set a new timer going (but do set a new timer going on every other message (other than timeouts)). This means that if nothing is going on, after a memory report, the process can wait as long as it needs to before the hibernate timeout fires. bug20980 changeset | files
39 hours agoMatthew Sackmanmerge in from 21087. Behaviour is now broken because the timeout can get > 10seconds which means the memory_report timer will always fire and reset the timeout - thus the queue process will never hibernate. bug20980 changeset | files
40 hours agoMatthew SackmanDone. In order to keep the code simple, the detection of naptime is done in 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: bug21087 changeset | files
2 days agoMatthew SackmanWhen converting to disk mode, use tx_publish and tx_commit instead of publish. This massively reduces the number of sync calls to disk_queue, potentially to one, if every message in the queue is non persistent (or the queue is non durable). bug20980 changeset | files
2 days agoMatthew SackmanWell after all that pain, simply doing the disk queue tests first seems to solve the problems. I don't quite buy this though, as all I was doing was stopping and starting the app so I don't understand why this was affecting the clustering configuration or causing issues _much_ further down the test line. But still, it seems to be repeatedly passing for me atm. bug20980 changeset | files
2 days agoMatthias Radestockmerge bug21060 into default default changeset | files
2 days agoMatthias Radestockbetter exception tag bug21060 changeset | files
2 days agoMatthias Radestockfix another off-by-one error bug21060 changeset | files
2 days agoMatthias Radestockfold bug21060 changeset | files
2 days agoTony Garnock-JonesFix off-by-one error (discovered by Matthias) bug21060 changeset | files
2 days agoMatthias Radestockcosmetic bug21060 changeset | files
3 days agoMatthew Sackmanmerge, but it still doesn't work. Sometimes it blows up on clustering with "All replicas on diskfull nodes are not active yet". bug20980 changeset | files
3 days agoMatthew SackmanWell, this seems to work. bug19662 changeset | files
3 days agoMatthew Sackmanand now clustering seems to work again... bug19662 changeset | files
3 days agoMatthew Sackmanchanged disk -> mixed mode so that messages stay on disk and don't get read. This means the conversion is much faster than it was which is a good thing, at the cost of slower initial delivery. bug20980 changeset | files
3 days agoMatthew Sackmanjust adding timing to the dump test bug20980 changeset | files
12 days agoEssien Ita Essientimeout() is now built in. Redefinition is deprecated bug19356 changeset | files
12 days agoEssien Ita EssienMerge with upstream bug19356 changeset | files
7 weeks agoEssien Ita EssienMerge with upstream bug19356 changeset | files
3 days agoMatthew Sackmandoh! bug20980 changeset | files
4 days agoMatthew Sackmanmmmm. It maybe sort of works. Needs work though bug20980 changeset | files
7 days agoMatthew Sackmanmerging in from 20470 bug20980 changeset | files
7 days agoMatthew SackmanHad been thinking about this optimisation for a while but someone mentioned it to me yesterday at the Erlang Factory conference. bug20470 changeset | files
9 days agoTony Garnock-JonesMerge default into amqp_0_9_1 amqp_0_9_1 changeset | files
9 days agoMatthew Sackmansome more scaffolding for tokens bug20980 changeset | files
9 days agoMatthew SackmanChanged reports so that we get bytes gained and lost since the last report. bug20980 changeset | files
9 days agoMatthew Sackmanmemory size tracking was wrong on startup in disk mode for mixed_queue (and actually for mixed mode too, given that mixed mode starts up in disk mode, then converts, which maintains the same size). bug20980 changeset | files
9 days agoMatthew Sackmanmerging in from 19662 bug20980 changeset | files
9 days agoMatthew SackmanRemoved the dumb timer:sleep, and after testing, properly sorted out the mnesia clustering details. This means that wait_for_tables now waits for _all_ tables which means the bug that was requiring the timer:sleep has gone away. bug19662 changeset | files
10 days agoMatthew Sackmanmerging in fix from 20470 bug20980 changeset | files
10 days agoMatthew SackmanFailed to either watch the logs or remember that the timer is cancelled on disk_queue exit bug20470 changeset | files
10 days agoMatthew Sackmanmerging in the recent non-tx performance fix in bug20470 bug20980 changeset | files
10 days agoMatthew SackmanRight, whilst tx_commits were being coalesced, this was not done properly protect non-tx publishes from unnecessary syncs. As a result, performance, of say: bug20470 changeset | files
10 days agoMatthew Sackmanmerging in bug19662 with reduced reverses bug20980 changeset | files
10 days agoMatthew Sackmanacktags in ack or tx_commit do not need to be ordered. Messages in tx_cancel do not need to be ordered either. Hence removal of quite a lot of lists:reverse. bug19662 changeset | files
10 days agoMatthew Sackmanmerging from bug19662 bug20980 changeset | files
10 days agoMatthew Sackmanwithout this, rabbit_disk_queue seems to refuse to start up if there are messages to be recovered, due to mnesia not being running fast enough. bug19662 changeset | files
10 days agoMatthew Sackmanonly reduce memory size when messages are acked, not when they're delivered. bug20980 changeset | files
10 days agoMatthew SackmanTidying up before starting to play with tokens. bug20980 changeset | files
11 days agoMatthew Sackmanwhoops, missed off a priority pcast. bug20980 changeset | files
11 days agoMatthew SackmanAdded ability to manually set queue modes. Also altered manager so that if you are in all mixed mode, and then set one queue to disk, and then call increase_memory_footprint, you will indeed set that one queue back to mixed mode. And vice versa with mixed and decrease bug20980 changeset | files
11 days agoTim ClarkUses openssl for md5 calculation so that script is portable between unix and os x bug20911 changeset | files
11 days agoMatthew SackmanAdded a time interval so that we report at a maximum of once per second. I guess the only reason for keeping the other counter which is the min number of messages the process has received between reporting memory, is that it's much faster to decrement that counter and ceq0 than do the time calculation for every single message. bug20980 changeset | files
11 days agoMatthew SackmanSwitched to tracking memory size of the queue at all times. Removed use of process_info(memory,self()) for reasons outlined in the bug comments. The annoying thing about using a 10% change as the threshold is that it means you get many many more updates when the queue is empty because the % change is much greater. bug20980 changeset | files
11 days agoMatthew SackmanThese two fixes were done in 20980 but should really be in this branch. bug19662 changeset | files
11 days agoMatthew Sackmanannoying bug which appeared ages ago and has only just been squashed. Meant queues were being started up in the wrong mode when in the "middle" mode... bug20980 changeset | files
11 days agoTim ClarkPackages port files into tar archive bug20911 changeset | files
11 days agoTim ClarkPortfile replaced by Portfile.in, Portfile created by makefile which substitutes version and check sums bug20911 changeset | files
11 days agoMatthew Sackmanmerging in from bug19662 bug20980 changeset | files
11 days agoMatthew Sackmansubstantially bulked up the tests for this bug. All tests pass. bug19662 changeset | files
11 days agoMatthew Sackmanfixed. bug19662 changeset | files
11 days agoTony Garnock-JonesConvenience rabbit_basic functions. bug21060 changeset | files
13 days agoMatthew SackmanA test. The problem really does exist. Not worked out how to fix it yet. bug19662 changeset | files
13 days agoMatthew Sackmanfixed bug documented in preceeding comment bug19662 changeset | files
2 weeks agoMatthew SackmanQuite a horrendous merge of 19662. All tests pass. bug20980 changeset | files
2 weeks agoMatthew Sackmancomment typeo bug19662 changeset | files
2 weeks agoMatthew Sackmanget_cache_info ==> cache_info. bug19662 changeset | files
2 weeks agoMatthew SackmanJust added a means to get the ets:info out for the cache. Testing shows that it does seem to get emptied successfully. bug19662 changeset | files
2 weeks agoMatthew Sackmanfixes bug19662 changeset | files
2 weeks agoMatthew SackmanAdded caching layer using ets which, when a message is shared between multiple queues, eliminates the need for multiple reads, provided the /next/ copy of the message is requested before the previous copy of the message has been acked. Should reduce memory pressure. bug19662 changeset | files
2 weeks agoMatthew SackmanAltered API so that the disk_queue understands about #basic_message. This means that the mixed_queue avoids unnecessary term_to_binary calls. Tests adjusted and whole test suite still passes bug19662 changeset | files
2 weeks agoMatthew SackmanReworked reporting of memory requests so that the queues are proactive about deciding when to report. This isn't quite good enough though because GC means the memory size fluctuates too much. Need to switch to just grabbing the size of the messages in the queue. bug20980 changeset | files
2 weeks agoMatthew Sackmanwiring things up bug20980 changeset | files
2 weeks agoMatthew Sackmanexercise tiny area of the code to try and suggest it might be a zero-sum game. bug20980 changeset | files
2 weeks agoMatthew Sackmaninitial work making the mixed_queue keep track of some number vaguely related to memory use when it's in disk only mode which could be used to estimate how much more memory is needed to switch to mixed mode bug20980 changeset | files
2 weeks agoMatthew Sackmancosmetic bug20470 changeset | files
2 weeks agoTim ClarkUpdated portfile for 1.6.0 release changeset | files
2 weeks agoMatthias Radestocktabs -> spaces changeset | files
2 weeks agoMatthew Sackmanstop the commit timer if we're no longer dirty. This means it should no longer be a repeat timer because once it's set were either going to receive the explicit sync call or we're going to timeout on message queue at which point we're no longer dirty and so we'll then cancel the timer.... bug20470 changeset | files
2 weeks agoMatthew SackmanDone. Problem was needing to reply instantly if we're not dirty. bug20470 changeset | files
2 weeks agoMatthew Sackmanwell, I think it works, but it's now much much slower. bug20470 changeset | files
2 weeks agoMatthew Sackmanremoving two usused functions: publish_with_seq and tx_commit_with_seq bug19662 changeset | files
2 weeks agoMatthew Sackmanjust merging in identical change from default bug19662 changeset | files
2 weeks agoMatthew SackmanTMPDIR should be honoured by Makefile changeset | files
2 weeks agoMatthew Sackmanfixing up my issues with tmp dir, hopefully once and for all. TMPDIR is a standard unix variable which should be honoured bug19662 changeset | files
2 weeks agoMatthew Sackmanremoval of two unused functions from disk_queue. There are two more unused functions which I can't work out what to do about... Also cosmetic bug19662 changeset | files
2 weeks agoMatthew Sackmanpreemptive tidying bug19662 changeset | files
2 weeks agoMatthew Sackmansorted out specs. bug19662 changeset | files
2 weeks agoMatthew Sackmancomment bug19662 changeset | files
2 weeks agoMatthew SackmanFunAcc0 ==> FunAcc bug19662 changeset | files
2 weeks agoMatthew Sackmanmerging in default bug19662 changeset | files
2 weeks agoMatthew Sackmanmore renaming and mnesia change to bat file bug19662 changeset | files
2 weeks agoMatthew SackmanRenaming variables. All tests still pass bug19662 changeset | files
2 weeks agoMatthew Sackmanadded batching for autoacks for general run_message_queue bug19662 changeset | files
2 weeks agoMatthew Sackmanadjusted HO-ness in deliver queue beautifully. Thus in the deliver_from_queue case, we now reduce n calls to mixed_queue:is_empty to 1 call and pass around the remaining count as the acc. l33t bug19662 changeset | files
2 weeks agoMatthew SackmanMore tidying bug19662 changeset | files
2 weeks agoMatthew Sackmanfurther discussion bug19662 changeset | files
2 weeks agoMatthew Sackmanpost case/if discussion bug19662 changeset | files
2 weeks agoMatthew Sackmanmainly if ==> case in suitable places, but also some formatting bug19662 changeset | files
2 weeks agoMatthew Sackmantabs and line length bug19662 changeset | files
2 weeks agoMatthew Sackmanfixed line lengths bug19662 changeset | files
2 weeks agoMatthias RadestockAdded tag rabbitmq_v1_6_0 for changeset 1588df06f913 changeset | files
2 weeks agoMatthias Radestockadd package changelog entries for 1.6.0 release rabbitmq_v1_6_0 changeset | files
2 weeks agoMatthew SackmanRemoving the failed experiment that was the odbc db queue bug19662 changeset | files
2 weeks agoMatthew Sackmanjust removing tabs bug19662 changeset | files
2 weeks agoMatthias Radestockmerge bug20961 into default changeset | files
3 weeks agoEmile Joubertmerge default into bug19984 bug19984 changeset | files
2 weeks agoMatthias Radestockemergency merge of bug20958 into default changeset | files
2 weeks agoMatthias Radestockmerge bug20979 into default changeset | files
2 weeks agoMatthias Radestockmerge bug20976 into default changeset | files
2 weeks agoTim ClarkFIx for escaping of arguments bug20958 changeset | files
2 weeks agoTim ClarkFixing up escaping of commandline arguments bug20961 changeset | files
2 weeks agoVlad Ionescumerging bug19911 into junk junk changeset | files
2 weeks agoVlad Ionescumerging bug19911 into junk bug19911 changeset | files
3 weeks agoVlad Ionescufixing dialyzer error in rabbitmq-erlang-client bug19911 changeset | files
3 weeks agoMatthew Sackmancleandb is now an rm -rf and build depends not on mnesia bug20979 changeset | files
3 weeks agoMatthew SackmanAltered dependencies and added comment to the app bug20976 changeset | files
3 weeks agoMatthew SackmanYep, as I'd thought, the next_seq_id field was totally unused for anything useful. The code is thus now a good bit simpler. bug19662 changeset | files
3 weeks agoTim ClarkAttempt to fix regexp in Portfile bug20961 changeset | files
3 weeks agoTim ClarkChanges to version and checksums bug20961 changeset | files
3 weeks agoMatthew SackmanMade mixed_queue track its length by itself. This avoids synchronous calls to the disk_queue when operating in disk only mode and seems to have substantially improved performance (in addition to avoiding a sync call, repeated lasting for the length of a queue (erlang stdlib) with a million+ items in it can't have been cheap). It now seems to be very much the case that when coming out of disk only mode, huge back logs are recovered reliably. bug19662 changeset | files
3 weeks agoMatthew Sackmanmerging in from default bug19662 changeset | files
3 weeks agoMatthew Sackmanmerging in bug20943 changeset | files
3 weeks agoMatthew SackmanAnd suddenly it works. Testing showed that removing the crude limit UNSENT_MESSAGE_LIMIT made performance better. This then made me wonder if the unblock and notify_sent messages weren't getting through fast enough, and sure enough, using pcast is much better there. Also, turning on dbg:tpl showed that the common path in mixed_queue was to call publish_delivered (i.e. the message has been delivered to a consumer, we just need to record this fact). Making sure everything in there for the non-persistent, non-durable but disk-only mode is asynchronous also helped performance massively. bug19662 changeset | files
3 weeks agoMatthias Radestockrefactoring: rename "round robin" to "active consumers" bug20943 changeset | files
3 weeks agoMatthias Radestockproper round-robining even when blocking bug20943 changeset | files
3 weeks agoMatthew Sackmanwell, I've made the acking for messages which are on disk but are not persistent/durable async, and it has improved some issues. But, if you switch to disk only mode, then allow, say 10k messages to build up (use MulticastMain) then switch back to ram mode, then it won't recover - the receive rate will stay very low, and rabbitmqctl list_queues will continue to grow insanely. This is very very odd, because querying the disk_queue directly for the queue length shows it drops to 0, but at least one CPU is maxed out at 100% use, messages continue to arrive, but the delivery rate never goes back up. Mysterious. bug19662 changeset | files
3 weeks agoMatthew SackmanTook advantage of the gen_server2 priorities. bug19662 changeset | files
3 weeks agoMatthew SackmanAdded means to alter all queues and switch to disk_only mode in the disk queue. bug19662 changeset | files
3 weeks agoMatthias Radestockemergency merge of bug20958 into default changeset | files
3 weeks agotimcRemoved default shell, changed wrapper to work without default shell bug20958 changeset | files
3 weeks agotimcCreates rabbitmq user with a default shell and uses correct arguments to the os x su command bug20958 changeset | files
3 weeks agoMatthew Sackmanjust merging in default. bug19662 changeset | files
3 weeks agoMatthew Sackmanmerge in bug20955 changeset | files
3 weeks agoMatthew SackmanTwo things have happened here. Firstly, the mixed_queue now functions correctly when being run in disk_only mode. This is _much_ more complicated than I had thought because of the fact that the presence of a message on disk has nothing to do with whether it is persistent or not. As a result early acking is required and requeuing operations are horrendous to say the least. bug19662 changeset | files
3 weeks agoMatthias Radestockrespect channel blocking when adding consumers bug20955 changeset | files
3 weeks agoHubert PlociniczakMerge bug20801 into default changeset | files
3 weeks agoHubert PlociniczakMerge two default branches into one. changeset | files
3 weeks agoMatthias Radestockfix off-by-one error changeset | files
3 weeks agoHubert PlociniczakUse dist macro for building correct distribution versions. bug20801 changeset | files
3 weeks agotimcMerge from bug20333 post verification changeset | files
3 weeks agoMatthias Radestockcosmetic changeset | files
3 weeks agoMatthias Radestockmerge bug20940 into default changeset | files
3 weeks agoMatthias Radestockcosmetic bug20940 changeset | files
3 weeks agoMatthew Sackmanjust committing as need to work from home tomorrow. Code in "interesting" state of flux. disk mode to mixed mode in the mixed_queue is annoyingly hard. bug19662 changeset | files
3 weeks agoMatthew SackmanMade can_send/2 into can_send/3. bug20940 changeset | files
3 weeks agoMatthew SackmanUsing delayed_write batches together small writes and reduces the number of OS calls. This is a good thing and makes writing to disk much faster. However, we can have the situation where we are trying to read a message off disk before that message has been fully written out to disk. Therefore, we need to fsync at choice times. Because fsync is quite expensive, we want to call fsync no more than absolutely necessary. Thus we now have a 'dirty' flag which tracks whether the current file has been written to sinc the last fsync, and we call fsync whenever is dirty and the file to read from is the current file. This has also had some similar changes elsewhere in the disk queue. In short however, it seems this does work as I'm no longer able to reproduce reads of messages which return all blanks. bug19662 changeset | files
3 weeks agoMatthew SackmanLogic failure which only came to light when trying to run the consumers as documented in bug 20470 bug19662 changeset | files
3 weeks agoMatthew Sackmancan now switch the mixed queue between modes bug19662 changeset | files
3 weeks agoMatthew Sackmantiny refactor bug19662 changeset | files
3 weeks agoMatthew Sackmanrefactorings and code cleanup bug19662 changeset | files
3 weeks agoBen HoodRemoved check for durable queues on transient exchanges amqp_0_9_1 changeset | files
3 weeks agoBen HoodMerged default back into amqp_0_9_1 amqp_0_9_1 changeset | files
3 weeks agoMatthew Sackmanidiot bug19662 changeset | files
3 weeks agoMatthew Sackmantiny refactorings bug19662 changeset | files
3 weeks agoMatthew Sackmanmerge in default, post the bug20782 merge. All the tests still pass and the test in comment #4 of bug20782 also has correct behaviour. bug19662 changeset | files
3 weeks agoMatthew Sackmanmerging in bug20782 changeset | files
4 weeks agoMatthew Sackmanwas just watching the logs go by when running tests and saw an explosion. Pretty basic typeo which hadn't been caught so far. bug19662 changeset | files
4 weeks agoMatthew Sackmanneed to leave the disk queue running so that the rest of the tests go through bug19662 changeset | files
4 weeks agoMatthew SackmanAll tests pass. Including clustering tests. "ram-nodes" in clustering now have mnesia schemas, but the tables are created as ram tables (other than the disk_queue, which does its own thing and is either disc_copies or disc_only_copies, but that table is also local_content - we don't want to try and duplicate that state across nodes). bug19662 changeset | files
4 weeks agoMatthew Sackmanall java tests now pass. tiny (but significant!) bug in the mixed_queue startup post disk_queue startup. bug19662 changeset | files
4 weeks agoMatthew SackmanJava functional tests now pass. bug19662 changeset | files
4 weeks agoMatthew Sackmanmerge from default, which was more effort than I'd expected. Also, started working through the java functional tests, discovered one bug in the mixed_queue (cancel not observing durable flag) and one bug in the amqqueue_process (not committing txns if there's no consumer pid). bug19662 changeset | files
4 weeks agoMatthias Radestockclean up tx records in queues when a transaction's channel dies bug20782 changeset | files
4 weeks agoMatthias Radestockrefactoring: bundle up all the data for a publish bug20782 changeset | files
4 weeks agoMatthew SackmanQueue recovery on startup now works. bug19662 changeset | files
4 weeks agoMatthew Sackmanadded dump_queue to the disk queue. This spits out a list of the queue contents from the current read pointer to the end of the queue (i.e. messages for which we are waiting for acks will not be included). Of course, at startup, all the read pointers are at the start of the queue (i.e. not waiting for any acks) so this grabs everything. Some minor refactoring was involved in the addition of this function. Also, I needed to change my definition of unfold so that it's now both simultaneously an anamorphism and a catamorphism instead of just an anamorphism (i.e. the accumulator / 'initial' value is spat out at the end). This could be a hylomorphism. Can't remember... bug19662 changeset | files
4 weeks agoMatthew Sackmansorted out the disk_queue tests which had been left behind with the last set of API changes. By fixing them, discovered a bug in the disk queue. Also made the tests a little more rigorous, and discovered a the rdq_stress_gc test was not doing anything like what I'd wanted. Fixed. bug19662 changeset | files
4 weeks agoTony Garnock-JonesSplit out internal_declare/2. changeset | files
4 weeks agoMatthew Sackmanremoved the persister and modified guid generation to use a persisted serial id stored on disk bug19662 changeset | files
4 weeks agoMatthew Sackmanonly write out persistent messages sent to a durable queue bug19662 changeset | files
4 weeks agoMatthew Sackmanmerge bug20633 into default changeset | files
5 weeks agoMatthew Sackman(just for testing - switch to disk only mode) bug19662 changeset | files
4 weeks agoMatthias Radestockmerge bug20877 into default changeset | files
4 weeks agoMatthias Radestockalign bug20877 changeset | files
4 weeks agoTony Garnock-JonesChange from number to atom. bug20877 changeset | files
4 weeks agoTony Garnock-Jonesmerge default into amqp_0_9_1 amqp_0_9_1 changeset | files
4 weeks agoTony Garnock-Jonesmerge bug20654 into default changeset | files
4 weeks agoTony Garnock-Jonesmerger bug20654 changeset | files
5 weeks agoTony Garnock-Jonesmerge default into bug20654 bug20654 changeset | files
5 weeks agoTony Garnock-Jonesmerge v1_5 into default changeset | files
4 weeks agoMatthias Radestockmake delete_binding return an error when the binding does not exist bug20633 changeset | files
5 weeks agoMatthias Radestockfix typo bug20654 changeset | files
5 weeks agoMatthew Sackmangen_server -> gen_server2, delete_queue calls purge_queue first in order to try and reduce horrible inefficient mnesia_match_object call. Also some refactoring and tidying. bug19662 changeset | files
5 weeks agoMatthew Sackmanjust merging in default branch bug19662 changeset | files
5 weeks agoMatthew SackmanBrought out starting the persister to rabbit.erl. Also, reduced the file size limit to 25MB. The reason is that it was observed that start up was taking a long time simply because the files were large (100MB). Given that the file being written to is never GC'd, reducing the file size limit forces new files to be created more frequently, thus increasing the use of GC and thereby keeping file utilisation higher. As a result, less time is wasted at startup scanning over delivered but not-yet-GC'd messages. bug19662 changeset | files
5 weeks agoMatthew Sackmanugh, managed to forget the need to compile before running dialyzer, hence just committed broken code... bug19662 changeset | files
5 weeks agoMatthew Sackmano) fix up -specs bug19662 changeset | files
5 weeks agoMatthew Sackmanpreemptive refactoring bug19662 changeset | files
6 weeks agoMatthew Sackmanduh! bug19662 changeset | files
6 weeks agoMatthew SackmanYup, basically, same bug in three places. Fixed. It all works. bug19662 changeset | files
6 weeks agoMatthew SackmanWell, it /tends/ to work, but sometimes falls over, apparently trying to read a message which has been erased from mnesia. Mysterious! bug19662 changeset | files
6 weeks agoMatthew SackmanIT WORKS! (for SendString and simpleconsumer) bug19662 changeset | files
6 weeks agoMatthew SackmanIt compiles. bug19662 changeset | files
6 weeks agoMatthew SackmanTiny changes to amqqueue_process, but mainly getting the mixed_queue api into proper shape. bug19662 changeset | files
6 weeks agoMatthew Sackmanjust a couple more comments / TODO items. bug19662 changeset | files
6 weeks agoMatthew SackmanStill WIP + DNC. However, deliver_queue is now rather funky, pretty much incorporating a HO fold. This does rather simplify matters as it means we get told inadvance that we need to produce a message only when we have a consumer for it, and at the same time we get told about whether this message is going to get an explicit ack, and we get an accumulator to play with as well. Pretty nifty - has simplified code elsewhere. bug19662 changeset | files
6 weeks agoMatthew SackmanWIP, DNC. However, I think the basic control flow is right, although there are a lot of bugs. One of the bigger remaining issues is the correct routing of AckTags around, and no doubt there will be assumptions I've made which are wrong, but I think it's getting there... bug19662 changeset | files
6 weeks agoMatthew SackmanMade deliver (in its various guises) also return the number of remaining messages bug19662 changeset | files
6 weeks agoMatthew SackmanAdded is_empty and length functions. bug19662 changeset | files
6 weeks agoMatthew SackmanFormatting only. Only just realised emacs was using tabs. Fixed. bug19662 changeset | files
6 weeks agoMatthias Radestockhelper method for not_found errors changeset | files
6 weeks agoMatthias Radestockrename UME to AE bug20654 changeset | files
6 weeks agoMatthias Radestockbreak ume cycles bug20654 changeset | files
6 weeks agoMatthias Radestockcarry 'mandatory' and 'immediate' flags through to UMEs bug20654 changeset | files
...
tags
2 weeks agorabbitmq_v1_6_0changeset | changelog | files
6 weeks agorabbitmq_v1_5_5changeset | changelog | files
2 months agorabbitmq_v1_5_4changeset | changelog | files
4 months agorabbitmq_v1_5_3changeset | changelog | files
4 months agorabbitmq_v1_5_2changeset | changelog | files
5 months agorabbitmq_v1_5_1changeset | changelog | files
6 months agorabbitmq_v1_5_0changeset | changelog | files
10 months agoAman-06-09-08_2changeset | changelog | files
10 months agoAman-06-09-08changeset | changelog | files
11 months agorabbitmq_v1_4_0changeset | changelog | files
...
branches
13 hours agoac274407d402bug20980changeset | changelog | files
40 hours ago20a0d1d30335bug21087changeset | changelog | files
2 days agoed4dc5bae236defaultchangeset | changelog | files
2 days agob5b638c95202bug21060changeset | changelog | files
3 days ago671ad1c0d425bug19662changeset | changelog | files
12 days ago478c0e159585bug19356changeset | changelog | files
7 days ago5f5d1a89b3f8bug20470changeset | changelog | files
9 days ago08a1729c8c39amqp_0_9_1changeset | changelog | files
11 days ago7acca3ef9db0bug20911changeset | changelog | files
3 weeks agod5c49c51ec27bug19984changeset | changelog | files
2 weeks agodb36cd7712febug20958changeset | changelog | files
2 weeks agoec17ac79adccbug20961changeset | changelog | files
2 weeks agofe3bbf377f4ejunkchangeset | changelog | files
2 weeks ago672138e80349bug19911changeset | changelog | files
3 weeks ago6b7a86c27983bug20979changeset | changelog | files
3 weeks agoe5a465011e87bug20976changeset | changelog | files
3 weeks ago0cd523684a23bug20943changeset | changelog | files
3 weeks ago4d8dfd9e0ea3bug20955changeset | changelog | files
3 weeks agof92246090ef9bug20801changeset | changelog | files
3 weeks ago3d8e2aaa6688bug20940changeset | changelog | files
4 weeks ago8f6a9f62922cbug20782changeset | changelog | files
4 weeks agod8dce9e89664bug20877changeset | changelog | files
4 weeks ago3a14db7f077ebug20654changeset | changelog | files
4 weeks ago3c7da5a9fc8ebug20633changeset | changelog | files
6 weeks ago2781ad4e623av1_5changeset | changelog | files
6 weeks ago1a4850bc9b7fbug20767changeset | changelog | files
6 weeks ago91ffcf98b5d8bug20676changeset | changelog | files
7 weeks agod2925d5195d0bug20745changeset | changelog | files
7 weeks ago6e391c08c22fbug20589changeset | changelog | files
8 weeks agoae1604805fd2bug20679changeset | changelog | files
8 weeks agob280ec830776bug20702changeset | changelog | files
8 weeks agoc24776a3a99bbug20649changeset | changelog | files
2 months agoc3f5d8319a50bug19230changeset | changelog | files
2 months ago71b85ffb9b22bug20630changeset | changelog | files
2 months agoba842c7975b5bug20592changeset | changelog | files
2 months agob8e9a37f90f5bug20599changeset | changelog | files
2 months ago3a58a6a6a4c0bug20354changeset | changelog | files
2 months agoc14e0b0396debug20597changeset | changelog | files
2 months agoc5ee92aecf43bug20590changeset | changelog | files
2 months ago3be50ac4fc8fbug20593changeset | changelog | files
2 months agofd87f65194c4bug19622changeset | changelog | files
2 months ago64aa5b42442fbug20333changeset | changelog | files
3 months agoe37680ec6ed0bug20552changeset | changelog | files
3 months agoac50eb425866bug20546changeset | changelog | files
3 months agoc6cf85bb1b11bug20527changeset | changelog | files
3 months ago509715dc8a44bug20526changeset | changelog | files
3 months agobb77cbfda31ebug20518changeset | changelog | files
3 months ago6f9831f7f80dbug20516changeset | changelog | files
3 months ago01f13d2d6b18bug20454changeset | changelog | files
3 months ago5ef7f4a97d00bug20461changeset | changelog | files
3 months agod076afc4bfa9bug20460changeset | changelog | files
3 months ago3dfff21930c4bug20500changeset | changelog | files
3 months ago6dd63c90dbb7bug20462changeset | changelog | files
3 months ago2936e8e048c8bug20471changeset | changelog | files
3 months ago29d2828b46bdbug20455changeset | changelog | files
6 months ago6c09274101a2ssl_async_recvchangeset | changelog | files
4 months ago2be38e84b047bug20423changeset | changelog | files
4 months ago8681910f5f87bug20410changeset | changelog | files
4 months agobf8d4b91818abug20329changeset | changelog | files
4 months ago794bf4c9adb6bug20383changeset | changelog | files
4 months ago54c9254b61f3bug20352changeset | changelog | files
4 months ago56f889762527bug20327changeset | changelog | files
4 months agod284eab54bd1bug20374changeset | changelog | files
4 months ago5bb9f5ed625dbug20345changeset | changelog | files
4 months agoab9eb10f2880bug20353changeset | changelog | files
4 months agoaee7d57de6bdbug20348changeset | changelog | files
4 months agoe2dae815b0eebug20326changeset | changelog | files
5 months agoef81d69486b1bug20260changeset | changelog | files
5 months agoe0f9b02880a4bug20275changeset | changelog | files
5 months ago6d6dbd7f9b50bug20288changeset | changelog | files
5 months ago6ad5a674ab45bug20193changeset | changelog | files
5 months agofe2097546acdbug20173changeset | changelog | files
5 months ago16001b1a1501bug20149changeset | changelog | files
5 months ago124e4af1ffc6bug20179changeset | changelog | files
5 months ago961a406d32edbug20097changeset | changelog | files
5 months agoe09b7b41952bv1_5_1changeset | changelog | files
5 months ago1860e7d2381abug20099changeset | changelog | files
5 months ago883f889d09d0bug19749changeset | changelog | files
5 months ago4a426a5e3f4bbug20064changeset | changelog | files
5 months ago3e82b163e230bug18557changeset | changelog | files
5 months ago595f7ffdf247bug20125changeset | changelog | files
5 months agofbfd2dc9f08dbug20152changeset | changelog | files
5 months ago84d2deb712f5bug20155changeset | changelog | files
5 months ago149475d4d7a8bug20111changeset | changelog | files
5 months ago06b16fb29a1cbug20088changeset | changelog | files
5 months agof0c19128c50bbug20035changeset | changelog | files
5 months ago9ae964d3c851bug20141changeset | changelog | files
5 months ago02458a6d02c5bug20121changeset | changelog | files
5 months agob9be298d4944bug20096changeset | changelog | files
5 months ago5871715de1fbbug20089changeset | changelog | files
5 months agoed35e5e9f4a3bug20098changeset | changelog | files
5 months ago515ca2894a51bug19759changeset | changelog | files
5 months agob8e7f9e3ab8ebug20071changeset | changelog | files
5 months agoc0649f73ab07bug20067changeset | changelog | files
5 months agocda3e39d0e3cbug20020changeset | changelog | files
5 months ago70695b7089b1bug20033changeset | changelog | files
5 months ago5ef6c9f5611cbug20082changeset | changelog | files
5 months agoe4de2be7be0dbug19213changeset | changelog | files
6 months agoeee7d41ae935bug20061changeset | changelog | files
6 months ago37772010d811bug20047changeset | changelog | files
6 months ago15f702aef3f7bug20046changeset | changelog | files
6 months agod1554c9ffab4bug20045changeset | changelog | files
6 months ago39d00746aac6bug20030changeset | changelog | files
6 months ago666561530a16bug20019changeset | changelog | files
6 months ago8572a017980dbug20002changeset | changelog | files
6 months agobe062bf6a1f1bug19999changeset | changelog | files
6 months ago67785e49bc9abug19568changeset | changelog | files
6 months ago6287bc3b93b9bug19993changeset | changelog | files
6 months ago015c613428e1bug19994changeset | changelog | files
6 months ago59b0c48d16d8bug19992changeset | changelog | files
6 months ago4b923a6e0f86bug19989changeset | changelog | files
6 months ago7cee59f5ed19bug19987changeset | changelog | files
6 months ago0a2d07e9d016bug19684changeset | changelog | files
6 months ago6d9930f93d0ebug19914changeset | changelog | files
6 months ago6d7c525ffa1cbug18381changeset | changelog | files
6 months ago76f306e4ce99bug19975changeset | changelog | files
6 months ago2827919ebc97bug19974changeset | changelog | files
7 months ago9461eccba440bug19961changeset | changelog | files
7 months agofea54c0cf137bug19929changeset | changelog | files
7 months agob74dbe5eea40bug19962changeset | changelog | files
7 months ago35e92ae53f82bug19888changeset | changelog | files
7 months ago37ae9de0382dbug19900changeset | changelog | files
7 months agoc73b5c19421ebug19889changeset | changelog | files
7 months ago3986d6b499c8bug19950changeset | changelog | files
7 months agofc26c02e1c3abgu19950changeset | changelog | files
7 months agoc205e00d7b3ebug19871changeset | changelog | files
7 months ago01dc337d8574bug19910changeset | changelog | files
7 months agobbe8b3d7699ebug19912changeset | changelog | files
7 months agoba485a67fb01bug19852changeset | changelog | files
7 months agoeb016f6262c9bug19860changeset | changelog | files
7 months ago966df31b5790bug19331changeset | changelog | files
7 months ago5065a88923dbbug19899changeset | changelog | files
7 months ago555d6994fb11bug19743changeset | changelog | files
7 months ago66e64f4ef627bug19859changeset | changelog | files
7 months agob6e27e481a58bug19826changeset | changelog | files
7 months ago3cf85e10dffdbug19754changeset | changelog | files
7 months ago0ee9f1b263b4bug19713changeset | changelog | files
7 months agob9a2fe404358bug19792changeset | changelog | files
7 months ago3238bcdd4dd4bug19615changeset | changelog | files
7 months ago3dd3851b02b3bug19801changeset | changelog | files
7 months ago995a226dda6bbug19758changeset | changelog | files
7 months ago330625e628a2bug19841changeset | changelog | files
7 months agoc5733cf10250bug19522changeset | changelog | files
7 months agof582def1e7e8bug19573changeset | changelog | files
7 months ago0627abb8cfe1bug19788changeset | changelog | files
7 months ago09838abdd392bug19790changeset | changelog | files
7 months agoc4e5781ab435bug19730changeset | changelog | files
7 months agoca7036991710bug19250changeset | changelog | files
8 months agoc9494c5659f6bug19468changeset | changelog | files
8 months agoa9ddd842f35abug18776changeset | changelog | files
8 months ago24040b9329c1bug19623changeset | changelog | files
8 months ago629f12e628b1bug19587changeset | changelog | files
8 months ago31db3bb1c168bug19572changeset | changelog | files
8 months agob1a70ec3af61bug19468_channelschangeset | changelog | files
8 months ago8f9313fa94b2bug19574changeset | changelog | files
8 months ago9a74de90b294bug18732changeset | changelog | files
8 months agoeeb197f35668bug19382changeset | changelog | files
8 months ago94a039fed9f1bug19552changeset | changelog | files
8 months agob60656e27d04bug19468_queueschangeset | changelog | files
8 months agofb38f87ca0dcbug19491changeset | changelog | files
8 months agoc4fe3e8e0a5abug19489changeset | changelog | files
9 months agoacee4fcbf60ebug19490changeset | changelog | files
9 months agofd95947dcf79bug19485changeset | changelog | files
9 months ago79d96918a8f1bug19487changeset | changelog | files
9 months agof35f64be7c82bug19219changeset | changelog | files
9 months ago63a841c77b1cbug19336changeset | changelog | files
9 months ago62d2571f7738bug19455changeset | changelog | files
9 months ago187b7f023d9ebug19332changeset | changelog | files
9 months ago6020f3f8d9d3bug19164changeset | changelog | files
9 months agod786aec1bec6bug19193changeset | changelog | files
9 months ago9848582d892cbug19166changeset | changelog | files
9 months agoea793553f33ebug19144changeset | changelog | files
10 months ago86324df55e9cbug19200changeset | changelog | files
10 months ago2c9599f8305dbug19329changeset | changelog | files
10 months ago8daf7f0615f9bug17070changeset | changelog | files
10 months agoff977b03cc0dbug19089changeset | changelog | files
10 months agoddb37dcbdfcabug18994changeset | changelog | files
10 months ago90c5777064bebug17940changeset | changelog | files
11 months ago571310e1b41dbug19139changeset | changelog | files
11 months ago08107a413fdfbug19135changeset | changelog | files
11 months ago63dd67352142bug18793changeset | changelog | files
11 months agoa198d6f3b741bug19069changeset | changelog | files
11 months agoe774492ccc4cbug18752changeset | changelog | files
12 months agoc8de7a62979bbug18784changeset | changelog | files
...
rabbitmq-server