hal/application-lifecycle-tests.lisp
in-package#:luv.tests
deftestrelease-report-attempts-every-step-in-source-order
let
eventsnil
conditionnil
handler-case
luv:with-release-report
luv:releasing:second
setfevents
appendevents'
:second
ok
equal'
:first:second:third
eventsok
ok
equal'
:first:third
mapcar#'luv:release-failure-name
luv:release-error-failurescondition
ok
every
lambda
failure
typep
luv:release-failure-conditionfailure
'errorluv:release-error-failurescondition
deftestrelease-unwind-preserves-primary-and-reports-all-cleanup-failures
let
primary
make-condition'simple-error:format-control"primary body failure"
caughtnil
warningnil
eventsnil
handler-bind
luv:release-warning
lambda
condition
setfwarningcondition
muffle-warningcondition
handler-case
error
condition
setfcaughtcondition
ok
eqprimarycaught
ok
equal'
:one:two:three
eventsok
ok
eqprimary
luv:release-warning-primary-conditionwarning
ok
equal'
:one:three
mapcar#'luv:release-failure-name
luv:release-warning-failureswarning
deftestnormal-release-unwind-signals-cleanup-failure
let
conditionnil
handler-case
luv:unwind-protect-releasing:body-value
luv:releasing:cleanup
error"normal cleanup failed"
ok
ok
equal'
:cleanup
mapcar#'luv:release-failure-name
luv:release-error-failurescondition
deftestcontained-release-failure-is-not-mislabeled-as-primary
let
warningnil
handler-bind
luv:release-warning
lambda
condition
setfwarningcondition
muffle-warningcondition
luv:with-release-warnings
luv:releasing:contained
error"contained release failure"
ok
ok
null
luv:release-warning-primary-conditionwarning
ok
equal'
:contained
mapcar#'luv:release-failure-name
luv:release-warning-failureswarning
deftestattachment-publication-finishes-before-a-racing-stop-can-begin
let*
controller
luv:make-stop-controller:name"attachment race"
publication-entered
sb-thread:make-semaphore:count0
continue-publication
sb-thread:make-semaphore:count0
stop-finished
sb-thread:make-semaphore:count0
eventsnil
publication-thread
sb-thread:make-thread
lambda
luv:call-with-running-stop-controllercontroller
lambda
push:publication-enteredevents
sb-thread:signal-semaphorepublication-entered
unless
sb-thread:wait-on-semaphorecontinue-publication:timeout1.0
error"The attachment publication was not released."
push:publication-finishedevents
:attachedunless
sb-thread:wait-on-semaphorepublication-entered:timeout1.0
error"The attachment publication did not begin."
let
stop-thread
sb-thread:make-thread
lambda
unwind-protect
sb-thread:signal-semaphorestop-finished
sb-thread:signal-semaphorecontinue-publication
ok
eq:attached
sb-thread:join-threadpublication-thread
unless
sb-thread:wait-on-semaphorestop-finished:timeout1.0
error"The racing stop did not finish."
sb-thread:join-threadstop-thread
ok
equal'
:publication-entered:publication-finished:stop
nreverseevents
ok
eq:stopped
luv:stop-controller-statecontroller
defteststopping-controller-rejects-publication-without-running-it
let*
controller
luv:make-stop-controller:name"closed attachment"
stop-entered
sb-thread:make-semaphore:count0
continue-stop
sb-thread:make-semaphore:count0
attachment
list:attachment
called-pnil
conditionnil
stop-thread
sb-thread:make-thread
lambda
luv:call-with-stop-controllercontroller
lambda
sb-thread:signal-semaphorestop-entered
unless
sb-thread:wait-on-semaphorecontinue-stop:timeout1.0
error"The attachment rejection stop was not released."
unless
sb-thread:wait-on-semaphorestop-entered:timeout1.0
error"The attachment rejection stop did not begin."
unwind-protect
handler-case
luv:application-attachment-closed
failure
setfconditionfailure
sb-thread:signal-semaphorecontinue-stop
sb-thread:join-threadstop-thread
ok
notcalled-p
ok
ok
eqcontroller
luv:application-attachment-closed-controllercondition
ok
eqattachment
luv:application-attachment-closed-attachmentcondition
ok
eq:stopping
luv:application-attachment-closed-statecondition
deftestterminal-duplicate-attachment-is-an-idempotent-success
let*
controller
luv:make-stop-controller:name"duplicate attachment"
attachment
list:attachment
publication-calls0
membership-calls0
luv:call-with-stop-controllercontroller
lambdanil
ok
eqattachment
luv:call-with-running-stop-controllercontroller
lambda
:attachmentattachment:already-attached-pincfpublication-calls
lambda
incfmembership-calls
tok
zeroppublication-calls
ok
deftestattachment-rejection-is-signalled-outside-the-controller-lock
let*
controller
luv:make-stop-controller:name"reentrant rejection"
conditionnil
observed-statenil
luv:call-with-stop-controllercontroller
lambdanil
handler-case
ok
ok
eq:stoppedobserved-state
defteststop-controller-runs-one-owner-and-publishes-values
let*
controller
luv:make-stop-controller:name"concurrency probe"
started
sb-thread:make-semaphore:count0
continue
sb-thread:make-semaphore:count0
calls0
owner
sb-thread:make-thread
lambda
multiple-value-list
luv:call-with-stop-controllercontroller
lambda
incfcalls
sb-thread:signal-semaphorestarted
unless
sb-thread:wait-on-semaphorecontinue:timeout1.0
error"stop-controller test owner was not released"
values:stopped42
unless
sb-thread:wait-on-semaphorestarted:timeout1.0
error"stop-controller test owner did not start"
let
waiter
sb-thread:make-thread
lambda
multiple-value-list
sb-thread:signal-semaphorecontinue
ok
equal'
:stopped42
sb-thread:join-threadowner
ok
equal'
:stopped42
sb-thread:join-threadwaiter
ok
equal'
:stopped42
multiple-value-list
ok
ok
eq:stopped
luv:stop-controller-statecontroller
ok
ok
null
luv:stop-controller-conditioncontroller
defteststop-controller-publishes-one-failure-to-every-caller
let*
controller
luv:make-stop-controller:name"failure probe"
primary
make-condition'simple-error:format-control"teardown failed"
calls0
first
handler-case
error
condition
conditionsecond
handler-case
error
condition
conditionok
eqprimaryfirst
ok
ok
ok
deftestrequested-stop-publishes-its-exact-failure
let*
controller
luv:make-stop-controller:name"async failure probe"
primary
make-condition'simple-error:format-control"async teardown failed"
calls0
multiple-value-bind
began-pworker
luv:request-controlled-stopcontroller
lambda
:thread-name"stop-controller failing test worker"incfcalls
errorprimary
okbegan-p
ok
typepworker'sb-thread:thread
sb-thread:join-threadworker
let
published
handler-case
luv:wait-for-controlled-stopcontroller
error
condition
conditionok
eqprimarypublished
ok
ok
multiple-value-bind
began-pworker
ok
notbegan-p
ok
nullworker
deftestcanvas-thread-guard-rejects-blocking-but-allows-request
let*
forbidden-threadsb-thread:*current-thread*
controller
luv:make-stop-controller:name"canvas-thread probe":blocking-thread-p
lambda
eqsb-thread:*current-thread*forbidden-thread
calls0
ok
eq:running
luv:stop-controller-statecontroller
multiple-value-bind
began-pworker
luv:request-controlled-stopcontroller
lambda
:thread-name"stop-controller test worker"incfcalls
values:done7
okbegan-p
ok
typepworker'sb-thread:thread
sb-thread:join-threadworker
Reading an already-published result never waits and is safe here.
ok
ok
multiple-value-bind
began-pworker
ok
notbegan-p
ok
nullworker
defmacro with-release-report
(&body body)defmacro releasing
(name &body body)define-condition release-error
All named failures from a completed release sequence.
define-condition release-warning
Named release failures reported without replacing an active transfer.
defmacro unwind-protect-releasing
(protected-form &body cleanup-forms)defmacro with-release-warnings
(&body body)defun make-stop-controller
(&key (name "application") blocking-thread-p)Make a one-shot stop controller named NAME. BLOCKING-THREAD-P, when supplied, is a quick predicate which is true on a thread that may request a stop but must never own or wait for one.
defun call-with-running-stop-controller
(controller function &key attachment already-attached-p)Call quick publication FUNCTION iff CONTROLLER is still running. The controller lock remains held across FUNCTION, making publication atomic with the RUNNING to STOPPING transition. FUNCTION and ALREADY-ATTACHED-P must therefore neither block nor reenter CONTROLLER. A true ALREADY-ATTACHED-P is an idempotent…
defun call-with-stop-controller
(controller function)Run FUNCTION as CONTROLLER's sole teardown, or observe its published result. A concurrent caller waits while the owner runs. A later caller receives the same values or signals the same condition without running FUNCTION again.
defun stop-controller-state
(controller)define-condition application-attachment-closed
An application attachment was offered after terminal teardown began.
define-arithmetic-operator not
Logical negation of one test or raw truth value.
define-arithmetic-operator =
Test whether two compatible scalars are equal.
defun stop-controller-result-values
(controller)defun stop-controller-condition
(controller)defun request-controlled-stop
(controller function &key thread-name)Request FUNCTION as CONTROLLER's teardown on one new worker thread. Return true and the worker when this call reserved ownership, or NIL and NIL when a stop was already requested or published. The worker contains any failure after publishing it; WAIT-FOR-CONTROLLED-STOP and synchronous callers receive that exact…
defun wait-for-controlled-stop
(controller)
This takes the same mutex. It can complete only when the semantic rejection was signalled after leaving the gate.