1 files changed, 57 insertions, 0 deletions

diff --git a/src/cancel.h b/src/cancel.h
new file mode 100644
index 0000000..3112809
--- /dev/null
+++ b/src/cancel.h
@@ -0,0 +1,57 @@
+#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;
+
+// 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
+
+void cancel_hook( lua_State* L, lua_Debug* ar);
+
+cancel_result thread_cancel( lua_State* L, Lane* s, 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__