Overview
| Comment: | Silence noise from tcp-server. Turn on throttling. |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.80-tcp-inmem |
| Files: | files | file ages | folders |
| SHA1: |
a8b8aa106fb5d5edcb771a14ceeb23ff |
| User & Date: | matt on 2023-02-21 21:35:37 |
| Other Links: | branch diff | manifest | tags |
Context
|
2023-02-22
| ||
| 11:05 | Oops. Was not creating .megatest directory. Leaf check-in: 0386246065 user: mrwellan tags: v1.80-tcp-inmem | |
|
2023-02-21
| ||
| 21:35 | Silence noise from tcp-server. Turn on throttling. check-in: a8b8aa106f user: matt tags: v1.80-tcp-inmem | |
| 20:25 | Fixed few minor issues and got creation of temporary no-sync in .megatest dir working ok. check-in: 6e2393b843 user: matt tags: v1.80-tcp-inmem | |
Changes
Modified api.scm from [a4804c006e] to [aacd193276].
| ︙ | ︙ | |||
247 248 249 250 251 252 253 |
(- newcount 10)
0)))
(set! *api-process-request-count* newcount)
(set! *db-last-access* (current-seconds))
(match indat
((cmd run-id params meta)
(let* ((status (cond
| | | | 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 |
(- newcount 10)
0)))
(set! *api-process-request-count* newcount)
(set! *db-last-access* (current-seconds))
(match indat
((cmd run-id params meta)
(let* ((status (cond
((> newcount 30) 'busy)
((> newcount 15) 'loaded)
(else 'ok)))
(errmsg (case status
((busy) (conc "Server overloaded, "newcount" threads in flight"))
((loaded) (conc "Server loaded, "newcount" threads in flight"))
(else #f)))
(result (case status
((busy) (- newcount 29))
|
| ︙ | ︙ |
Modified tcp-transportmod.scm from [6b8eb0ba39] to [9959f6dce6].
| ︙ | ︙ | |||
579 580 581 582 583 584 585 |
;; for the entire server system
;;
(define (tt:start-tcp-server ttdat)
(setup-listener ttdat)
(let* ((socket (tt-socket ttdat))
(handler (tt-handler ttdat)))
((make-tcp-server socket handler)
| | | 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 |
;; for the entire server system
;;
(define (tt:start-tcp-server ttdat)
(setup-listener ttdat)
(let* ((socket (tt-socket ttdat))
(handler (tt-handler ttdat)))
((make-tcp-server socket handler)
#f ;; yes, send error messages to std-err
)))
;; create a tcp listener and return a populated udat struct with
;; my port, address, hostname, pid etc.
;; return #f if fail to find a port to allocate.
;;
;; if udata-in is #f create the record
|
| ︙ | ︙ |