Overview
| Comment: | Added some instrumentation |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.70-captain-ulex | v1.70-defunct-try |
| Files: | files | file ages | folders |
| SHA1: |
e99d345eb00a59ecbd63dd1f33c79a83 |
| User & Date: | matt on 2020-01-29 22:38:28 |
| Other Links: | branch diff | manifest | tags |
Context
|
2020-02-01
| ||
| 04:39 | Added ability to pass in existing udata to ulex setup Leaf check-in: 3d501185de user: matt tags: v1.70-captain-ulex, v1.70-defunct-try | |
|
2020-01-29
| ||
| 22:38 | Added some instrumentation check-in: e99d345eb0 user: matt tags: v1.70-captain-ulex, v1.70-defunct-try | |
| 21:06 | send-recieve fully using read/write (not a space-delimited string). check-in: 86f34c5c1b user: matt tags: v1.70-captain-ulex, v1.70-defunct-try | |
Changes
Modified ulex/ulex.scm from [725a72d111] to [8636c80a0f].
| ︙ | ︙ | |||
576 577 578 579 580 581 582 583 584 585 |
(conc qrykey " " host-port)))))
(else (conc qrykey " BADDATA"))))
;; for work items:
;; handler is one of; immediate, read-only, read-write, high-priority
((immediate read-only normal low-priority) ;; do this work immediately
;; host-port (caller), pid (caller), qrykey (cookie), params <= all from first line
;; data => a single line encoded however you want, or should I build json into it?
(let* ((pdat (get-peer-dat udata host-port)))
(match params ;; dbfile prockey procparam
((dbfile prockey procparam)
| > | > | > | 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 |
(conc qrykey " " host-port)))))
(else (conc qrykey " BADDATA"))))
;; for work items:
;; handler is one of; immediate, read-only, read-write, high-priority
((immediate read-only normal low-priority) ;; do this work immediately
;; host-port (caller), pid (caller), qrykey (cookie), params <= all from first line
;; data => a single line encoded however you want, or should I build json into it?
(print "handlerkey=" handlerkey)
(let* ((pdat (get-peer-dat udata host-port)))
(match params ;; dbfile prockey procparam
((dbfile prockey procparam)
(case handlerkey
((immediate read-only)
(process-request udata pdat dbfile qrykey prockey procparam data))
((normal low-priority) ;; split off later and add logic to support low priority
(add-to-work-queue udata pdat dbfile qrykey prockey procparam data))
(else
#f)))
(else
(print "INFO: params=" params " handlerkey=" handlerkey " controldat=" controldat)
#f))))
(else
;; (add-to-work-queue udata (get-peer-dat udata host-port) handlerkey qrykey data)
#f)))
(else
(print "BAD DATA? controldat=" controldat " data=" data)
#f)));; handles the incoming messages and dispatches to queues
|
| ︙ | ︙ |