23
23
#include "iotjs_reqwrap.h"
24
24
25
25
26
- static void iotjs_udpwrap_destroy (iotjs_udpwrap_t * udpwrap );
27
- IOTJS_DEFINE_NATIVE_HANDLE_INFO (udpwrap );
26
+ IOTJS_DEFINE_NATIVE_HANDLE_INFO_THIS_MODULE (udpwrap );
28
27
29
28
30
29
iotjs_udpwrap_t * iotjs_udpwrap_create (const iotjs_jval_t * judp ) {
@@ -33,7 +32,7 @@ iotjs_udpwrap_t* iotjs_udpwrap_create(const iotjs_jval_t* judp) {
33
32
34
33
iotjs_handlewrap_initialize (& _this -> handlewrap , judp ,
35
34
(uv_handle_t * )(& _this -> handle ),
36
- & udpwrap_native_info );
35
+ & this_module_native_info );
37
36
38
37
const iotjs_environment_t * env = iotjs_environment_get ();
39
38
uv_udp_init (iotjs_environment_loop (env ), & _this -> handle );
@@ -58,12 +57,6 @@ iotjs_udpwrap_t* iotjs_udpwrap_from_handle(uv_udp_t* udp_handle) {
58
57
}
59
58
60
59
61
- iotjs_udpwrap_t * iotjs_udpwrap_from_jobject (const iotjs_jval_t * judp ) {
62
- iotjs_handlewrap_t * handlewrap = iotjs_handlewrap_from_jobject (judp );
63
- return (iotjs_udpwrap_t * )handlewrap ;
64
- }
65
-
66
-
67
60
uv_udp_t * iotjs_udpwrap_udp_handle (iotjs_udpwrap_t * udpwrap ) {
68
61
IOTJS_VALIDATED_STRUCT_METHOD (iotjs_udpwrap_t , udpwrap );
69
62
uv_handle_t * handle = iotjs_handlewrap_get_uv_handle (& _this -> handlewrap );
@@ -135,12 +128,9 @@ JHANDLER_FUNCTION(UDP) {
135
128
136
129
137
130
JHANDLER_FUNCTION (Bind ) {
138
- DJHANDLER_CHECK_THIS ( object );
131
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
139
132
DJHANDLER_CHECK_ARGS (2 , string , number );
140
133
141
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
142
- iotjs_udpwrap_t * udp_wrap = iotjs_udpwrap_from_jobject (judp );
143
-
144
134
iotjs_string_t address = JHANDLER_GET_ARG (0 , string );
145
135
const int port = JHANDLER_GET_ARG (1 , number );
146
136
const iotjs_jval_t * this_obj = JHANDLER_GET_THIS (object );
@@ -234,12 +224,9 @@ static void OnRecv(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf,
234
224
235
225
236
226
JHANDLER_FUNCTION (RecvStart ) {
237
- DJHANDLER_CHECK_THIS ( object );
227
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
238
228
DJHANDLER_CHECK_ARGS (0 );
239
229
240
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
241
- iotjs_udpwrap_t * udp_wrap = iotjs_udpwrap_from_jobject (judp );
242
-
243
230
int err =
244
231
uv_udp_recv_start (iotjs_udpwrap_udp_handle (udp_wrap ), OnAlloc , OnRecv );
245
232
@@ -252,12 +239,9 @@ JHANDLER_FUNCTION(RecvStart) {
252
239
253
240
254
241
JHANDLER_FUNCTION (RecvStop ) {
255
- DJHANDLER_CHECK_THIS ( object );
242
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
256
243
DJHANDLER_CHECK_ARGS (0 );
257
244
258
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
259
- iotjs_udpwrap_t * udp_wrap = iotjs_udpwrap_from_jobject (judp );
260
-
261
245
int r = uv_udp_recv_stop (iotjs_udpwrap_udp_handle (udp_wrap ));
262
246
263
247
iotjs_jhandler_return_number (jhandler , r );
@@ -292,14 +276,11 @@ static void OnSend(uv_udp_send_t* req, int status) {
292
276
// [2] ip
293
277
// [3] callback function
294
278
JHANDLER_FUNCTION (Send ) {
295
- DJHANDLER_CHECK_THIS ( object );
279
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
296
280
DJHANDLER_CHECK_ARGS (3 , object , number , string );
297
281
IOTJS_ASSERT (iotjs_jval_is_function (iotjs_jhandler_get_arg (jhandler , 3 )) ||
298
282
iotjs_jval_is_undefined (iotjs_jhandler_get_arg (jhandler , 3 )));
299
283
300
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
301
- iotjs_udpwrap_t * udp_wrap = iotjs_udpwrap_from_jobject (judp );
302
-
303
284
const iotjs_jval_t * jbuffer = JHANDLER_GET_ARG (0 , object );
304
285
const unsigned short port = JHANDLER_GET_ARG (1 , number );
305
286
iotjs_string_t address = JHANDLER_GET_ARG (2 , string );
@@ -337,13 +318,10 @@ JHANDLER_FUNCTION(Send) {
337
318
338
319
// Close socket
339
320
JHANDLER_FUNCTION (Close ) {
340
- DJHANDLER_CHECK_THIS ( object );
321
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
341
322
DJHANDLER_CHECK_ARGS (0 );
342
323
343
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
344
- iotjs_handlewrap_t * wrap = iotjs_handlewrap_from_jobject (judp );
345
-
346
- iotjs_handlewrap_close (wrap , NULL );
324
+ iotjs_handlewrap_close (udp_wrap , NULL );
347
325
}
348
326
349
327
@@ -355,16 +333,13 @@ JHANDLER_FUNCTION(GetSockeName) {
355
333
}
356
334
357
335
358
- #define IOTJS_UV_SET_SOCKOPT (fn ) \
359
- DJHANDLER_CHECK_THIS(object); \
360
- DJHANDLER_CHECK_ARGS(1, number); \
361
- \
362
- const iotjs_jval_t* judp = JHANDLER_GET_THIS(object); \
363
- iotjs_udpwrap_t* udp_wrap = iotjs_udpwrap_from_jobject(judp); \
364
- \
365
- int flag = JHANDLER_GET_ARG(0, number); \
366
- int err = fn(iotjs_udpwrap_udp_handle(udp_wrap), flag); \
367
- \
336
+ #define IOTJS_UV_SET_SOCKOPT (fn ) \
337
+ JHANDLER_DECLARE_THIS_PTR(udpwrap, udp_wrap); \
338
+ DJHANDLER_CHECK_ARGS(1, number); \
339
+ \
340
+ int flag = JHANDLER_GET_ARG(0, number); \
341
+ int err = fn(iotjs_udpwrap_udp_handle(udp_wrap), flag); \
342
+ \
368
343
iotjs_jhandler_return_number(jhandler, err);
369
344
370
345
@@ -416,12 +391,9 @@ JHANDLER_FUNCTION(SetMulticastLoopback) {
416
391
417
392
void SetMembership (iotjs_jhandler_t * jhandler , uv_membership membership ) {
418
393
#if !defined(__NUTTX__ ) && !defined(__TIZENRT__ )
419
- DJHANDLER_CHECK_THIS ( object );
394
+ JHANDLER_DECLARE_THIS_PTR ( udpwrap , udp_wrap );
420
395
DJHANDLER_CHECK_ARGS (1 , string );
421
396
422
- const iotjs_jval_t * judp = JHANDLER_GET_THIS (object );
423
- iotjs_udpwrap_t * udp_wrap = iotjs_udpwrap_from_jobject (judp );
424
-
425
397
iotjs_string_t address = JHANDLER_GET_ARG (0 , string );
426
398
const iotjs_jval_t * arg1 = iotjs_jhandler_get_arg (jhandler , 1 );
427
399
bool isUndefinedOrNull =
0 commit comments