1 /*
2 * Copyright (c) 2021-2023 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 "socket_async_work.h"
17
18 #include "base_async_work.h"
19 #include "bind_context.h"
20 #include "common_context.h"
21 #include "connect_context.h"
22 #include "local_socket_context.h"
23 #include "local_socket_exec.h"
24 #include "local_socket_server_context.h"
25 #include "multicast_get_loopback_context.h"
26 #include "multicast_get_ttl_context.h"
27 #include "multicast_membership_context.h"
28 #include "multicast_set_loopback_context.h"
29 #include "multicast_set_ttl_context.h"
30 #include "socket_exec.h"
31 #include "tcp_extra_context.h"
32 #include "tcp_send_context.h"
33 #include "tcp_server_common_context.h"
34 #include "tcp_server_extra_context.h"
35 #include "tcp_server_listen_context.h"
36 #include "tcp_server_send_context.h"
37 #include "udp_extra_context.h"
38 #include "udp_send_context.h"
39
40 namespace OHOS::NetStack::Socket {
ExecUdpBind(napi_env env,void * data)41 void SocketAsyncWork::ExecUdpBind(napi_env env, void *data)
42 {
43 BaseAsyncWork::ExecAsyncWork<BindContext, SocketExec::ExecUdpBind>(env, data);
44 }
45
ExecUdpSend(napi_env env,void * data)46 void SocketAsyncWork::ExecUdpSend(napi_env env, void *data)
47 {
48 BaseAsyncWork::ExecAsyncWork<UdpSendContext, SocketExec::ExecUdpSend>(env, data);
49 }
50
ExecUdpAddMembership(napi_env env,void * data)51 void SocketAsyncWork::ExecUdpAddMembership(napi_env env, void *data)
52 {
53 BaseAsyncWork::ExecAsyncWork<MulticastMembershipContext, SocketExec::ExecUdpAddMembership>(env, data);
54 }
55
ExecUdpDropMembership(napi_env env,void * data)56 void SocketAsyncWork::ExecUdpDropMembership(napi_env env, void *data)
57 {
58 BaseAsyncWork::ExecAsyncWork<MulticastMembershipContext, SocketExec::ExecUdpDropMembership>(env, data);
59 }
60
ExecSetMulticastTTL(napi_env env,void * data)61 void SocketAsyncWork::ExecSetMulticastTTL(napi_env env, void *data)
62 {
63 BaseAsyncWork::ExecAsyncWork<MulticastSetTTLContext, SocketExec::ExecSetMulticastTTL>(env, data);
64 }
65
ExecGetMulticastTTL(napi_env env,void * data)66 void SocketAsyncWork::ExecGetMulticastTTL(napi_env env, void *data)
67 {
68 BaseAsyncWork::ExecAsyncWork<MulticastGetTTLContext, SocketExec::ExecGetMulticastTTL>(env, data);
69 }
70
ExecSetLoopbackMode(napi_env env,void * data)71 void SocketAsyncWork::ExecSetLoopbackMode(napi_env env, void *data)
72 {
73 BaseAsyncWork::ExecAsyncWork<MulticastSetLoopbackContext, SocketExec::ExecSetLoopbackMode>(env, data);
74 }
75
ExecGetLoopbackMode(napi_env env,void * data)76 void SocketAsyncWork::ExecGetLoopbackMode(napi_env env, void *data)
77 {
78 BaseAsyncWork::ExecAsyncWork<MulticastGetLoopbackContext, SocketExec::ExecGetLoopbackMode>(env, data);
79 }
80
ExecTcpBind(napi_env env,void * data)81 void SocketAsyncWork::ExecTcpBind(napi_env env, void *data)
82 {
83 BaseAsyncWork::ExecAsyncWork<BindContext, SocketExec::ExecTcpBind>(env, data);
84 }
85
ExecConnect(napi_env env,void * data)86 void SocketAsyncWork::ExecConnect(napi_env env, void *data)
87 {
88 BaseAsyncWork::ExecAsyncWork<ConnectContext, SocketExec::ExecConnect>(env, data);
89 }
90
ExecClose(napi_env env,void * data)91 void SocketAsyncWork::ExecClose(napi_env env, void *data)
92 {
93 BaseAsyncWork::ExecAsyncWork<CloseContext, SocketExec::ExecClose>(env, data);
94 }
95
ExecTcpSend(napi_env env,void * data)96 void SocketAsyncWork::ExecTcpSend(napi_env env, void *data)
97 {
98 BaseAsyncWork::ExecAsyncWork<TcpSendContext, SocketExec::ExecTcpSend>(env, data);
99 }
100
ExecGetState(napi_env env,void * data)101 void SocketAsyncWork::ExecGetState(napi_env env, void *data)
102 {
103 BaseAsyncWork::ExecAsyncWork<GetStateContext, SocketExec::ExecGetState>(env, data);
104 }
105
ExecGetRemoteAddress(napi_env env,void * data)106 void SocketAsyncWork::ExecGetRemoteAddress(napi_env env, void *data)
107 {
108 BaseAsyncWork::ExecAsyncWork<GetRemoteAddressContext, SocketExec::ExecGetRemoteAddress>(env, data);
109 }
110
ExecTcpSetExtraOptions(napi_env env,void * data)111 void SocketAsyncWork::ExecTcpSetExtraOptions(napi_env env, void *data)
112 {
113 BaseAsyncWork::ExecAsyncWork<TcpSetExtraOptionsContext, SocketExec::ExecTcpSetExtraOptions>(env, data);
114 }
115
ExecUdpSetExtraOptions(napi_env env,void * data)116 void SocketAsyncWork::ExecUdpSetExtraOptions(napi_env env, void *data)
117 {
118 BaseAsyncWork::ExecAsyncWork<UdpSetExtraOptionsContext, SocketExec::ExecUdpSetExtraOptions>(env, data);
119 }
120
ExecTcpGetSocketFd(napi_env env,void * data)121 void SocketAsyncWork::ExecTcpGetSocketFd(napi_env env, void *data)
122 {
123 BaseAsyncWork::ExecAsyncWork<GetSocketFdContext, SocketExec::ExecTcpGetSocketFd>(env, data);
124 }
125
ExecUdpGetSocketFd(napi_env env,void * data)126 void SocketAsyncWork::ExecUdpGetSocketFd(napi_env env, void *data)
127 {
128 BaseAsyncWork::ExecAsyncWork<GetSocketFdContext, SocketExec::ExecUdpGetSocketFd>(env, data);
129 }
130
ExecTcpConnectionSend(napi_env env,void * data)131 void SocketAsyncWork::ExecTcpConnectionSend(napi_env env, void *data)
132 {
133 BaseAsyncWork::ExecAsyncWork<TcpServerSendContext, SocketExec::ExecTcpConnectionSend>(env, data);
134 }
135
ExecTcpConnectionGetRemoteAddress(napi_env env,void * data)136 void SocketAsyncWork::ExecTcpConnectionGetRemoteAddress(napi_env env, void *data)
137 {
138 BaseAsyncWork::ExecAsyncWork<TcpServerGetRemoteAddressContext, SocketExec::ExecTcpConnectionGetRemoteAddress>(env,
139 data);
140 }
141
ExecTcpConnectionClose(napi_env env,void * data)142 void SocketAsyncWork::ExecTcpConnectionClose(napi_env env, void *data)
143 {
144 BaseAsyncWork::ExecAsyncWork<TcpServerCloseContext, SocketExec::ExecTcpConnectionClose>(env, data);
145 }
146
ExecTcpServerListen(napi_env env,void * data)147 void SocketAsyncWork::ExecTcpServerListen(napi_env env, void *data)
148 {
149 BaseAsyncWork::ExecAsyncWork<TcpServerListenContext, SocketExec::ExecTcpServerListen>(env, data);
150 }
151
ExecTcpServerSetExtraOptions(napi_env env,void * data)152 void SocketAsyncWork::ExecTcpServerSetExtraOptions(napi_env env, void *data)
153 {
154 BaseAsyncWork::ExecAsyncWork<TcpServerSetExtraOptionsContext, SocketExec::ExecTcpServerSetExtraOptions>(env, data);
155 }
156
ExecTcpServerGetState(napi_env env,void * data)157 void SocketAsyncWork::ExecTcpServerGetState(napi_env env, void *data)
158 {
159 BaseAsyncWork::ExecAsyncWork<TcpServerGetStateContext, SocketExec::ExecTcpServerGetState>(env, data);
160 }
161
ExecLocalSocketBind(napi_env env,void * data)162 void SocketAsyncWork::ExecLocalSocketBind(napi_env env, void *data)
163 {
164 BaseAsyncWork::ExecAsyncWork<LocalSocketBindContext, LocalSocketExec::ExecLocalSocketBind>(env, data);
165 }
166
ExecLocalSocketConnect(napi_env env,void * data)167 void SocketAsyncWork::ExecLocalSocketConnect(napi_env env, void *data)
168 {
169 BaseAsyncWork::ExecAsyncWork<LocalSocketConnectContext, LocalSocketExec::ExecLocalSocketConnect>(env, data);
170 }
171
ExecLocalSocketSend(napi_env env,void * data)172 void SocketAsyncWork::ExecLocalSocketSend(napi_env env, void *data)
173 {
174 BaseAsyncWork::ExecAsyncWork<LocalSocketSendContext, LocalSocketExec::ExecLocalSocketSend>(env, data);
175 }
176
ExecLocalSocketClose(napi_env env,void * data)177 void SocketAsyncWork::ExecLocalSocketClose(napi_env env, void *data)
178 {
179 BaseAsyncWork::ExecAsyncWork<LocalSocketCloseContext, LocalSocketExec::ExecLocalSocketClose>(env, data);
180 }
181
ExecLocalSocketGetState(napi_env env,void * data)182 void SocketAsyncWork::ExecLocalSocketGetState(napi_env env, void *data)
183 {
184 BaseAsyncWork::ExecAsyncWork<LocalSocketGetStateContext, LocalSocketExec::ExecLocalSocketGetState>(env, data);
185 }
186
ExecLocalSocketGetSocketFd(napi_env env,void * data)187 void SocketAsyncWork::ExecLocalSocketGetSocketFd(napi_env env, void *data)
188 {
189 BaseAsyncWork::ExecAsyncWork<LocalSocketGetSocketFdContext, LocalSocketExec::ExecLocalSocketGetSocketFd>(env, data);
190 }
191
ExecLocalSocketSetExtraOptions(napi_env env,void * data)192 void SocketAsyncWork::ExecLocalSocketSetExtraOptions(napi_env env, void *data)
193 {
194 BaseAsyncWork::ExecAsyncWork<LocalSocketSetExtraOptionsContext, LocalSocketExec::ExecLocalSocketSetExtraOptions>(
195 env, data);
196 }
197
ExecLocalSocketGetExtraOptions(napi_env env,void * data)198 void SocketAsyncWork::ExecLocalSocketGetExtraOptions(napi_env env, void *data)
199 {
200 BaseAsyncWork::ExecAsyncWork<LocalSocketGetExtraOptionsContext, LocalSocketExec::ExecLocalSocketGetExtraOptions>(
201 env, data);
202 }
203
ExecLocalSocketServerListen(napi_env env,void * data)204 void SocketAsyncWork::ExecLocalSocketServerListen(napi_env env, void *data)
205 {
206 BaseAsyncWork::ExecAsyncWork<LocalSocketServerListenContext, LocalSocketExec::ExecLocalSocketServerListen>(env,
207 data);
208 }
209
ExecLocalSocketServerGetState(napi_env env,void * data)210 void SocketAsyncWork::ExecLocalSocketServerGetState(napi_env env, void *data)
211 {
212 BaseAsyncWork::ExecAsyncWork<LocalSocketServerGetStateContext, LocalSocketExec::ExecLocalSocketServerGetState>(
213 env, data);
214 }
215
ExecLocalSocketServerSetExtraOptions(napi_env env,void * data)216 void SocketAsyncWork::ExecLocalSocketServerSetExtraOptions(napi_env env, void *data)
217 {
218 BaseAsyncWork::ExecAsyncWork<LocalSocketServerSetExtraOptionsContext,
219 LocalSocketExec::ExecLocalSocketServerSetExtraOptions>(env, data);
220 }
221
ExecLocalSocketServerGetExtraOptions(napi_env env,void * data)222 void SocketAsyncWork::ExecLocalSocketServerGetExtraOptions(napi_env env, void *data)
223 {
224 BaseAsyncWork::ExecAsyncWork<LocalSocketServerGetExtraOptionsContext,
225 LocalSocketExec::ExecLocalSocketServerGetExtraOptions>(env, data);
226 }
227
ExecLocalSocketConnectionSend(napi_env env,void * data)228 void SocketAsyncWork::ExecLocalSocketConnectionSend(napi_env env, void *data)
229 {
230 BaseAsyncWork::ExecAsyncWork<LocalSocketServerSendContext, LocalSocketExec::ExecLocalSocketConnectionSend>(env,
231 data);
232 }
233
ExecLocalSocketConnectionClose(napi_env env,void * data)234 void SocketAsyncWork::ExecLocalSocketConnectionClose(napi_env env, void *data)
235 {
236 BaseAsyncWork::ExecAsyncWork<LocalSocketServerCloseContext, LocalSocketExec::ExecLocalSocketConnectionClose>(env,
237 data);
238 }
239
BindCallback(napi_env env,napi_status status,void * data)240 void SocketAsyncWork::BindCallback(napi_env env, napi_status status, void *data)
241 {
242 BaseAsyncWork::AsyncWorkCallback<BindContext, SocketExec::BindCallback>(env, status, data);
243 }
244
UdpSendCallback(napi_env env,napi_status status,void * data)245 void SocketAsyncWork::UdpSendCallback(napi_env env, napi_status status, void *data)
246 {
247 BaseAsyncWork::AsyncWorkCallback<UdpSendContext, SocketExec::UdpSendCallback>(env, status, data);
248 }
249
UdpAddMembershipCallback(napi_env env,napi_status status,void * data)250 void SocketAsyncWork::UdpAddMembershipCallback(napi_env env, napi_status status, void *data)
251 {
252 BaseAsyncWork::AsyncWorkCallback<MulticastMembershipContext, SocketExec::UdpAddMembershipCallback>(env, status,
253 data);
254 }
255
UdpDropMembershipCallback(napi_env env,napi_status status,void * data)256 void SocketAsyncWork::UdpDropMembershipCallback(napi_env env, napi_status status, void *data)
257 {
258 BaseAsyncWork::AsyncWorkCallback<MulticastMembershipContext, SocketExec::UdpDropMembershipCallback>(env, status,
259 data);
260 }
261
UdpSetMulticastTTLCallback(napi_env env,napi_status status,void * data)262 void SocketAsyncWork::UdpSetMulticastTTLCallback(napi_env env, napi_status status, void *data)
263 {
264 BaseAsyncWork::AsyncWorkCallback<MulticastSetTTLContext, SocketExec::UdpSetMulticastTTLCallback>(env, status, data);
265 }
266
UdpGetMulticastTTLCallback(napi_env env,napi_status status,void * data)267 void SocketAsyncWork::UdpGetMulticastTTLCallback(napi_env env, napi_status status, void *data)
268 {
269 BaseAsyncWork::AsyncWorkCallback<MulticastGetTTLContext, SocketExec::UdpGetMulticastTTLCallback>(env, status, data);
270 }
271
UdpSetLoopbackModeCallback(napi_env env,napi_status status,void * data)272 void SocketAsyncWork::UdpSetLoopbackModeCallback(napi_env env, napi_status status, void *data)
273 {
274 BaseAsyncWork::AsyncWorkCallback<MulticastSetLoopbackContext, SocketExec::UdpSetLoopbackModeCallback>(env, status,
275 data);
276 }
277
UdpGetLoopbackModeCallback(napi_env env,napi_status status,void * data)278 void SocketAsyncWork::UdpGetLoopbackModeCallback(napi_env env, napi_status status, void *data)
279 {
280 BaseAsyncWork::AsyncWorkCallback<MulticastGetLoopbackContext, SocketExec::UdpGetLoopbackModeCallback>(env, status,
281 data);
282 }
283
ConnectCallback(napi_env env,napi_status status,void * data)284 void SocketAsyncWork::ConnectCallback(napi_env env, napi_status status, void *data)
285 {
286 BaseAsyncWork::AsyncWorkCallback<ConnectContext, SocketExec::ConnectCallback>(env, status, data);
287 }
288
TcpSendCallback(napi_env env,napi_status status,void * data)289 void SocketAsyncWork::TcpSendCallback(napi_env env, napi_status status, void *data)
290 {
291 BaseAsyncWork::AsyncWorkCallback<TcpSendContext, SocketExec::TcpSendCallback>(env, status, data);
292 }
293
CloseCallback(napi_env env,napi_status status,void * data)294 void SocketAsyncWork::CloseCallback(napi_env env, napi_status status, void *data)
295 {
296 BaseAsyncWork::AsyncWorkCallback<CloseContext, SocketExec::CloseCallback>(env, status, data);
297 }
298
GetStateCallback(napi_env env,napi_status status,void * data)299 void SocketAsyncWork::GetStateCallback(napi_env env, napi_status status, void *data)
300 {
301 BaseAsyncWork::AsyncWorkCallback<GetStateContext, SocketExec::GetStateCallback>(env, status, data);
302 }
303
GetRemoteAddressCallback(napi_env env,napi_status status,void * data)304 void SocketAsyncWork::GetRemoteAddressCallback(napi_env env, napi_status status, void *data)
305 {
306 BaseAsyncWork::AsyncWorkCallback<GetRemoteAddressContext, SocketExec::GetRemoteAddressCallback>(env, status, data);
307 }
308
TcpSetExtraOptionsCallback(napi_env env,napi_status status,void * data)309 void SocketAsyncWork::TcpSetExtraOptionsCallback(napi_env env, napi_status status, void *data)
310 {
311 BaseAsyncWork::AsyncWorkCallback<TcpSetExtraOptionsContext, SocketExec::TcpSetExtraOptionsCallback>(env, status,
312 data);
313 }
314
UdpSetExtraOptionsCallback(napi_env env,napi_status status,void * data)315 void SocketAsyncWork::UdpSetExtraOptionsCallback(napi_env env, napi_status status, void *data)
316 {
317 BaseAsyncWork::AsyncWorkCallback<UdpSetExtraOptionsContext, SocketExec::UdpSetExtraOptionsCallback>(env, status,
318 data);
319 }
320
TcpGetSocketFdCallback(napi_env env,napi_status status,void * data)321 void SocketAsyncWork::TcpGetSocketFdCallback(napi_env env, napi_status status, void *data)
322 {
323 BaseAsyncWork::AsyncWorkCallback<GetSocketFdContext, SocketExec::TcpGetSocketFdCallback>(env, status, data);
324 }
325
UdpGetSocketFdCallback(napi_env env,napi_status status,void * data)326 void SocketAsyncWork::UdpGetSocketFdCallback(napi_env env, napi_status status, void *data)
327 {
328 BaseAsyncWork::AsyncWorkCallback<GetSocketFdContext, SocketExec::UdpGetSocketFdCallback>(env, status, data);
329 }
330
TcpConnectionSendCallback(napi_env env,napi_status status,void * data)331 void SocketAsyncWork::TcpConnectionSendCallback(napi_env env, napi_status status, void *data)
332 {
333 BaseAsyncWork::AsyncWorkCallback<TcpServerSendContext, SocketExec::TcpConnectionSendCallback>(env, status, data);
334 }
335
TcpConnectionCloseCallback(napi_env env,napi_status status,void * data)336 void SocketAsyncWork::TcpConnectionCloseCallback(napi_env env, napi_status status, void *data)
337 {
338 BaseAsyncWork::AsyncWorkCallback<TcpServerCloseContext, SocketExec::TcpConnectionCloseCallback>(env, status, data);
339 }
340
TcpConnectionGetRemoteAddressCallback(napi_env env,napi_status status,void * data)341 void SocketAsyncWork::TcpConnectionGetRemoteAddressCallback(napi_env env, napi_status status, void *data)
342 {
343 BaseAsyncWork::AsyncWorkCallback<TcpServerGetRemoteAddressContext,
344 SocketExec::TcpConnectionGetRemoteAddressCallback>(env, status, data);
345 }
346
ListenCallback(napi_env env,napi_status status,void * data)347 void SocketAsyncWork::ListenCallback(napi_env env, napi_status status, void *data)
348 {
349 BaseAsyncWork::AsyncWorkCallback<TcpServerListenContext, SocketExec::ListenCallback>(env, status, data);
350 }
351
TcpServerSetExtraOptionsCallback(napi_env env,napi_status status,void * data)352 void SocketAsyncWork::TcpServerSetExtraOptionsCallback(napi_env env, napi_status status, void *data)
353 {
354 BaseAsyncWork::AsyncWorkCallback<TcpServerSetExtraOptionsContext, SocketExec::TcpServerSetExtraOptionsCallback>(
355 env, status, data);
356 }
357
TcpServerGetStateCallback(napi_env env,napi_status status,void * data)358 void SocketAsyncWork::TcpServerGetStateCallback(napi_env env, napi_status status, void *data)
359 {
360 BaseAsyncWork::AsyncWorkCallback<TcpServerGetStateContext, SocketExec::TcpServerGetStateCallback>(env, status,
361 data);
362 }
363
LocalSocketBindCallback(napi_env env,napi_status status,void * data)364 void SocketAsyncWork::LocalSocketBindCallback(napi_env env, napi_status status, void *data)
365 {
366 BaseAsyncWork::AsyncWorkCallback<LocalSocketBindContext, LocalSocketExec::LocalSocketBindCallback>(env, status,
367 data);
368 }
369
LocalSocketConnectCallback(napi_env env,napi_status status,void * data)370 void SocketAsyncWork::LocalSocketConnectCallback(napi_env env, napi_status status, void *data)
371 {
372 BaseAsyncWork::AsyncWorkCallback<LocalSocketConnectContext, LocalSocketExec::LocalSocketConnectCallback>(
373 env, status, data);
374 }
375
LocalSocketSendCallback(napi_env env,napi_status status,void * data)376 void SocketAsyncWork::LocalSocketSendCallback(napi_env env, napi_status status, void *data)
377 {
378 BaseAsyncWork::AsyncWorkCallback<LocalSocketSendContext, LocalSocketExec::LocalSocketSendCallback>(env, status,
379 data);
380 }
381
LocalSocketCloseCallback(napi_env env,napi_status status,void * data)382 void SocketAsyncWork::LocalSocketCloseCallback(napi_env env, napi_status status, void *data)
383 {
384 BaseAsyncWork::AsyncWorkCallback<LocalSocketCloseContext, LocalSocketExec::LocalSocketCloseCallback>(env, status,
385 data);
386 }
387
LocalSocketGetStateCallback(napi_env env,napi_status status,void * data)388 void SocketAsyncWork::LocalSocketGetStateCallback(napi_env env, napi_status status, void *data)
389 {
390 BaseAsyncWork::AsyncWorkCallback<LocalSocketGetStateContext, LocalSocketExec::LocalSocketGetStateCallback>(
391 env, status, data);
392 }
393
LocalSocketGetSocketFdCallback(napi_env env,napi_status status,void * data)394 void SocketAsyncWork::LocalSocketGetSocketFdCallback(napi_env env, napi_status status, void *data)
395 {
396 BaseAsyncWork::AsyncWorkCallback<LocalSocketGetSocketFdContext, LocalSocketExec::LocalSocketGetSocketFdCallback>(
397 env, status, data);
398 }
399
LocalSocketSetExtraOptionsCallback(napi_env env,napi_status status,void * data)400 void SocketAsyncWork::LocalSocketSetExtraOptionsCallback(napi_env env, napi_status status, void *data)
401 {
402 BaseAsyncWork::AsyncWorkCallback<LocalSocketSetExtraOptionsContext,
403 LocalSocketExec::LocalSocketSetExtraOptionsCallback>(env, status, data);
404 }
405
LocalSocketGetExtraOptionsCallback(napi_env env,napi_status status,void * data)406 void SocketAsyncWork::LocalSocketGetExtraOptionsCallback(napi_env env, napi_status status, void *data)
407 {
408 BaseAsyncWork::AsyncWorkCallback<LocalSocketGetExtraOptionsContext,
409 LocalSocketExec::LocalSocketGetExtraOptionsCallback>(env, status, data);
410 }
411
LocalSocketServerListenCallback(napi_env env,napi_status status,void * data)412 void SocketAsyncWork::LocalSocketServerListenCallback(napi_env env, napi_status status, void *data)
413 {
414 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerListenContext, LocalSocketExec::LocalSocketServerListenCallback>(
415 env, status, data);
416 }
417
LocalSocketServerGetStateCallback(napi_env env,napi_status status,void * data)418 void SocketAsyncWork::LocalSocketServerGetStateCallback(napi_env env, napi_status status, void *data)
419 {
420 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerGetStateContext,
421 LocalSocketExec::LocalSocketServerGetStateCallback>(env, status, data);
422 }
423
LocalSocketServerSetExtraOptionsCallback(napi_env env,napi_status status,void * data)424 void SocketAsyncWork::LocalSocketServerSetExtraOptionsCallback(napi_env env, napi_status status, void *data)
425 {
426 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerSetExtraOptionsContext,
427 LocalSocketExec::LocalSocketServerSetExtraOptionsCallback>(env, status, data);
428 }
429
LocalSocketServerGetExtraOptionsCallback(napi_env env,napi_status status,void * data)430 void SocketAsyncWork::LocalSocketServerGetExtraOptionsCallback(napi_env env, napi_status status, void *data)
431 {
432 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerGetExtraOptionsContext,
433 LocalSocketExec::LocalSocketServerGetExtraOptionsCallback>(env, status, data);
434 }
435
LocalSocketConnectionSendCallback(napi_env env,napi_status status,void * data)436 void SocketAsyncWork::LocalSocketConnectionSendCallback(napi_env env, napi_status status, void *data)
437 {
438 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerSendContext, LocalSocketExec::LocalSocketConnectionSendCallback>(
439 env, status, data);
440 }
441
LocalSocketConnectionCloseCallback(napi_env env,napi_status status,void * data)442 void SocketAsyncWork::LocalSocketConnectionCloseCallback(napi_env env, napi_status status, void *data)
443 {
444 BaseAsyncWork::AsyncWorkCallback<LocalSocketServerCloseContext,
445 LocalSocketExec::LocalSocketConnectionCloseCallback>(env, status, data);
446 }
447 } // namespace OHOS::NetStack::Socket
448