Berry cleaned udp class (#19449)

This commit is contained in:
s-hadinger 2023-09-03 21:49:35 +02:00 committed by GitHub
parent a781ba3fc2
commit fe0423c6cd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 29 additions and 38 deletions

View File

@ -5,18 +5,33 @@
* *
*******************************************************************/ *******************************************************************/
#include "be_constobj.h" #include "be_constobj.h"
#include "be_mapping.h"
#ifdef USE_WEBCLIENT #ifdef USE_WEBCLIENT
extern int be_udp_init(struct bvm *vm);
extern int be_udp_deinit(struct bvm *vm);
extern int be_udp_begin(struct bvm *vm);
extern int be_udp_stop(struct bvm *vm);
extern int be_udp_begin_mcast(struct bvm *vm);
extern int be_udp_send(struct bvm *vm);
extern int be_udp_send_mcast(struct bvm *vm);
extern int be_udp_read(struct bvm *vm); extern int be_udp_read(struct bvm *vm);
extern void *be_udp_init_ntv(void);
BE_FUNC_CTYPE_DECLARE(be_udp_init_ntv, "+.p", "")
extern void *be_udp_deinit_ntv(void *udp);
BE_FUNC_CTYPE_DECLARE(be_udp_deinit_ntv, "=.p", "")
extern int32_t be_udp_begin_ntv(void *udp, const char *host, int32_t port);
BE_FUNC_CTYPE_DECLARE(be_udp_begin_ntv, "b", ".si")
extern void be_udp_stop_ntv(void *udp);
BE_FUNC_CTYPE_DECLARE(be_udp_stop_ntv, "", ".")
extern int32_t be_udp_begin_mcast_ntv(void *udp, const char *host, int32_t port);
BE_FUNC_CTYPE_DECLARE(be_udp_begin_mcast_ntv, "b", ".si")
extern int32_t be_udp_send_ntv(void *udp, const char *host, int32_t port, const uint8_t* buf, int32_t len);
BE_FUNC_CTYPE_DECLARE(be_udp_send_ntv, "b", ".si(bytes)~")
extern int32_t be_udp_send_mcast_ntv(void *udp, const uint8_t* buf, int32_t len);
BE_FUNC_CTYPE_DECLARE(be_udp_send_mcast_ntv, "b", ".(bytes)~")
#include "be_mapping.h" #include "be_mapping.h"
#include "be_fixed_be_class_udp.h" #include "be_fixed_be_class_udp.h"
@ -26,16 +41,16 @@ class be_class_udp (scope: global, name: udp) {
.p, var .p, var
remote_ip, var remote_ip, var
remote_port, var remote_port, var
init, func(be_udp_init) init, ctype_func(be_udp_init_ntv)
deinit, func(be_udp_deinit) deinit, ctype_func(be_udp_deinit_ntv)
send, func(be_udp_send) send, ctype_func(be_udp_send_ntv)
send_multicast, func(be_udp_send_mcast) send_multicast, ctype_func(be_udp_send_mcast_ntv)
begin, func(be_udp_begin) begin, ctype_func(be_udp_begin_ntv)
begin_multicast, func(be_udp_begin_mcast) begin_multicast, ctype_func(be_udp_begin_mcast_ntv)
read, func(be_udp_read) read, func(be_udp_read)
close, func(be_udp_stop) close, ctype_func(be_udp_stop_ntv)
} }
@const_object_info_end */ @const_object_info_end */

View File

