gnunet: add scheduler-add-delayed.

And add timeout to 'gnunet-guile search'.

2 files changed, 10 insertions, 0 deletions

diff --git a/gnunet-guile b/gnunet-guile
index ac37bfe..165fc88 100755
--- a/gnunet-guile
+++ b/gnunet-guile
@@ -178,10 +178,14 @@ Publish on gnunet FILE using CONFIGURATION using KEYWORDS.
      ((eq? status %fs-status-search-error)
       (format #t "* Error searching: ~a\n" (fs-progress-info-search-error-message info))))))
 
+(define (search/timeout)
+  (scheduler-shutdown))
+
 (define (search/task configuration uri)
   (lambda ()
     (let ((fs (fs-start configuration "gnunet-guile" search/progress)))
       (let ((search-context (fs-search-start fs uri 1 %fs-search-option-none)))
+        (scheduler-add-delayed (* 30 (expt 10 6)) search/timeout)
         (scheduler-add-shutdown (search/task/shutdown search-context))))))
 
 (define (search-exec configuration keywords)
diff --git a/gnunet.scm b/gnunet.scm
index 3fbdf47..cba3d5a 100644
--- a/gnunet.scm
+++ b/gnunet.scm
@@ -242,6 +242,12 @@ The task will be run with the DEFAULT priority."
       (let ((task (ffi:procedure->pointer ffi:void thunk '())))
         (func task ffi:%null-pointer)))))
 
+(define-public scheduler-add-delayed
+  (let ((func (util '* "GNUNET_SCHEDULER_add_delayed" ffi:uint64 '* '*)))
+    (lambda (timeout callback)
+      (func timeout
+            (ffi:procedure->pointer ffi:void (lambda _ (callback)) '(*))
+            ffi:%null-pointer))))
 
 (define-public scheduler-shutdown
   (let ((func (util ffi:void "GNUNET_SCHEDULER_shutdown")))