diff options
| author | Damien F. Katz <damien@apache.org> | 2009-05-31 23:43:22 +0000 |
|---|---|---|
| committer | Damien F. Katz <damien@apache.org> | 2009-05-31 23:43:22 +0000 |
| commit | 227ac8db0384d3f4ca5bbd479642807442692c85 (patch) | |
| tree | 79ff10074817aed2ada4dd8da2738f2e012ec592 /src/couchdb/couch_ref_counter.erl | |
| parent | 3f6d703833af0c2c7b6aa31525b6593588312e94 (diff) | |
Added timeout and heartbeat options to the _changes api
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@780529 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb/couch_ref_counter.erl')
| -rw-r--r-- | src/couchdb/couch_ref_counter.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/couchdb/couch_ref_counter.erl b/src/couchdb/couch_ref_counter.erl index 4c824aa6..0fbec729 100644 --- a/src/couchdb/couch_ref_counter.erl +++ b/src/couchdb/couch_ref_counter.erl @@ -75,7 +75,9 @@ handle_cast({drop, Pid}, #srv{referrers=Referrers}=Srv) -> erlang:demonitor(MonRef, [flush]), dict:erase(Pid, Referrers); {ok, {MonRef, Num}} -> - dict:store(Pid, {MonRef, Num-1}, Referrers) + dict:store(Pid, {MonRef, Num-1}, Referrers); + error -> + Referrers end, maybe_close_async(Srv#srv{referrers=Referrers2}). |