commit 41d82533aa59ca271619e822f4542faa5f3d028c
author Paul J. Davis <paul.joseph.davis@gmail.com> Tue Apr 23 17:05:55 2013 -0500
committer Robert Newson <rnewson@apache.org> Tue Jul 29 11:26:06 2014 +0100
tree 8d051dbac8b87cf0e07032d1354b4a80b057c831
parent f17c21fb635f86319cce46fd502e01efebea59f8

Update to use new couch_event application

src/ddoc_cache.app.src

diff --git a/src/ddoc_cache.app.src b/src/ddoc_cache.app.src
index 55a108f..7d03bdf 100644
--- a/src/ddoc_cache.app.src
+++ b/src/ddoc_cache.app.src
@@ -28,6 +28,7 @@
         kernel,
         stdlib,
         crypto,
+        couch_event,
         ets_lru,
         mem3,
         fabric,

src/ddoc_cache_opener.erl

diff --git a/src/ddoc_cache_opener.erl b/src/ddoc_cache_opener.erl
index 0a0198e..c0a85b4 100644
--- a/src/ddoc_cache_opener.erl
+++ b/src/ddoc_cache_opener.erl
@@ -37,7 +37,7 @@
 ]).
 
 -export([
-    evictor/1
+    handle_db_event/3
 ]).
 
 
@@ -63,7 +63,9 @@
 init(_) ->
     process_flag(trap_exit, true),
     ets:new(?OPENING, [set, protected, named_table, {keypos, #opener.key}]),
-    {ok, Evictor} = couch_db_update_notifier:start_link(fun ?MODULE:evictor/1),
+    {ok, Evictor} = couch_event:link_listener(
+            ?MODULE, handle_db_event, nil, [all_dbs]
+        ),
     {ok, #st{
         evictor = Evictor
     }}.
@@ -127,7 +129,7 @@
 
 handle_info({'EXIT', Pid, Reason}, #st{evictor=Pid}=St) ->
     couch_log:error("ddoc_cache_opener evictor died ~w", [Reason]),
-    {ok, Evictor} = couch_db_update_notifier:start_link(fun ?MODULE:evictor/1),
+    {ok, Evictor} = couch_event:link_listener(?MODULE, evictor, nil, [all_dbs]),
     {noreply, St#st{evictor=Evictor}};
 
 handle_info({'EXIT', _Pid, {open_ok, Key, Resp}}, St) ->
@@ -157,14 +159,14 @@
     {ok, State}.
 
 
-evictor({created, ShardDbName}) ->
-    DbName = mem3:dbname(ShardDbName),
-    gen_server:cast(?MODULE, {evict, DbName});
-evictor({deleted, ShardDbName}) ->
-    DbName = mem3:dbname(ShardDbName),
-    gen_server:cast(?MODULE, {evict, DbName});
-evictor(_) ->
-    ok.
+handle_db_event(ShardDbName, created, St) ->
+    gen_server:cast(?MODULE, {evict, mem3:dbname(ShardDbName)}),
+    {ok, St};
+handle_db_event(ShardDbName, deleted, St) ->
+    gen_server:cast(?MODULE, {evict, mem3:dbname(ShardDbName)}),
+    {ok, St};
+handle_db_event(_DbName, _Event, St) ->
+    {ok, St}.
 
 
 open_ddoc({DbName, validation_funs}=Key) ->