33 using ::grpc::ServerAsyncResponseWriter;
34 using ::grpc::ServerAsyncWriter;
35 using ::grpc::ServerContext;
61   ::grpc::Status CreateConnection(  in CreateConnection()
62       ::grpc::ServerContext* context,  in CreateConnection()
64       ::grpc::ServerWriter<ConnectionEvent>* writer) override {  in CreateConnection()
69 …return ::grpc::Status(::grpc::StatusCode::RESOURCE_EXHAUSTED, "Only one outstanding request is sup…  in CreateConnection()
71 …per_connection_events_.emplace_back(std::make_unique<::bluetooth::grpc::GrpcEventQueue<ConnectionE…  in CreateConnection()
76   ::grpc::Status Disconnect(  in Disconnect()
77 …::grpc::ServerContext* context, const HandleMsg* request, ::google::protobuf::Empty* response) ove…  in Disconnect()
82       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle");  in Disconnect()
85       return ::grpc::Status::OK;  in Disconnect()
89   ::grpc::Status AuthenticationRequested(  in AuthenticationRequested()
90 …::grpc::ServerContext* context, const HandleMsg* request, ::google::protobuf::Empty* response) ove…  in AuthenticationRequested()
95       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle");  in AuthenticationRequested()
98       return ::grpc::Status::OK;  in AuthenticationRequested()
106       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle"); \
111       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle"); \
115   ::grpc::Status ConnectionCommand(  in ConnectionCommand()
116       ::grpc::ServerContext* context,  in ConnectionCommand()
123       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid command packet");  in ConnectionCommand()
129         return ::grpc::Status::OK;  in ConnectionCommand()
135         return ::grpc::Status::OK;  in ConnectionCommand()
141         return ::grpc::Status::OK;  in ConnectionCommand()
147         return ::grpc::Status::OK;  in ConnectionCommand()
152         return ::grpc::Status::OK;  in ConnectionCommand()
157         return ::grpc::Status::OK;  in ConnectionCommand()
163         return ::grpc::Status::OK;  in ConnectionCommand()
170         return ::grpc::Status::OK;  in ConnectionCommand()
175         return ::grpc::Status::OK;  in ConnectionCommand()
180         return ::grpc::Status::OK;  in ConnectionCommand()
185         return ::grpc::Status::OK;  in ConnectionCommand()
191         return ::grpc::Status::OK;  in ConnectionCommand()
197         return ::grpc::Status::OK;  in ConnectionCommand()
202         return ::grpc::Status::OK;  in ConnectionCommand()
208         return ::grpc::Status::OK;  in ConnectionCommand()
213         return ::grpc::Status::OK;  in ConnectionCommand()
218         return ::grpc::Status::OK;  in ConnectionCommand()
223         return ::grpc::Status::OK;  in ConnectionCommand()
228         return ::grpc::Status::OK;  in ConnectionCommand()
233         return ::grpc::Status::OK;  in ConnectionCommand()
239         return ::grpc::Status::OK;  in ConnectionCommand()
244         return ::grpc::Status::OK;  in ConnectionCommand()
249         return ::grpc::Status::OK;  in ConnectionCommand()
255         return ::grpc::Status::OK;  in ConnectionCommand()
258         return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid command packet");  in ConnectionCommand()
263   ::grpc::Status FetchIncomingConnection(  in FetchIncomingConnection()
264       ::grpc::ServerContext* context,  in FetchIncomingConnection()
266       ::grpc::ServerWriter<ConnectionEvent>* writer) override {  in FetchIncomingConnection()
268 …return ::grpc::Status(::grpc::StatusCode::RESOURCE_EXHAUSTED, "Only one outstanding connection is …  in FetchIncomingConnection()
270 …per_connection_events_.emplace_back(std::make_unique<::bluetooth::grpc::GrpcEventQueue<ConnectionE…  in FetchIncomingConnection()
275   ::grpc::Status SendAclData(  in SendAclData()
276 …::grpc::ServerContext* context, const AclData* request, ::google::protobuf::Empty* response) overr…  in SendAclData()
283         return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle");  in SendAclData()
295         return ::grpc::Status(::grpc::StatusCode::RESOURCE_EXHAUSTED, "Can't send packet");  in SendAclData()
298     return ::grpc::Status::OK;  in SendAclData()
311   ::grpc::Status FetchAclData(  in FetchAclData()
312 …::grpc::ServerContext* context, const HandleMsg* request, ::grpc::ServerWriter<AclData>* writer) o…  in FetchAclData()
315       return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, "Invalid handle");  in FetchAclData()
385         std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>> event_stream)  in Connection()
546     std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>> event_stream_;
547     ::bluetooth::grpc::GrpcEventQueue<AclData> pending_acl_data_{std::string("PendingAclData") +
556 …std::vector<std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>>> per_connection_ev…
561   ::bluetooth::grpc::GrpcFacadeModule::ListDependencies(list);  in ListDependencies()
566   ::bluetooth::grpc::GrpcFacadeModule::Start();  in Start()
572   ::bluetooth::grpc::GrpcFacadeModule::Stop();  in Stop()
575 ::grpc::Service* AclManagerFacadeModule::GetService() const {  in GetService()