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
|
#if !defined( __LANES_CANCEL_H__)
#define __LANES_CANCEL_H__ 1
#include "lua.h"
#include "lualib.h"
#include "lauxlib.h"
#include "uniquekey.h"
#include "macros_and_utils.h"
// ################################################################################################
typedef struct s_Lane Lane; // forward
/*
* Lane cancellation request modes
*/
enum e_cancel_request
{
CANCEL_NONE, // no pending cancel request
CANCEL_SOFT, // user wants the lane to cancel itself manually on cancel_test()
CANCEL_HARD // user wants the lane to be interrupted (meaning code won't return from those functions) from inside linda:send/receive calls
};
typedef enum
{
CR_Timeout,
CR_Cancelled,
CR_Killed
} cancel_result;
typedef enum
{
CO_Invalid = -2,
CO_Hard = -1,
CO_Soft = 0,
CO_Count = LUA_MASKCOUNT,
CO_Line = LUA_MASKLINE,
CO_Call = LUA_MASKCALL,
CO_Ret = LUA_MASKRET,
} CancelOp;
// crc64/we of string "CANCEL_ERROR" generated at http://www.nitrxgen.net/hashgen/
static DECLARE_CONST_UNIQUE_KEY(CANCEL_ERROR, 0xe97d41626cc97577); // 'cancel_error' sentinel
// crc64/we of string "CANCEL_TEST_KEY" generated at http://www.nitrxgen.net/hashgen/
static DECLARE_CONST_UNIQUE_KEY(CANCEL_TEST_KEY, 0xe66f5960c57d133a); // used as registry key
cancel_result thread_cancel( lua_State* L, Lane* s, CancelOp op_, double secs_, bool_t force_, double waitkill_timeout_);
static inline int cancel_error( lua_State* L)
{
STACK_GROW( L, 1);
push_unique_key( L, CANCEL_ERROR); // special error value
return lua_error( L); // doesn't return
}
// ################################################################################################
// ################################################################################################
LUAG_FUNC( cancel_test);
LUAG_FUNC( thread_cancel);
// ################################################################################################
#endif // __LANES_CANCEL_H__
|
