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_stream.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_stream.erl')
| -rw-r--r-- | src/couchdb/couch_stream.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/couchdb/couch_stream.erl b/src/couchdb/couch_stream.erl index 964dc150..d957268f 100644 --- a/src/couchdb/couch_stream.erl +++ b/src/couchdb/couch_stream.erl @@ -60,10 +60,10 @@ open(State, Fd) -> {ok, #stream{pid = Pid, fd = Fd}}. close(#stream{pid = Pid, fd = _Fd}) -> - gen_server:call(Pid, close). + gen_server:call(Pid, close, infinity). get_state(#stream{pid = Pid, fd = _Fd}) -> - gen_server:call(Pid, get_state). + gen_server:call(Pid, get_state, infinity). ensure_buffer(#stream{pid = Pid, fd = _Fd}, Bytes) -> gen_server:call(Pid, {ensure_buffer, Bytes}). @@ -118,7 +118,7 @@ write_term(Stream, Term) -> write(#stream{}, <<>>) -> {ok, {0,0}}; write(#stream{pid = Pid}, Bin) when is_binary(Bin) -> - gen_server:call(Pid, {write, Bin}). + gen_server:call(Pid, {write, Bin}, infinity). init({{Pos, BytesRemaining}, Fd}) -> |