@@ -38,10 +38,11 @@ (debug:print 0 "Attempting to start the server ...") (let* ((rpc:listener (server:find-free-port-and-open (rpc:default-server-port))) (th1 (make-thread (cute (rpc:make-server rpc:listener) "rpc:server") 'rpc:server)) + (th2 (make-thread (lambda ()(db:updater db)))) (hostname (if (string=? "-" hostn) (get-host-name) hostn)) (ipaddrstr (if (string=? "-" hostn) (string-intersperse (map number->string (u8vector->list (hostname->ip hostname))) ".") @@ -96,10 +97,15 @@ (rpc:publish-procedure! 'rdb:test-set-log! (lambda (run-id test-name item-path logf) (db:test-set-log! db run-id test-name item-path logf))) + + (rpc:publish-procedure! + 'rpc:get-test-data-by-id + (lambda (test-id) + (db:get-test-data-by-id db test-id))) (rpc:publish-procedure! 'serve:get-toppath (lambda () *toppath*)) @@ -196,11 +202,12 @@ (set! *rpc:listener* rpc:listener) (on-exit (lambda () (sqlite3:execute db "DELETE FROM metadat WHERE var='SERVER' and val=?;" host:port) (sqlite3:finalize! db))) (thread-start! th1) - (thread-join! th1))) ;; rpc:server))) + (thread-start! th2) + (thread-join! th2))) ;; rpc:server))) (define (server:find-free-port-and-open port) (handle-exceptions exn (begin