~ubuntu-branches/debian/wheezy/couchdb/wheezy

%   Copyright 2007, 2008 Damien Katz <damien_katz@yahoo.com>

%

%   Licensed under the Apache License, Version 2.0 (the "License");

%   you may not use this file except in compliance with the License.

%   You may obtain a copy of the License at

%

%       http://www.apache.org/licenses/LICENSE-2.0

%

%   Unless required by applicable law or agreed to in writing, software

%   distributed under the License is distributed on an "AS IS" BASIS,

%   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

%   See the License for the specific language governing permissions and

%   limitations under the License.

 

%

% This causes an OS process to spawned and it is notified every time a database is updated.

%

% The notifications are in the form of a the database name sent as a line of text to the OS processes

% stdout.

%

 

-module(couch_db_update_notifier).

 

-behaviour(gen_event).

 

-export([start_link/1, notify_all/1]).

-export([init/1, terminate/2, handle_event/2, handle_call/2, handle_info/2, code_change/3,stop/1]).

 

-define(ERR_HANDLE, {Port, {exit_status, Status}} -> {stop, {unknown_error, Status}, {unknown_error, Status}, Port}).

 

start_link(Exec) ->

    couch_event_sup:start_link(couch_db_update, {couch_db_update_notifier, make_ref()}, Exec).

 

notify_all(DbName) ->

    gen_event:notify(couch_db_update, {db_updated, DbName}).

 

stop(Pid) ->

    couch_event_sup:stop(Pid).

 

init(Exec) ->

    Port = open_port({spawn, Exec}, [stream, exit_status, hide]),

    {ok, Port}.

 

terminate(_Reason, _Port) ->

    ok.

 

handle_event({db_updated, DbName}, Port) ->

    %% send a notification

    true = port_command(Port, DbName ++ "\n"),

    {ok, Port}.

 

handle_call(_Request, State) ->

    {ok, ok, State}.

 

handle_info({'EXIT', _, _Reason}, _Port) ->

    remove_handler.

 

code_change(_OldVsn, State, _Extra) ->

    {ok, State}.