[ARVADOS] updated: 05512d3b4fab8ea17bd66cb92fffefeabefa5d86

[git at public.curoverse.com]

Summary of changes:
 tools/keepexercise/keepexercise.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

       via  05512d3b4fab8ea17bd66cb92fffefeabefa5d86 (commit)
      from  eb2e48747b0444c1e8019168db319a6e63615e2c (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.


commit 05512d3b4fab8ea17bd66cb92fffefeabefa5d86
Author: Tom Clegg <tom at curoverse.com>
Date:   Wed Oct 7 03:16:10 2015 -0400

    7410: fixup keepexercise

diff --git a/tools/keepexercise/keepexercise.go b/tools/keepexercise/keepexercise.go
index 48627e3..fda0d5f 100644
--- a/tools/keepexercise/keepexercise.go
+++ b/tools/keepexercise/keepexercise.go
@@ -47,9 +47,10 @@ func main() {
 		log.Fatal(err)
 	}
 	kc.Want_replicas = *Replicas
+	kc.Client.Timeout = 10 * time.Minute
 
 	nextBuf := make(chan []byte, *WriteThreads)
-	nextLocator := make(chan string, *ReadThreads + *WriteThreads)
+	nextLocator := make(chan string, *ReadThreads+*WriteThreads)
 
 	go countBeans(nextLocator)
 	for i := 0; i < *WriteThreads; i++ {
@@ -122,7 +123,7 @@ func doWrites(kc *keepclient.KeepClient, nextBuf chan []byte, nextLocator chan s
 			continue
 		}
 		bytesOutChan <- uint64(len(buf))
-		for cap(nextLocator) > len(nextLocator) + *WriteThreads {
+		for cap(nextLocator) > len(nextLocator)+*WriteThreads {
 			// Give the readers something to do, unless
 			// they have lots queued up already.
 			nextLocator <- locator

-----------------------------------------------------------------------


hooks/post-receive
--