Overview
| Comment: | Cached writes for steps working correctly |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | v1.80-cached-writes |
| Files: | files | file ages | folders |
| SHA1: |
eee1dce5a3b70264f3bbd27e5e0538ad |
| User & Date: | matt on 2023-10-12 21:04:08 |
| Other Links: | branch diff | manifest | tags |
Context
|
2023-10-13
| ||
| 20:42 | Merged in cached writes check-in: cdc7397963 user: matt tags: v1.80-matt-fixme | |
| 20:41 | Oops. Forgot to clean out the cache after processing the cached writes Leaf check-in: b564f3f99c user: matt tags: v1.80-cached-writes | |
|
2023-10-12
| ||
| 21:04 | Cached writes for steps working correctly check-in: eee1dce5a3 user: matt tags: v1.80-cached-writes | |
| 03:52 | wip check-in: a560665ddd user: matt tags: v1.80-cached-writes | |
Changes
Modified api.scm from [c477d1f287] to [b3b853adfc].
| ︙ | ︙ | |||
369 370 371 372 373 374 375 |
((dec-var) (apply db:dec-var dbstruct params))
((del-var) (apply db:del-var dbstruct params))
((add-var) (apply db:add-var dbstruct params))
((insert-run) (apply db:insert-run dbstruct params))
;; STEPS
| > | > | 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 |
((dec-var) (apply db:dec-var dbstruct params))
((del-var) (apply db:del-var dbstruct params))
((add-var) (apply db:add-var dbstruct params))
((insert-run) (apply db:insert-run dbstruct params))
;; STEPS
((teststep-set-status!)
;; (apply db:teststep-set-status! dbstruct params))
(db:add-cached-write dbstruct db:teststep-set-status! run-id params))
((delete-steps-for-test!) (apply db:delete-steps-for-test! dbstruct params))
;; TEST DATA
((test-data-rollup) (apply db:test-data-rollup dbstruct params))
((csv->test-data) (apply db:csv->test-data dbstruct params))
;; MISC
|
| ︙ | ︙ |
Modified db.scm from [6147e64f05] to [43baddb3c1].
| ︙ | ︙ | |||
4257 4258 4259 4260 4261 4262 4263 |
(dbfile:add-dbdat dbstruct #f dbdat)
(system "rm -rf tempdir")))
;;======================================================================
;; cached writes stuff
;;======================================================================
| | > > | > | | | | 4257 4258 4259 4260 4261 4262 4263 4264 4265 4266 4267 4268 4269 4270 4271 4272 4273 4274 4275 4276 4277 4278 4279 4280 4281 4282 4283 4284 4285 4286 4287 4288 4289 4290 4291 4292 4293 4294 4295 4296 4297 4298 4299 4300 4301 4302 4303 4304 4305 4306 4307 4308 4309 |
(dbfile:add-dbdat dbstruct #f dbdat)
(system "rm -rf tempdir")))
;;======================================================================
;; cached writes stuff
;;======================================================================
(define (db:add-cached-write dbstruct proc run-id params)
(debug:print 0 *default-log-port* "Adding cached write for run-id "run-id" params " params)
(mutex-lock! *cached-writes-mutex*)
(let* ((hkey (cons dbstruct run-id))
(cached-writes-queue (hash-table-ref/default *cached-writes-queues* hkey '())))
(hash-table-set! *cached-writes-queues* hkey (cons (list proc params) cached-writes-queue)))
(if (not *cached-writes-flag*)
(begin
(set! *cached-writes-flag* #t)
(thread-start! (make-thread
(lambda ()
(debug:print 0 *default-log-port* "process cached writes thread started.")
(thread-sleep! 1)
(db:process-cached-writes-queue))))))
(mutex-unlock! *cached-writes-mutex*))
(define (db:process-cached-writes-queue)
(mutex-lock! *cached-writes-mutex*)
(hash-table-for-each
*cached-writes-queues*
(lambda (hkey writes-list)
(let* ((dbstruct (car hkey))
(run-id (cdr hkey)))
(debug:print 0 *default-log-port* "Processing "(length writes-list)" cached writes for run "run-id)
(db:with-db
dbstruct
run-id
#t
(lambda (dbdat db)
(sqlite3:with-transaction
db
(lambda ()
(for-each
(lambda (queued-write)
(match queued-write
((proc params)(apply proc dbstruct params))
(else (assert #f "BAD queued-write"))))
writes-list))))))))
(set! *cached-writes-flag* #f)
(mutex-unlock! *cached-writes-mutex*))
;; (db:extract-ods-file db "outputfile.ods" '(("sysname" "%")("fsname" "%")("datapath" "%")) "%")
;;======================================================================
;; moving watch dogs here due to dependencies
;;======================================================================
|
| ︙ | ︙ |