218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
|
(define (tasks:get-server mdb run-id)
(let ((res #f)
(best #f))
(sqlite3:for-each-row
(lambda (id interface port pubport transport pid hostname)
(set! res (vector id interface port pubport transport pid hostname)))
mdb
"SELECT id,interface,port,pubport,transport,pid,hostname FROM servers
WHERE strftime('%s','now')-heartbeat < 10
AND mt_version=? AND run_id=? AND state='running'
|
>
>
<
|
|
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
|
(define (tasks:get-server mdb run-id)
(let ((res #f)
(best #f))
(sqlite3:for-each-row
(lambda (id interface port pubport transport pid hostname)
(set! res (vector id interface port pubport transport pid hostname)))
mdb
;; removed:
;; strftime('%s','now')-heartbeat < 10 AND
"SELECT id,interface,port,pubport,transport,pid,hostname FROM servers
WHERE mt_version=? AND run_id=? AND state='running'
ORDER BY start_time DESC LIMIT 1;" (common:version-signature) run-id)
res))
;; (define (tasks:get-all-servers mdb)
;; (let ((res '()))
;; (sqlite3:for-each-row
;; (lambda (id interface port pubport transport pid hostname)
|