@ -25,7 +25,7 @@
- export ( [ init / 1 , handle_call / 2 , handle_event / 2 , handle_info / 2 , terminate / 2 ,
code_change / 3 ] ) .
- include ( " lage r.hrl" ) .
- include ( " rum .hrl " ) .
- define ( TEST_SINK_NAME , '__lager_test_sink' ) . % % < -- used by parse transform
- define ( TEST_SINK_EVENT , '__lager_test_sink_lager_event' ) . % % < -- used by lager API calls and internals for gen_event
@ -57,7 +57,7 @@
- endif .
init ( Level ) - >
{ ok , #state { level = lage r_ util: config_to_mask ( Level ) , buffer = [ ] , ignored = [ ] } } .
{ ok , #state { level = rumU til : config_to_mask ( Level ) , buffer = [ ] , ignored = [ ] } } .
handle_call ( count , #state { buffer = Buffer } = State ) - >
{ ok , length ( Buffer ) , State } ;
@ -84,7 +84,7 @@ handle_call(get_buffer, #state{buffer=Buffer} = State) ->
handle_call ( get_loglevel , #state { level = Level } = State ) - >
{ ok , Level , State } ;
handle_call ( { set_loglevel , Level } , State ) - >
{ ok , ok , State #state { level = lage r_ util: config_to_mask ( Level ) } } ;
{ ok , ok , State #state { level = rumU til : config_to_mask ( Level ) } } ;
handle_call ( print_state , State ) - >
spawn ( fun ( ) - > lager : info ( " State ~p " , [ lager : pr ( State , ? MODULE ) ] ) end ) ,
timer : sleep ( 100 ) ,
@ -98,7 +98,7 @@ handle_call(_Request, State) ->
handle_event ( { log , Msg } ,
#state { level = LogLevel , buffer = Buffer , ignored = Ignored } = State ) - >
case lage r_ util: is_loggable ( Msg , LogLevel , ? MODULE ) of
case rumU til : is_loggable ( Msg , LogLevel , ? MODULE ) of
true - >
{ ok , State #state { buffer = Buffer ++
[ { lager_msg : severity_as_int ( Msg ) ,
@ -193,19 +193,19 @@ lager_test_() ->
lager : warning ( " test message " ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( " test message " , Message ) ,
ok
end
} ,
{ " logging with macro works " ,
fun ( ) - >
? lager_w arning ( " test message " , [ ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertEqual ( " test message " , Message ) ,
ok
? rumW arning( " test message " , [ ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( " test message " , Message ) ,
ok
end
} ,
{ " unsafe logging works " ,
@ -213,7 +213,7 @@ lager_test_() ->
lager : warning_unsafe ( " test message " ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( " test message " , Message ) ,
ok
end
@ -223,19 +223,19 @@ lager_test_() ->
lager : warning ( " test message ~p " , [ self ( ) ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( lists : flatten ( io_lib : format ( " test message ~p " , [ self ( ) ] ) ) , lists : flatten ( Message ) ) ,
ok
end
} ,
{ " logging with macro and arguments works " ,
fun ( ) - >
? lager_w arning ( " test message ~p " , [ self ( ) ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertEqual ( lists : flatten ( io_lib : format ( " test message ~p " , [ self ( ) ] ) ) , lists : flatten ( Message ) ) ,
ok
? rumW arning( " test message ~p " , [ self ( ) ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( lists : flatten ( io_lib : format ( " test message ~p " , [ self ( ) ] ) ) , lists : flatten ( Message ) ) ,
ok
end
} ,
{ " unsafe logging with args works " ,
@ -243,7 +243,7 @@ lager_test_() ->
lager : warning_unsafe ( " test message ~p " , [ self ( ) ] ) ,
? assertEqual ( 1 , count ( ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( lists : flatten ( io_lib : format ( " test message ~p " , [ self ( ) ] ) ) , lists : flatten ( Message ) ) ,
ok
end
@ -417,7 +417,7 @@ lager_test_() ->
lager : debug ( " this message will be ignored " ) ,
? assertEqual ( 0 , count ( ) ) ,
? assertEqual ( 0 , count_ignored ( ) ) ,
lager_config : set ( loglevel , { element ( 2 , lage r_ util: config_to_mask ( debug ) ) , [ ] } ) ,
lager_config : set ( loglevel , { element ( 2 , rumU til : config_to_mask ( debug ) ) , [ ] } ) ,
lager : debug ( " this message should be ignored " ) ,
? assertEqual ( 0 , count ( ) ) ,
? assertEqual ( 1 , count_ignored ( ) ) ,
@ -432,7 +432,7 @@ lager_test_() ->
} ,
{ " tracing works " ,
fun ( ) - >
lager_config : set ( loglevel , { element ( 2 , lage r_ util: config_to_mask ( error ) ) , [ ] } ) ,
lager_config : set ( loglevel , { element ( 2 , rumU til : config_to_mask ( error ) ) , [ ] } ) ,
ok = lager : info ( " hello world " ) ,
? assertEqual ( 0 , count ( ) ) ,
lager : trace ( ? MODULE , [ { module , ? MODULE } ] , debug ) ,
@ -449,7 +449,7 @@ lager_test_() ->
fun ( ) - >
lager : set_loglevel ( ? MODULE , error ) ,
? assertEqual ( { ? ERROR bor ? CRITICAL bor ? ALERT bor ? EMERGENCY , [ ] } , lager_config : get ( loglevel ) ) ,
lager_config : set ( loglevel , { element ( 2 , lage r_ util: config_to_mask ( error ) ) , [ ] } ) ,
lager_config : set ( loglevel , { element ( 2 , rumU til : config_to_mask ( error ) ) , [ ] } ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 0 , count ( ) ) ,
lager : trace ( ? MODULE , [ { requestid , 6 } , { foo , bar } ] , debug ) ,
@ -468,7 +468,7 @@ lager_test_() ->
fun ( ) - >
lager : set_loglevel ( ? MODULE , error ) ,
? assertEqual ( { ? ERROR bor ? CRITICAL bor ? ALERT bor ? EMERGENCY , [ ] } , lager_config : get ( loglevel ) ) ,
lager_config : set ( loglevel , { element ( 2 , lage r_ util: config_to_mask ( error ) ) , [ ] } ) ,
lager_config : set ( loglevel , { element ( 2 , rumU til : config_to_mask ( error ) ) , [ ] } ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 0 , count ( ) ) ,
lager : trace ( ? MODULE , [ { requestid , '>' , 5 } , { requestid , '<' , 7 } , { foo , bar } ] , debug ) ,
@ -535,40 +535,40 @@ lager_test_() ->
{ " tracing custom attributes works with event stream processing statistics and reductions " ,
fun ( ) - >
lager : set_loglevel ( ? MODULE , error ) ,
? assertEqual ( { ? ERROR bor ? CRITICAL bor ? ALERT bor ? EMERGENCY , [ ] } , lager_config : get ( loglevel ) ) ,
lager_config : set ( loglevel , { element ( 2 , lage r_ util: config_to_mask ( error ) ) , [ ] } ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 0 , count ( ) ) ,
lager : trace ( ? MODULE , [ { beta , '*' } ] ) ,
lager : trace ( ? MODULE , [ { meta , " data " } ] ) ,
lager : info ( [ { meta , " data " } ] , " hello world " ) ,
lager : info ( [ { beta , 2 } ] , " hello world " ) ,
lager : info ( [ { beta , 2 . 1 } , { foo , bar } ] , " hello world " ) ,
lager : info ( [ { meta , < < " data " > > } ] , " hello world " ) ,
? assertEqual ( 8 , ? DEFAULT_TRACER : info ( input ) ) ,
? assertEqual ( 6 , ? DEFAULT_TRACER : info ( output ) ) ,
? assertEqual ( 2 , ? DEFAULT_TRACER : info ( filter ) ) ,
lager : clear_all_traces ( ) ,
lager : trace ( ? MODULE , [ { meta , " data " } ] ) ,
lager : trace ( ? MODULE , [ { beta , '>' , 2 } , { beta , '<' , 2 . 12 } ] ) ,
lager : info ( [ { meta , " data " } ] , " hello world " ) ,
lager : info ( [ { beta , 2 } ] , " hello world " ) ,
lager : info ( [ { beta , 2 . 1 } , { foo , bar } ] , " hello world " ) ,
lager : info ( [ { meta , < < " data " > > } ] , " hello world " ) ,
? assertEqual ( 8 , ? DEFAULT_TRACER : info ( input ) ) ,
? assertEqual ( 4 , ? DEFAULT_TRACER : info ( output ) ) ,
? assertEqual ( 4 , ? DEFAULT_TRACER : info ( filter ) ) ,
lager : clear_all_traces ( ) ,
lager : trace_console ( [ { beta , '>' , 2 } , { meta , " data " } ] ) ,
lager : trace_console ( [ { beta , '>' , 2 } , { beta , '<' , 2 . 12 } ] ) ,
Reduced = { all , [ { any , [ { beta , '<' , 2 . 12 } , { meta , '=' , " data " } ] } ,
{ beta , '>' , 2 } ] } ,
? assertEqual ( Reduced , ? DEFAULT_TRACER : info ( 'query' ) ) ,
lager : clear_all_traces ( ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 5 , count ( ) ) ,
ok
? assertEqual ( { ? ERROR bor ? CRITICAL bor ? ALERT bor ? EMERGENCY , [ ] } , lager_config : get ( loglevel ) ) ,
lager_config : set ( loglevel , { element ( 2 , rumU til : config_to_mask ( error ) ) , [ ] } ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 0 , count ( ) ) ,
lager : trace ( ? MODULE , [ { beta , '*' } ] ) ,
lager : trace ( ? MODULE , [ { meta , " data " } ] ) ,
lager : info ( [ { meta , " data " } ] , " hello world " ) ,
lager : info ( [ { beta , 2 } ] , " hello world " ) ,
lager : info ( [ { beta , 2 . 1 } , { foo , bar } ] , " hello world " ) ,
lager : info ( [ { meta , < < " data " > > } ] , " hello world " ) ,
? assertEqual ( 8 , ? RumDefTracer : info ( input ) ) ,
? assertEqual ( 6 , ? RumDefTracer : info ( output ) ) ,
? assertEqual ( 2 , ? RumDefTracer : info ( filter ) ) ,
lager : clear_all_traces ( ) ,
lager : trace ( ? MODULE , [ { meta , " data " } ] ) ,
lager : trace ( ? MODULE , [ { beta , '>' , 2 } , { beta , '<' , 2 . 12 } ] ) ,
lager : info ( [ { meta , " data " } ] , " hello world " ) ,
lager : info ( [ { beta , 2 } ] , " hello world " ) ,
lager : info ( [ { beta , 2 . 1 } , { foo , bar } ] , " hello world " ) ,
lager : info ( [ { meta , < < " data " > > } ] , " hello world " ) ,
? assertEqual ( 8 , ? RumDefTracer : info ( input ) ) ,
? assertEqual ( 4 , ? RumDefTracer : info ( output ) ) ,
? assertEqual ( 4 , ? RumDefTracer : info ( filter ) ) ,
lager : clear_all_traces ( ) ,
lager : trace_console ( [ { beta , '>' , 2 } , { meta , " data " } ] ) ,
lager : trace_console ( [ { beta , '>' , 2 } , { beta , '<' , 2 . 12 } ] ) ,
Reduced = { all , [ { any , [ { beta , '<' , 2 . 12 } , { meta , '=' , " data " } ] } ,
{ beta , '>' , 2 } ] } ,
? assertEqual ( Reduced , ? RumDefTracer : info ( 'query' ) ) ,
lager : clear_all_traces ( ) ,
lager : info ( [ { requestid , 6 } ] , " hello world " ) ,
? assertEqual ( 5 , count ( ) ) ,
ok
end
} ,
{ " persistent traces work " ,
@ -605,17 +605,17 @@ lager_test_() ->
{ " stopped trace stops and removes its event handler - default sink (gh#267) " ,
{ timeout , 10 ,
fun ( ) - >
Sink = ? DEFAULT_SINK ,
StartHandlers = gen_event : which_handlers ( Sink ) ,
{ _ , T0 } = lager_config : get ( { Sink , loglevel } ) ,
StartGlobal = lager_config : global_get ( handlers ) ,
? assertEqual ( [ ] , T0 ) ,
{ ok , TestTrace1 } = lager : trace_file ( " /tmp/test " , [ { a , b } ] ) ,
MidHandlers = gen_event : which_handlers ( Sink ) ,
{ ok , TestTrace2 } = lager : trace_file ( " /tmp/test " , [ { c , d } ] ) ,
MidHandlers = gen_event : which_handlers ( Sink ) ,
? assertEqual ( length ( StartHandlers ) + 1 , length ( MidHandlers ) ) ,
MidGlobal = lager_config : global_get ( handlers ) ,
Sink = ? RumDefSink ,
StartHandlers = gen_event : which_handlers ( Sink ) ,
{ _ , T0 } = lager_config : get ( { Sink , loglevel } ) ,
StartGlobal = lager_config : global_get ( handlers ) ,
? assertEqual ( [ ] , T0 ) ,
{ ok , TestTrace1 } = lager : trace_file ( " /tmp/test " , [ { a , b } ] ) ,
MidHandlers = gen_event : which_handlers ( Sink ) ,
{ ok , TestTrace2 } = lager : trace_file ( " /tmp/test " , [ { c , d } ] ) ,
MidHandlers = gen_event : which_handlers ( Sink ) ,
? assertEqual ( length ( StartHandlers ) + 1 , length ( MidHandlers ) ) ,
MidGlobal = lager_config : global_get ( handlers ) ,
? assertEqual ( length ( StartGlobal ) + 1 , length ( MidGlobal ) ) ,
{ _ , T1 } = lager_config : get ( { Sink , loglevel } ) ,
? assertEqual ( 2 , length ( T1 ) ) ,
@ -640,8 +640,8 @@ lager_test_() ->
fun ( ) - >
print_state ( ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( info ) ) ,
{ mask , Mask } = lage r_ util: config_to_mask ( info ) ,
? assertMatch ( Level , rumU til : level_to_num ( info ) ) ,
{ mask , Mask } = rumU til : config_to_mask ( info ) ,
? assertEqual ( " State #state{level={mask, " ++ integer_to_list ( Mask ) ++ " },buffer=[],ignored=[]} " , lists : flatten ( Message ) ) ,
ok
end
@ -650,7 +650,7 @@ lager_test_() ->
fun ( ) - >
print_bad_state ( ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( info ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( info ) ) ,
? assertEqual ( " State {state,1} " , lists : flatten ( Message ) ) ,
ok
end
@ -660,7 +660,7 @@ lager_test_() ->
spawn ( fun ( ) - > lager : info ( " State ~p " , [ lager : pr ( { state , 1 } , lager ) ] ) end ) ,
timer : sleep ( 100 ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( info ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( info ) ) ,
? assertEqual ( " State {state,1} " , lists : flatten ( Message ) ) ,
ok
end
@ -670,7 +670,7 @@ lager_test_() ->
spawn ( fun ( ) - > lager : info ( " State ~p " , [ lager : pr ( ok , lager ) ] ) end ) ,
timer : sleep ( 100 ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( info ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( info ) ) ,
? assertEqual ( " State ok " , lists : flatten ( Message ) ) ,
ok
end
@ -680,7 +680,7 @@ lager_test_() ->
spawn ( fun ( ) - > lager : info ( " State ~p " , [ lager : pr ( { state , 1 } , not_a_module ) ] ) end ) ,
timer : sleep ( 1000 ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( info ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( info ) ) ,
? assertEqual ( " State {state,1} " , lists : flatten ( Message ) ) ,
ok
end
@ -766,7 +766,7 @@ extra_sinks_test_() ->
? TEST_SINK_NAME : warning ( " test message " ) ,
? assertEqual ( 1 , count ( ? TEST_SINK_EVENT ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ? TEST_SINK_EVENT ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( " test message " , Message ) ,
ok
end
@ -776,7 +776,7 @@ extra_sinks_test_() ->
? TEST_SINK_NAME : warning ( " test message ~p " , [ self ( ) ] ) ,
? assertEqual ( 1 , count ( ? TEST_SINK_EVENT ) ) ,
{ Level , _ Time , Message , _ Metadata } = pop ( ? TEST_SINK_EVENT ) ,
? assertMatch ( Level , lage r_ util: level_to_num ( warning ) ) ,
? assertMatch ( Level , rumU til : level_to_num ( warning ) ) ,
? assertEqual ( lists : flatten ( io_lib : format ( " test message ~p " , [ self ( ) ] ) ) , lists : flatten ( Message ) ) ,
ok
end
@ -850,7 +850,7 @@ extra_sinks_test_() ->
? TEST_SINK_NAME : debug ( " this message will be ignored " ) ,
? assertEqual ( 0 , count ( ? TEST_SINK_EVENT ) ) ,
? assertEqual ( 0 , count_ignored ( ? TEST_SINK_EVENT ) ) ,
lager_config : set ( { ? TEST_SINK_EVENT , loglevel } , { element ( 2 , lage r_ util: config_to_mask ( debug ) ) , [ ] } ) ,
lager_config : set ( { ? TEST_SINK_EVENT , loglevel } , { element ( 2 , rumU til : config_to_mask ( debug ) ) , [ ] } ) ,
? TEST_SINK_NAME : debug ( " this message should be ignored " ) ,
? assertEqual ( 0 , count ( ? TEST_SINK_EVENT ) ) ,
? assertEqual ( 1 , count_ignored ( ? TEST_SINK_EVENT ) ) ,
@ -1032,7 +1032,7 @@ crash_fsm_test_() ->
fun ( Sink ) - >
{ Name ,
fun ( ) - >
case { FsmModule =:= crash_statem , lage r_ util: otp_version ( ) < 19 } of
case { FsmModule =:= crash_statem , rumU til : otp_version ( ) < 19 } of
{ true , true } - > ok ;
_ - >
Pid = whereis ( FsmModule ) ,
@ -1040,7 +1040,7 @@ crash_fsm_test_() ->
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
test_body ( Expected , lists : flatten ( Msg ) ) ,
? assertEqual ( Pid , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level )
? assertEqual ( rumU til : level_to_num ( error ) , Level )
end
end
}
@ -1085,7 +1085,7 @@ error_logger_redirect_crash_test_() ->
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
test_body ( Expected , lists : flatten ( Msg ) ) ,
? assertEqual ( Pid , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level )
? assertEqual ( rumU til : level_to_num ( error ) , Level )
end
}
end
@ -1175,7 +1175,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( [ { this , is } , a , { silly , format } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = " this: is, a, silly: format " ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1187,7 +1187,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( " this is less silly " ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = " this is less silly " ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1198,7 +1198,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_msg ( " doom, doom has come upon you all " ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = " doom, doom has come upon you all " ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1209,7 +1209,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_msg ( " ~ ts " , [ " Привет! " ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Привет! " , lists : flatten ( Msg ) )
end
@ -1228,7 +1228,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( [ { this , is } , a , { silly , format } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = " this: is, a, silly: format " ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1239,7 +1239,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( [ [ { this , is } , a , { silly , format } ] | | _ < - lists : seq ( 0 , 600 ) ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assert ( length ( lists : flatten ( Msg ) ) < 5000 )
end
@ -1249,7 +1249,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( { foolish , bees } ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " {foolish,bees} " , lists : flatten ( Msg ) )
end
@ -1259,7 +1259,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( { foolish , bees } ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " {foolish,bees} " , lists : flatten ( Msg ) )
end
@ -1269,7 +1269,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( " this is less silly " ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " this is less silly " , lists : flatten ( Msg ) )
end
@ -1279,7 +1279,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( string : copies ( " this is less silly " , 1000 ) ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assert ( length ( lists : flatten ( Msg ) ) < 5100 )
end
@ -1289,7 +1289,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( [ " this is less silly " , { than , " this " } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " \" this is less silly \" , than: \" this \" " , lists : flatten ( Msg ) )
end
@ -1299,7 +1299,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_msg ( " doom, doom has come upon you all " ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " doom, doom has come upon you all " , lists : flatten ( Msg ) )
end
@ -1309,7 +1309,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_msg ( " doom, doom has come upon you all ~p " , [ string : copies ( " doom " , 10000 ) ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assert ( length ( lists : flatten ( Msg ) ) < 5100 )
end
@ -1319,7 +1319,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_msg ( " ~ ts " , [ " Привет! " ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Привет! " , lists : flatten ( Msg ) )
end
@ -1348,7 +1348,7 @@ error_logger_redirect_test_() ->
sync_error_logger : warning_msg ( " ~ ts " , [ " Привет! " ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( Lvl ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( Lvl ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Привет! " , lists : flatten ( Msg ) )
end
@ -1360,7 +1360,7 @@ error_logger_redirect_test_() ->
sync_error_logger : warning_msg ( " doom, doom has come upon you all " ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( Lvl ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( Lvl ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " doom, doom has come upon you all " , lists : flatten ( Msg ) )
end
@ -1372,7 +1372,7 @@ error_logger_redirect_test_() ->
sync_error_logger : warning_report ( [ { i , like } , pie ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( Lvl ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( Lvl ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " i: like, pie " , lists : flatten ( Msg ) )
end
@ -1384,7 +1384,7 @@ error_logger_redirect_test_() ->
sync_error_logger : warning_report ( { foolish , bees } ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( Lvl ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( Lvl ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " {foolish,bees} " , lists : flatten ( Msg ) )
end
@ -1394,7 +1394,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( [ { application , foo } , { exited , quittin_time } , { type , lazy } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Application foo exited with reason: quittin_time " , lists : flatten ( Msg ) )
end
@ -1404,7 +1404,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( supervisor_report , [ { errorContext , france } , { offender , [ { name , mini_steve } , { mfargs , { a , b , [ c ] } } , { pid , bleh } ] } , { reason , fired } , { supervisor , { local , steve } } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor steve had child mini_steve started with a:b(c) at bleh exit with reason fired in context france " , lists : flatten ( Msg ) )
end
@ -1414,7 +1414,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( supervisor_report , [ { errorContext , france } , { offender , [ { name , mini_steve } , { mfargs , { a , b , [ c ] } } , { pid , bleh } ] } , { reason , { function_clause , [ { crash , handle_info , [ foo ] } ] } } , { supervisor , { local , steve } } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor steve had child mini_steve started with a:b(c) at bleh exit with reason no function clause matching crash:handle_info(foo) in context france " , lists : flatten ( Msg ) )
end
@ -1425,7 +1425,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( supervisor_report , [ { errorContext , france } , { offender , [ { name , mini_steve } , { mfargs , { a , b , [ c ] } } , { pid , bleh } ] } , { reason , { function_clause , [ { crash , handle_info , [ foo ] } ] } } , { supervisor , somepid } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor somepid had child mini_steve started with a:b(c) at bleh exit with reason no function clause matching crash:handle_info(foo) in context france " , lists : flatten ( Msg ) )
end
@ -1436,7 +1436,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( supervisor_report , [ { errorContext , france } , { offender , [ { mod , mini_steve } , { pid , bleh } ] } , { reason , fired } , { supervisor , { local , steve } } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor steve had child at module mini_steve at bleh exit with reason fired in context france " , lists : flatten ( Msg ) )
end
@ -1446,7 +1446,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( progress , [ { application , foo } , { started_at , node ( ) } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( info ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( info ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " Application foo started on node ~w " , [ node ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1459,7 +1459,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( progress , [ { supervisor , { local , foo } } , { started , [ { mfargs , { foo , bar , 1 } } , { pid , baz } ] } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( debug ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( debug ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor foo started foo:bar/1 at pid baz " , lists : flatten ( Msg ) )
end
@ -1471,7 +1471,7 @@ error_logger_redirect_test_() ->
sync_error_logger : info_report ( progress , [ { supervisor , somepid } , { started , [ { mfargs , { foo , bar , 1 } } , { pid , baz } ] } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( debug ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( debug ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Supervisor somepid started foo:bar/1 at pid baz " , lists : flatten ( Msg ) )
end
@ -1481,7 +1481,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , [ ] } , { error_info , { error , emfile , [ { stack , trace , 1 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: maximum number of file descriptors exhausted, check ulimit -n " , [ self ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1492,7 +1492,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , [ ] } , { error_info , { error , system_limit , [ { erlang , spawn , 1 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: system limit: maximum number of processes exceeded " , [ self ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1503,7 +1503,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , [ ] } , { error_info , { error , system_limit , [ { erlang , spawn_opt , 1 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: system limit: maximum number of processes exceeded " , [ self ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1514,7 +1514,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , [ ] } , { error_info , { error , system_limit , [ { erlang , open_port , 1 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: system limit: maximum number of ports exceeded " , [ self ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1525,7 +1525,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , [ ] } , { error_info , { error , system_limit , [ { erlang , list_to_atom , 1 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: system limit: tried to create an atom larger than 255, or maximum atom count exceeded " , [ self ( ) ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1536,7 +1536,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_report ( crash_report , [ [ { pid , self ( ) } , { registered_name , test } , { error_info , { error , system_limit , [ { ets , new , [ segment_offsets , [ ordered_set , public ] ] } , { mi_segment , open_write , 1 } , { mi_buffer_converter , handle_cast , 2 } , { gen_server , handle_msg , 5 } , { proc_lib , init_p_do_apply , 3 } ] } } ] , [ ] ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
Expected = lists : flatten ( io_lib : format ( " CRASH REPORT Process ~w with 0 neighbours crashed with reason: system limit: maximum number of ETS tables exceeded " , [ test ] ) ) ,
? assertEqual ( Expected , lists : flatten ( Msg ) )
@ -1612,7 +1612,7 @@ error_logger_redirect_test_() ->
sync_error_logger : error_msg ( " webmachine error: path= ~p ~n ~p ~n " , [ Path , Reason ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Webmachine error at path \" /cgi-bin/phpmyadmin \" : no match of right hand value {error,timeout} in myapp:dostuff/2 line 123 " , lists : flatten ( Msg ) )
@ -1633,7 +1633,7 @@ error_logger_redirect_test_() ->
" Request " , Stack ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Cowboy handler my_handler terminated in my_handler:init/3 with reason: no match of right hand value {error,timeout} in my_handler:init/3 line 123 " , lists : flatten ( Msg ) )
end
@ -1652,7 +1652,7 @@ error_logger_redirect_test_() ->
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Cowboy handler my_handler terminated in my_handler:somecallback/3 with reason: no match of right hand value {error,timeout} in my_handler:somecallback/3 line 123 " , lists : flatten ( Msg ) )
end
@ -1666,7 +1666,7 @@ error_logger_redirect_test_() ->
[ my_handler , to_json , 2 , " Request " , { } ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Cowboy handler my_handler terminated with reason: call to undefined function my_handler:to_json/2 " , lists : flatten ( Msg ) )
end
@ -1683,7 +1683,7 @@ error_logger_redirect_test_() ->
[ my_listner , ConnectionPid , 1 , self ( ) , { badmatch , 2 } , Stack ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
{ Level , _ , Msg , Metadata } = pop ( Sink ) ,
? assertEqual ( lage r_ util: level_to_num ( error ) , Level ) ,
? assertEqual ( rumU til : level_to_num ( error ) , Level ) ,
? assertEqual ( self ( ) , proplists : get_value ( pid , Metadata ) ) ,
? assertEqual ( " Cowboy stream 1 with ranch listener my_listner and "
" connection process <0.82.0> had its request process exit "
@ -1707,7 +1707,7 @@ error_logger_redirect_test_() ->
? assertEqual ( 0 , count_ignored ( Sink ) ) ,
lager : set_loglevel ( Sink , ? MODULE , undefined , error ) ,
? assertEqual ( { ? ERROR bor ? CRITICAL bor ? ALERT bor ? EMERGENCY , [ ] } , lager_config : get ( { Sink , loglevel } ) ) ,
lager_config : set ( { Sink , loglevel } , { element ( 2 , lage r_ util: config_to_mask ( debug ) ) , [ ] } ) ,
lager_config : set ( { Sink , loglevel } , { element ( 2 , rumU til : config_to_mask ( debug ) ) , [ ] } ) ,
sync_error_logger : info_report ( [ hello , world ] ) ,
_ = gen_event : which_handlers ( error_logger ) ,
? assertEqual ( 1 , count ( Sink ) ) ,
@ -1785,7 +1785,7 @@ async_threshold_test_() ->
% % put a ton of things in the queue
WorkCnt = erlang : max ( 10 , ( erlang : system_info ( schedulers ) * 2 ) ) ,
OtpVsn = lage r_ util: otp_version ( ) ,
OtpVsn = rumU til : otp_version ( ) ,
% newer OTPs * may * handle the messages faster , so we ' ll send more
MsgCnt = ( ( OtpVsn * OtpVsn ) div 2 ) ,
Workers = spawn_stuffers ( WorkCnt , [ MsgCnt , info , " hello world " ] , [ ] ) ,