// // Copyright 2017 The Android Open Source Project // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // #pragma once #include "os/log.h" #include #include #include "hci_packetizer.h" #include "model/controller/dual_mode_controller.h" #include "model/setup/async_manager.h" #include "model/setup/test_channel_transport.h" #include "model/setup/test_command_handler.h" #include "model/setup/test_model.h" namespace android { namespace hardware { namespace bluetooth { namespace V1_1 { namespace sim { class BluetoothDeathRecipient; class BluetoothHci : public IBluetoothHci { public: BluetoothHci(); ::android::hardware::Return initialize( const sp& cb) override; ::android::hardware::Return initialize_1_1( const sp& cb) override; ::android::hardware::Return sendHciCommand(const ::android::hardware::hidl_vec& packet) override; ::android::hardware::Return sendAclData(const ::android::hardware::hidl_vec& packet) override; ::android::hardware::Return sendScoData(const ::android::hardware::hidl_vec& packet) override; ::android::hardware::Return sendIsoData( const ::android::hardware::hidl_vec& packet) override; ::android::hardware::Return close() override; static void OnPacketReady(); static BluetoothHci* get(); private: ::android::hardware::Return initialize_impl( const sp& cb, const sp& cb_1_1); sp death_recipient_; std::function&)> unlink_cb_; void HandleIncomingPacket(); test_vendor_lib::AsyncManager async_manager_; void SetUpTestChannel(int port); void SetUpHciServer(int port, const std::function& on_connect); void SetUpLinkLayerServer(int port, const std::function& on_connect); int ConnectToRemoteServer(const std::string& server, int port); std::shared_ptr controller_; test_vendor_lib::TestChannelTransport test_channel_transport_; test_vendor_lib::TestChannelTransport remote_hci_transport_; test_vendor_lib::TestChannelTransport remote_link_layer_transport_; test_vendor_lib::AsyncUserId user_id_ = async_manager_.GetNextUserId(); test_vendor_lib::TestModel test_model_{ [this]() { return async_manager_.GetNextUserId(); }, [this](test_vendor_lib::AsyncUserId user_id, std::chrono::milliseconds delay, const test_vendor_lib::TaskCallback& task) { return async_manager_.ExecAsync(user_id, delay, task); }, [this](test_vendor_lib::AsyncUserId user_id, std::chrono::milliseconds delay, std::chrono::milliseconds period, const test_vendor_lib::TaskCallback& task) { return async_manager_.ExecAsyncPeriodically(user_id, delay, period, task); }, [this](test_vendor_lib::AsyncUserId user_id) { async_manager_.CancelAsyncTasksFromUser(user_id); }, [this](test_vendor_lib::AsyncTaskId task) { async_manager_.CancelAsyncTask(task); }, [this](const std::string& server, int port) { return ConnectToRemoteServer(server, port); }}; test_vendor_lib::TestCommandHandler test_channel_{test_model_}; }; extern "C" IBluetoothHci* HIDL_FETCH_IBluetoothHci(const char* name); } // namespace sim } // namespace V1_1 } // namespace bluetooth } // namespace hardware } // namespace android