99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
(dbdir (conc areapath "/.mtdb")))
(if (and (not *journal-stats*)
(file-exists? dbdir))
(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* ((stats (tt:get-journal-stats))
(load (or (alist-ref dbfname stats equal?) 0)))
(if (> load 0)
(let ((dely (* 10 load)))
(debug:print 0 *default-log-port* "Journal load "load" delaying queries "dely"s.")
(thread-sleep! dely)))))
(case (rmt:transport-mode)
((tcp)
|
|
<
|
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
(dbdir (conc areapath "/.mtdb")))
(if (and (not *journal-stats*)
(file-exists? dbdir))
(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)
(let ((dely (* 10 load)))
(debug:print 0 *default-log-port* "Journal load "load" delaying queries "dely"s.")
(thread-sleep! dely)))))
(case (rmt:transport-mode)
((tcp)
|