361
362
363
364
365
366
367
368
369
370
371
372
373
374
|
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
|
+
|
run-ids
(rmt:get-all-run-ids)))
(result '()))
(if (null? run-id-list)
'()
(for-each
(lambda (th)
(thread-join! th)) ;; I assume that joining completed threads just moves on
(let loop ((hed (car run-id-list))
(tal (cdr run-id-list))
(threads '()))
(let* ((newthread (make-thread
(lambda ()
(let ((res (rmt:send-receive 'get-tests-for-run-mindata hed (list hed testpatt states status not-in))))
|
382
383
384
385
386
387
388
389
390
391
392
393
394
395
|
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
|
+
+
+
+
+
+
+
+
+
+
|
(newthreads (cons newthread threads)))
(thread-start! newthread)
(thread-sleep! 0.5) ;; give that thread some time to start
(if (null? tal)
newthreads
(loop (car tal)(cdr tal) newthreads))))))
result))
;; ;; IDEA: Threadify these - they spend a lot of time waiting ...
;; ;;
;; (define (rmt:get-tests-for-runs-mindata run-ids testpatt states status not-in)
;; (let ((run-id-list (if run-ids
;; run-ids
;; (rmt:get-all-run-ids))))
;; (apply append (map (lambda (run-id)
;; (rmt:send-receive 'get-tests-for-run-mindata run-id (list run-ids testpatt states status not-in)))
;; run-id-list))))
(define (rmt:delete-test-records run-id test-id)
(rmt:send-receive 'delete-test-records run-id (list run-id test-id)))
;; This is not needed as test steps are deleted on test delete call
;;
;; (define (rmt:delete-test-step-records run-id test-id)
|