diff options
| author | Eric Avdey <eiri@eiri.ca> | 2018-04-09 14:30:38 -0300 |
|---|---|---|
| committer | Eric Avdey <eiri@eiri.ca> | 2018-04-13 09:49:42 -0300 |
| commit | 581bd05844c8b30ca0afa4c3d94e7e4fec60467f (patch) | |
| tree | 92c2a8dab5101f2f1a7edad4612bb0252ce9b83e | |
| parent | b0f673fb51bf521f96729499e939e29f0c58fe8c (diff) | |
| download | couchdb-581bd05844c8b30ca0afa4c3d94e7e4fec60467f.tar.gz | |
Adopt fake_db to PSE changes
With db headers moved into engine's state, any fake_db call,
that's trying to setup sequences for tests (e.g. in mem3_shards)
crashing with context setup failed.
It's not trivial to compose a proper `engine` field outside of
couch app, so instead this fix makes fake_db to set engine
transparently, unless it was provided in a payload.
| -rw-r--r-- | src/couch/src/test_util.erl | 26 |
1 files changed, 24 insertions, 2 deletions
diff --git a/src/couch/src/test_util.erl b/src/couch/src/test_util.erl index e0a53a6f7..738e9a3fb 100644 --- a/src/couch/src/test_util.erl +++ b/src/couch/src/test_util.erl @@ -15,6 +15,7 @@ -include_lib("couch/include/couch_eunit.hrl"). -include("couch_db.hrl"). -include("couch_db_int.hrl"). +-include("couch_bt_engine.hrl"). -export([init_code_path/0]). -export([source_file/1, build_file/1]). @@ -234,7 +235,8 @@ stop(#test_context{mocked = Mocked, started = Apps}) -> meck:unload(Mocked), stop_applications(Apps). -fake_db(Fields) -> +fake_db(Fields0) -> + {ok, Db, Fields} = maybe_set_engine(Fields0), Indexes = lists:zip( record_info(fields, db), lists:seq(2, record_info(size, db)) @@ -242,7 +244,27 @@ fake_db(Fields) -> lists:foldl(fun({FieldName, Value}, Acc) -> Idx = couch_util:get_value(FieldName, Indexes), setelement(Idx, Acc, Value) - end, #db{}, Fields). + end, Db, Fields). + +maybe_set_engine(Fields0) -> + case lists:member(engine, Fields0) of + true -> + {ok, #db{}, Fields0}; + false -> + {ok, Header, Fields} = get_engine_header(Fields0), + Db = #db{engine = {couch_bt_engine, #st{header = Header}}}, + {ok, Db, Fields} + end. + +get_engine_header(Fields) -> + Keys = [disk_version, update_seq, unused, id_tree_state, + seq_tree_state, local_tree_state, purge_seq, purged_docs, + security_ptr, revs_limit, uuid, epochs, compacted_seq], + {HeadFields, RestFields} = lists:partition( + fun({K, _}) -> lists:member(K, Keys) end, Fields), + Header0 = couch_bt_engine_header:new(), + Header = couch_bt_engine_header:set(Header0, HeadFields), + {ok, Header, RestFields}. now_us() -> {MegaSecs, Secs, MicroSecs} = os:timestamp(), |