Home
last modified time | relevance | path

Searched refs:Revs (Results 1 – 25 of 90) sorted by relevance

1234

/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch/test/eunit/
H A Dcouch_key_tree_prop_tests.erl39 ?FORALL(Revs, g_revs(),
40 ?FORALL({RevTree, Branch}, {g_revtree(Revs), g_revtree(Revs, 1)},
211 g_revtree(Revs) when is_list(Revs) ->
215 g_revtree(Size, Revs) when is_integer(Size), is_list(Revs) ->
217 g_revtree(Revs, MaxBranches) when is_list(Revs), is_integer(MaxBranches) ->
231 g_treenode(0, Revs, _) ->
232 {elements(Revs), x, []};
236 [Rev | ChildRevs] = Revs,
300 Revs = revs(Expected, Existing),
301 case length(Revs) > Expected of
[all …]
H A Dcouch_changes_tests.erl31 Revs = [R || {ok, R} <- [
38 Rev = lists:nth(3, Revs),
42 Revs1 = Revs ++ [Rev1],
248 should_handle_deleted_docs({DbName, Revs}) ->
251 Rev3_2 = element(6, Revs),
306 Rev4 = element(4, Revs),
307 Rev3_2 = element(6, Revs),
408 Rev3_2 = element(6, Revs),
426 should_select_with_continuous({DbName, Revs}) ->
449 Rev4 = element(4, Revs),
[all …]
H A Dcouch_db_doc_tests.erl60 {ok, [{ok, #doc{revs = {11, Revs}}}]} = open_doc_rev(Db, DocId, Rev10),
61 ?_assertEqual(5, length(Revs)).
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/fabric/src/
H A Dfabric_doc_missing_revs.erl31 ResultDict = dict:from_list([{Id, {{nil,Revs},[]}} || {Id, Revs} <- AllIdsRevs]),
67 force_reply(Id, {{nil,Revs}, Anc}, Acc) ->
69 [{Id, Revs, Anc} | Acc];
72 force_reply(Id, {Revs, Anc}, Acc) ->
73 [{Id, Revs, Anc} | Acc].
81 maybe_reply(Id, {Revs, Anc}, {stop, Acc}) ->
82 {stop, [{Id, Revs, Anc} | Acc]}.
85 dict:to_list(lists:foldl(fun({Id, Revs}, D0) ->
87 dict:append(Shard, {Id, Revs}, D1)
H A Dfabric_doc_open_revs.erl36 go(DbName, Id, Revs, Options) ->
38 [Id, Revs, Options]),
45 revs = Revs,
88 revs = Revs,
94 IsTree = Revs == all orelse Latest,
349 state0(Revs, Latest) ->
355 revs = Revs,
793 reply_to_element({ok, #doc{revs = Revs}} = Reply) ->
794 {_, [Rev | _]} = Revs,
795 {{Rev, Revs}, {Reply, 1}};
H A Dfabric_rpc.erl236 open_revs(DbName, Id, Revs, Options) ->
237 with_db(DbName, Options, {couch_db, open_doc_revs, [Id, Revs, Options]}).
254 {ok, lists:zipwith(fun({Id, Revs}, FullDocInfoResult) ->
257 MissingRevs = couch_key_tree:find_missing(RevisionTree, Revs),
260 {Id, Revs, []}
396 AllowableRevs = lists:foldl(fun({Node, Revs}, RevAcc) ->
403 {ok, FiltRevs} = couch_db:fold_purge_infos(Db, StartSeq, FoldFun, Revs),
H A Dfabric_view_all_docs.erl310 {ok, #doc{deleted=true, revs=Revs}} ->
312 {RevPos, [RevId|_]} = Revs,
315 {ok, #doc{revs=Revs} = Doc0} ->
317 {RevPos, [RevId|_]} = Revs,
H A Dfabric_util.erl183 make_key({ok, #doc{id=Id,revs=Revs}}) ->
184 {Id, Revs};
199 remove_ancestors([{_,{{ok, #doc{revs = {Pos, Revs}}}, Count}} = Head | Tail], Acc) ->
208 not lists:prefix(History, Revs)
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch_replicator/src/
H A Dcouch_replicator_worker.erl236 remote_process_batch([{Id, Revs, PAs} | Rest], Parent) ->
245 Revs),
257 fetch_doc(Source, {Id, Revs, PAs}, DocHandler, Acc) ->
260 Source, Id, Revs, [{atts_since, PAs}, latest], DocHandler, Acc)
265 [Id, couch_doc:revs_to_strs(Revs)]),
269 couch_replicator_api_wrap:open_doc_revs(Source, Id, Revs, [latest], DocHandler, Acc);
273 [Id, couch_doc:revs_to_strs(Revs)]),
277 couch_replicator_api_wrap:open_doc_revs(Source, Id, Revs, [latest], DocHandler, Acc)
435 Revs = [Rev || #rev_info{rev = Rev} <- RevsInfo],
436 {[{Id, Revs} | IdRevAcc], CountAcc + length(Revs)}
H A Dcouch_replicator_api_wrap.erl174 JsonBody = {[{Id, couch_doc:revs_to_strs(Revs)} || {Id, Revs} <- IdRevs]},
195 open_doc_revs(#httpdb{retries = 0} = HttpDb, Id, Revs, Options, _Fun, _Acc) ->
197 QS = options_to_query_args(HttpDb, Path, [revs, {open_revs, Revs} | Options]),
203 open_doc_revs(#httpdb{} = HttpDb, Id, Revs, Options, Fun, Acc) ->
248 Ret = receive_docs_loop(Streamer, Fun, Id, Revs, Ref, Acc),
271 open_doc_revs(HttpDb, Id, Revs, Options1, Fun, Acc)
287 open_doc_revs(RetryDb, Id, Revs, Options, Fun, Acc)
565 options_to_query_args([{open_revs, Revs} | Rest], Acc) ->
593 receive_docs_loop(Streamer, Fun, Id, Revs, Ref, Acc) ->
596 erlang:put(open_doc_revs, {Id, Revs, Ref, Streamer}),
[all …]
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/ddoc_cache/src/
H A Dddoc_cache_entry_ddocid.erl39 insert({DbName, DDocId}, {ok, #doc{revs = Revs} = DDoc}) ->
40 {Depth, [RevId | _]} = Revs,
/dports/devel/p5-VCP-autrijus/VCP-autrijus-snapshot-0.9-20050110/t/
H A D00revs.t14 use VCP::Revs;
25 sub { $rs = VCP::Revs->new( STORE_LOC => tmpdir ) ; ok( ref $rs, "VCP::Revs" ) },
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/mem3/src/
H A Dmem3_rep.erl369 FoldFun = fun({PSeq, UUID, Id, Revs}, {Count, Infos, _}) ->
370 NewCount = Count + length(Revs),
371 NewInfos = [{UUID, Id, Revs} | Infos],
478 {C + length(Revs), NewTargets};
543 chunk_revs(Revs) ->
545 chunk_revs(Revs, Limit).
547 chunk_revs(Revs, Limit) ->
548 chunk_revs(Revs, {0, []}, [], Limit).
554 Revs,
562 [{Id, Next, A}|Revs],
[all …]
H A Dmem3_reshard_store.erl170 {ok, #doc{revs = {_, Revs}}} ->
171 {ok, _} = couch_db:delete_doc(Db, DocId, Revs),
183 {ok, #doc{revs = Revs}} ->
184 BaseDoc#doc{revs = Revs};
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch/src/
H A Dcouch_db.erl311 apply_open_options2(#doc{atts=Atts0,revs=Revs}=Doc,
339 open_doc_revs(Db, Id, Revs, Options) ->
407 || {UUID, Id, Revs} <- UUIDsIdsRevs],
966 case Revs of
1012 case Revs of
1034 {{Start, RevId}, {Leaf, Revs}} ||
1253 Revs = [Rev || {Rev, _} <- DocPath],
1254 make_doc(Db, Id, IsDel, Sp, {Pos, Revs}).
1631 fun({Id, Revs}, Lookup) ->
1635 case Revs of
[all …]
H A Dcouch_bt_engine.erl744 Revs = lists:map(fun({Rev, Seq, Bp}) ->
753 revs = Revs ++ DeletedRevs
794 purge_tree_split({PurgeSeq, UUID, DocId, Revs}) ->
795 {UUID, {PurgeSeq, DocId, Revs}}.
798 purge_tree_join(UUID, {PurgeSeq, DocId, Revs}) ->
799 {PurgeSeq, UUID, DocId, Revs}.
802 purge_seq_tree_split({PurgeSeq, UUID, DocId, Revs}) ->
803 {PurgeSeq, {UUID, DocId, Revs}}.
806 purge_seq_tree_join(PurgeSeq, {UUID, DocId, Revs}) ->
807 {PurgeSeq, UUID, DocId, Revs}.
[all …]
H A Dcouch_httpd_db.erl330 Revs = {0, []};
333 Revs = {Pos, [RevId]}
335 Doc#doc{id=Id,revs=Revs}
395 Results2 = [{Id, couch_doc:revs_to_strs(Revs)} || {Id, Revs, _} <- Results],
507 open_revs = Revs,
517 case Revs of
522 {ok, Results} = couch_db:open_doc_revs(Db, DocId, Revs, Options),
792 couch_doc_from_req(Req, _Db, DocId, #doc{revs=Revs}=Doc) ->
801 case Revs of
809 _ -> Revs
/dports/devel/p5-VCP-autrijus/VCP-autrijus-snapshot-0.9-20050110/lib/VCP/Filter/
H A Dchangesets.pm702 Revs => [ $r ],
711 push @{$change->{Revs}}, $self->destore_rev( $r_index );
721 map( " " . $_->as_string . "\n", @{$_->{Revs}} ),
793 @{delete $cur_change->{Revs}}
835 $cur_change->{Revs} = \@revs_to_keep;
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/ddoc_cache/test/eunit/
H A Dddoc_cache_tutil.erl59 {ok, #doc{revs = Revs}} = fabric:open_doc(DbName, DDocId, [?ADMIN_CTX]),
60 {Depth, [RevId | _]} = Revs,
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch_pse_tests/src/
H A Dcpse_test_purge_bad_checkpoints.erl24 {ok, Revs} = cpse_util:save_docs(couch_db:name(Db1), [
38 Rev = lists:nth(Idx + 1, Revs),
H A Dcpse_test_copy_purge_infos.erl47 AEPFold = fun({PSeq, UUID, Id, Revs}, {CPSeq, CPurges}) ->
48 {max(PSeq, CPSeq), [{UUID, Id, Revs} | CPurges]}
H A Dcpse_util.erl175 PurgeInfos = lists:map(fun({UUID, DocIdJson, Revs}) ->
176 {UUID, ?JSON_DECODE(?JSON_ENCODE(DocIdJson)), Revs}
242 aep_fold({_PSeq, UUID, Id, Revs}, Acc) ->
243 {ok, [{UUID, Id, Revs} | Acc]}.
506 FoldFun = fun({PSeq, UUID, Id, Revs}, Acc) ->
507 {ok, [{PSeq, UUID, Id, Revs} | Acc]}
H A Dcpse_test_fold_purge_infos.erl161 fold_fun({_PSeq, _UUID, Id, Revs}, Acc) ->
162 {ok, [{Id, Revs} | Acc]}.
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/docs/src/cluster/
H A Dpurging.rst41 purge_tree: UUID -> {PurgeSeq, DocId, Revs}
42 purge_seq_tree: PurgeSeq -> {UUID, DocId, Revs}
48 a tuple ``{UUID -> {PurgeSeq, DocId, Revs}}`` is added to ``purge_tree``,
49 a tuple is ``{PurgeSeq -> {UUID, DocId, Revs}}`` added ``to purge_seq_tree``.
123 internal purge trees: 1) ``purge_tree``: ``{UUID -> {PurgeSeq, DocId, Revs}}``
125 replica; 2) ``purge_seq_tree``: ``{PurgeSeq -> {UUID, DocId, Revs}}`` allows to
/dports/devel/p5-VCP-autrijus/VCP-autrijus-snapshot-0.9-20050110/lib/VCP/
H A DDest.pm25 use VCP::Revs ;
43 use VCP::Revs ;

1234