Grab bag of Cloudant patches to couch OTP application

- Removal of couch_db and couch_ref_counter processes. Active DBs are
  accessible through a protected ets table owned by couch_server.
- #full_doc_info{} in by_id and by_seq trees for faster compaction at the
  expense of more disk usage afterwards. Proposed as COUCHDB-738 but not
  accepted upstream.
- Replication via distributed Erlang.
- Better hot upgrade support (uses exported functions much more often).
- Configurable btree chunk sizes allow for larger (but still bounded)
  reductions.
- Shorter names for btree fields in #db{} and #db_header{}.
- couch_view_group does not keep a reference to the #db{}.
- Terms are stored compressed (again).

1 files changed, 15 insertions, 2 deletions

diff --git a/apps/couch/src/couch_file.erl b/apps/couch/src/couch_file.erl
index 0a891712..2d539f64 100644
--- a/apps/couch/src/couch_file.erl
+++ b/apps/couch/src/couch_file.erl
@@ -69,10 +69,10 @@ open(Filepath, Options) ->
 %%----------------------------------------------------------------------
 
 append_term(Fd, Term) ->
-    append_binary(Fd, term_to_binary(Term)).
+    append_binary(Fd, term_to_binary(Term, [compressed, {minor_version,1}])).
     
 append_term_md5(Fd, Term) ->
-    append_binary_md5(Fd, term_to_binary(Term)).
+    append_binary_md5(Fd, term_to_binary(Term, [compressed, {minor_version,1}])).
 
 
 %%----------------------------------------------------------------------
@@ -237,6 +237,7 @@ init_status_error(ReturnPid, Ref, Error) ->
 
 init({Filepath, Options, ReturnPid, Ref}) ->
     process_flag(trap_exit, true),
+    timer:send_after(60000, maybe_close),
     case lists:member(create, Options) of
     true ->
         filelib:ensure_dir(Filepath),
@@ -479,6 +480,18 @@ handle_cast(close, Fd) ->
 code_change(_OldVsn, State, _Extra) ->
     {ok, State}.
 
+handle_info(maybe_close, Fd) ->
+    case process_info(self(), monitored_by) of
+    {monitored_by, [_StatsCollector]} ->
+        {stop, normal, Fd};
+    {monitored_by, []} ->
+        ?LOG_ERROR("~p ~p is un-monitored, maybe stats collector died",
+            [?MODULE, self()]),
+        {stop, normal, Fd};
+    _Else ->
+        timer:send_after(10000, maybe_close),
+        {noreply, Fd}
+    end;
 handle_info({'EXIT', _, normal}, Fd) ->
     {noreply, Fd};
 handle_info({'EXIT', _, Reason}, Fd) ->