aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristopher Baines <mail@cbaines.net>2020-02-24 22:03:09 +0000
committerChristopher Baines <mail@cbaines.net>2020-02-24 22:03:09 +0000
commit30dd62f000fdf69cdec581b4bb8d48a15db6cbe2 (patch)
treee0263f93f0f8286fc3eada360d100f51db4bb54f
parent2f41fe79be6873c4329881fbce6bde671666e16e (diff)
downloaddata-service-30dd62f000fdf69cdec581b4bb8d48a15db6cbe2.tar
data-service-30dd62f000fdf69cdec581b4bb8d48a15db6cbe2.tar.gz
Clean up some time logging code
-rw-r--r--guix-data-service/model/package-derivation-by-guix-revision-range.scm61
-rw-r--r--guix-data-service/model/utils.scm37
2 files changed, 39 insertions, 59 deletions
diff --git a/guix-data-service/model/package-derivation-by-guix-revision-range.scm b/guix-data-service/model/package-derivation-by-guix-revision-range.scm
index f9c2371..712f546 100644
--- a/guix-data-service/model/package-derivation-by-guix-revision-range.scm
+++ b/guix-data-service/model/package-derivation-by-guix-revision-range.scm
@@ -19,18 +19,10 @@
#:use-module (ice-9 match)
#:use-module (squee)
#:use-module (guix-data-service database)
+ #:use-module (guix-data-service utils)
#:export (update-package-derivations-table
rebuild-package-derivations-table))
-(define (log-time action f)
- (simple-format #t "debug: Starting ~A\n" action)
- (let* ((start-time (current-time))
- (result (f))
- (time-taken (- (current-time) start-time)))
- (simple-format #t "debug: Finished ~A, took ~A seconds\n"
- action time-taken)
- result))
-
(define (delete-guix-revision-package-derivation-entries conn
git-repository-id
guix-revision-id
@@ -128,21 +120,21 @@ LOCK TABLE ONLY package_derivations_by_guix_revision_range
(for-each
(match-lambda
((branch-name)
- (log-time
- (simple-format #f "deleting package derivation entries for ~A" branch-name)
- (lambda ()
- (delete-guix-revision-package-derivation-entries conn
- git-repository-id
- guix-revision-id
- branch-name)))
- (log-time
- (simple-format #f "inserting package derivation entries for ~A" branch-name)
- (lambda ()
- (insert-guix-revision-package-derivation-entries
- conn
- git-repository-id
- branch-name
- #:guix-revision-id guix-revision-id)))))
+ (with-time-logging
+ (simple-format #f "deleting package derivation entries for ~A"
+ branch-name)
+ (delete-guix-revision-package-derivation-entries conn
+ git-repository-id
+ guix-revision-id
+ branch-name))
+ (with-time-logging
+ (simple-format #f "inserting package derivation entries for ~A"
+ branch-name)
+ (insert-guix-revision-package-derivation-entries
+ conn
+ git-repository-id
+ branch-name
+ #:guix-revision-id guix-revision-id))))
(exec-query
conn
"SELECT name FROM git_branches WHERE commit = $1 AND git_repository_id = $2"
@@ -162,10 +154,9 @@ LOCK TABLE ONLY package_derivations_by_guix_revision_range
LOCK TABLE ONLY package_derivations_by_guix_revision_range
IN SHARE ROW EXCLUSIVE MODE")
- (log-time
- (simple-format #f "deleting all package derivation entries")
- (lambda ()
- (exec-query conn "DELETE FROM package_derivations_by_guix_revision_range")))
+ (with-time-logging
+ (simple-format #f "deleting all package derivation entries")
+ (exec-query conn "DELETE FROM package_derivations_by_guix_revision_range"))
(let ((git-branches-and-repository-ids
(exec-query
@@ -174,11 +165,11 @@ LOCK TABLE ONLY package_derivations_by_guix_revision_range
(for-each
(match-lambda
((branch-name git-repository-id)
- (log-time
- (simple-format #f "inserting package derivation entries for ~A" branch-name)
- (lambda ()
- (insert-guix-revision-package-derivation-entries
- conn
- git-repository-id
- branch-name)))))
+ (with-time-logging
+ (simple-format #f "inserting package derivation entries for ~A"
+ branch-name)
+ (insert-guix-revision-package-derivation-entries
+ conn
+ git-repository-id
+ branch-name))))
git-branches-and-repository-ids)))))
diff --git a/guix-data-service/model/utils.scm b/guix-data-service/model/utils.scm
index 1dc62ee..11916e8 100644
--- a/guix-data-service/model/utils.scm
+++ b/guix-data-service/model/utils.scm
@@ -22,6 +22,7 @@
#:use-module (ice-9 receive)
#:use-module (squee)
#:use-module (guix-data-service database)
+ #:use-module (guix-data-service utils)
#:export (NULL
quote-string
value->quoted-string-or-null
@@ -248,15 +249,6 @@
(error (simple-format #f "normalise-values: error: ~A\n" unknown))))
data))
- (define (log-time action f)
- (simple-format #t "debug: Starting ~A\n" action)
- (let* ((start-time (current-time))
- (result (f))
- (time-taken (- (current-time) start-time)))
- (simple-format #t "debug: Finished ~A, took ~A seconds\n"
- action time-taken)
- result))
-
(let* ((existing-entries
(if use-temporary-table?
(let ((temp-table-name
@@ -281,23 +273,20 @@
"ANALYZE " temp-table-name))
;; Populate the temporary table
- (log-time
- (string-append "populating " temp-table-name)
- (lambda ()
- (exec-query conn
- (insert-sql data
- #:table-name temp-table-name))))
+ (with-time-logging (string-append "populating " temp-table-name)
+ (exec-query conn
+ (insert-sql data
+ #:table-name temp-table-name)))
;; Use the temporary table to find the existing values
(let ((result
- (log-time
- (string-append "querying the " temp-table-name)
- (lambda ()
- (exec-query->vhash
- conn
- (temp-table-select-query temp-table-name)
- cdr
- (lambda (result)
- (string->number (first result))))))))
+ (with-time-logging
+ (string-append "querying the " temp-table-name)
+ (exec-query->vhash
+ conn
+ (temp-table-select-query temp-table-name)
+ cdr
+ (lambda (result)
+ (string->number (first result)))))))
(exec-query conn (string-append "DROP TABLE " temp-table-name))
result))