diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-05-15 17:26:20 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-05-15 17:26:20 +0100 |
| commit | 8a9dd51ada181c9ce136f3295f34b13b147614ed (patch) | |
| tree | 2bb1ec4c7d6dd42e3385dda3407995aaa44f54c6 /src | |
| parent | b5cb4324a2b25a5ba79f4b2865e63ad7cebe4e6b (diff) | |
| download | rabbitmq-server-git-8a9dd51ada181c9ce136f3295f34b13b147614ed.tar.gz | |
cosmetic: more consistent and easier to read match syntax
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 34 |
1 files changed, 18 insertions, 16 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 5e5ac4ce3f..bcee4b1da0 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -871,11 +871,11 @@ journal_plus_segment(JEntries, SegEntries) -> %% Here, the Out is the Seg Array which we may be adding to (for %% items only in the journal), modifying (bits in both), or erasing %% from (ack in journal, not segment). -journal_plus_segment(Obj = {{_Guid, _IsPersistent}, no_del, no_ack}, +journal_plus_segment({{_Guid, _IsPersistent}, no_del, no_ack} = Obj, not_found, RelSeq, Out) -> array:set(RelSeq, Obj, Out); -journal_plus_segment(Obj = {{_Guid, _IsPersistent}, del, no_ack}, +journal_plus_segment({{_Guid, _IsPersistent}, del, no_ack} = Obj, not_found, RelSeq, Out) -> array:set(RelSeq, Obj, Out); @@ -885,7 +885,7 @@ journal_plus_segment({{_Guid, _IsPersistent}, del, ack}, array:reset(RelSeq, Out); journal_plus_segment({no_pub, del, no_ack}, - {Pub = {_Guid, _IsPersistent}, no_del, no_ack}, + {{_Guid, _IsPersistent} = Pub, no_del, no_ack}, RelSeq, Out) -> array:set(RelSeq, {Pub, del, no_ack}, Out); @@ -917,21 +917,23 @@ journal_minus_segment(JEntries, SegEntries) -> %% publish or ack is in both the journal and the segment. %% Both the same. Must be at least the publish -journal_minus_segment(Obj, Obj = {{_Guid, _IsPersistent}, _Del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent}, _Del, no_ack} = Obj, + Obj, _RelSeq, Out, PubsRemoved, AcksRemoved) -> {Out, PubsRemoved + 1, AcksRemoved}; -journal_minus_segment(Obj, Obj = {{_Guid, _IsPersistent}, _Del, ack}, +journal_minus_segment({{_Guid, _IsPersistent}, _Del, ack} = Obj, + Obj, _RelSeq, Out, PubsRemoved, AcksRemoved) -> {Out, PubsRemoved + 1, AcksRemoved + 1}; %% Just publish in journal -journal_minus_segment(Obj = {{_Guid, _IsPersistent}, no_del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent}, no_del, no_ack} = Obj, not_found, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, Obj, Out), PubsRemoved, AcksRemoved}; %% Just deliver in journal -journal_minus_segment(Obj = {no_pub, del, no_ack}, +journal_minus_segment({no_pub, del, no_ack} = Obj, {{_Guid, _IsPersistent}, no_del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, Obj, Out), PubsRemoved, AcksRemoved}; @@ -941,7 +943,7 @@ journal_minus_segment({no_pub, del, no_ack}, {Out, PubsRemoved, AcksRemoved}; %% Just ack in journal -journal_minus_segment(Obj = {no_pub, no_del, ack}, +journal_minus_segment({no_pub, no_del, ack} = Obj, {{_Guid, _IsPersistent}, del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, Obj, Out), PubsRemoved, AcksRemoved}; @@ -951,18 +953,18 @@ journal_minus_segment({no_pub, no_del, ack}, {Out, PubsRemoved, AcksRemoved}; %% Publish and deliver in journal -journal_minus_segment(Obj = {{_Guid, _IsPersistent}, del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent}, del, no_ack} = Obj, not_found, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, Obj, Out), PubsRemoved, AcksRemoved}; -journal_minus_segment({Pub, del, no_ack}, - {Pub = {_Guid, _IsPersistent}, no_del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent} = Pub, del, no_ack}, + {Pub, no_del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, {no_pub, del, no_ack}, Out), PubsRemoved + 1, AcksRemoved}; %% Deliver and ack in journal -journal_minus_segment(Obj = {no_pub, del, ack}, +journal_minus_segment({no_pub, del, ack} = Obj, {{_Guid, _IsPersistent}, no_del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, Obj, Out), PubsRemoved, AcksRemoved}; @@ -981,13 +983,13 @@ journal_minus_segment({{_Guid, _IsPersistent}, del, ack}, not_found, _RelSeq, Out, PubsRemoved, AcksRemoved) -> {Out, PubsRemoved, AcksRemoved}; -journal_minus_segment({Pub, del, ack}, - {Pub = {_Guid, _IsPersistent}, no_del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent} = Pub, del, ack}, + {Pub, no_del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, {no_pub, del, ack}, Out), PubsRemoved + 1, AcksRemoved}; -journal_minus_segment({Pub, del, ack}, - {Pub = {_Guid, _IsPersistent}, del, no_ack}, +journal_minus_segment({{_Guid, _IsPersistent} = Pub, del, ack}, + {Pub, del, no_ack}, RelSeq, Out, PubsRemoved, AcksRemoved) -> {array:set(RelSeq, {no_pub, no_del, ack}, Out), PubsRemoved + 1, AcksRemoved}. |
