diff options
Diffstat (limited to 'components/dlink_bt/src/dlink_bt_rpc.erl')
| -rw-r--r-- | components/dlink_bt/src/dlink_bt_rpc.erl | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/components/dlink_bt/src/dlink_bt_rpc.erl b/components/dlink_bt/src/dlink_bt_rpc.erl index c4276bd..e0835f9 100644 --- a/components/dlink_bt/src/dlink_bt_rpc.erl +++ b/components/dlink_bt/src/dlink_bt_rpc.erl @@ -475,7 +475,7 @@ handle_socket(_FromPid, SetupBTAddr, SetupChannel, error, _ExtraArgs) -> %% JSON-RPC entry point %% CAlled by local exo http server -handle_notification("service_available", Args) -> +handle_notification(<<"service_available">>, Args) -> {ok, SvcName} = rvi_common:get_json_element(["service"], Args), {ok, DataLinkModule} = rvi_common:get_json_element(["data_link_module"], Args), @@ -484,7 +484,7 @@ handle_notification("service_available", Args) -> DataLinkModule ]}), ok; -handle_notification("service_unavailable", Args) -> +handle_notification(<<"service_unavailable">>, Args) -> {ok, SvcName} = rvi_common:get_json_element(["service"], Args), {ok, DataLinkModule} = rvi_common:get_json_element(["data_link_module"], Args), @@ -498,7 +498,7 @@ handle_notification(Other, _Args) -> ?info("dlink_bt:handle_notification(~p): unknown", [ Other ]), ok. -handle_rpc("setup_data_link", Args) -> +handle_rpc(<<"setup_data_link">>, Args) -> { ok, Service } = rvi_common:get_json_element(["service"], Args), { ok, Opts } = rvi_common:get_json_element(["opts"], Args), @@ -508,12 +508,12 @@ handle_rpc("setup_data_link", Args) -> {ok, [ {status, rvi_common:json_rpc_status(Res)} , { timeout, Timeout }]}; -handle_rpc("disconenct_data_link", Args) -> +handle_rpc(<<"disconenct_data_link">>, Args) -> { ok, NetworkAddress} = rvi_common:get_json_element(["network_address"], Args), [Res] = gen_server:call(?SERVER, { rvi, disconnect_data_link, [NetworkAddress]}), {ok, [ {status, rvi_common:json_rpc_status(Res)} ]}; -handle_rpc("send_data", Args) -> +handle_rpc(<<"send_data">>, Args) -> { ok, ProtoMod } = rvi_common:get_json_element(["proto_mod"], Args), { ok, Service } = rvi_common:get_json_element(["service"], Args), { ok, Data } = rvi_common:get_json_element(["data"], Args), @@ -602,7 +602,8 @@ handle_call({rvi, send_data, [ProtoMod, Service, Data, DataLinkOpts]}, _From, St %% FIXME: What to do if we have multiple connections to the same service? [ConnPid | _T] -> - ?debug("dlink_bt:send(~p): ~s", [ProtoMod, Data]), + ?debug("dlink_bt:send(~p,Pid=~p[~p]): ~p", + [ProtoMod, ConnPid, catch is_process_alive(ConnPid), Data]), Res = bt_connection:send( ConnPid, [ { ?DLINK_ARG_TRANSACTION_ID, 1 }, |