X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=s3bench%2Fs3pipeline.py;h=47216b151194a80af06e0fa7902838dd810bb24f;hb=9d32f47c84c4b8aae2ec6fd63d1a4f008228e82f;hp=bad40df25adad704c77720f53cc1ea2c4fff2875;hpb=24a4a426420f78de98786633d8191e7f24bf046c;p=bluesky.git

diff --git a/s3bench/s3pipeline.py b/s3bench/s3pipeline.py
index bad40df..47216b1 100755
--- a/s3bench/s3pipeline.py
+++ b/s3bench/s3pipeline.py
@@ -24,7 +24,7 @@ class HttpResponseParser:
 
         if not self.header and self.content_length is not None:
             consumed = min(self.content_length, len(self.buf))
-            print "Got", consumed, "bytes of data"
+            #print "Got", consumed, "bytes of data"
             self.content_length -= consumed
             self.buf = self.buf[consumed:]
 
@@ -41,7 +41,7 @@ class HttpResponseParser:
 
         line = self.buf[0:crlf]
         self.buf = self.buf[crlf+2:]
-        print "Header line:", line
+        #print "Header line:", line
         if line.lower().startswith('content-length'):
             self.content_length = int(line[16:])
             print "Content length:", self.content_length
@@ -72,7 +72,7 @@ class PipelinedRequester:
         auth_path = conn.calling_format.build_auth_path(self.bucket, key)
 
         headers = {'User-Agent': boto.UserAgent + " (pipelined)",
-                   'Content-Length': str(0), 'Connection': 'keep-alive'}
+                   'Content-Length': str(0)}
         conn.add_aws_auth_header(headers, method, auth_path)
 
         req = "%s %s HTTP/1.1\r\nHost: %s\r\n" % (method, path, self.host)
@@ -80,9 +80,11 @@ class PipelinedRequester:
         self.sock.sendall(req)
 
 requester = PipelinedRequester(bucket_name)
-for i in range(16):
-    requester.send_request('file-8192-' + str(i))
-    if i == 0:
+for i in range(12, 18):
+    requester.send_request('file-%d-1' % (1 << i,))
+    if i == 12:
         time.sleep(2)
+for i in range(32):
+    requester.send_request('file-8192-%d' % (i,))
 
 time.sleep(5)