[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