Static log fun
This commit is contained in:
parent
b69ababf0f
commit
c8670ae1b9
@ -6,8 +6,6 @@
|
|||||||
|
|
||||||
-export([connect/4, slowly_connect/4]).
|
-export([connect/4, slowly_connect/4]).
|
||||||
|
|
||||||
-include("$zx_include/zx_logger.hrl").
|
|
||||||
|
|
||||||
|
|
||||||
connect(Node = {Host, Port}, Request, From, Timeout) ->
|
connect(Node = {Host, Port}, Request, From, Timeout) ->
|
||||||
Timer = erlang:send_after(Timeout, self(), timeout),
|
Timer = erlang:send_after(Timeout, self(), timeout),
|
||||||
@ -236,3 +234,10 @@ url({Node, Port}, Path) when is_list(Node) ->
|
|||||||
["https://", Node, ":", integer_to_list(Port), Path];
|
["https://", Node, ":", integer_to_list(Port), Path];
|
||||||
url({Node, Port}, Path) when is_tuple(Node) ->
|
url({Node, Port}, Path) when is_tuple(Node) ->
|
||||||
["https://", inet:ntoa(Node), ":", integer_to_list(Port), Path].
|
["https://", inet:ntoa(Node), ":", integer_to_list(Port), Path].
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
log(Level, Format, Args) ->
|
||||||
|
Raw = io_lib:format("~w ~w: " ++ Format, [?MODULE, self() | Args]),
|
||||||
|
Entry = unicode:characters_to_list(Raw),
|
||||||
|
logger:log(Level, Entry).
|
||||||
|
@ -29,8 +29,6 @@
|
|||||||
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
||||||
code_change/3, terminate/2]).
|
code_change/3, terminate/2]).
|
||||||
|
|
||||||
%% TODO: Make logging more flexible
|
|
||||||
-include("$zx_include/zx_logger.hrl").
|
|
||||||
|
|
||||||
|
|
||||||
%%% Type and Record Definitions
|
%%% Type and Record Definitions
|
||||||
@ -197,7 +195,7 @@ handle_info({'DOWN', Mon, process, PID, Info}, State) ->
|
|||||||
NewState = handle_down(PID, Mon, Info, State),
|
NewState = handle_down(PID, Mon, Info, State),
|
||||||
{noreply, NewState};
|
{noreply, NewState};
|
||||||
handle_info(Unexpected, State) ->
|
handle_info(Unexpected, State) ->
|
||||||
ok = log("Unexpected info: ~tp~n", [Unexpected]),
|
ok = log(warning, "Unexpected info: ~tp~n", [Unexpected]),
|
||||||
{noreply, State}.
|
{noreply, State}.
|
||||||
|
|
||||||
|
|
||||||
@ -287,3 +285,10 @@ do_request(Request,
|
|||||||
do_request(Request, From, State = #s{chain_nodes = {[], Used}}) ->
|
do_request(Request, From, State = #s{chain_nodes = {[], Used}}) ->
|
||||||
Fresh = lists:reverse(Used),
|
Fresh = lists:reverse(Used),
|
||||||
do_request(Request, From, State#s{chain_nodes = {Fresh, []}}).
|
do_request(Request, From, State#s{chain_nodes = {Fresh, []}}).
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
log(Level, Format, Args) ->
|
||||||
|
Raw = io_lib:format("~w ~w: " ++ Format, [?MODULE, self() | Args]),
|
||||||
|
Entry = unicode:characters_to_list(Raw),
|
||||||
|
Loading…
x
Reference in New Issue
Block a user