scottk/wlan-cloud-loadsim
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-loadsim.git synced 2025-11-03 20:18:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixing transact

Browse Source
This commit is contained in:
stephb9959
2021-04-01 14:20:35 -07:00
parent da5b4b5561
commit aea3ded79d
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/ovsdb_process.erl
View File

@@ -9,6 +9,12 @@
-module(ovsdb_process). -module(ovsdb_process).
-author("stephb"). -author("stephb").
%% [rows=[Row [columns={freq_band=2.4G}], Row [columns={freq_band=5GU}], Row [columns={freq_band=5GL}]]]
%% [rows=[Row [columns={freq_band=2.4G}]], [Row [columns={freq_band=5GU}]], Row [columns={freq_band=5GL}]]]
-compile({parse_transform, lager_transform}). -compile({parse_transform, lager_transform}).
-include("../include/ovsdb_definitions.hrl"). -include("../include/ovsdb_definitions.hrl").
@@ -41,8 +47,8 @@ do(#{ <<"method">> := <<"monitor">>, <<"id">> := ID, <<"params">> := Params } =
Response = #{ <<"id">> => ID, <<"result">> => #{}, <<"error">> => null }, Response = #{ <<"id">> => ID, <<"result">> => #{}, <<"error">> => null },
{ reply , jsx:encode(Response), NewState } { reply , jsx:encode(Response), NewState }
end; end;
do(#{ <<"method">> := <<"transact">> , <<"id">> := ID, <<"params">> := [<<"Open_vSwitch">> | Operations] } = _Request, APS ) -> do(#{ <<"method">> := <<"transact">> , <<"id">> := ID, <<"params">> := [<<"Open_vSwitch">> | Operations] } = Request, APS ) ->
% log_transact(ID,Params,APS), ?L_IA("~p: Transact request: ~p",[APS#ap_state.id,Request]),
transact(ID,Operations,APS,[]); transact(ID,Operations,APS,[]);
do(#{ <<"id">> := ID, <<"result">> := _Result, <<"error">> := _Error } = _Request, APS )-> do(#{ <<"id">> := ID, <<"result">> := _Result, <<"error">> := _Error } = _Request, APS )->
?L_IA("~p: OVSDB-REQUEST:Received answer (ignoring): ~p.~n,",[APS#ap_state.id,ID]), ?L_IA("~p: OVSDB-REQUEST:Received answer (ignoring): ~p.~n,",[APS#ap_state.id,ID]),
@@ -80,11 +86,14 @@ report_monitored_table(TableName,APS) ->
-spec transact( Id::integer(), Params::[], APS::ap_state(), Response::list() ) -> { reply, binary(),NewState::ap_state() } | -spec transact( Id::integer(), Params::[], APS::ap_state(), Response::list() ) ->
{ reply, binary(),NewState::ap_state() } |
{ noreply , NewState::ap_state() }. { noreply , NewState::ap_state() }.
transact( Id, [] ,APS, ResponseAcc )-> transact( Id, [] ,APS, ResponseAcc )->
Response = #{ <<"id">> => Id, <<"error">> => null, <<"result">> => lists:reverse(ResponseAcc)}, Response = #{ <<"id">> => Id, <<"error">> => null, <<"result">> => lists:reverse(ResponseAcc)},
{ reply, jsx:encode(Response),APS}; ResponseJson = jsx:encode(Response),
?L_IA("~p: JSON Response: ~p.",[APS#ap_state.id,ResponseJson]),
{ reply, ResponseJson,APS};
transact( Id, [#{ <<"columns">> := Columns, <<"op">> := <<"select">>, <<"table">> := Table , <<"where">> := Where } | MoreOperations ] = _Params ,APS, ResponseAcc )-> transact( Id, [#{ <<"columns">> := Columns, <<"op">> := <<"select">>, <<"table">> := Table , <<"where">> := Where } | MoreOperations ] = _Params ,APS, ResponseAcc )->
case lists:member(Table,APS#ap_state.known_table_names) of case lists:member(Table,APS#ap_state.known_table_names) of
false -> false ->