Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | nuke active_consumer_countbug25415 | Matthias Radestock | 2013-01-24 | 1 | -11/+3 |
| | |||||
* | merge stable into default | Matthias Radestock | 2013-01-24 | 1 | -2/+4 |
|\ | |||||
| * | merge bug25412 into stable | Matthias Radestock | 2013-01-24 | 1 | -2/+4 |
| |\ | |||||
| | * | Don't just {reply, Cmd, State} since that will end up going into send/2 - ↵bug25412 | Simon MacMullen | 2013-01-24 | 1 | -2/+4 |
| | | | | | | | | | | | | which will decide not to send... | ||||
* | | | Merge heads | Simon MacMullen | 2013-01-24 | 2 | -20/+39 |
|\ \ \ | |||||
| * \ \ | merge bug25383 into default | Matthias Radestock | 2013-01-24 | 2 | -20/+39 |
| |\ \ \ | |||||
| | * | | | improved connection refusal logic / error messagebug25383 | Matthias Radestock | 2013-01-24 | 2 | -20/+39 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | plus some tests to go with that And a tweak to the "become 1.0" API | ||||
| | * | | | merge default into bug25383 | Matthias Radestock | 2013-01-24 | 0 | -0/+0 |
| | |\ \ \ | |/ / / / | |||||
* | | | | | stable to default | Simon MacMullen | 2013-01-24 | 142 | -145/+145 |
|\ \ \ \ \ | |/ / / / |/| | / / | | |/ / | |/| | | |||||
| * | | | Merge bug25343 | Simon MacMullen | 2013-01-24 | 142 | -145/+145 |
| |\ \ \ | |||||
| | * | | | Update copyright 2013bug25343 | Emile Joubert | 2013-01-23 | 142 | -145/+145 |
| | | | | | |||||
* | | | | | Quick patch to backing queue quickcheck correcting fold fun arity | Emile Joubert | 2013-01-24 | 1 | -5/+6 |
| | | | | | |||||
* | | | | | stable to default | Simon MacMullen | 2013-01-24 | 36 | -1358/+2200 |
|\ \ \ \ \ | |/ / / / |/| | | | | |||||
| * | | | | merge bug24980 into default | Tim Watson | 2013-01-23 | 17 | -179/+309 |
| |\ \ \ \ | |||||
| | * \ \ \ | merge bug25394 into default | Tim Watson | 2013-01-22 | 5 | -25/+35 |
| | |\ \ \ \ | |||||
| | | * \ \ \ | merge stable into default | Matthias Radestock | 2013-01-22 | 1 | -10/+8 |
| | | |\ \ \ \ | | | | |/ / / | |||||
| | | * | | | | merge stable into default | Matthias Radestock | 2013-01-22 | 35 | -1287/+2134 |
| | | |\ \ \ \ | |||||
| | | | * \ \ \ | merge bug25395 into default | Tim Watson | 2013-01-21 | 8 | -25/+54 |
| | | | |\ \ \ \ | |||||
| | | | | * \ \ \ | stable to default | Simon MacMullen | 2013-01-21 | 35 | -1287/+2101 |
| | | | | |\ \ \ \ | |||||
| | | | | | * \ \ \ | merge bug25397 into default | Tim Watson | 2013-01-21 | 6 | -17/+35 |
| | | | | | |\ \ \ \ | |||||
| | | | | | | * \ \ \ | merge bug25409 into default | Tim Watson | 2013-01-21 | 4 | -3/+27 |
| | | | | | | |\ \ \ \ | |||||
| | | | | | | * | | | | | USe pg_local rather than an ets table. | Simon MacMullen | 2013-01-21 | 1 | -6/+3 |
| | | | | | | | | | | | | |||||
| | | | | | | * | | | | | cosmetic: move spec of internal function and make it more precise | Matthias Radestock | 2013-01-20 | 1 | -8/+5 |
| | | | | | | | | | | | | |||||
| | * | | | | | | | | | | populate slave's msg_id_ack with sync'ed messages pending ackbug25394 | Matthias Radestock | 2013-01-19 | 2 | -24/+30 |
| | | | | | | | | | | | | |||||
| | * | | | | | | | | | | eager sync of messages pending ack | Matthias Radestock | 2013-01-19 | 5 | -24/+23 |
| | | | | | | | | | | | | |||||
| | * | | | | | | | | | | merge bug25409 into bug25394 | Matthias Radestock | 2013-01-19 | 9 | -85/+131 |
| | |\ \ \ \ \ \ \ \ \ \ | | | |_|_|_|_|_|/ / / / | | |/| | | | | | | | | | |||||
| | | * | | | | | | | | | merge bug25395 into bug25394 | Matthias Radestock | 2013-01-19 | 0 | -0/+0 |
| | | |\ \ \ \ \ \ \ \ \ | | | | |_|/ / / / / / / | | | |/| | | | / / / / | | | | | |_|_|/ / / / | | | | |/| | | | | | | |||||
| | | * | | | | | | | | merge bug25397 into bug25395bug25395 | Matthias Radestock | 2013-01-19 | 0 | -0/+0 |
| | | |\ \ \ \ \ \ \ \ | | | | | |_|_|/ / / / | | | | |/| | | | | | | |||||
| | | | * | | | | | | | merge default into bug25397bug25397 | Matthias Radestock | 2013-01-19 | 1 | -64/+57 |
| | | | |\ \ \ \ \ \ \ | | | | | |/ / / / / / | | | | |/| | | | | | | |||||
| | | | | * | | | | | | merge default into bug25397 | Matthias Radestock | 2013-01-17 | 1 | -64/+57 |
| | | | | |\ \ \ \ \ \ | |||||
| | | * | | \ \ \ \ \ \ | merge default into bug25395 | Matthias Radestock | 2013-01-19 | 4 | -77/+103 |
| | | |\ \ \ \ \ \ \ \ \ | | | | |/ / / / / / / / | | | |/| | | | | | | | | |||||
| | | | * | | | | | | | | pass 'unacked' flag to BQ:fold fun | Matthias Radestock | 2013-01-15 | 4 | -18/+21 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | so it can distinguish between 'ready' messages and those pending ack | ||||
| | | | * | | | | | | | | merge bug25397 into bug25395 | Matthias Radestock | 2013-01-15 | 2 | -15/+45 |
| | | | |\ \ \ \ \ \ \ \ | | | | | |_|/ / / / / / | | | | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | which involved tweaking the variable_queue_with_holes result slightly, and ripping out a whole bunch of now-redundant test code. | ||||
| | | | | * | | | | | | | merge default into bug25395 | Matthias Radestock | 2013-01-15 | 1 | -23/+68 |
| | | | | |\ \ \ \ \ \ \ | |||||
| | | | | * \ \ \ \ \ \ \ | merge default into bug25395 | Matthias Radestock | 2013-01-14 | 1 | -56/+80 |
| | | | | |\ \ \ \ \ \ \ \ | |||||
| | | | | | * | | | | | | | | refactor | Matthias Radestock | 2013-01-13 | 1 | -19/+14 |
| | | | | | | | | | | | | | | |||||
| | | | | | * | | | | | | | | include pending_acks in 'fold' | Matthias Radestock | 2013-01-13 | 1 | -13/+46 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | we implement this as a zipper over three iterators | ||||
| | | | | | * | | | | | | | | merge bug25397 into bug25395 | Matthias Radestock | 2013-01-13 | 1 | -2/+2 |
| | | | | | |\ \ \ \ \ \ \ \ | |||||
| | | | | | * \ \ \ \ \ \ \ \ | merge bug25397 into bug25395 | Matthias Radestock | 2013-01-12 | 1 | -30/+30 |
| | | | | | |\ \ \ \ \ \ \ \ \ | |||||
| | | | | | * \ \ \ \ \ \ \ \ \ | merge default into bug25395 | Matthias Radestock | 2013-01-12 | 1 | -21/+24 |
| | | | | | |\ \ \ \ \ \ \ \ \ \ | |||||
| | | | | | * \ \ \ \ \ \ \ \ \ \ | merge bug25397 into bug25395 | Matthias Radestock | 2013-01-12 | 1 | -56/+52 |
| | | | | | |\ \ \ \ \ \ \ \ \ \ \ | |||||
| | | | * | | \ \ \ \ \ \ \ \ \ \ \ | merge bug25400 into bug25397 | Matthias Radestock | 2013-01-15 | 1 | -64/+57 |
| | | | |\ \ \ \ \ \ \ \ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | which is rather conflict-ridden; essentially requiring the rewriting of the crux of the change in bug25400 in the context of new iterator. | ||||
| | | | | * \ \ \ \ \ \ \ \ \ \ \ \ \ | merge degault into bug25397 | Matthias Radestock | 2013-01-15 | 1 | -23/+68 |
| | | | | |\ \ \ \ \ \ \ \ \ \ \ \ \ \ | | | | | | | |_|_|_|_|_|/ / / / / / / | | | | | | |/| | | | | | | | | | | | | |||||
| | | | | * | | | | | | | | | | | | | | merge default into bug25397 | Matthias Radestock | 2013-01-14 | 1 | -56/+52 |
| | | | | |\ \ \ \ \ \ \ \ \ \ \ \ \ \ | | | | | | |_|/ / / / / / / / / / / / | | | | | |/| | | | | | / / / / / / / | | | | | | | |_|_|_|_|/ / / / / / / | | | | | | |/| | | | | | | | | | | | |||||
| | | | | | * | | | | | | | | | | | | cosmetic | Matthias Radestock | 2013-01-13 | 1 | -2/+2 |
| | | | | | | |_|_|_|/ / / / / / / | | | | | | |/| | | | | | | | | | | |||||
| | | | | | * | | | | | | | | | | | only pass the minimum necessary state to 'next' | Matthias Radestock | 2013-01-12 | 1 | -23/+26 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | i.e. the IndexState. The remainder of the State is encapsulated inside the iterator state. Technically we only need q{1-4} and delta, but it's simpler and more obvious to just pass a read-only State around. | ||||
| | | | | | * | | | | | | | | | | | return MsgStatus only from iterator | Matthias Radestock | 2013-01-12 | 1 | -10/+7 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | leaving the message reading to the fold | ||||
| | | | | | * | | | | | | | | | | | merge default into bug25397 | Matthias Radestock | 2013-01-12 | 1 | -56/+52 |
| | | | | | |\ \ \ \ \ \ \ \ \ \ \ | | | | | | | | |_|/ / / / / / / / | | | | | | | |/| | / / / / / / / | | | | | | | |_|_|/ / / / / / / | | | | | | |/| | | | | | | | | | |||||
| | | | | | | * | | | | | | | | | pass State to iterator | Matthias Radestock | 2013-01-12 | 1 | -51/+43 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | We want to be able to zip this iterator with other iterators that also manipulate the vqstate. Hence we must pass the State explicitly rather than keeping it opaque inside the iterator state. Also, some refactoring on read_msg. | ||||
| | | | | | | * | | | | | | | | | merge default into bug25397 | Matthias Radestock | 2013-01-12 | 1 | -48/+52 |
| | | | | | | |\ \ \ \ \ \ \ \ \ | | | | | | | | |_|/ / / / / / / | | | | | | | |/| | | | | | | | |