Megatest

Check-in [76ef9fc5ad]
Login
Overview
Comment:Removing mark-incomplete from runs queue processing
Downloads: Tarball | ZIP archive | SQL archive
Timelines: family | ancestors | descendants | both | temp-hacks
Files: files | file ages | folders
SHA1: 76ef9fc5add6c92dff5260122f0a197bbd64bfd2
User & Date: mrwellan on 2014-12-09 10:51:22
Other Links: branch diff | manifest | tags
Context
2014-12-09
18:06
big hacks Closed-Leaf check-in: 5ed3476481 user: mrwellan tags: temp-hacks
10:51
Removing mark-incomplete from runs queue processing check-in: 76ef9fc5ad user: mrwellan tags: temp-hacks
10:27
Treat any exceptions when logging into server as a dead server (for now) check-in: 19f6ae918c user: mrwellan tags: v1.60
Changes

Modified runs.scm from [866c85daf6] to [15eacb131a].

365
366
367
368
369
370
371


372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408

    (if (not (null? required-tests))
	(debug:print-info 1 "Adding " required-tests " to the run queue"))
    ;; NOTE: these are all parent tests, items are not expanded yet.
    (debug:print-info 4 "test-records=" (hash-table->alist test-records))
    (let ((reglen (configf:lookup *configdat* "setup" "runqueue")))
      (if (> (length (hash-table-keys test-records)) 0)


	  (let* ((keep-going        #t)
		 (run-queue-retries 5)
		 (th1        (make-thread (lambda ()
					    (handle-exceptions
					     exn
					     (begin
					       (print-call-chain (current-error-port))
					       (debug:print 0 "ERROR: failure in runs:run-tests-queue thread, error: " ((condition-property-accessor 'exn 'message) exn))
					       (if (> run-queue-retries 0)
						   (begin
						     (set! run-queue-retries (- run-queue-retries 1))
						     (runs:run-tests-queue run-id runname test-records keyvals flags test-patts required-tests (any->number reglen) all-tests-registry))))
					     (runs:run-tests-queue run-id runname test-records keyvals flags test-patts required-tests (any->number reglen) all-tests-registry)))
					  "runs:run-tests-queue"))
		 (th2        (make-thread (lambda ()				    
					    ;; (rmt:find-and-mark-incomplete-all-runs))))) CAN'T INTERRUPT IT ...
					    (let ((run-ids (rmt:get-all-run-ids)))
					      (for-each (lambda (run-id)
							  (if keep-going
							      (handle-exceptions
							       exn
							       (debug:print 0 "error in calling find-and-mark-incomplete for run-id " run-id)
							       (rmt:find-and-mark-incomplete run-id #f)))) ;; ovr-deadtime)))
							run-ids)))
					  "runs: mark-incompletes")))
	    (thread-start! th1)
	    (thread-start! th2)
	    (thread-join! th1)
	    (set! keep-going #f)
	    (thread-join! th2)
	    ;; if run-count > 0 call, set -preclean and -rerun STUCK/DEAD
	    (if (> run-count 0)
		(begin
		  (if (not (hash-table-ref/default flags "-preclean" #f))
		      (hash-table-set! flags "-preclean" #t))
		  (if (not (hash-table-ref/default flags "-rerun" #f))
		      (hash-table-set! flags "-rerun" "STUCK/DEAD,n/a,ZERO_ITEMS"))







>
>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|







365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410

    (if (not (null? required-tests))
	(debug:print-info 1 "Adding " required-tests " to the run queue"))
    ;; NOTE: these are all parent tests, items are not expanded yet.
    (debug:print-info 4 "test-records=" (hash-table->alist test-records))
    (let ((reglen (configf:lookup *configdat* "setup" "runqueue")))
      (if (> (length (hash-table-keys test-records)) 0)
	  (begin
	    (runs:run-tests-queue run-id runname test-records keyvals flags test-patts required-tests (any->number reglen) all-tests-registry)
	    ;; (let* ((keep-going        #t)
	    ;;   	 (run-queue-retries 5)
	    ;;   	 (th1        (make-thread (lambda ()
	    ;;   				    (handle-exceptions
	    ;;   				     exn
	    ;;   				     (begin
	    ;;   				       (print-call-chain (current-error-port))
	    ;;   				       (debug:print 0 "ERROR: failure in runs:run-tests-queue thread, error: " ((condition-property-accessor 'exn 'message) exn))
	    ;;   				       (if (> run-queue-retries 0)
	    ;;   					   (begin
	    ;;   					     (set! run-queue-retries (- run-queue-retries 1))
	    ;;   					     (runs:run-tests-queue run-id runname test-records keyvals flags test-patts required-tests (any->number reglen) all-tests-registry))))
	    ;;   				     (runs:run-tests-queue run-id runname test-records keyvals flags test-patts required-tests (any->number reglen) all-tests-registry)))
	    ;;   				  "runs:run-tests-queue"))
	    ;;   	 (th2        (make-thread (lambda ()				    
	    ;;   				    ;; (rmt:find-and-mark-incomplete-all-runs))))) CAN'T INTERRUPT IT ...
	    ;;   				    (let ((run-ids (rmt:get-all-run-ids)))
	    ;;   				      (for-each (lambda (run-id)
	    ;;   						  (if keep-going
	    ;;   						      (handle-exceptions
	    ;;   						       exn
	    ;;   						       (debug:print 0 "error in calling find-and-mark-incomplete for run-id " run-id)
	    ;;   						       (rmt:find-and-mark-incomplete run-id #f)))) ;; ovr-deadtime)))
	    ;;   						run-ids)))
	    ;;   				  "runs: mark-incompletes")))
	    ;;       (thread-start! th1)
	    ;;       (thread-start! th2)
	    ;;       (thread-join! th1)
	    ;;       (set! keep-going #f)
	    ;;       (thread-join! th2)
	    ;; if run-count > 0 call, set -preclean and -rerun STUCK/DEAD
	    (if (> run-count 0)
		(begin
		  (if (not (hash-table-ref/default flags "-preclean" #f))
		      (hash-table-set! flags "-preclean" #t))
		  (if (not (hash-table-ref/default flags "-rerun" #f))
		      (hash-table-set! flags "-rerun" "STUCK/DEAD,n/a,ZERO_ITEMS"))