@@ -164,10 +164,8 @@ handle_cast(run , State) ->
164164
165165 NewState = maps :map (fun
166166 (K , V1 ) when is_map (V1 ) ->
167- {SetId , _CardinalityId } = achlys_util :get_variable_identifier (K ),
168- {ok , {Id ,_ ,_ ,_ }} = lasp :declare ({SetId , state_awset }, state_awset ),
169- % Id = achlys_util:declare_crdt(K , state_awset),
170- % Id = maybe_declare_crdt(K , state_awset_ps),
167+ {SetId , _CardinalityId } = achlys_util :get_variable_identifier (K ),
168+ {ok , {Id ,_ ,_ ,_ }} = lasp :declare ({SetId , state_awset }, state_awset ),
171169
172170 V2 = mapz :deep_put ([crdt ], Id , V1 ),
173171 T = create_table (K ),
@@ -217,7 +215,6 @@ handle_info(temperature , State) ->
217215 Res = maybe_get_temp () ,
218216 case Res of
219217 {ok , [Temp ]} when is_number (Temp ) ->
220- % true = ets:insert_new(State#state.measures , {?TIME , [Temp]});
221218 true = ets :insert_new (temperature , {? TIME , erlang :round (Temp )});
222219 _ ->
223220 logger :log (notice , " Could not fetch temperature : ~p ~n " , [Res ])
@@ -231,7 +228,6 @@ handle_info(pressure , State) ->
231228 Res = maybe_get_press () ,
232229 case Res of
233230 {ok , [Press ]} when is_number (Press ) ->
234- % true = ets:insert_new(State#state.measures , {?TIME , [Press]});
235231 true = ets :insert_new (pressure , {? TIME , erlang :round (Press )});
236232 _ ->
237233 logger :log (notice , " Could not fetch pressure : ~p ~n " , [Res ])
@@ -251,14 +247,10 @@ handle_info({mean, Val} , State) ->
251247 Len = ets :info (Val , size ),
252248 _ = case Len >= A of
253249 true ->
254- % Mean = get_mean(Val) ,
255- % {ok, {C2, _, _, _}} = lasp:update(C , {add , {State#state.number , T, Mean}} , self());
256250 {_Sample , Mean } = get_mean (Val ) ,
257251 ComputedSample = (maps :get (Val , State # state .aggregations ) * A ) ,
258- % logger:log(debug , "ETS size : ~p Computed : ~p ~n" , [Sample,ComputedSample]) ,
259252 {ok , {C2 , _ , _ , _ }} = lasp :update (
260253 C ,
261- % {add , {State#state.number , ComputedSample , erlang:round(Mean)}} ,
262254 {add , {ComputedSample , erlang :round (Mean )}} ,
263255 self ());
264256 _ ->
@@ -345,7 +337,6 @@ code_change(_OldVsn , State , _Extra) ->
345337get_mean (Tab ) ->
346338 Sum = ets :foldl (fun
347339 (Elem , AccIn ) ->
348- % {_ , [Temp]} = Elem ,
349340 {_ , Temp } = Elem ,
350341 Temp + AccIn
351342 end , 0 , Tab ) ,
@@ -391,8 +382,7 @@ is_pmod_nav_alive() ->
391382 _ :_ ->
392383 {error , unknown }
393384 end .
394- % error:{badmatch, {device, ?PMOD_NAV_SLOT, pmod_nav, _Pid, _Ref}} ->
395- % {error, no_pmod_nav};
385+
396386create_table (Name ) ->
397387 case ets :info (Name , size ) of
398388 undefined ->
0 commit comments