Overview
| Comment: | Improve message for journal load |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.81-journal-based-throttling |
| Files: | files | file ages | folders |
| SHA1: |
f5a00d621d7c2a550fd5b40fc71da861 |
| User & Date: | mrwellan on 2024-07-11 14:40:38 |
| Other Links: | branch diff | manifest | tags |
Context
|
2024-07-11
| ||
| 15:42 | CI/CD: Automated commit after successful test, build, and deploy for v1.81-journal-based-throttling check-in: 04d06badd2 user: fdiskadm tags: v1.81 | |
| 15:29 | Changed ready to merge to just ready in setcicd. Changed load tolerance from 4 to 10 in server start. Leaf check-in: 3fd515775a user: mrwellan tags: v1.81-journal-based-throttling | |
| 14:40 | Improve message for journal load check-in: f5a00d621d user: mrwellan tags: v1.81-journal-based-throttling | |
| 13:28 | Added setcicd script for registering branches ready to merge check-in: 3ced0f4705 user: mrwellan tags: v1.81-journal-based-throttling | |
Changes
Modified rmt.scm from [e8bc4b391f] to [0cdd3c737a].
| ︙ | ︙ | |||
102 103 104 105 106 107 108 |
(tt:start-stats dbdir)) ;; fixme - find the right call to get the db directory
;; check the load on dbfname and add some delay using a droop curve of sorts
(if *journal-stats*
(let* ((load (tt:get-journal-stats dbfname)))
(if (> load 0.1) ;; start activating delay at 10% journal load time
(let ((dely (* 50 (* load load)))) ;; 100% journal time=50sec delay
| | | 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 |
(tt:start-stats dbdir)) ;; fixme - find the right call to get the db directory
;; check the load on dbfname and add some delay using a droop curve of sorts
(if *journal-stats*
(let* ((load (tt:get-journal-stats dbfname)))
(if (> load 0.1) ;; start activating delay at 10% journal load time
(let ((dely (* 50 (* load load)))) ;; 100% journal time=50sec delay
(debug:print 0 *default-log-port* "Journal load "load" on "dbfname" delaying queries "dely"s.")
(thread-sleep! dely)))))
(case (rmt:transport-mode)
((tcp)
(let* ((start-time (current-seconds)) ;; snapshot time so all use cases get same value
(attemptnum (+ 1 attemptnum))
(mtexe (common:find-local-megatest))
|
| ︙ | ︙ |