aboutsummaryrefslogtreecommitdiff
path: root/scripts/nar-herder.in
diff options
context:
space:
mode:
authorChristopher Baines <mail@cbaines.net>2023-09-11 12:34:50 +0100
committerChristopher Baines <mail@cbaines.net>2023-09-12 13:11:00 +0100
commit27e6906e188da98ce06e755c079e852bc01c770d (patch)
treef6cb00c1513e549d0342f09993221597fca8372b /scripts/nar-herder.in
parent69fff1fc640257b8f5338810f572b209318f5554 (diff)
downloadnar-herder-27e6906e188da98ce06e755c079e852bc01c770d.tar
nar-herder-27e6906e188da98ce06e755c079e852bc01c770d.tar.gz
Make sure to use streaming http requests everywhere
As this avoids blocking.
Diffstat (limited to 'scripts/nar-herder.in')
-rw-r--r--scripts/nar-herder.in10
1 files changed, 7 insertions, 3 deletions
diff --git a/scripts/nar-herder.in b/scripts/nar-herder.in
index 18fe6d5..247eeef 100644
--- a/scripts/nar-herder.in
+++ b/scripts/nar-herder.in
@@ -36,6 +36,7 @@
(srfi srfi-19)
(srfi srfi-37)
(srfi srfi-43)
+ (srfi srfi-71)
(ice-9 ftw)
(ice-9 match)
(ice-9 format)
@@ -480,9 +481,12 @@
(lambda ()
(simple-format (current-error-port)
"starting downloading the database\n")
- (http-get database-uri
- #:decode-body? #f
- #:streaming? #t))
+ (let ((port
+ socket
+ (open-socket-for-uri* database-uri)))
+ (http-get database-uri
+ #:port port
+ #:streaming? #t)))
(lambda (response body)
(when (not (= (response-code response) 200))
(error "unable to fetch database from mirror"))