Packages

bpe

6.5.3
13.5.22-aleph 11.4.16 11.4.15 11.4.14 11.4.13 9.9.7 9.9.6 8.12.4 8.12.3 8.12.1 8.12.0 retired 8.2.1 8.2.0 8.1.0 7.11.0 7.10.4 7.10.3 7.10.2 7.10.1 7.9.1 7.9.0 7.8.2 7.8.1 7.8.0 7.6.4 7.6.3 7.6.2 7.6.1 7.6.0 7.5.15 7.5.14 7.5.13 7.5.12 7.5.11 7.5.10 7.5.9 7.5.8 7.5.7 7.5.6 7.5.5 7.5.3 7.5.2 7.5.1 7.5.0 7.4.11 7.4.10 7.4.9 7.4.8 7.4.7 7.4.6 7.4.5 7.4.4 7.4.3 7.4.2 7.4.1 7.4.0 7.3.0 7.2.8 7.2.7 7.2.6 7.1.6 7.1.5 7.1.4 7.1.3 7.1.2 6.12.7 6.12.6 6.12.5 6.12.3 6.12.2 6.12.1 6.12.0 6.11.0 6.10.0 6.5.3 6.5.2 6.5.1 6.5.0 6.4.0 6.3.0 5.12.0 5.11.4 5.11.3 5.11.2 5.11.1 5.11.0 5.8.7 5.8.6 5.8.5 5.8.4 5.8.3 5.8.2 5.8.1 5.8.0 5.7.0 5.6.0 5.5.2 5.5.1 5.4.0 5.2.0 5.1.3 5.1.2 5.1.1 4.12.4 4.12.3 4.12.2 4.12.1 4.12.0 4.11.8 4.11.7 4.11.6 4.11.5 4.11.4 4.11.3 4.11.2 4.11.1 4.11.0 4.10.24 4.10.23 4.10.22 4.10.21 4.10.20 4.10.19 4.10.18 4.10.17 4.10.16 4.10.15 4.10.14 4.10.13 4.10.12 4.10.11 4.10.10 4.10.9 4.10.8 4.10.7 4.10.6 4.10.5 4.10.4 4.10.3 4.10.2 4.10.1 4.10.0 4.9.18 4.9.17 4.9.16 4.9.15 4.9.14 4.9.13 4.9.12 4.9.11 4.9.10 4.9.9 4.9.8 4.9.7 4.9.6 4.9.5 4.9.4 4.9.3 4.9.2 4.9.1 4.9.0 4.8.1 4.8.0 4.7.5 4.7.3 4.7.2 4.7.1 4.7.0 4.6.0 2.4.0 0.7.16

ERP/1: RTP GST WebRTC ICE SDP H.264 H.265 MP4 MPEG-2 HLS HEVC

HexDocs

Current section

Files

Jump to
Readme
171 Versions
3 Dependencies
Dependants
Files
Activity
bpe src ext bpe_ping.erl
Raw

src/ext/bpe_ping.erl 

-module(bpe_ping).

-include_lib("bpe/include/bpe.hrl").

-compile(export_all).



timer_restart(Diff) -> {X,Y,Z} = Diff, erlang:send_after(500*(Z+60*Y+60*60*X),self(),{timer,ping}).

ping() -> application:get_env(bpe,ping,{0,0,30}).

termination() -> application:get_env(bpe,boundary,{7,{0,0,0}}).

ping(State=#process{timer=Timer,id=Id,modified = #ts{time=Time2}, events=_Events,notifications=_Pid}) ->

    case Timer of [] -> skip; _ -> erlang:cancel_timer(Timer) end,

    case bpe:head(Id) of

        #hist{time=#ts{time=Time1}} ->

            {D1,Diff1} = calendar:time_difference(Time1,calendar:local_time()),

            {D2,Diff2} = calendar:time_difference(Time2,calendar:local_time()),

            % io:format("BPE timer ~p: ~p~n",[Id,[{D1,Diff1},{D2,Diff2}]]),

            case {D1,Diff1} > termination() orelse {D2,Diff2} > termination() of

                 true  -> {stop,normal,State};

                 false -> {noreply,State#process{timer=timer_restart(ping())}} end;

        _ -> skip

    end.