174 lines
6 KiB
Erlang
174 lines
6 KiB
Erlang
%% -------------------------------------------------------------------
|
|
%%
|
|
%% Machi: a small village of replicated files
|
|
%%
|
|
%% Copyright (c) 2014 Basho Technologies, Inc. All Rights Reserved.
|
|
%%
|
|
%% This file is provided to you 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.
|
|
%%
|
|
%% -------------------------------------------------------------------
|
|
%%%-------------------------------------------------------------------
|
|
%%% @author Hans Svensson <>
|
|
%%% @copyright (C) 2012, Hans Svensson
|
|
%%% @doc
|
|
%%%
|
|
%%% @end
|
|
%%% Created : 19 Mar 2012 by Hans Svensson <>
|
|
%%%-------------------------------------------------------------------
|
|
-module(handle_errors).
|
|
|
|
-behaviour(gen_event).
|
|
|
|
%% API
|
|
-export([start_link/0, add_handler/0]).
|
|
|
|
%% gen_event callbacks
|
|
-export([init/1, handle_event/2, handle_call/2,
|
|
handle_info/2, terminate/2, code_change/3]).
|
|
|
|
-define(SERVER, ?MODULE).
|
|
|
|
-record(state, { errors = [] }).
|
|
|
|
%%%===================================================================
|
|
%%% gen_event callbacks
|
|
%%%===================================================================
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @doc
|
|
%% Creates an event manager
|
|
%%
|
|
%% @spec start_link() -> {ok, Pid} | {error, Error}
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
start_link() ->
|
|
gen_event:start_link({local, ?SERVER}).
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @doc
|
|
%% Adds an event handler
|
|
%%
|
|
%% @spec add_handler() -> ok | {'EXIT', Reason} | term()
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
add_handler() ->
|
|
gen_event:add_handler(?SERVER, ?MODULE, []).
|
|
|
|
%%%===================================================================
|
|
%%% gen_event callbacks
|
|
%%%===================================================================
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% Whenever a new event handler is added to an event manager,
|
|
%% this function is called to initialize the event handler.
|
|
%%
|
|
%% @spec init(Args) -> {ok, State}
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
init([]) ->
|
|
{ok, #state{}}.
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% Whenever an event manager receives an event sent using
|
|
%% gen_event:notify/2 or gen_event:sync_notify/2, this function is
|
|
%% called for each installed event handler to handle the event.
|
|
%%
|
|
%% @spec handle_event(Event, State) ->
|
|
%% {ok, State} |
|
|
%% {swap_handler, Args1, State1, Mod2, Args2} |
|
|
%% remove_handler
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
handle_event({error, _, {_, "Hintfile '~s' has bad CRC" ++ _, _}}, State) ->
|
|
{ok, State};
|
|
handle_event({error, _, {_, "** Generic server" ++ _, _}}, State) ->
|
|
{ok, State};
|
|
handle_event({error, _, {_, "Failed to merge ~p: ~p\n", [_, not_ready]}}, State) ->
|
|
{ok, State};
|
|
handle_event({error, _, {_, "Failed to merge ~p: ~p\n", [_, {merge_locked, _, _}]}}, State) ->
|
|
{ok, State};
|
|
handle_event({error, _, {_, "Failed to read lock data from ~s: ~p\n", [_, {invalid_data, <<>>}]}}, State) ->
|
|
{ok, State};
|
|
handle_event({error, _, Event}, State) ->
|
|
{ok, State#state{ errors = [Event|State#state.errors] }};
|
|
handle_event(_Event, State) ->
|
|
{ok, State}.
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% Whenever an event manager receives a request sent using
|
|
%% gen_event:call/3,4, this function is called for the specified
|
|
%% event handler to handle the request.
|
|
%%
|
|
%% @spec handle_call(Request, State) ->
|
|
%% {ok, Reply, State} |
|
|
%% {swap_handler, Reply, Args1, State1, Mod2, Args2} |
|
|
%% {remove_handler, Reply}
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
handle_call(get_errors, S) ->
|
|
{ok, S#state.errors, S#state{ errors = [] }};
|
|
handle_call(_Request, State) ->
|
|
Reply = ok,
|
|
{ok, Reply, State}.
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% This function is called for each installed event handler when
|
|
%% an event manager receives any other message than an event or a
|
|
%% synchronous request (or a system message).
|
|
%%
|
|
%% @spec handle_info(Info, State) ->
|
|
%% {ok, State} |
|
|
%% {swap_handler, Args1, State1, Mod2, Args2} |
|
|
%% remove_handler
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
handle_info(_Info, State) ->
|
|
{ok, State}.
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% Whenever an event handler is deleted from an event manager, this
|
|
%% function is called. It should be the opposite of Module:init/1 and
|
|
%% do any necessary cleaning up.
|
|
%%
|
|
%% @spec terminate(Reason, State) -> void()
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
terminate(_Reason, _State) ->
|
|
ok.
|
|
|
|
%%--------------------------------------------------------------------
|
|
%% @private
|
|
%% @doc
|
|
%% Convert process state when code is changed
|
|
%%
|
|
%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
|
|
%% @end
|
|
%%--------------------------------------------------------------------
|
|
code_change(_OldVsn, State, _Extra) ->
|
|
{ok, State}.
|
|
|
|
%%%===================================================================
|
|
%%% Internal functions
|
|
%%%===================================================================
|