Add page scan module (122f2734) · Commits · e / os / android_packages_modules_Bluetooth

system/gd/neighbor/page.cc

0 → 100644

+206 −0

Original line number	Diff line number	Diff line
		/*
		* Copyright 2019 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.
		*/
		#define LOG_TAG "bt_gd_neigh"

		#include <memory>

		#include "common/bind.h"
		#include "hci/hci_layer.h"
		#include "hci/hci_packets.h"
		#include "module.h"
		#include "neighbor/page.h"
		#include "neighbor/scan_parameters.h"
		#include "os/handler.h"
		#include "os/log.h"

		namespace bluetooth {
		namespace neighbor {

		struct PageModule::impl {
		void SetScanActivity(ScanParameters params);
		ScanParameters GetScanActivity() const;

		void SetScanType(hci::PageScanType type);

		void SetTimeout(PageTimeout timeout);

		void Start();
		void Stop();

		impl(PageModule& page_module);

		private:
		PageModule& module_;

		ScanParameters scan_parameters_;
		hci::PageScanType scan_type_;
		PageTimeout timeout_;

		void OnCommandComplete(hci::CommandCompleteView status);

		hci::HciLayer* hci_layer_;
		os::Handler* handler_;
		};

		const ModuleFactory neighbor::PageModule::Factory = ModuleFactory([]() { return new neighbor::PageModule(); });

		neighbor::PageModule::impl::impl(neighbor::PageModule& module) : module_(module) {}

		void neighbor::PageModule::impl::OnCommandComplete(hci::CommandCompleteView view) {
		switch (view.GetCommandOpCode()) {
		case hci::OpCode::WRITE_PAGE_SCAN_ACTIVITY: {
		auto packet = hci::WritePageScanActivityCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		} break;

		case hci::OpCode::READ_PAGE_SCAN_ACTIVITY: {
		auto packet = hci::ReadPageScanActivityCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		scan_parameters_.interval = packet.GetPageScanInterval();
		scan_parameters_.window = packet.GetPageScanWindow();
		} break;

		case hci::OpCode::WRITE_PAGE_SCAN_TYPE: {
		auto packet = hci::WritePageScanTypeCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		} break;

		case hci::OpCode::READ_PAGE_SCAN_TYPE: {
		auto packet = hci::ReadPageScanTypeCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		scan_type_ = packet.GetPageScanType();
		} break;

		case hci::OpCode::WRITE_PAGE_TIMEOUT: {
		auto packet = hci::WritePageTimeoutCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		} break;

		case hci::OpCode::READ_PAGE_TIMEOUT: {
		auto packet = hci::ReadPageTimeoutCompleteView::Create(view);
		ASSERT(packet.IsValid());
		ASSERT(packet.GetStatus() == hci::ErrorCode::SUCCESS);
		timeout_ = packet.GetPageTimeout();
		} break;

		default:
		LOG_ERROR("Unhandled command %s", hci::OpCodeText(view.GetCommandOpCode()).c_str());
		break;
		}
		}

		void neighbor::PageModule::impl::Start() {
		hci_layer_ = module_.GetDependency<hci::HciLayer>();
		handler_ = module_.GetHandler();

		hci_layer_->EnqueueCommand(hci::ReadPageScanActivityBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);

		hci_layer_->EnqueueCommand(hci::ReadPageScanTypeBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);

		hci_layer_->EnqueueCommand(hci::ReadPageTimeoutBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);
		}

		void neighbor::PageModule::impl::Stop() {
		LOG_DEBUG("Page scan interval:%hd window:%hd", scan_parameters_.interval, scan_parameters_.window);
		LOG_DEBUG("Page scan_type:%s", hci::PageScanTypeText(scan_type_).c_str());
		}

		void neighbor::PageModule::impl::SetScanActivity(ScanParameters params) {
		hci_layer_->EnqueueCommand(hci::WritePageScanActivityBuilder::Create(params.interval, params.window),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);

		hci_layer_->EnqueueCommand(hci::ReadPageScanActivityBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);
		LOG_DEBUG("Set page scan activity interval:0x%x/%.02fms window:0x%x/%.02fms", params.interval,
		ScanIntervalTimeMs(params.interval), params.window, ScanWindowTimeMs(params.window));
		}

		ScanParameters neighbor::PageModule::impl::GetScanActivity() const {
		return scan_parameters_;
		}

		void neighbor::PageModule::impl::SetScanType(hci::PageScanType scan_type) {
		hci_layer_->EnqueueCommand(hci::WritePageScanTypeBuilder::Create(scan_type),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);

		hci_layer_->EnqueueCommand(hci::ReadPageScanTypeBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);
		LOG_DEBUG("Set page scan type:%s", hci::PageScanTypeText(scan_type).c_str());
		}

		void neighbor::PageModule::impl::SetTimeout(PageTimeout timeout) {
		hci_layer_->EnqueueCommand(hci::WritePageTimeoutBuilder::Create(timeout),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);

		hci_layer_->EnqueueCommand(hci::ReadPageTimeoutBuilder::Create(),
		common::BindOnce(&impl::OnCommandComplete, common::Unretained(this)), handler_);
		LOG_DEBUG("Set page scan timeout:0x%x/%.02fms", timeout, PageTimeoutMs(timeout));
		}

		/**
		* General API here
		*/
		neighbor::PageModule::PageModule() : pimpl_(std::make_unique<impl>(*this)) {}

		neighbor::PageModule::~PageModule() {
		pimpl_.reset();
		}

		void neighbor::PageModule::SetScanActivity(ScanParameters params) {
		pimpl_->SetScanActivity(params);
		}

		ScanParameters neighbor::PageModule::GetScanActivity() const {
		return pimpl_->GetScanActivity();
		}

		void neighbor::PageModule::SetInterlacedScan() {
		pimpl_->SetScanType(hci::PageScanType::INTERLACED);
		}

		void neighbor::PageModule::SetStandardScan() {
		pimpl_->SetScanType(hci::PageScanType::STANDARD);
		}

		void neighbor::PageModule::SetTimeout(PageTimeout timeout) {
		pimpl_->SetTimeout(timeout);
		}

		/**
		* Module methods here
		*/
		void neighbor::PageModule::ListDependencies(ModuleList* list) {
		list->add<hci::HciLayer>();
		}

		void neighbor::PageModule::Start() {
		pimpl_->Start();
		}

		void neighbor::PageModule::Stop() {
		pimpl_->Stop();
		}

		} // namespace neighbor
		} // namespace bluetooth

