1 /*
2  * Copyright (C) 2022 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 "chre/platform/linux/pal_nan.h"
18 #include "chre/platform/assert.h"
19 #include "chre/util/memory.h"
20 
21 namespace chre {
22 
subscribe(const struct chreWifiNanSubscribeConfig *,uint32_t * subscriptionId)23 uint8_t PalNanEngine::subscribe(
24     const struct chreWifiNanSubscribeConfig * /*config*/,
25     uint32_t *subscriptionId) {
26   uint8_t errorCode = CHRE_ERROR;
27   if ((mFlags & FAIL_SUBSCRIBE) == 0) {
28     uint32_t id = ++mSubscriptionIdCounter;
29     mActiveSubscriptions.insert(id);
30     *subscriptionId = id;
31     errorCode = CHRE_ERROR_NONE;
32   }
33   return errorCode;
34 }
35 
subscribeCancel(uint32_t subscriptionId)36 bool PalNanEngine::subscribeCancel(uint32_t subscriptionId) {
37   const bool isActive = isSubscriptionActive(subscriptionId);
38   mActiveSubscriptions.erase(subscriptionId);
39   return isActive;
40 }
41 
isSubscriptionActive(uint32_t subscriptionId)42 bool PalNanEngine::isSubscriptionActive(uint32_t subscriptionId) {
43   return mActiveSubscriptions.count(subscriptionId) == 1;
44 }
45 
sendDiscoveryEvent(uint32_t subscriptionId)46 void PalNanEngine::sendDiscoveryEvent(uint32_t subscriptionId) {
47   constexpr size_t kSomeArraySize = 11;
48   auto *event = memoryAlloc<struct chreWifiNanDiscoveryEvent>();
49   CHRE_ASSERT_NOT_NULL(event);
50 
51   auto *serviceSpecificInfo =
52       static_cast<uint8_t *>(chre::memoryAlloc(kSomeArraySize));
53   CHRE_ASSERT_NOT_NULL(serviceSpecificInfo);
54 
55   event->subscribeId = subscriptionId;
56   event->publishId = --mPublisherIdCounter;
57   std::memcpy(event->publisherAddress, kSomePublishMac, CHRE_WIFI_BSSID_LEN);
58   event->serviceSpecificInfo = std::move(serviceSpecificInfo);
59   event->serviceSpecificInfoSize = kSomeArraySize;
60 
61   mWifiCallbacks->nanServiceDiscoveryCallback(event);
62 }
63 
destroyDiscoveryEvent(chreWifiNanDiscoveryEvent * event)64 void PalNanEngine::destroyDiscoveryEvent(chreWifiNanDiscoveryEvent *event) {
65   memoryFree(const_cast<uint8_t *>(event->serviceSpecificInfo));
66   memoryFree(event);
67 }
68 
onServiceLost(uint32_t subscribeId,uint32_t publishId)69 void PalNanEngine::onServiceLost(uint32_t subscribeId, uint32_t publishId) {
70   mWifiCallbacks->nanServiceLostCallback(subscribeId, publishId);
71 }
72 
onServiceTerminated(uint32_t subscribeId)73 void PalNanEngine::onServiceTerminated(uint32_t subscribeId) {
74   mWifiCallbacks->nanServiceTerminatedCallback(CHRE_ERROR, subscribeId);
75 }
76 
77 }  // namespace chre
78