Add 'apps/fabric/' from commit '5e2f90537f5b54adc94c58b58512a05b058fa804'

git-subtree-dir: apps/fabric
git-subtree-mainline: 72d7a60124b4ee7e31912fe7ed3a50bbc5cb9f64
git-subtree-split: 5e2f90537f5b54adc94c58b58512a05b058fa804

1 files changed, 35 insertions, 0 deletions

diff --git a/apps/fabric/src/fabric_db_meta.erl b/apps/fabric/src/fabric_db_meta.erl
new file mode 100644
index 00000000..ee15fc72
--- /dev/null
+++ b/apps/fabric/src/fabric_db_meta.erl
@@ -0,0 +1,35 @@
+-module(fabric_db_meta).
+
+-export([set_revs_limit/3, set_security/3]).
+
+-include("fabric.hrl").
+-include_lib("mem3/include/mem3.hrl").
+
+set_revs_limit(DbName, Limit, Options) ->
+    Shards = mem3:shards(DbName),
+    Workers = fabric_util:submit_jobs(Shards, set_revs_limit, [Limit, Options]),
+    Waiting = length(Workers) - 1,
+    case fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Waiting) of
+    {ok, ok} ->
+        ok;
+    Error ->
+        Error
+    end.
+
+set_security(DbName, SecObj, Options) ->
+    Shards = mem3:shards(DbName),
+    Workers = fabric_util:submit_jobs(Shards, set_security, [SecObj, Options]),
+    Waiting = length(Workers) - 1,
+    case fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Waiting) of
+    {ok, ok} ->
+        ok;
+    Error ->
+        Error
+    end.
+
+handle_message(ok, _, 0) ->
+    {stop, ok};
+handle_message(ok, _, Waiting) ->
+    {ok, Waiting - 1};
+handle_message(Error, _, _Waiting) ->
+    {error, Error}.
\ No newline at end of file