Ryan Mulder
130 lines
3.7 KiB
C
130 lines
3.7 KiB
C
/**
|
|
* @file
|
|
* @brief Implementation of global websocket functions.
|
|
* @author Kirill Neznamov <kirill.neznamov@dsr-corporation.com>
|
|
* @date May 2022
|
|
* @copyright SPDX-License-Identifier: GPL-2.0-or-later WITH GCC-exception-2.0
|
|
*/
|
|
#define _GNU_SOURCE
|
|
#include <string.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <pthread.h>
|
|
#include <libwebsockets.h>
|
|
#include "websocket-global.h"
|
|
#include "bacnet/basic/sys/debug.h"
|
|
|
|
#if LWS_MAX_SMP <= 1
|
|
#warning \
|
|
"Libwebsockets must be built with LWS_MAX_SMP > 1 (otherwise it does not support thread synchronization in correct way)"
|
|
#endif
|
|
|
|
static pthread_mutex_t websocket_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;
|
|
static pthread_mutex_t websocket_dispatch_mutex =
|
|
PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;
|
|
|
|
#if (BSC_DEBUG_WEBSOCKET_MUTEX_ENABLED != 1)
|
|
|
|
void bsc_websocket_global_lock(void)
|
|
{
|
|
pthread_mutex_lock(&websocket_mutex);
|
|
}
|
|
|
|
void bsc_websocket_global_unlock(void)
|
|
{
|
|
pthread_mutex_unlock(&websocket_mutex);
|
|
}
|
|
|
|
void bws_dispatch_lock(void)
|
|
{
|
|
pthread_mutex_lock(&websocket_dispatch_mutex);
|
|
}
|
|
|
|
void bws_dispatch_unlock(void)
|
|
{
|
|
pthread_mutex_unlock(&websocket_dispatch_mutex);
|
|
}
|
|
|
|
#else
|
|
static volatile int websocket_mutex_cnt = 0;
|
|
static volatile int websocket_dispatch_mutex_cnt = 0;
|
|
|
|
void bsc_websocket_global_lock_dbg(char *f, int line)
|
|
{
|
|
debug_printf(
|
|
"bsc_websocket_global_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f,
|
|
line, websocket_mutex_cnt, pthread_self());
|
|
websocket_mutex_cnt++;
|
|
fflush(stdout);
|
|
pthread_mutex_lock(&websocket_mutex);
|
|
debug_printf(
|
|
"bsc_websocket_global_lock_dbg() <<< lock_cnt %d tid = %ld\n",
|
|
websocket_mutex_cnt, pthread_self());
|
|
fflush(stdout);
|
|
}
|
|
|
|
void bsc_websocket_global_unlock_dbg(char *f, int line)
|
|
{
|
|
debug_printf(
|
|
"bsc_websocket_global_unlock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n",
|
|
f, line, websocket_mutex_cnt, pthread_self());
|
|
websocket_mutex_cnt--;
|
|
fflush(stdout);
|
|
pthread_mutex_unlock(&websocket_mutex);
|
|
debug_printf(
|
|
"bsc_websocket_global_unlock_dbg() <<< lock_cnt %d tid = %ld\n",
|
|
websocket_mutex_cnt, pthread_self());
|
|
fflush(stdout);
|
|
}
|
|
|
|
void bws_dispatch_lock_dbg(char *f, int line)
|
|
{
|
|
debug_printf(
|
|
"bws_dispatch_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line,
|
|
websocket_dispatch_mutex_cnt, pthread_self());
|
|
websocket_dispatch_mutex_cnt++;
|
|
fflush(stdout);
|
|
pthread_mutex_lock(&websocket_dispatch_mutex);
|
|
debug_printf(
|
|
"bws_dispatch_lock_dbg() <<< lock_cnt %d tid = %ld\n",
|
|
websocket_dispatch_mutex_cnt, pthread_self());
|
|
fflush(stdout);
|
|
}
|
|
|
|
void bws_dispatch_unlock_dbg(char *f, int line)
|
|
{
|
|
debug_printf(
|
|
"bws_dispatch_unlock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line,
|
|
websocket_dispatch_mutex_cnt, pthread_self());
|
|
websocket_dispatch_mutex_cnt--;
|
|
fflush(stdout);
|
|
pthread_mutex_unlock(&websocket_dispatch_mutex);
|
|
debug_printf(
|
|
"bws_dispatch_unlock_dbg() <<< lock_cnt %d tid = %ld\n",
|
|
websocket_dispatch_mutex_cnt, pthread_self());
|
|
fflush(stdout);
|
|
}
|
|
|
|
#endif
|
|
|
|
static bool bsc_websocket_log_initialized = false;
|
|
|
|
void bsc_websocket_init_log(void)
|
|
{
|
|
bsc_websocket_global_lock();
|
|
if (!bsc_websocket_log_initialized) {
|
|
bsc_websocket_log_initialized = true;
|
|
#if DEBUG_LIBWEBSOCKETS_ENABLED == 1
|
|
debug_printf("LWS_MAX_SMP = %d", LWS_MAX_SMP);
|
|
lws_set_log_level(
|
|
LLL_ERR | LLL_WARN | LLL_NOTICE | LLL_INFO | LLL_DEBUG |
|
|
LLL_PARSER | LLL_HEADER | LLL_EXT | LLL_CLIENT | LLL_LATENCY |
|
|
LLL_USER | LLL_THREAD,
|
|
NULL);
|
|
#else
|
|
lws_set_log_level(0, NULL);
|
|
#endif
|
|
}
|
|
bsc_websocket_global_unlock();
|
|
}
|