2525-record (state ,{raw_edge_list ,tap_ds ,tap_client_data ,query_count ,time_stamp }).
2626
2727start ()->
28+ Pid = spawn (? MODULE ,start ,[0 ,2 ,30 ]),
29+ Pid .
30+
31+
32+
33+ start (Time ,Interval ,MsgTime )->
2834 Receivers = tap_loom :get_ofdp_recv_list (),
2935 case Receivers of
30- [] -> timer :sleep (2000 ),
31- io :format (" tap_aggr: waiting for data recievers...~n " ),
32- start ();
33- _ -> io :format (" tap_aggr: starting...~n " ),
36+ [] -> timer :sleep (Interval * 1000 ),
37+ case Rem = Time rem MsgTime of
38+ Rem when Rem == 0 ->
39+ error_logger :info_msg (" tap_aggr: waiting for data recievers for ~p seconds...~n " ,[Time ]),
40+ start (Time + Interval ,Interval ,MsgTime );
41+ _ -> start (Time + Interval ,Interval ,MsgTime )
42+ end ;
43+ _ -> error_logger :info_msg (" tap_aggr: starting...~n " ),
3444 TapDS = tap_ds :start (),
3545 TCD = whereis (tap_client_data ),
3646 {_Date ,Time } = calendar :universal_time (),
@@ -41,6 +51,7 @@ start()->
4151 end .
4252
4353
54+
4455listen (State )->
4556 receive
4657 {dns_reply ,Reply }->
0 commit comments