system/gd/neighbor/page.h

0 → 100644

+61 −0

Original line number	Diff line number	Diff line
		/*
		* Copyright 2019 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 <memory>

		#include "hci/hci_packets.h"
		#include "module.h"
		#include "neighbor/scan_parameters.h"

		namespace bluetooth {
		namespace neighbor {

		using PageTimeout = uint16_t; // Range = 0x0001 to 0xffff, Time N * 0.625ms

		inline double PageTimeoutMs(PageTimeout timeout) {
		return kTimeTickMs * timeout;
		}

		class PageModule : public bluetooth::Module {
		public:
		void SetScanActivity(ScanParameters params);
		ScanParameters GetScanActivity() const;

		void SetInterlacedScan();
		void SetStandardScan();

		void SetTimeout(PageTimeout timeout);

		static const ModuleFactory Factory;

		PageModule();
		~PageModule();

		protected:
		void ListDependencies(ModuleList* list) override;
		void Start() override;
		void Stop() override;

		private:
		struct impl;
		std::unique_ptr<impl> pimpl_;

		DISALLOW_COPY_AND_ASSIGN(PageModule);
		};

		} // namespace neighbor
		} // namespace bluetooth

system/gd/neighbor/scan.cc

+18 −18

Original line number	Diff line number	Diff line
		@@ -59,7 +59,7 @@ neighbor::ScanModule::impl::impl(neighbor::ScanModule& module)
		: module_(module), inquiry_scan_enabled_(false), page_scan_enabled_(false) {}

		void neighbor::ScanModule::impl::OnCommandComplete(hci::CommandCompleteView view) {
		switch veiwstatus.GetCommandOpCode()) {
		switch (view.GetCommandOpCode()) {
		case hci::OpCode::READ_SCAN_ENABLE: {
		auto packet = hci::ReadScanEnableCompleteView::Create(view);
		ASSERT(packet.IsValid());