1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
1076
|
(define (db:lock-and-delta-sync no-sync-db dbstruct from-db-file runid)
(assert (not *db-sync-in-progress*) "FATAL: db:lock-and-sync called while a sync is in progress.")
(debug:print-info 3 *default-log-port* "db:lock-and-delta-sync")
(let* ((lockdat (db:no-sync-get-lock no-sync-db from-db-file))
(gotlock (car lockdat))
(locktime (cdr lockdat)))
(debug:print-info 3 *default-log-port* "db:lock-and-delta-sync: go lock?")
(if gotlock
(begin
(debug:print 0 *default-log-port* "db:lock-and-delta-sync copying db")
(db:sync-touched dbstruct runid)
(db:no-sync-del! no-sync-db from-db-file)
#t)
(begin
(debug:print 0 *default-log-port* "could not get lock for " from-db-file " from no-sync-db")
#f
))))
|
|
|
|
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
1076
|
(define (db:lock-and-delta-sync no-sync-db dbstruct from-db-file runid)
(assert (not *db-sync-in-progress*) "FATAL: db:lock-and-sync called while a sync is in progress.")
(debug:print-info 3 *default-log-port* "db:lock-and-delta-sync")
(let* ((lockdat (db:no-sync-get-lock no-sync-db from-db-file))
(gotlock (car lockdat))
(locktime (cdr lockdat)))
(debug:print-info 3 *default-log-port* "db:lock-and-delta-sync: got lock?")
(if gotlock
(begin
(debug:print 0 *default-log-port* "db:lock-and-delta-sync copying db "runid" at "(current-seconds))
(db:sync-touched dbstruct runid)
(db:no-sync-del! no-sync-db from-db-file)
#t)
(begin
(debug:print 0 *default-log-port* "could not get lock for " from-db-file " from no-sync-db")
#f
))))
|