[ARVADOS] updated: 5c85b61fff7db3a110971191a70647261eef1c31
git at public.curoverse.com
git at public.curoverse.com
Mon Nov 16 14:14:07 EST 2015
Summary of changes:
sdk/python/tests/keepstub.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
via 5c85b61fff7db3a110971191a70647261eef1c31 (commit)
from 4aa4ae976940d7ba11ad7c3391cb03139fb2ef25 (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 5c85b61fff7db3a110971191a70647261eef1c31
Author: Tom Clegg <tom at curoverse.com>
Date: Mon Nov 16 14:14:23 2015 -0500
7235: Insert delay after writing bytes, not before.
diff --git a/sdk/python/tests/keepstub.py b/sdk/python/tests/keepstub.py
index 860b2a5..9cf22da 100644
--- a/sdk/python/tests/keepstub.py
+++ b/sdk/python/tests/keepstub.py
@@ -72,12 +72,12 @@ class Handler(BaseHTTPServer.BaseHTTPRequestHandler, object):
outage_happened = True
num_write_bytes = min(BYTES_PER_WRITE,
num_bytes - num_sent_bytes)
- if self.server.bandwidth is not None:
- target_time += num_write_bytes / self.server.bandwidth
- self.server._sleep_at_least(target_time - time.time())
self.wfile.write(data_to_write[
num_sent_bytes:num_sent_bytes+num_write_bytes])
num_sent_bytes += num_write_bytes
+ if self.server.bandwidth is not None:
+ target_time += num_write_bytes / self.server.bandwidth
+ self.server._sleep_at_least(target_time - time.time())
return None
def rfile_bandwidth_read(self, bytes_to_read):
@@ -97,10 +97,10 @@ class Handler(BaseHTTPServer.BaseHTTPRequestHandler, object):
next_bytes_to_read = min(BYTES_PER_READ,
bytes_to_read - bytes_read)
data += self.rfile.read(next_bytes_to_read)
+ bytes_read += next_bytes_to_read
if self.server.bandwidth is not None:
target_time += next_bytes_to_read / self.server.bandwidth
self.server._sleep_at_least(target_time - time.time())
- bytes_read += next_bytes_to_read
return data
def handle(self, *args, **kwargs):
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list