aboutsummaryrefslogtreecommitdiffstats
path: root/src/libunixonacid/sassclient_cancel.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/libunixonacid/sassclient_cancel.c')
-rw-r--r--src/libunixonacid/sassclient_cancel.c39
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 ;
+}