1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
-module(cluster_ops_test).
-include("../../couch/src/couch_db.hrl").
-include_lib("eunit/include/eunit.hrl").
% read_quorum_test() ->
% % we need to be running a cluster here...
% % not sure how to start things up for unit tests
% % but we're testing reads when a node is missing a doc, so disable internal
% % replication - a bit harsh if anything else is here, but hey, it's a test
% rpc:multicall(showroom, stop, []),
% rpc:multicall(supervisor, terminate_child,
% [couch_primary_services, couch_replication_supervisor]),
% rpc:multicall(supervisor, delete_child,
% [couch_primary_services, couch_replication_supervisor]),
% % create db
% DbName = <<"cluster_ops_test">>,
% showroom_db:delete_db(DbName, []),
% {Status, #db{name=DbName}} = showroom_db:create_db(DbName, []),
% ?assertEqual(ok, Status),
% % open db
% {ok, Db} = showroom_db:open_db(DbName, []),
% % make a test doc
% Key = <<"a">>,
% Json = {[{<<"_id">>,Key}]},
% Doc = couch_doc:from_json_obj(Json),
% Clock = vector_clock:create(node()),
% NewDoc = Doc#doc{clock=Clock},
% % insert a doc in two shards out of three
% % TODO: we need N=3, need to fix that at db create time Options above
% % (fb 1001)
% {M,F,A} = {dynomite_couch_api, put,[Db, NewDoc, []]},
% CorrectNodeParts = membership2:nodeparts_for_key(Key),
% [{MissingNode, MissingPart} | BadNodeParts] = CorrectNodeParts,
% MapFun = fun({Node,Part}) ->
% rpc:call(Node, M, F, [[Part | A]])
% end,
% {Good, Bad} = pcall(MapFun, BadNodeParts, 2),
% ?assertEqual(2, length(Good)),
% ?assertEqual([], Bad),
% % make sure it's notfound on the MissingNode
% MissingNodeGet = rpc:call(MissingNode, dynomite_couch_api, get,
% [[MissingPart, Db, Key, nil, []]]),
% ?assertEqual({not_found, {[], [missing]}}, MissingNodeGet),
% JsonDoc = {[{<<"_id">>,<<"a">>},
% {<<"_rev">>,
% <<"1-967a00dff5e02add41819138abb3284d">>}]},
% % r=3 should fail
% {r_quorum_not_met, {[{message, _M}, {good, G}, {bad, B}]}} =
% showroom_doc:open_doc(Db, Key, nil, [{r, "3"}]),
% ?assertEqual([JsonDoc,JsonDoc], G),
% ?assertEqual([{not_found, missing}], B),
% % r=2 should never fail (run it many times to make sure)
% do_opens({Db, Key, nil, [{r, "2"}]}, 20),
% ok.
% pcall(MapFun, Servers, Const) ->
% Replies = lib_misc:pmap(MapFun, Servers, Const),
% lists:partition(fun valid/1, Replies).
% valid({ok, _}) -> true;
% valid(ok) -> true;
% valid(_) -> false.
% do_opens(_,0) -> ok;
% do_opens({Db, DocId, Refs, Options} = Payload, Times) ->
% {Status, _Doc} = showroom_doc:open_doc(Db, DocId, Refs, Options),
% ?assertEqual(ok, Status),
% do_opens(Payload, Times-1).
|
