diff options
| -rw-r--r-- | src/couch/src/couch_db_updater.erl | 3 | ||||
| -rw-r--r-- | src/couch/src/couch_emsort.erl | 9 |
2 files changed, 8 insertions, 4 deletions
diff --git a/src/couch/src/couch_db_updater.erl b/src/couch/src/couch_db_updater.erl index 4786ee70f..f8cf764fc 100644 --- a/src/couch/src/couch_db_updater.erl +++ b/src/couch/src/couch_db_updater.erl @@ -1342,7 +1342,8 @@ copy_docs(Db, #db{fd = DestFd} = NewDb, MixedInfos, Retry) -> NewDb#db.seq_tree, NewInfos, RemoveSeqs), EMSortFd = couch_emsort:get_fd(NewDb#db.id_tree), - {ok, LocSizes} = couch_file:append_terms(EMSortFd, NewInfos), + EMOpts = [{compression, none}], + {ok, LocSizes} = couch_file:append_terms(EMSortFd, NewInfos, EMOpts), EMSortEntries = lists:zipwith(fun(FDI, {Loc, _}) -> #full_doc_info{ id = Id, diff --git a/src/couch/src/couch_emsort.erl b/src/couch/src/couch_emsort.erl index 2a25a2322..80edcbd2c 100644 --- a/src/couch/src/couch_emsort.erl +++ b/src/couch/src/couch_emsort.erl @@ -216,7 +216,8 @@ write_kvs(Ems, KVs) -> lists:foldr(fun(KV, Acc) -> append_item(Ems, Acc, KV, Ems#ems.chain_chunk) end, {[], nil}, lists:sort(KVs)), - {ok, Final, _} = couch_file:append_term(Ems#ems.fd, {LastKVs, LastPos}), + {ok, Final, _} = couch_file:append_term(Ems#ems.fd, {LastKVs, LastPos}, + [{compression, none}]), Final. @@ -263,7 +264,8 @@ merge_chains(Ems, Choose, BB) -> merge_chains(Ems, _Choose, [], ChainAcc) -> - {ok, CPos, _} = couch_file:append_term(Ems#ems.fd, ChainAcc), + {ok, CPos, _} = couch_file:append_term(Ems#ems.fd, ChainAcc, + [{compression, none}]), CPos; merge_chains(#ems{chain_chunk=CC}=Ems, Choose, Chains, Acc) -> {KV, RestChains} = choose_kv(Choose, Ems, Chains), @@ -311,7 +313,8 @@ ins_big_chain(Rest, Chain, Acc) -> append_item(Ems, {List, Prev}, Pos, Size) when length(List) >= Size -> - {ok, PrevList, _} = couch_file:append_term(Ems#ems.fd, {List, Prev}), + {ok, PrevList, _} = couch_file:append_term(Ems#ems.fd, {List, Prev}, + [{compression, none}]), {[Pos], PrevList}; append_item(_Ems, {List, Prev}, Pos, _Size) -> {[Pos | List], Prev}. |