Overview
| Comment: | tweaks |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | trunk |
| Files: | files | file ages | folders |
| SHA1: |
399a5a4dfd5462bc905b6e1106ef76a8 |
| User & Date: | matt on 2015-09-16 23:58:41 |
| Other Links: | manifest | tags |
Context
|
2015-09-21
| ||
| 21:06 | reference.txt check-in: 892fac9e25 user: matt tags: trunk | |
|
2015-09-16
| ||
| 23:58 | tweaks check-in: 399a5a4dfd user: matt tags: trunk | |
| 00:56 | Partial resurection of nsmg transport check-in: 3e20c90912 user: matt tags: trunk | |
Changes
Modified api.scm from [7425d00411] to [ec567b2608].
| ︙ | ︙ | |||
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 68 69 70 |
testmeta-get-record
have-incompletes?
synchash-get
))
(define api:write-queries
'(
;; general call can be a write - must treat it as such
general-call
;; SERVERS
start-server
kill-server
;; TESTS
test-set-state-status-by-id
delete-test-records
|
| ︙ | ︙ |
Modified rmt.scm from [58033889c8] to [85489149c0].
1 2 3 4 5 6 7 8 9 10 11 | ;;====================================================================== ;; Copyright 2006-2013, Matthew Welland. ;; ;; This program is made available under the GNU GPL version 2.0 or ;; greater. See the accompanying file COPYING for details. ;; ;; This program is distributed WITHOUT ANY WARRANTY; without even the ;; implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR ;; PURPOSE. ;;====================================================================== | | | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | ;;====================================================================== ;; Copyright 2006-2013, Matthew Welland. ;; ;; This program is made available under the GNU GPL version 2.0 or ;; greater. See the accompanying file COPYING for details. ;; ;; This program is distributed WITHOUT ANY WARRANTY; without even the ;; implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR ;; PURPOSE. ;;====================================================================== (use json format nanomsg) (declare (unit rmt)) (declare (uses api)) (declare (uses tdb)) (declare (uses http-transport)) (declare (uses nmsg-transport)) |
| ︙ | ︙ | |||
149 150 151 152 153 154 155 | ;; Note: The tasks db was checked for a server in starting mode in the rmt:get-connection-info call ;; (if (and (< attemptnum 15) (member cmd api:write-queries)) (let ((faststart (configf:lookup *configdat* "server" "faststart"))) (hash-table-delete! *runremote* run-id) ;; (mutex-unlock! *send-receive-mutex*) | | | 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 | ;; Note: The tasks db was checked for a server in starting mode in the rmt:get-connection-info call ;; (if (and (< attemptnum 15) (member cmd api:write-queries)) (let ((faststart (configf:lookup *configdat* "server" "faststart"))) (hash-table-delete! *runremote* run-id) ;; (mutex-unlock! *send-receive-mutex*) (if (equal? faststart "no") (begin (tasks:start-and-wait-for-server (db:delay-if-busy (tasks:open-db)) run-id 10) (thread-sleep! (random 5)) ;; give some time to settle and minimize collison? (rmt:send-receive cmd rid params attemptnum: (+ attemptnum 1))) (let ((start-time (current-milliseconds)) (max-query (string->number (or (configf:lookup *configdat* "server" "server-query-threshold") "300"))) |
| ︙ | ︙ |