Add is_valid_context(), fixes/refactorings

diff --git a/src/UDPConnection.cpp b/src/UDPConnection.cpp
index d57cdac1d2dc55fcf12c3758fa535a92b2c12bf9..b8ddc83770901e0d30d2bdc2d72e930a4900bd32 100644 (file)
--- a/src/UDPConnection.cpp
+++ b/src/UDPConnection.cpp
@@ -1809,10 +1809,10 @@ UDPC_HContext UDPC_init_threaded_update_ms(
     return (UDPC_HContext) ctx;
 }
 
-void UDPC_enable_threaded_update(UDPC_HContext ctx) {
+int UDPC_enable_threaded_update(UDPC_HContext ctx) {
     UDPC::Context *c = UDPC::verifyContext(ctx);
     if(!c || c->flags.test(0) || c->thread.joinable()) {
-        return;
+        return 0;
     }
 
     c->flags.set(0);
@@ -1821,12 +1821,13 @@ void UDPC_enable_threaded_update(UDPC_HContext ctx) {
     c->thread = std::thread(UDPC::threadedUpdate, c);
 
     UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Started threaded update");
+    return 1;
 }
 
-void UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS) {
+int UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS) {
     UDPC::Context *c = UDPC::verifyContext(ctx);
     if(!c || c->flags.test(0) || c->thread.joinable()) {
-        return;
+        return 0;
     }
 
     c->flags.set(0);
@@ -1841,12 +1842,13 @@ void UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS) {
     c->thread = std::thread(UDPC::threadedUpdate, c);
 
     UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Started threaded update");
+    return 1;
 }
 
-void UDPC_disable_threaded_update(UDPC_HContext ctx) {
+int UDPC_disable_threaded_update(UDPC_HContext ctx) {
     UDPC::Context *c = UDPC::verifyContext(ctx);
     if(!c || !c->flags.test(0) || !c->thread.joinable()) {
-        return;
+        return 0;
     }
 
     c->threadRunning.store(false);
@@ -1854,6 +1856,11 @@ void UDPC_disable_threaded_update(UDPC_HContext ctx) {
     c->flags.reset(0);
 
     UDPC_CHECK_LOG(c, UDPC_LoggingType::UDPC_INFO, "Stopped threaded update");
+    return 1;
+}
+
+int UDPC_is_valid_context(UDPC_HContext ctx) {
+    return UDPC::verifyContext(ctx) != nullptr ? 1 : 0;
 }
 
 void UDPC_destroy(UDPC_HContext ctx) {

diff --git a/src/UDPConnection.h b/src/UDPConnection.h
index eb95ef63b59b4ac721b725cf808af34c1df975aa..b96873e780fb750c6f3beea13a8021e4bba391eb 100644 (file)
--- a/src/UDPConnection.h
+++ b/src/UDPConnection.h
@@ -135,9 +135,11 @@ UDPC_HContext UDPC_init_threaded_update_ms(
     int updateMS,
     int isUsingLibsodium);
 
-void UDPC_enable_threaded_update(UDPC_HContext ctx);
-void UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS);
-void UDPC_disable_threaded_update(UDPC_HContext ctx);
+int UDPC_enable_threaded_update(UDPC_HContext ctx);
+int UDPC_enable_threaded_update_ms(UDPC_HContext ctx, int updateMS);
+int UDPC_disable_threaded_update(UDPC_HContext ctx);
+
+int UDPC_is_valid_context(UDPC_HContext ctx);
 
 void UDPC_destroy(UDPC_HContext ctx);