1 /*
2 * Copyright (c) 2021 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "my_file_descriptor_listener.h"
17 #include "sensors_log_domain.h"
18
19 namespace OHOS {
20 namespace Sensors {
21 using namespace OHOS::HiviewDFX;
22 using namespace OHOS::AppExecFwk;
23
24 namespace {
25 constexpr HiLogLabel LABEL = { LOG_CORE, SensorsLogDomain::SENSOR_SERVICE, "MyFileDescriptorListener" };
26 constexpr int32_t RECEIVE_DATA_SIZE = 100;
27 } // namespace
28
MyFileDescriptorListener()29 MyFileDescriptorListener::MyFileDescriptorListener()
30 {
31 channel_ = nullptr;
32 receiveDataBuff_ =
33 new (std::nothrow) TransferSensorEvents[sizeof(struct TransferSensorEvents) * RECEIVE_DATA_SIZE];
34 if (receiveDataBuff_ == nullptr) {
35 HiLog::Error(LABEL, "%{public}s receiveDataBuff_ memory request failed", __func__);
36 }
37 }
38
~MyFileDescriptorListener()39 MyFileDescriptorListener::~MyFileDescriptorListener()
40 {
41 HiLog::Debug(LABEL, "%{public}s begin", __func__);
42 if (receiveDataBuff_ != nullptr) {
43 delete[] receiveDataBuff_;
44 receiveDataBuff_ = nullptr;
45 }
46 }
47
OnReadable(int32_t fileDescriptor)48 void MyFileDescriptorListener::OnReadable(int32_t fileDescriptor)
49 {
50 HiLog::Debug(LABEL, "%{public}s begin", __func__);
51 if (fileDescriptor < 0) {
52 HiLog::Error(LABEL, "%{public}s fileDescriptor: %{public}d", __func__, fileDescriptor);
53 return;
54 }
55
56 FileDescriptorListener::OnReadable(fileDescriptor);
57 if (receiveDataBuff_ == nullptr) {
58 return;
59 }
60 int32_t len =
61 recv(fileDescriptor, receiveDataBuff_, sizeof(struct TransferSensorEvents) * RECEIVE_DATA_SIZE, 0);
62 int32_t eventSize = static_cast<int32_t>(sizeof(struct TransferSensorEvents));
63 while (len > 0) {
64 int32_t num = len / eventSize;
65 for (int i = 0; i < num; i++) {
66 SensorEvent event = {
67 .sensorTypeId = receiveDataBuff_[i].sensorTypeId,
68 .version = receiveDataBuff_[i].version,
69 .timestamp = receiveDataBuff_[i].timestamp,
70 .option = receiveDataBuff_[i].option,
71 .mode = receiveDataBuff_[i].mode,
72 .dataLen = receiveDataBuff_[i].dataLen,
73 .data = receiveDataBuff_[i].data
74 };
75 channel_->dataCB_(&event, 1, channel_->privateData_);
76 }
77 len = recv(fileDescriptor, receiveDataBuff_, sizeof(struct TransferSensorEvents) * RECEIVE_DATA_SIZE, 0);
78 }
79 }
80
OnWritable(int32_t fileDescriptor)81 void MyFileDescriptorListener::OnWritable(int32_t fileDescriptor){}
82
SetChannel(SensorDataChannel * channel)83 void MyFileDescriptorListener::SetChannel(SensorDataChannel* channel)
84 {
85 channel_ = channel;
86 }
87
OnShutdown(int32_t fileDescriptor)88 void MyFileDescriptorListener::OnShutdown(int32_t fileDescriptor)
89 {
90 if (fileDescriptor < 0) {
91 HiLog::Error(LABEL, "%{public}s param is error: %{public}d", __func__, fileDescriptor);
92 return;
93 }
94
95 FileDescriptorListener::OnShutdown(fileDescriptor);
96 if (receiveDataBuff_ != nullptr) {
97 delete[] receiveDataBuff_;
98 receiveDataBuff_ = nullptr;
99 }
100 }
101
OnException(int32_t fileDescriptor)102 void MyFileDescriptorListener::OnException(int32_t fileDescriptor)
103 {
104 if (fileDescriptor < 0) {
105 HiLog::Error(LABEL, "%{public}s param is error: %{public}d", __func__, fileDescriptor);
106 return;
107 }
108
109 FileDescriptorListener::OnException(fileDescriptor);
110 if (receiveDataBuff_ != nullptr) {
111 delete[] receiveDataBuff_;
112 receiveDataBuff_ = nullptr;
113 }
114 }
115 } // namespace Sensors
116 } // namespace OHOS