diff options
| author | Damien F. Katz <damien@apache.org> | 2009-01-23 04:15:47 +0000 |
|---|---|---|
| committer | Damien F. Katz <damien@apache.org> | 2009-01-23 04:15:47 +0000 |
| commit | 5dd96d8ee5f89524fa0be0f087a21f81b6b68ec4 (patch) | |
| tree | c4931d99e50a77aebe695279bc8567e1eee7499c /src/couchdb/couch_db.erl | |
| parent | 0a46c330072a3811d98a5c989d4c6486cff83df2 (diff) | |
Added task status checking, to help debug the progress of long running tasks, like view indexing and compaction.
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@736906 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb/couch_db.erl')
| -rw-r--r-- | src/couchdb/couch_db.erl | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/couchdb/couch_db.erl b/src/couchdb/couch_db.erl index b3102044..c35bb913 100644 --- a/src/couchdb/couch_db.erl +++ b/src/couchdb/couch_db.erl @@ -14,7 +14,7 @@ -behaviour(gen_server). -export([open/2,close/1,create/2,start_compact/1,get_db_info/1]). --export([open_ref_counted/2,num_refs/1,monitor/1]). +-export([open_ref_counted/2,num_refs/1,monitor/1,count_changes_since/2]). -export([update_doc/3,update_docs/4,update_docs/2,update_docs/3,delete_doc/3]). -export([get_doc_info/2,open_doc/2,open_doc/3,open_doc_revs/4]). -export([get_missing_revs/2,name/1,doc_to_tree/1,get_update_seq/1,get_committed_update_seq/1]). @@ -468,6 +468,18 @@ enum_docs_reduce_to_count(Reds) -> fun couch_db_updater:btree_by_id_reduce/2, Reds), Count. +count_changes_since(Db, SinceSeq) -> + {ok, Changes} = + couch_btree:fold_reduce(Db#db.docinfo_by_seq_btree, + SinceSeq + 1, % startkey + ok, % endkey + fun(_,_) -> true end, % groupkeys + fun(_SeqStart, PartialReds, ok) -> + {ok, couch_btree:final_reduce(Db#db.docinfo_by_seq_btree, PartialReds)} + end, + ok), + Changes. + enum_docs_since(Db, SinceSeq, Direction, InFun, Ctx) -> couch_btree:fold(Db#db.docinfo_by_seq_btree, SinceSeq + 1, Direction, InFun, Ctx). |