1 /*
2 * Copyright (c) 2021-2022 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 "native_implement_eventhandler.h"
17
18 #include <cstdint> // for int32_t, uint32_t
19 #include <memory> // for shared_ptr, operator!=
20
21 #include "event_runner.h"
22 #include "errors.h" // for ErrCode
23 #include "event_handler_errors.h" // for EVENT_HANDLER_ERR_NO_EVEN...
24 #include "event_queue.h" // for EventQueue
25 #include "file_descriptor_listener.h"
26
27 struct FileDescriptorCallbacks {
28 const FileFDCallback readableCallback_;
29 const FileFDCallback writableCallback_;
30 const FileFDCallback shutdownCallback_;
31 const FileFDCallback exceptionCallback_;
32 };
33
34 class NativeFileDescriptorListener : public OHOS::AppExecFwk::FileDescriptorListener {
35 public:
NativeFileDescriptorListener(const struct FileDescriptorCallbacks * fileDescriptorCallbacks)36 explicit NativeFileDescriptorListener(const struct FileDescriptorCallbacks *fileDescriptorCallbacks)
37 {
38 if (!fileDescriptorCallbacks) {
39 return;
40 }
41 if (fileDescriptorCallbacks->readableCallback_ != nullptr) {
42 onReadableCallback_ = fileDescriptorCallbacks->readableCallback_;
43 }
44 if (fileDescriptorCallbacks->writableCallback_ != nullptr) {
45 onWritableCallback_ = fileDescriptorCallbacks->writableCallback_;
46 }
47 if (fileDescriptorCallbacks->shutdownCallback_ != nullptr) {
48 onShutdownCallback_ = fileDescriptorCallbacks->shutdownCallback_;
49 }
50 if (fileDescriptorCallbacks->exceptionCallback_ != nullptr) {
51 onExceptionCallback_ = fileDescriptorCallbacks->exceptionCallback_;
52 }
53 }
54
~NativeFileDescriptorListener()55 ~NativeFileDescriptorListener()
56 {}
57
58 /**
59 * Called while file descriptor is readable.
60 *
61 * @param fileDescriptor File descriptor which is readable.
62 */
OnReadable(int32_t filedescriptor)63 void OnReadable(int32_t filedescriptor)
64 {
65 if (onReadableCallback_ != nullptr) {
66 onReadableCallback_(filedescriptor);
67 }
68 }
69
70 /**
71 * Called while file descriptor is writable.
72 *
73 * @param fileDescriptor File descriptor which is writable.
74 */
OnWritable(int32_t filedescriptor)75 void OnWritable(int32_t filedescriptor)
76 {
77 if (onWritableCallback_ != nullptr) {
78 onWritableCallback_(filedescriptor);
79 }
80 }
81
82 /**
83 * Called while shutting down this file descriptor.
84 *
85 * @param fileDescriptor File descriptor which is shutting down.
86 */
OnShutdown(int32_t filedescriptor)87 void OnShutdown(int32_t filedescriptor)
88 {
89 if (onShutdownCallback_ != nullptr) {
90 onShutdownCallback_(filedescriptor);
91 }
92 }
93
94 /**
95 * Called while error happened on this file descriptor.
96 *
97 * @param fileDescriptor Error happened on this file descriptor.
98 */
OnException(int32_t filedescriptor)99 void OnException(int32_t filedescriptor)
100 {
101 if (onExceptionCallback_ != nullptr) {
102 onExceptionCallback_(filedescriptor);
103 }
104 }
105
106 NativeFileDescriptorListener(const NativeFileDescriptorListener &) = delete;
107 NativeFileDescriptorListener &operator=(const NativeFileDescriptorListener &) = delete;
108 NativeFileDescriptorListener(NativeFileDescriptorListener &&) = delete;
109 NativeFileDescriptorListener &operator=(NativeFileDescriptorListener &&) = delete;
110
111 private:
112 FileFDCallback onReadableCallback_ = nullptr;
113 FileFDCallback onWritableCallback_ = nullptr;
114 FileFDCallback onShutdownCallback_ = nullptr;
115 FileFDCallback onExceptionCallback_ = nullptr;
116 };
117
EventRunnerNativeImplement(bool current)118 EventRunnerNativeImplement::EventRunnerNativeImplement(bool current)
119 {
120 if (current) {
121 eventRunner_ = EventRunner::Current();
122 } else {
123 eventRunner_ = EventRunner::Create(false);
124 }
125 }
126
~EventRunnerNativeImplement()127 EventRunnerNativeImplement::~EventRunnerNativeImplement()
128 {
129 eventRunner_ = nullptr;
130 }
131
GetEventRunnerNativeObj()132 const EventRunnerNativeImplement *EventRunnerNativeImplement::GetEventRunnerNativeObj()
133 {
134 return new EventRunnerNativeImplement(true);
135 }
136
CreateEventRunnerNativeObj()137 const EventRunnerNativeImplement *EventRunnerNativeImplement::CreateEventRunnerNativeObj()
138 {
139 return new EventRunnerNativeImplement(false);
140 }
141
RunEventRunnerNativeObj() const142 ErrCode EventRunnerNativeImplement::RunEventRunnerNativeObj() const
143 {
144 if (eventRunner_ != nullptr) {
145 return eventRunner_->Run();
146 }
147 return OHOS::AppExecFwk::EVENT_HANDLER_ERR_NO_EVENT_RUNNER;
148 }
149
StopEventRunnerNativeObj() const150 ErrCode EventRunnerNativeImplement::StopEventRunnerNativeObj() const
151 {
152 if (eventRunner_ != nullptr) {
153 return eventRunner_->Stop();
154 }
155 return OHOS::AppExecFwk::EVENT_HANDLER_ERR_NO_EVENT_RUNNER;
156 }
157
AddFileDescriptorListener(int32_t fileDescriptor,uint32_t events,const FileDescriptorCallbacks * fdCallbacks) const158 ErrCode EventRunnerNativeImplement::AddFileDescriptorListener(
159 int32_t fileDescriptor, uint32_t events, const FileDescriptorCallbacks *fdCallbacks) const
160 {
161 auto nativeFileDescriptorListener = std::make_shared<NativeFileDescriptorListener>(fdCallbacks);
162 if (!eventRunner_ || !eventRunner_->GetEventQueue()) {
163 return OHOS::AppExecFwk::EVENT_HANDLER_ERR_NO_EVENT_RUNNER;
164 }
165 return eventRunner_->GetEventQueue()->AddFileDescriptorListener(
166 fileDescriptor, events, nativeFileDescriptorListener);
167 }
168
RemoveFileDescriptorListener(int32_t fileDescriptor) const169 void EventRunnerNativeImplement::RemoveFileDescriptorListener(int32_t fileDescriptor) const
170 {
171 if (!eventRunner_ || !eventRunner_->GetEventQueue()) {
172 return;
173 }
174 eventRunner_->GetEventQueue()->RemoveFileDescriptorListener(fileDescriptor);
175 }