From d275d3f3b9e5bd10f14afc93030a57b3d63b978f Mon Sep 17 00:00:00 2001 From: Zatolokin Pavel Date: Thu, 25 Feb 2016 17:25:50 +0200 Subject: [PATCH] add till for process pid cache --- src/bpe_proc.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/bpe_proc.erl b/src/bpe_proc.erl index 8867f78..9493677 100644 --- a/src/bpe_proc.erl +++ b/src/bpe_proc.erl @@ -86,7 +86,8 @@ init(Process) -> Proc = case kvs:get(process,Process#process.id) of {ok,Exists} -> Exists; {error,_} -> Process end, - wf:cache({process,Proc#process.id},self()), + Till = n2o_session:till(calendar:local_time(), wf:config(bpe,ttl,24*60*60)), + wf:cache({process,Proc#process.id},self(),Till), [ wf:reg({messageEvent,Name,Proc#process.id}) || {Name,_} <- bpe:events(Proc) ], {ok, Proc#process{timer=erlang:send_after(crypto:rand_uniform(1,10000),self(),{timer,ping})}}.