@ -39,24 +39,15 @@ extern "C" {
// init() // init()
WiFiUDP *be_udp_init_ntv(void) { WiFiUDP *be_udp_init_ntv(void) {
AddLog(LOG_LEVEL_INFO, "be_udp_init_ntv start");
WiFiUDP *udp = new WiFiUDP(); WiFiUDP *udp = new WiFiUDP();
AddLog(LOG_LEVEL_INFO, "be_udp_init_ntv udp=%p", udp);
return udp; return udp;
} }
int32_t be_udp_init(struct bvm *vm) {
AddLog(LOG_LEVEL_INFO, "be_udp_init start");
return be_call_c_func(vm, (void*) &be_udp_init_ntv, "+.p", "");
}
// deinit() // deinit()
void *be_udp_deinit_ntv(WiFiUDP *udp) { void *be_udp_deinit_ntv(WiFiUDP *udp) {
if (udp != nullptr) { delete udp; } if (udp != nullptr) { delete udp; }
return nullptr; return nullptr;
} }
int32_t be_udp_deinit(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_deinit_ntv, "=.p", "");
}
// udp.begin(interface:string, port:int) -> bool // udp.begin(interface:string, port:int) -> bool
int32_t be_udp_begin_ntv(WiFiUDP *udp, const char *host, int32_t port) { int32_t be_udp_begin_ntv(WiFiUDP *udp, const char *host, int32_t port) {
@ -67,17 +58,11 @@ AddLog(LOG_LEVEL_INFO, "be_udp_init start");
} }
return udp->begin(addr, port); return udp->begin(addr, port);
} }
int32_t be_udp_begin(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_begin_ntv, "b", ".si");
}
// udp.stop() -> nil // udp.stop() -> nil
void be_udp_stop_ntv(WiFiUDP *udp) { void be_udp_stop_ntv(WiFiUDP *udp) {
udp->stop(); udp->stop();
} }
int32_t be_udp_stop(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_stop_ntv, "b", ".");
}
// udp.begin_multicast(address:string, port:int) -> nil // udp.begin_multicast(address:string, port:int) -> nil
int32_t be_udp_begin_mcast_ntv(WiFiUDP *udp, const char *host, int32_t port) { int32_t be_udp_begin_mcast_ntv(WiFiUDP *udp, const char *host, int32_t port) {
@ -87,9 +72,6 @@ AddLog(LOG_LEVEL_INFO, "be_udp_init start");
} }
return udp->WiFiUDP::beginMulticast(addr, port); return udp->WiFiUDP::beginMulticast(addr, port);
} }
int32_t be_udp_begin_mcast(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_begin_mcast_ntv, "b", ".si");
}
// udp.send(address:string, port:int, payload:bytes) -> bool // udp.send(address:string, port:int, payload:bytes) -> bool
int32_t be_udp_send_ntv(WiFiUDP *udp, const char *host, int32_t port, const uint8_t* buf, int32_t len) { int32_t be_udp_send_ntv(WiFiUDP *udp, const char *host, int32_t port, const uint8_t* buf, int32_t len) {
@ -104,9 +86,6 @@ AddLog(LOG_LEVEL_INFO, "be_udp_init start");
if (!udp->endPacket()) { return 0; } if (!udp->endPacket()) { return 0; }
return btrue; return btrue;
} }
int32_t be_udp_send(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_send_ntv, "b", ".si(bytes)~");
}
// udp.send_multicast(payload:bytes) -> bool // udp.send_multicast(payload:bytes) -> bool
int32_t be_udp_send_mcast_ntv(WiFiUDP *udp, const uint8_t* buf, int32_t len) { int32_t be_udp_send_mcast_ntv(WiFiUDP *udp, const uint8_t* buf, int32_t len) {
@ -116,9 +95,6 @@ AddLog(LOG_LEVEL_INFO, "be_udp_init start");
if (!udp->endPacket()) { return 0; } if (!udp->endPacket()) { return 0; }
return btrue; return btrue;
} }
int32_t be_udp_send_mcast(struct bvm *vm) {
return be_call_c_func(vm, (void*) &be_udp_send_mcast_ntv, "b", ".(bytes)~");
}
// udp.read() -> bytes or nil // udp.read() -> bytes or nil
int32_t be_udp_read(struct bvm *vm) { int32_t be_udp_read(struct bvm *vm) {