Steve Karg
cf77abac9b
* Added BACnet Secure Connect datalink. * Added BACnet/SC hub application --------- Co-authored-by: Kirill Neznamov <kirill.neznamov@dsr-corporation.com> Co-authored-by: Mikhail Antropov <michail.antropov@dsr-corporation.com> Co-authored-by: Ondřej Hruška <ondra@ondrovo.com> Co-authored-by: Patrick Grimm <patrick@lunatiki.de>
106 lines
3.2 KiB
C
106 lines
3.2 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
|
|
*/
|
|
#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"
|
|
|
|
static pthread_mutex_t websocket_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER;
|
|
static pthread_mutex_t websocket_dispatch_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER;
|
|
|
|
#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 int volatile websocket_mutex_cnt = 0;
|
|
static int volatile websocket_dispatch_mutex_cnt = 0;
|
|
|
|
void bsc_websocket_global_lock_dbg(char *f, int line)
|
|
{
|
|
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);
|
|
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)
|
|
{
|
|
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);
|
|
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)
|
|
{
|
|
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);
|
|
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)
|
|
{
|
|
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);
|
|
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
|
|
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();
|
|
}
|