cco/cl-scopes
3
0
Fork 0
Code Issues 1 Pull requests Releases Wiki Activity Actions

code clean-up - remove obsolete stuff after release of restartable tasks

Browse source
This commit is contained in:
Helmut Merz 2025-06-16 19:21:42 +02:00
parent 17899b934c
commit f498b0cf78
2 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/actor.lisp
View file

@ -68,12 +68,10 @@
(defgeneric send (tsk msg) (defgeneric send (tsk msg)
(:method ((tsk async:mailbox) msg) (:method ((tsk async:mailbox) msg)
;(util:lgi msg)
(async:snd tsk msg))) (async:snd tsk msg)))
(defun become (bhv) (defun become (bhv)
(set-bhv *self* bhv) (set-bhv *self* bhv))
bhv)
;;;; handling restartable tasks ;;;; handling restartable tasks
@ -82,13 +80,13 @@
(multiple-value-bind (msg ok) (async:try-rcv tsk) (multiple-value-bind (msg ok) (async:try-rcv tsk)
(if ok (if ok
(if (eq (content msg) +quit-message+) (if (eq (content msg) +quit-message+)
(progn (async:set-status tsk :stopped) nil) (async:set-status tsk :stopped)
(progn (progn
(async:set-status tsk :running) (async:set-status tsk :running)
(let ((*self* tsk)) (let ((*self* tsk))
(funcall bhv msg) (funcall bhv msg)
(ac-loop tsk (async:behavior tsk))))) (ac-loop tsk (async:behavior tsk)))))
(progn (async:set-status tsk :suspended) bhv)))) (async:set-status tsk :suspended))))
(defmethod send ((tsk async:restartable-task) msg) (defmethod send ((tsk async:restartable-task) msg)
(let ((status (async:get-status tsk))) (let ((status (async:get-status tsk)))

3
core/core.lisp
View file

@ -100,8 +100,7 @@
(dolist (ctx (alx:hash-table-values (services *root*))) (dolist (ctx (alx:hash-table-values (services *root*)))
(funcall (config:shutdown (config ctx)) ctx)) (funcall (config:shutdown (config ctx)) ctx))
;(actor:stop *root*) ;(actor:stop *root*)
(async:finish) (async:finish))
)
(defun add-action (ctx pat hdlr) (defun add-action (ctx pat hdlr)
(let* ((acts (actions ctx)) (let* ((acts (actions ctx))