From ad900636080477eb2c8df7a225a71825e5380d3d Mon Sep 17 00:00:00 2001 From: Kai Stevenson Date: Mon, 20 Mar 2023 03:51:08 -0700 Subject: added proper cancellation token handling; cleanup when host is found to be unresponsive --- src/fscomch.h | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) (limited to 'src/fscomch.h') diff --git a/src/fscomch.h b/src/fscomch.h index bc92467..6aa7fb7 100644 --- a/src/fscomch.h +++ b/src/fscomch.h @@ -14,15 +14,22 @@ typedef struct Match { } match_t; match_t init_match(char* uuid, FILE* streamIn, FILE* streamOut); void destroy_match(match_t match); +typedef struct CancellationToken { + int timeout; + volatile char* value; +} cancelToken_t; +cancelToken_t init_cancel_token_timeout(int seconds); +cancelToken_t init_cancel_token_never(); /* returns null if the matchfile is already extant */ FILE* try_lock_match(); /* creates a new match, waits for it to be joined by another player */ -match_t await_match(FILE* matchFile, char* cancelToken); +match_t await_match(FILE* matchFile, cancelToken_t cancelToken); /* joins an existing match */ match_t join_match(); void send_message(char* content, match_t match); /* blocks */ -char* read_message(match_t match, char* cancelToken); +char* read_message(match_t match, cancelToken_t cancelToken); char* make_uuid(); +void* cancel_in_secs(void* token); #endif -- cgit v1.3.1