diff options
Diffstat (limited to 'src/libunixonacid/sassclient_cancel.c')
| -rw-r--r-- | src/libunixonacid/sassclient_cancel.c | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/src/libunixonacid/sassclient_cancel.c b/src/libunixonacid/sassclient_cancel.c new file mode 100644 index 0000000..bc4273e --- /dev/null +++ b/src/libunixonacid/sassclient_cancel.c @@ -0,0 +1,39 @@ +/* ISC license. */ + +#include <stdint.h> +#include <errno.h> +#include <time.h> +#include <pthread.h> + +#include <skalibs/uint32.h> +#include <skalibs/tai.h> +#include <skalibs/textclient.h> +#include <skalibs/gensetdyn.h> +#include <skalibs/sassclient.h> +#include "sassclient-internal.h" + +int sassclient_cancel (sassclient *a, uint32_t id, tain const *deadline, tain *stamp) +{ + int e ; + + { + struct timespec ts ; + tain diff ; + tain_sub(&diff, deadline, stamp) ; + if (!timespec_from_tain_relative(&ts, &diff)) return 0 ; + e = pthread_mutex_timedlock(&a->connection_mutex, &ts) ; +// e = pthread_mutex_clocklock(&a->connection_mutex, CLOCK_MONOTONIC, &ts) ; + if (e) return (errno = e, 0) ; + } + + e = sassclient_cancel_internal(a, id, deadline, stamp) ; + if (e) goto err ; + gensetdyn_delete(&a->store, id) ; + pthread_mutex_unlock(&a->connection_mutex) ; + return 1 ; + + err: + pthread_mutex_unlock(&a->connection_mutex) ; + errno = e ; + return 0 ; +} |
