254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
|
(inmem (dbr:dbstruct-get-inmem dbstruct))
(refdb (dbr:dbstruct-get-refdb dbstruct))
(olddb (dbr:dbstruct-get-olddb dbstruct)))
(if (or (not (number? mtime))
(not (number? stime))
(> mtime stime)
force-sync)
(let ((num-synced (db:sync-tables db:sync-tests-only inmem refdb rundb slavedb olddb)))
(dbr:dbstruct-set-stime! dbstruct (current-milliseconds))
num-synced)
0)))
;; close all opened run-id dbs
(define (db:close-all dbstruct)
;; finalize main.db
|
|
|
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
|
(inmem (dbr:dbstruct-get-inmem dbstruct))
(refdb (dbr:dbstruct-get-refdb dbstruct))
(olddb (dbr:dbstruct-get-olddb dbstruct)))
(if (or (not (number? mtime))
(not (number? stime))
(> mtime stime)
force-sync)
(let ((num-synced (db:sync-tables db:sync-tests-only inmem refdb rundb olddb)))
(dbr:dbstruct-set-stime! dbstruct (current-milliseconds))
num-synced)
0)))
;; close all opened run-id dbs
(define (db:close-all dbstruct)
;; finalize main.db
|