stephenseo/UDPConnection
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages 1 Wiki Activity Actions

Minor changes/fixes, clang-format fixes

Browse source
This commit is contained in:
Stephen Seo 2019-07-21 13:45:42 +09:00
parent 084700d54b
commit 640102c091
2 changed files with 39 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cpp_impl/src/UDPC_Defines.hpp
View file

@ -25,7 +25,7 @@ struct Context {
char atostrBuf[16];
}; // struct Context
bool VerifyContext(void *ctx);
Context* verifyContext(void *ctx);
bool isBigEndian();

51
cpp_impl/src/UDPConnection.cpp
View file

@ -1,7 +1,6 @@
#include "UDPC_Defines.hpp"
#include "UDPConnection.h"
#include <optional>
UDPC::Context::Context(bool isThreaded)
@ -20,15 +19,15 @@ UDPC::Context::Context(bool isThreaded)
}
}
bool UDPC::VerifyContext(void *ctx) {
UDPC::Context *UDPC::verifyContext(void *ctx) {
if(ctx == nullptr) {
return false;
return nullptr;
}
UDPC::Context *c = (UDPC::Context *)ctx;
if(c->_contextIdentifier == UDPC_CONTEXT_IDENTIFIER) {
return true;
return c;
} else {
return false;
return nullptr;
}
}
@ -46,7 +45,6 @@ bool UDPC::isBigEndian() {
return *isBigEndian;
}
void *UDPC_init(uint16_t listenPort, uint32_t listenAddr, int isClient) {
UDPC::Context *ctx = new UDPC::Context(false);
@ -61,16 +59,17 @@ void *UDPC_init_threaded_update(uint16_t listenPort, uint32_t listenAddr,
}
void UDPC_destroy(void *ctx) {
if (UDPC::VerifyContext(ctx)) {
delete (UDPC::Context *)ctx;
UDPC::Context *UDPC_ctx = UDPC::verifyContext(ctx);
if(UDPC_ctx) {
delete UDPC_ctx;
}
}
void UDPC_update(void *ctx) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return;
}
UDPC::Context *c = (UDPC::Context *)ctx;
if(c->flags.test(0)) {
// is threaded, update should not be called
return;
@ -80,70 +79,70 @@ void UDPC_update(void *ctx) {
}
int UDPC_get_queue_send_available(void *ctx, uint32_t addr) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return 0;
}
UDPC::Context *c = (UDPC::Context *)ctx;
// TODO impl
return 0;
}
void UDPC_queue_send(void *ctx, uint32_t destAddr, uint16_t destPort,
uint32_t isChecked, void *data, uint32_t size) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return;
}
UDPC::Context *c = (UDPC::Context *)ctx;
// TODO impl
}
int UDPC_set_accept_new_connections(void *ctx, int isAccepting) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return 0;
}
UDPC::Context *c = (UDPC::Context *)ctx;
return c->isAcceptNewConnections.exchange(isAccepting == 0 ? false : true);
}
int UDPC_drop_connection(void *ctx, uint32_t addr, uint16_t port) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return 0;
}
UDPC::Context *c = (UDPC::Context *)ctx;
// TODO impl
return 0;
}
uint32_t UDPC_set_protocol_id(void *ctx, uint32_t id) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return 0;
}
UDPC::Context *c = (UDPC::Context *)ctx;
return c->protocolID.exchange(id);
}
UDPC_LoggingType set_logging_type(void *ctx, UDPC_LoggingType loggingType) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return static_cast<UDPC_LoggingType>(0);
}
UDPC::Context *c = (UDPC::Context *)ctx;
return static_cast<UDPC_LoggingType>(c->loggingType.exchange(loggingType));
}
PacketInfo UDPC_get_received(void *ctx) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return PacketInfo{{0}, 0, 0, 0, 0, 0};
}
UDPC::Context *c = (UDPC::Context *)ctx;
// TODO impl
return PacketInfo{{0}, 0, 0, 0, 0, 0};
}
const char *UDPC_atostr(void *ctx, uint32_t addr) {
if (!UDPC::VerifyContext(ctx)) {
UDPC::Context *c = UDPC::verifyContext(ctx);
if(!c) {
return nullptr;
}
UDPC::Context *c = (UDPC::Context *)ctx;
int index = 0;
for(int x = 0; x < 4; ++x) {
unsigned char temp = (addr >> (x * 8)) & 0xFF;