shrinkbug24031

1 files changed, 10 insertions, 14 deletions

diff --git a/src/rabbit_misc.erl b/src/rabbit_misc.erl
index 814a5bbc..87181c24 100644
--- a/src/rabbit_misc.erl
+++ b/src/rabbit_misc.erl
@@ -467,20 +467,16 @@ map_in_order(F, L) ->
 %% We ignore entries that have been modified or removed.
 table_filter(Pred, PrePostCommitFun, TableName) ->
     lists:foldl(
-      fun (E, Acc) -> case execute_mnesia_transaction(
-                             fun () -> case mnesia:match_object(TableName, E,
-                                                                read) of
-                                           [] -> false;
-                                           _  -> Pred(E)
-                                       end
-                             end,
-                             fun (false, _Tx) -> false;
-                                 (true,   Tx) -> PrePostCommitFun(E, Tx),
-                                                 true
-                             end) of
-                          false -> Acc;
-                          true  -> [E | Acc]
-                      end
+      fun (E, Acc) ->
+              case execute_mnesia_transaction(
+                     fun () -> mnesia:match_object(TableName, E, read) =/= []
+                                   andalso Pred(E) end,
+                     fun (false, _Tx) -> false;
+                         (true,   Tx) -> PrePostCommitFun(E, Tx), true
+                     end) of
+                  false -> Acc;
+                  true  -> [E | Acc]
+              end
       end, [], dirty_read_all(TableName)).
 
 dirty_read_all(TableName) ->