Overview
| Comment: | add bbtest rmt api func for testing |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | rpc-transport | rpc-transport-bbtest |
| Files: | files | file ages | folders |
| SHA1: |
8b8c6928929cc2535cfeb3657c9b92d9 |
| User & Date: | bjbarcla on 2016-01-07 17:13:06 |
| Other Links: | branch diff | manifest | tags |
Context
|
2016-01-08
| ||
| 16:55 | factored out two functions from http-transport:keep-running to simplify: http-transport:get-server-info,http-transport:sync-inmemdb-to-db check-in: 33e9582eb3 user: bjbarcla tags: rpc-transport, rpc-transport-bbtest | |
|
2016-01-07
| ||
| 17:13 | add bbtest rmt api func for testing check-in: 8b8c692892 user: bjbarcla tags: rpc-transport, rpc-transport-bbtest | |
|
2016-01-06
| ||
| 15:31 | Create new branch named "rpc-support" Closed-Leaf check-in: d223d55c09 user: bjbarcla tags: rpc-transport | |
Changes
Modified Makefile from [c0b2515300] to [579f73e2e6].
1 2 3 4 | # make install CSCOPTS='-accumulate-profile -profile-name $(PWD)/profile-ww$(shell date +%V.%u)' PREFIX=$(PWD) CSCOPTS= INSTALL=install | | | 1 2 3 4 5 6 7 8 9 10 11 12 |
# make install CSCOPTS='-accumulate-profile -profile-name $(PWD)/profile-ww$(shell date +%V.%u)'
PREFIX=$(PWD)
CSCOPTS=
INSTALL=install
SRCFILES = common.scm bb.scm items.scm launch.scm \
ods.scm runconfig.scm server.scm configf.scm \
db.scm keys.scm margs.scm megatest-version.scm \
process.scm runs.scm tasks.scm tests.scm genexample.scm \
http-transport.scm nmsg-transport.scm filedb.scm \
client.scm gutils.scm synchash.scm daemon.scm mt.scm dcommon.scm \
tree.scm ezsteps.scm lock-queue.scm sdb.scm \
rmt.scm api.scm tdb.scm rpc-transport.scm \
|
| ︙ | ︙ |
Modified api.scm from [7425d00411] to [ee00bee346].
| ︙ | ︙ | |||
9 10 11 12 13 14 15 | ;; PURPOSE. ;;====================================================================== (declare (unit api)) (declare (uses rmt)) (declare (uses db)) (declare (uses tasks)) | | | 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
;; PURPOSE.
;;======================================================================
(declare (unit api))
(declare (uses rmt))
(declare (uses db))
(declare (uses tasks))
(declare (uses bb))
;; allow these queries through without starting a server
;;
(define api:read-only-queries
'(get-key-val-pairs
get-keys
test-toplevel-num-items
get-test-info-by-id
|
| ︙ | ︙ | |||
53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
testmeta-get-record
have-incompletes?
synchash-get
))
(define api:write-queries
'(
;; SERVERS
start-server
kill-server
;; TESTS
test-set-state-status-by-id
delete-test-records
| > | 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
testmeta-get-record
have-incompletes?
synchash-get
))
(define api:write-queries
'(
bbtest
;; SERVERS
start-server
kill-server
;; TESTS
test-set-state-status-by-id
delete-test-records
|
| ︙ | ︙ | |||
116 117 118 119 120 121 122 | #t (let ((cmd (vector-ref dat 0)) (params (vector-ref dat 1))) (case (if (symbol? cmd) cmd (string->symbol cmd)) | > > > | | 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 |
#t
(let ((cmd (vector-ref dat 0))
(params (vector-ref dat 1)))
(case (if (symbol? cmd)
cmd
(string->symbol cmd))
;; Brandon's test to extend API
((bbtest) (apply bb:test params))
;;===============================================
;; READ/WRITE QUERIES
;;===============================================
;; SERVERS
((start-server) (apply server:kind-run params))
((kill-server) (set! *server-run* #f))
|
| ︙ | ︙ |
Modified rmt.scm from [58033889c8] to [02ebc7dccc].
| ︙ | ︙ | |||
582 583 584 585 586 587 588 589 590 591 592 593 594 595 |
(define (rmt:get-runs-by-patt keys runnamepatt targpatt offset limit fields) ;; fields of #f uses default
(rmt:send-receive 'get-runs-by-patt #f (list keys runnamepatt targpatt offset limit fields)))
(define (rmt:find-and-mark-incomplete run-id ovr-deadtime)
(if (rmt:send-receive 'have-incompletes? run-id (list run-id ovr-deadtime))
(rmt:send-receive 'mark-incomplete run-id (list run-id ovr-deadtime))))
;;======================================================================
;; M U L T I R U N Q U E R I E S
;;======================================================================
;; Need to move this to multi-run section and make associated changes
(define (rmt:find-and-mark-incomplete-all-runs #!key (ovr-deadtime #f))
(let ((run-ids (rmt:get-all-run-ids)))
| > > > > | 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 |
(define (rmt:get-runs-by-patt keys runnamepatt targpatt offset limit fields) ;; fields of #f uses default
(rmt:send-receive 'get-runs-by-patt #f (list keys runnamepatt targpatt offset limit fields)))
(define (rmt:find-and-mark-incomplete run-id ovr-deadtime)
(if (rmt:send-receive 'have-incompletes? run-id (list run-id ovr-deadtime))
(rmt:send-receive 'mark-incomplete run-id (list run-id ovr-deadtime))))
(define (rmt:bbtest )
(rmt:send-receive 'bbtest #f '()))
;;======================================================================
;; M U L T I R U N Q U E R I E S
;;======================================================================
;; Need to move this to multi-run section and make associated changes
(define (rmt:find-and-mark-incomplete-all-runs #!key (ovr-deadtime #f))
(let ((run-ids (rmt:get-all-run-ids)))
|
| ︙ | ︙ |