scsh-conservatory
/
scsh-make
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

renamed cml-fork-collecting to cml-fork/collecting

This commit is contained in:
jottbee 2005-03-12 09:03:18 +00:00
parent 05600a0c92
commit b3f20e6ed0
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cml-pe.scm
View File

@ -23,7 +23,7 @@
(cml-sync-ch/receive-rv res-ch))) (cml-sync-ch/receive-rv res-ch)))
(define (cml-fork-collecting fds sig-ch thunk) (define (cml-fork/collecting fds sig-ch thunk)
(let* ((ch (cml-sync-ch/make-channel)) (let* ((ch (cml-sync-ch/make-channel))
(res-ch (cml-sync-ch/make-channel)) (res-ch (cml-sync-ch/make-channel))
(sig-rv (cml-sync-ch/receive-rv sig-ch)) (sig-rv (cml-sync-ch/receive-rv sig-ch))

8
jobd.scm
View File

@ -12,21 +12,21 @@
jobber-sig-index jobber-sig-index
(shutdown stop continue)) (shutdown stop continue))
(define (cml-fork-collecting->rv id job-desc sig-ch) (define (cml-fork/collecting->rv id job-desc sig-ch)
(let* ((ch (cml-sync-ch/make-channel)) (let* ((ch (cml-sync-ch/make-channel))
(cwd (job-desc-wd job-desc)) (cwd (job-desc-wd job-desc))
(env (job-desc-env job-desc)) (env (job-desc-env job-desc))
(cmd (job-desc-cmd job-desc)) (cmd (job-desc-cmd job-desc))
(fds (list 1 2)) (fds (list 1 2))
(thunk (lambda () (with-total-env ,env (with-cwd cwd cmd)))) (thunk (lambda () (with-total-env ,env (with-cwd cwd cmd))))
(res-rv (cml-fork-collecting fds sig-ch thunk))) (res-rv (cml-fork/collecting fds sig-ch thunk)))
(spawn (spawn
(lambda () (lambda ()
(let ((results (cml-rv/sync res-rv))) (let ((results (cml-rv/sync res-rv)))
(cml-sync-ch/send ch (make-job-res (list-ref results 0) (cml-sync-ch/send ch (make-job-res (list-ref results 0)
(list-ref results 1) (list-ref results 1)
(list-ref results 2))))) (list-ref results 2)))))
(format #t "cml-fork-collecting->rv (no. ~a)\n" id)) (format #t "cml-fork/collecting->rv (no. ~a)\n" id))
(cml-sync-ch/receive-rv ch))) (cml-sync-ch/receive-rv ch)))
;;; ->alist? ;;; ->alist?
@ -48,7 +48,7 @@
(res-ch (cdr j-des+res-ch)) (res-ch (cdr j-des+res-ch))
(to-process-element (cml-sync-ch/make-channel)) (to-process-element (cml-sync-ch/make-channel))
(sig-rcv-rv (cml-mcast-ch/mcast-port-receive-rv sig-mport)) (sig-rcv-rv (cml-mcast-ch/mcast-port-receive-rv sig-mport))
(job-res-rv (cml-fork-collecting->rv id j-des to-process-element))) (job-res-rv (cml-fork/collecting->rv id j-des to-process-element)))
(let finish-job () (let finish-job ()
(cml-rv/select (cml-rv/select
(cml-rv/wrap sig-rcv-rv (cml-rv/wrap sig-rcv-rv