blob: 34cef33f64fc4029be1ef2ebd77aed4f44702a3f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#pragma once
#ifdef __cplusplus
extern "C" {
#endif // __cplusplus
#include "lua.h"
#ifdef __cplusplus
}
#endif // __cplusplus
#include "threading.h"
#include "macros_and_utils.h"
// forwards
struct DeepPrelude;
struct Keepers;
struct Lane;
// ################################################################################################
/*
* Do we want to activate full lane tracking feature? (EXPERIMENTAL)
*/
#define HAVE_LANE_TRACKING() 1
// ################################################################################################
// everything we need to provide to lua_newstate()
struct AllocatorDefinition
{
lua_Alloc allocF;
void* allocUD;
};
// mutex-protected allocator for use with Lua states that share a non-threadsafe allocator
struct ProtectedAllocator
{
AllocatorDefinition definition;
MUTEX_T lock;
};
// ################################################################################################
// everything regarding the Lanes universe is stored in that global structure
// held as a full userdata in the master Lua state that required it for the first time
// don't forget to initialize all members in LG_configure()
struct Universe
{
// for verbose errors
bool verboseErrors;
bool demoteFullUserdata;
// before a state is created, this function will be called to obtain the allocator
lua_CFunction provide_allocator;
// after a state is created, this function will be called right after the bases libraries are loaded
lua_CFunction on_state_create_func;
// if allocator="protected" is found in the configuration settings, a wrapper allocator will protect all allocator calls with a mutex
// contains a mutex and the original allocator definition
ProtectedAllocator protected_allocator;
AllocatorDefinition internal_allocator;
Keepers* keepers;
// Initialized by 'init_once_LOCKED()': the deep userdata Linda object
// used for timers (each lane will get a proxy to this)
volatile DeepPrelude* timer_deep; // = nullptr
#if HAVE_LANE_TRACKING()
MUTEX_T tracking_cs;
Lane* volatile tracking_first; // will change to TRACKING_END if we want to activate tracking
#endif // HAVE_LANE_TRACKING()
MUTEX_T selfdestruct_cs;
// require() serialization
MUTEX_T require_cs;
// Lock for reference counter inc/dec locks (to be initialized by outside code) TODO: get rid of this and use atomics instead!
MUTEX_T deep_lock;
MUTEX_T mtid_lock;
lua_Integer last_mt_id;
#if USE_DEBUG_SPEW()
int debugspew_indent_depth;
#endif // USE_DEBUG_SPEW()
Lane* volatile selfdestruct_first;
// After a lane has removed itself from the chain, it still performs some processing.
// The terminal desinit sequence should wait for all such processing to terminate before force-killing threads
int volatile selfdestructing_count;
};
Universe* universe_get( lua_State* L);
Universe* universe_create( lua_State* L);
void universe_store( lua_State* L, Universe* U);
|
