1 /*
2 * Copyright 2019 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17 #include "neighbor/facade/facade.h"
18
19 #include <memory>
20
21 #include "blueberry/facade/neighbor/facade.grpc.pb.h"
22 #include "common/bind.h"
23 #include "grpc/grpc_event_queue.h"
24 #include "hci/hci_packets.h"
25
26 using ::grpc::ServerAsyncResponseWriter;
27 using ::grpc::ServerAsyncWriter;
28 using ::grpc::ServerContext;
29
30 namespace bluetooth {
31 namespace neighbor {
32 namespace facade {
33
34 using namespace blueberry::facade::neighbor;
35
36 class NeighborFacadeService : public NeighborFacade::Service {
37 public:
NeighborFacadeService(ConnectabilityModule * connectability_module,DiscoverabilityModule * discoverability_module,InquiryModule * inquiry_module,NameModule * name_module,PageModule *,ScanModule * scan_module,::bluetooth::os::Handler * facade_handler)38 NeighborFacadeService(
39 ConnectabilityModule* connectability_module,
40 DiscoverabilityModule* discoverability_module,
41 InquiryModule* inquiry_module,
42 NameModule* name_module,
43 PageModule*,
44 ScanModule* scan_module,
45 ::bluetooth::os::Handler* facade_handler)
46 : connectability_module_(connectability_module),
47 discoverability_module_(discoverability_module),
48 inquiry_module_(inquiry_module),
49 name_module_(name_module),
50 scan_module_(scan_module),
51 facade_handler_(facade_handler) {}
52
SetConnectability(::grpc::ServerContext * context,const EnableMsg * request,::google::protobuf::Empty * response)53 ::grpc::Status SetConnectability(
54 ::grpc::ServerContext* context, const EnableMsg* request, ::google::protobuf::Empty* response) override {
55 if (request->enabled()) {
56 connectability_module_->StartConnectability();
57 } else {
58 connectability_module_->StopConnectability();
59 }
60 return ::grpc::Status::OK;
61 }
62
SetDiscoverability(::grpc::ServerContext * context,const DiscoverabilitiyMsg * request,::google::protobuf::Empty * response)63 ::grpc::Status SetDiscoverability(
64 ::grpc::ServerContext* context,
65 const DiscoverabilitiyMsg* request,
66 ::google::protobuf::Empty* response) override {
67 switch (request->mode()) {
68 case DiscoverabilityMode::OFF:
69 discoverability_module_->StopDiscoverability();
70 break;
71 case DiscoverabilityMode::LIMITED:
72 discoverability_module_->StartLimitedDiscoverability();
73 break;
74 case DiscoverabilityMode::GENERAL:
75 discoverability_module_->StartGeneralDiscoverability();
76 break;
77 default:
78 LOG_ALWAYS_FATAL("Unknown discoverability mode %d", static_cast<int>(request->mode()));
79 }
80 return ::grpc::Status::OK;
81 }
82
SetInquiryMode(::grpc::ServerContext * context,const InquiryMsg * request,::grpc::ServerWriter<InquiryResultMsg> * writer)83 ::grpc::Status SetInquiryMode(
84 ::grpc::ServerContext* context,
85 const InquiryMsg* request,
86 ::grpc::ServerWriter<InquiryResultMsg>* writer) override {
87 inquiry_module_->RegisterCallbacks(inquiry_callbacks_);
88 switch (request->result_mode()) {
89 case ResultMode::STANDARD:
90 inquiry_module_->SetStandardInquiryResultMode();
91 break;
92 case ResultMode::RSSI:
93 inquiry_module_->SetInquiryWithRssiResultMode();
94 break;
95 case ResultMode::EXTENDED:
96 inquiry_module_->SetExtendedInquiryResultMode();
97 break;
98 default:
99 LOG_ALWAYS_FATAL("Unknown result mode %d", static_cast<int>(request->result_mode()));
100 }
101 switch (request->inquiry_mode()) {
102 case DiscoverabilityMode::OFF:
103 inquiry_module_->StopInquiry();
104 break;
105 case DiscoverabilityMode::LIMITED:
106 inquiry_module_->StartLimitedInquiry(request->length_1_28s(), request->max_results());
107 break;
108 case DiscoverabilityMode::GENERAL:
109 inquiry_module_->StartGeneralInquiry(request->length_1_28s(), request->max_results());
110 break;
111 default:
112 LOG_ALWAYS_FATAL("Unknown discoverability mode %d", static_cast<int>(request->inquiry_mode()));
113 }
114 return pending_events_.RunLoop(context, writer);
115 }
116
ReadRemoteName(::grpc::ServerContext * context,const RemoteNameRequestMsg * request,::google::protobuf::Empty * response)117 ::grpc::Status ReadRemoteName(
118 ::grpc::ServerContext* context,
119 const RemoteNameRequestMsg* request,
120 ::google::protobuf::Empty* response) override {
121 hci::Address remote;
122 ASSERT(hci::Address::FromString(request->address(), remote));
123 hci::PageScanRepetitionMode mode;
124 switch (request->page_scan_repetition_mode()) {
125 case 0:
126 mode = hci::PageScanRepetitionMode::R0;
127 break;
128 case 1:
129 mode = hci::PageScanRepetitionMode::R1;
130 break;
131 case 2:
132 mode = hci::PageScanRepetitionMode::R2;
133 break;
134 default:
135 LOG_ALWAYS_FATAL("Unknown PageScanRepetition mode %d", static_cast<int>(request->page_scan_repetition_mode()));
136 }
137 name_module_->ReadRemoteNameRequest(
138 remote,
139 mode,
140 request->clock_offset(),
141 (request->clock_offset() != 0 ? hci::ClockOffsetValid::VALID : hci::ClockOffsetValid::INVALID),
142 common::Bind(&NeighborFacadeService::on_remote_name, common::Unretained(this)),
143 facade_handler_);
144 return ::grpc::Status::OK;
145 }
146
GetRemoteNameEvents(::grpc::ServerContext * context,const::google::protobuf::Empty * request,::grpc::ServerWriter<RemoteNameResponseMsg> * writer)147 ::grpc::Status GetRemoteNameEvents(
148 ::grpc::ServerContext* context,
149 const ::google::protobuf::Empty* request,
150 ::grpc::ServerWriter<RemoteNameResponseMsg>* writer) override {
151 return pending_remote_names_.RunLoop(context, writer);
152 }
153
EnableInquiryScan(::grpc::ServerContext * context,const EnableMsg * request,::google::protobuf::Empty * response)154 ::grpc::Status EnableInquiryScan(
155 ::grpc::ServerContext* context, const EnableMsg* request, ::google::protobuf::Empty* response) override {
156 if (request->enabled()) {
157 scan_module_->SetInquiryScan();
158 } else {
159 scan_module_->ClearInquiryScan();
160 }
161 return ::grpc::Status::OK;
162 }
163
EnablePageScan(::grpc::ServerContext * context,const EnableMsg * request,::google::protobuf::Empty * response)164 ::grpc::Status EnablePageScan(
165 ::grpc::ServerContext* context, const EnableMsg* request, ::google::protobuf::Empty* response) override {
166 if (request->enabled()) {
167 scan_module_->SetPageScan();
168 } else {
169 scan_module_->ClearPageScan();
170 }
171 return ::grpc::Status::OK;
172 }
173
174 private:
on_incoming_inquiry_result(hci::EventView view)175 void on_incoming_inquiry_result(hci::EventView view) {
176 InquiryResultMsg inquiry_result_msg;
177 inquiry_result_msg.set_packet(std::string(view.begin(), view.end()));
178 pending_events_.OnIncomingEvent(std::move(inquiry_result_msg));
179 }
180
on_incoming_inquiry_complete(hci::ErrorCode status)181 void on_incoming_inquiry_complete(hci::ErrorCode status) {
182 InquiryResultMsg inquiry_result_msg;
183 inquiry_result_msg.set_packet(hci::ErrorCodeText(status));
184 pending_events_.OnIncomingEvent(std::move(inquiry_result_msg));
185 }
186
187 InquiryCallbacks inquiry_callbacks_{
__anon5eba715c0102() 188 .result = [this](hci::InquiryResultView view) { on_incoming_inquiry_result(view); },
__anon5eba715c0202() 189 .result_with_rssi = [this](hci::InquiryResultWithRssiView view) { on_incoming_inquiry_result(view); },
__anon5eba715c0302() 190 .extended_result = [this](hci::ExtendedInquiryResultView view) { on_incoming_inquiry_result(view); },
__anon5eba715c0402() 191 .complete = [this](hci::ErrorCode status) { on_incoming_inquiry_complete(status); }};
192
on_remote_name(hci::ErrorCode status,hci::Address address,std::array<uint8_t,248> name)193 void on_remote_name(hci::ErrorCode status, hci::Address address, std::array<uint8_t, 248> name) {
194 RemoteNameResponseMsg response;
195 response.set_status(static_cast<int>(status));
196 response.set_address(address.ToString());
197 response.set_name(name.begin(), name.size());
198 pending_remote_names_.OnIncomingEvent(response);
199 }
200
201 ConnectabilityModule* connectability_module_;
202 DiscoverabilityModule* discoverability_module_;
203 InquiryModule* inquiry_module_;
204 NameModule* name_module_;
205 ScanModule* scan_module_;
206 ::bluetooth::os::Handler* facade_handler_;
207 ::bluetooth::grpc::GrpcEventQueue<InquiryResultMsg> pending_events_{"InquiryResponses"};
208 ::bluetooth::grpc::GrpcEventQueue<RemoteNameResponseMsg> pending_remote_names_{"RemoteNameResponses"};
209 };
210
ListDependencies(ModuleList * list) const211 void NeighborFacadeModule::ListDependencies(ModuleList* list) const {
212 ::bluetooth::grpc::GrpcFacadeModule::ListDependencies(list);
213 list->add<ConnectabilityModule>();
214 list->add<DiscoverabilityModule>();
215 list->add<InquiryModule>();
216 list->add<NameModule>();
217 list->add<PageModule>();
218 list->add<ScanModule>();
219 }
220
Start()221 void NeighborFacadeModule::Start() {
222 ::bluetooth::grpc::GrpcFacadeModule::Start();
223 service_ = new NeighborFacadeService(
224 GetDependency<ConnectabilityModule>(),
225 GetDependency<DiscoverabilityModule>(),
226 GetDependency<InquiryModule>(),
227 GetDependency<NameModule>(),
228 GetDependency<PageModule>(),
229 GetDependency<ScanModule>(),
230 GetHandler());
231 }
232
Stop()233 void NeighborFacadeModule::Stop() {
234 delete service_;
235 ::bluetooth::grpc::GrpcFacadeModule::Stop();
236 }
237
GetService() const238 ::grpc::Service* NeighborFacadeModule::GetService() const {
239 return service_;
240 }
241
242 const ModuleFactory NeighborFacadeModule::Factory =
__anon5eba715c0502() 243 ::bluetooth::ModuleFactory([]() { return new NeighborFacadeModule(); });
244
245 } // namespace facade
246 } // namespace neighbor
247 } // namespace bluetooth
248