Overview
| Comment: | Merged changes from v2.0001 |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v2.0001-ulex-one-shot |
| Files: | files | file ages | folders |
| SHA1: |
3253e6faaa873f662a06da53ef75fa7d |
| User & Date: | matt on 2022-01-14 08:15:03 |
| Other Links: | branch diff | manifest | tags |
Context
|
2022-01-14
| ||
| 08:15 | Merged changes from v2.0001 check-in: 3253e6faaa user: matt tags: v2.0001-ulex-one-shot | |
| 08:13 | wip check-in: eccf4ded3f user: matt tags: v2.0001-ulex-one-shot | |
|
2022-01-13
| ||
| 23:56 | Merged Leaf check-in: caf99578ef user: matt tags: v2.0001-ulex-one-shot | |
| 18:50 | Merged fork check-in: 6bbd0fa9a2 user: matt tags: v2.0001, ulex-smoketest | |
Changes
Modified ulex-trials/Makefile from [cec464a43d] to [d90f81714d].
1 2 3 4 5 6 7 | ulex-test : ulex-test.scm ../ulex/ulex.scm csc ulex-test.scm test : ulex-test for x in $$(seq 9);do export NBFAKE_LOG=NBFAKE_$$x;sleep 1;nbfake ./ulex-test run 828$$x;echo $$cmd;$$cmd;done clean : | | | 1 2 3 4 5 6 7 8 | ulex-test : ulex-test.scm ../ulex/ulex.scm csc ulex-test.scm test : ulex-test for x in $$(seq 9);do export NBFAKE_LOG=NBFAKE_$$x;sleep 1;nbfake ./ulex-test run 828$$x;echo $$cmd;$$cmd;done clean : rm -f ulex-test .runners/* NBFAKE* |
Added ulex-trials/server-one.scm version [dc113b1a00].
> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
(import tcp-server format (chicken tcp) (chicken io) (chicken string) (prefix sqlite3 sqlite3:) sql-de-lite srfi-18 simple-exceptions mailbox s11n)
(let* ((work-mailbox (make-mailbox))
(notify-mailbox (make-mailbox))
(th1 (make-thread (lambda ()
((make-tcp-server
(tcp-listen 6505)
(lambda ()
(let* ((db (sqlite3:open-database "test.db"))
(rec-data (deserialize)))
(sqlite3:set-busy-handler! db (sqlite3:make-busy-timeout 136000))
;;(exec (sql db "INSERT INTO entries (received,send) VALUES (?,?);") "something" (conc "Server One Response: " "something else"))
(sqlite3:execute db "INSERT INTO entries (received,send) VALUES (?,?);" "something" (conc "Server One Response: " "something else"))
(mailbox-send! work-mailbox rec-data)
(format (current-error-port) (conc rec-data))
(write-line (conc "Response to: " (conc rec-data)))
;;(close-database db)
)))
#t))
"receive"))
(th2 (make-thread (lambda ()
(print "Jeff is here")
(let loop ((entries 0))
(thread-sleep! 0.01)
(print "Preparding to send entries" entries)
(handle-exceptions exn (begin (print "Had an issue: " (message exn))(thread-sleep! 10))
(define-values (i o) (tcp-connect "localhost" 6504))
(serialize (list "localhost:6505" "from-server-one") o)
(print (read-line i))
(close-input-port i)
(close-output-port o))
(loop (+ entries 1)))) "send"))
(th3 (make-thread (lambda ()
(print "In mailbox thread")
(let loop2 ((entries2 0))
(print "Processing: " (mailbox-receive! work-mailbox))
(mailbox-send! notify-mailbox (list 'ack))
(thread-sleep! 0.01)
(loop2 1))) "processing"))
(th4 (make-thread (lambda ()
(print "In notify-mailbox thread")
(let loop3 ((entries3 0))
(print "Notifying: " (mailbox-receive! notify-mailbox))
(handle-exceptions exn (begin (print "Had an issue: " (message exn))(thread-sleep! 10))
(define-values (i o) (tcp-connect "localhost" 6504))
(serialize (list 'ack "from-server-one") o)
(print (read-line i))
(close-input-port i)
(close-output-port o))
;;(thread-sleep! 1)
(loop3 1))) "notify"))
)
(thread-start! th1)
(thread-start! th2)
(thread-start! th3)
(thread-start! th4)
(thread-join! th2)
)
(print "Done here")
|
Added ulex-trials/server-two.scm version [385cb5b500].
> > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
(import tcp-server format (chicken tcp) (chicken io) (chicken string) (prefix sqlite3 sqlite3:) sql-de-lite srfi-18 simple-exceptions mailbox s11n)
(let* ((work-mailbox (make-mailbox))
(notify-mailbox (make-mailbox))
(th1 (make-thread (lambda ()
((make-tcp-server
(tcp-listen 6504)
(lambda ()
(let* ((db (sqlite3:open-database "test.db"))
(rec-data (deserialize)))
(sqlite3:set-busy-handler! db (sqlite3:make-busy-timeout 136000))
;;(exec (sql db "INSERT INTO entries (received,send) VALUES (?,?);") "something" (conc "Server One Response: " "something else"))
(sqlite3:execute db "INSERT INTO entries (received,send) VALUES (?,?);" "something" (conc "Server One Response: " "something else"))
(mailbox-send! work-mailbox rec-data)
(format (current-error-port) (conc rec-data))
(write-line (conc "Response to: " (conc rec-data)))
;;(close-database db)
)))
#t))
"receive"))
(th2 (make-thread (lambda ()
(print "Jeff is here")
(let loop ((entries 0))
(thread-sleep! 0.01)
(print "Preparding to send entries" entries)
(handle-exceptions exn (begin (print "Had an issue: " (message exn))(thread-sleep! 10))
(define-values (i o) (tcp-connect "localhost" 6505))
(serialize (list "localhost:6505" "from-server-two") o)
(print (read-line i))
(close-input-port i)
(close-output-port o))
(loop (+ entries 1)))) "send"))
(th3 (make-thread (lambda ()
(print "In mailbox thread")
(let loop2 ((entries2 0))
(print "Processing: " (mailbox-receive! work-mailbox))
(mailbox-send! notify-mailbox (list 'ack))
(thread-sleep! 0.01)
(loop2 1))) "processing"))
(th4 (make-thread (lambda ()
(print "In notify-mailbox thread")
(let loop3 ((entries3 0))
(print "Notifying: " (mailbox-receive! notify-mailbox))
(handle-exceptions exn (begin (print "Had an issue: " (message exn))(thread-sleep! 10))
(define-values (i o) (tcp-connect "localhost" 6505))
(serialize (list 'ack "from-server-two") o)
(print (read-line i))
(close-input-port i)
(close-output-port o))
;;(thread-sleep! 1)
(loop3 1))) "notify"))
)
(thread-start! th1)
(thread-start! th2)
(thread-start! th3)
(thread-start! th4)
(thread-join! th2)
)
(print "Done here")
|