| Index: tools/telemetry/third_party/gsutilz/third_party/boto/boto/requestlog.py
|
| diff --git a/tools/telemetry/third_party/gsutilz/third_party/boto/boto/requestlog.py b/tools/telemetry/third_party/gsutilz/third_party/boto/boto/requestlog.py
|
| deleted file mode 100644
|
| index d8009fe76f6662373b7653c2b872c0a8cf67e1bc..0000000000000000000000000000000000000000
|
| --- a/tools/telemetry/third_party/gsutilz/third_party/boto/boto/requestlog.py
|
| +++ /dev/null
|
| @@ -1,39 +0,0 @@
|
| -import sys
|
| -from datetime import datetime
|
| -from threading import Thread
|
| -import Queue
|
| -
|
| -from boto.utils import RequestHook
|
| -from boto.compat import long_type
|
| -
|
| -
|
| -class RequestLogger(RequestHook):
|
| - """
|
| - This class implements a request logger that uses a single thread to
|
| - write to a log file.
|
| - """
|
| - def __init__(self, filename='/tmp/request_log.csv'):
|
| - self.request_log_file = open(filename, 'w')
|
| - self.request_log_queue = Queue.Queue(100)
|
| - Thread(target=self._request_log_worker).start()
|
| -
|
| - def handle_request_data(self, request, response, error=False):
|
| - len = 0 if error else response.getheader('Content-Length')
|
| - now = datetime.now()
|
| - time = now.strftime('%Y-%m-%d %H:%M:%S')
|
| - td = (now - request.start_time)
|
| - duration = (td.microseconds + long_type(td.seconds + td.days * 24 * 3600) * 1e6) / 1e6
|
| -
|
| - # write output including timestamp, status code, response time, response size, request action
|
| - self.request_log_queue.put("'%s', '%s', '%s', '%s', '%s'\n" % (time, response.status, duration, len, request.params['Action']))
|
| -
|
| - def _request_log_worker(self):
|
| - while True:
|
| - try:
|
| - item = self.request_log_queue.get(True)
|
| - self.request_log_file.write(item)
|
| - self.request_log_file.flush()
|
| - self.request_log_queue.task_done()
|
| - except:
|
| - import traceback
|
| - traceback.print_exc(file=sys.stdout)
|
|
|