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>
81 lines
1.8 KiB
C
81 lines
1.8 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 <libwebsockets.h>
|
|
#include <string.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <windows.h>
|
|
#include "websocket-global.h"
|
|
|
|
static HANDLE websocket_mutex = NULL;
|
|
static HANDLE websocket_dispatch_mutex = NULL;
|
|
|
|
static void bsc_init_mutex(volatile HANDLE *m)
|
|
{
|
|
HANDLE p;
|
|
if (*m == NULL) {
|
|
p = CreateMutex(NULL, FALSE, NULL);
|
|
if (InterlockedCompareExchangePointer((PVOID *)m, (PVOID)p, NULL) !=
|
|
NULL) {
|
|
CloseHandle(p);
|
|
}
|
|
}
|
|
}
|
|
|
|
void bsc_mutex_lock(volatile HANDLE *m)
|
|
{
|
|
bsc_init_mutex(m);
|
|
WaitForSingleObject(*m, INFINITE);
|
|
}
|
|
|
|
void bsc_mutex_unlock(volatile HANDLE *m)
|
|
{
|
|
ReleaseMutex(*m);
|
|
}
|
|
|
|
void bsc_websocket_global_lock(void)
|
|
{
|
|
bsc_mutex_lock(&websocket_mutex);
|
|
}
|
|
|
|
void bsc_websocket_global_unlock(void)
|
|
{
|
|
bsc_mutex_unlock(&websocket_mutex);
|
|
}
|
|
|
|
void bws_dispatch_lock(void)
|
|
{
|
|
bsc_mutex_lock(&websocket_dispatch_mutex);
|
|
}
|
|
|
|
void bws_dispatch_unlock(void)
|
|
{
|
|
bsc_mutex_unlock(&websocket_dispatch_mutex);
|
|
}
|
|
|
|
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();
|
|
}
|