551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
|
(lambda (count)
(set! res count))
tdb
"SELECT count(id) FROM test_rundat;")
res))
0)
(define (db:update-central-meta-info db test-id cpuload diskfree minutes num-records uname hostname)
(sqlite3:execute db "UPDATE tests SET cpuload=?,diskfree=? WHERE id=?;"
cpuload
diskfree
test-id)
(if minutes (sqlite3:execute db "UPDATE tests SET run_duration=? WHERE id=?;" minutes test-id))
(if (eq? num-records 0)
(sqlite3:execute db "UPDATE tests SET uname=?,host=? WHERE id=?;"
uname hostname test-id)))
(define (tests:set-meta-info db test-id run-id testname itemdat minutes)
;; DOES cdb:remote-run under the hood!
(let* ((tdb (db:open-test-db-by-test-id db test-id))
(num-records (test:tdb-get-rundat-count tdb))
(cpuload (get-cpu-load))
(diskfree (get-df (current-directory))))
(if (eq? (modulo num-records 10) 0) ;; every ten records update central
(let ((uname (get-uname "-srvpio"))
(hostname (get-host-name)))
(cdb:remote-run db:update-central-meta-info db test-id cpuload diskfree minutes num-records uname hostname)))
(sqlite3:execute tdb "INSERT INTO test_rundat (update_time,cpuload,diskfree,run_duration) VALUES (strftime('%s','now'),?,?,?);"
cpuload diskfree minutes)))
;;======================================================================
;; A R C H I V I N G
;;======================================================================
|
|
>
>
>
>
|
|
|
|
>
>
|
|
>
|
<
>
|
>
|
|
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
|
(lambda (count)
(set! res count))
tdb
"SELECT count(id) FROM test_rundat;")
res))
0)
(define (tests:update-central-meta-info test-id cpuload diskfree minutes num-records uname hostname)
;; This is a good candidate for threading the requests to enable
;; transactionized write at the server
(cdb:tests-update-cpuload-diskfree *runremote* test-id cpuload diskfree)
;; (let ((db (open-db)))
;; (sqlite3:execute db "UPDATE tests SET cpuload=?,diskfree=? WHERE id=?;"
;; cpuload
;; diskfree
;; test-id)
(if minutes
(cdb:tests-update-run-duration *runremote* test-id minutes))
;; (sqlite3:execute db "UPDATE tests SET run_duration=? WHERE id=?;" minutes test-id))
(if (eq? num-records 0)
(cdb:tests-update-uname-host *runremote* test-id uname hostname))
;;(sqlite3:execute db "UPDATE tests SET uname=?,host=? WHERE id=?;" uname hostname test-id))
;;(sqlite3:finalize! db))
)
(define (tests:set-meta-info db test-id run-id testname itemdat minutes)
;; DOES cdb:remote-run under the hood!
(let* ((tdb (db:open-test-db-by-test-id db test-id))
(num-records (test:tdb-get-rundat-count tdb))
(cpuload (get-cpu-load))
(diskfree (get-df (current-directory))))
(if (eq? (modulo num-records 10) 0) ;; every ten records update central
(let ((uname (get-uname "-srvpio"))
(hostname (get-host-name)))
(tests:update-central-meta-info test-id cpuload diskfree minutes num-records uname hostname)))
(sqlite3:execute tdb "INSERT INTO test_rundat (update_time,cpuload,diskfree,run_duration) VALUES (strftime('%s','now'),?,?,?);"
cpuload diskfree minutes)))
;;======================================================================
;; A R C H I V I N G
;;======================================================================
|