tmp: test a sync

emqx · Sep 28, 2023 · 4bd1381 · 4bd1381
1 parent fb96dfe
commit 4bd1381
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/c_src/quicer_listener.c b/c_src/quicer_listener.c
@@ -23,6 +23,7 @@ limitations under the License.
 #include <openssl/x509.h>
 
 extern QuicerRegistrationCTX *G_r_ctx;
+extern pthread_mutex_t GRegLock;
 
 BOOLEAN parse_registration(ErlNifEnv *env,
                            ERL_NIF_TERM options,
@@ -334,12 +335,15 @@ listen2(ErlNifEnv *env, __unused_parm__ int argc, const ERL_NIF_TERM argv[])
 
       // quic_registration is not set, use global registration
       // msquic should reject if global registration is NULL (closed)
+      pthread_mutex_lock(&GRegLock);
       if (G_r_ctx)
         {
           Registration = G_r_ctx->Registration;
+          pthread_mutex_unlock(&GRegLock);
         }
       else
         {
+          pthread_mutex_unlock(&GRegLock);
           ret = ERROR_TUPLE_2(ATOM_QUIC_REGISTRATION);
           goto exit;
         }

diff --git a/test/quicer_SUITE.erl b/test/quicer_SUITE.erl
@@ -321,7 +321,6 @@ tc_open_listener_inval_reg(Config) ->
   quicer:reg_open(),
   ok.
 
-
 tc_stream_client_init(Config) ->
   Port = select_port(),
   Owner = self(),