| /external/chromium-trace/catapult/firefighter/base/ |
| bigquery.py | 36 truncate=False, num_retries=5):
71 body=body, media_body=media_body).execute(num_retries=num_retries))
79 def InsertRowsSync(self, dataset_id, table_id, rows, num_retries=5):
91 body=insert_data).execute(num_retries=num_retries)
96 def QueryAsync(self, query, num_retries=5):
112 body=body).execute(num_retries=num_retries)
114 def QuerySync(self, query, timeout=60, num_retries=5)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/utils/ |
| test_utils.py | 207 response = retry_url('http://10.10.10.10/foo', num_retries=1)
217 response = retry_url('http://10.10.10.10/foo', num_retries=1)
223 response = retry_url('http://10.10.10.10/foo', num_retries=1)
248 num_retries = 2
251 response = LazyLoadMetadata(url, num_retries)
259 num_retries = 2
262 response = LazyLoadMetadata(url, num_retries)
276 num_retries=5, timeout=None)
281 userdata = get_instance_userdata(timeout=1, num_retries=2)
288 num_retries=2, timeout=1
[all...] |
| /external/autotest/server/site_tests/brillo_BootLoader/ |
| brillo_BootLoader.py | 171 num_retries = 1
172 while num_retries < 10 and self.get_current_slot() == 1:
173 logging.info('Still with B after %d retries' % num_retries)
174 num_retries += 1
179 'as GOOD' % num_retries)
180 logging.info('Falled back to A after %d retries.', num_retries)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/gs/ |
| test_resumable_downloads.py | 98 tracker_file_name=tracker_file_name, num_retries=0)
123 res_download_handler = ResumableDownloadHandler(num_retries=1)
141 res_download_handler = ResumableDownloadHandler(num_retries=1)
159 res_download_handler = ResumableDownloadHandler(num_retries=1)
182 tracker_file_name=tracker_file_name, num_retries=1)
198 res_download_handler = ResumableDownloadHandler(num_retries=3)
225 tracker_file_name=tracker_file_name, num_retries=0)
261 res_download_handler = ResumableDownloadHandler(num_retries=1)
|
| test_resumable_uploads.py | 114 tracker_file_name=tracker_file_name, num_retries=0)
143 res_upload_handler = ResumableUploadHandler(num_retries=1)
161 res_upload_handler = ResumableUploadHandler(num_retries=1)
179 res_upload_handler = ResumableUploadHandler(num_retries=1)
200 tracker_file_name=tracker_file_name, num_retries=1)
218 res_upload_handler = ResumableUploadHandler(num_retries=3)
241 tracker_file_name=tracker_file_name, num_retries=1)
278 res_upload_handler = ResumableUploadHandler(num_retries=1)
345 tracker_file_name=tracker_file_name, num_retries=0)
387 res_upload_handler = ResumableUploadHandler(num_retries=1
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
| test_concurrent.py | 143 'upload_id', job_queue, result_queue, num_retries=1,
154 # total attempts is 1 + num_retries so if I have num_retries of 2,
162 'upload_id', job_queue, result_queue, num_retries=2,
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/s3/ |
| resumable_download_handler.py | 40 progress (per configurable num_retries param), the download will be aborted.
98 def __init__(self, tracker_file_name=None, num_retries=None):
110 :type num_retries: int
111 :param num_retries: the number of times we'll re-try a resumable
117 self.num_retries = num_retries
271 if self.num_retries is None:
272 self.num_retries = config.getint('Boto', 'num_retries', 6)
329 if progress_less_iterations > self.num_retries
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/ |
| utils.py | 198 def retry_url(url, retry_on_404=True, num_retries=10, timeout=None):
205 for i in range(0, num_retries):
226 if i + 1 != num_retries:
233 def _get_instance_metadata(url, num_retries, timeout=None):
234 return LazyLoadMetadata(url, num_retries, timeout)
238 def __init__(self, url, num_retries, timeout=None):
240 self._num_retries = num_retries
244 data = boto.utils.retry_url(self._url, num_retries=self._num_retries, timeout=self._timeout)
284 num_retries=self._num_retries,
380 data='meta-data/', timeout=None, num_retries=5)
[all...] |
| connection.py | 475 self.num_retries = 6
[all...] |
| provider.py | 386 # The num_retries arg is actually the total number of attempts made,
390 timeout=timeout, num_retries=attempts,
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/apitools/apitools/base/py/ |
| base_api.py | 224 num_retries=5, max_retry_wait=60, credentials_args=None,
235 self.num_retries = num_retries
352 def num_retries(self): member in class:BaseApiClient
355 @num_retries.setter
356 def num_retries(self, value): member in class:BaseApiClient
360 'Cannot have negative value for num_retries')
376 def WithRetries(self, num_retries):
377 old_num_retries = self.num_retries
378 self.num_retries = num_retrie
[all...] |
| http_wrapper.py | 48 # num_retries: Number of retries consumed; used for exponential backoff.
50 'ExceptionRetryArgs', ['http', 'http_request', 'exc', 'num_retries',
281 retry_args.num_retries, max_wait=retry_args.max_retry_wait))
300 (Httplib2.Http, Request, Exception, int num_retries).
|
| transfer.py | 67 auto_transfer=True, http=None, num_retries=5):
76 self.num_retries = num_retries
103 def num_retries(self): member in class:_Transfer
106 @num_retries.setter
107 def num_retries(self, value): member in class:_Transfer
111 'Cannot have negative value for num_retries')
396 retries=self.num_retries)
782 retries=self.num_retries)
819 retries=self.num_retries)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| gcs_json_api.py | 225 self.num_retries = GetNumRetries()
239 self.api_client.num_retries = self.num_retries
675 num_retries=self.num_retries)
679 num_retries=self.num_retries)
711 while retries <= self.num_retries:
725 if retries > self.num_retries:
728 (self.num_retries, unicode(e).encode(UTF8))
[all...] |
| boto_resumable_upload.py | 29 no progress (per configurable num_retries param), the upload will be
75 resume_url=None, num_retries=None):
84 num_retries: Number of times to retry the upload making no progress.
92 self.num_retries = num_retries
490 if self.progress_less_iterations > self.num_retries:
550 if self.num_retries is None:
551 self.num_retries = GetNumRetries()
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/gs/ |
| resumable_upload_handler.py | 44 no progress (per configurable num_retries param), the upload will be
64 def __init__(self, tracker_file_name=None, num_retries=None):
76 :type num_retries: int
77 :param num_retries: the number of times we'll re-try a resumable upload
82 self.num_retries = num_retries
556 if self.progress_less_iterations > self.num_retries:
637 if self.num_retries is None:
638 self.num_retries = config.getint('Boto', 'num_retries', 6
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/gslib/addlhelp/ |
| retries.py | 41 by editing the num_retries and max_retry_delay configuration variables in the
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/glacier/ |
| concurrent.py | 218 worker_queue, result_queue, num_retries=5,
227 self._num_retries = num_retries
364 num_retries=5,
383 self._num_retries = num_retries
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/manage/ |
| cmdshell.py | 66 def connect(self, num_retries=5):
70 :type num_retries: int
71 :param num_retries: The maximum number of connection attempts.
74 while retry < num_retries:
|
| /external/chromium-trace/catapult/third_party/apiclient/googleapiclient/ |
| http.py | 521 def next_chunk(self, num_retries=0):
525 num_retries: Integer, number of times to retry 500's with randomized
545 for retry_num in range(num_retries + 1):
669 def execute(self, http=None, num_retries=0):
675 num_retries: Integer, number of times to retry 500's with randomized
694 _, body = self.next_chunk(http=http, num_retries=num_retries)
715 for retry_num in range(num_retries + 1):
745 def next_chunk(self, http=None, num_retries=0):
770 num_retries: Integer, number of times to retry 500's with randomize
[all...] |
| /frameworks/compile/libbcc/gdb_plugin/ |
| android-commands.py | 384 # after num_retries attempts. num_retries=0 means retry
386 def _wait_for_process(self, process_name, retry_delay=1, num_retries=10):
389 retries_left = num_retries
|
| /system/update_engine/common/ |
| utils.cc | 708 int num_retries = 1; local
709 for (;; ++num_retries) {
712 if (errno != EBUSY || num_retries >= kUnmountMaxNumOfRetries)
720 PLOG(WARNING) << "Error unmounting " << mountpoint << " after " << num_retries local
[all...] |
| /cts/apps/CameraITS/pymodules/its/ |
| device.py | 99 NUM_RETRIES = 100
104 for i in range(NUM_RETRIES):
109 if i == NUM_RETRIES - 1:
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/provider/ |
| test_provider.py | 391 timeout=4.0, num_retries=10,
|
| /packages/providers/ContactsProvider/tests/assets/testUnsynced/ |
| legacy_contacts.sql | 16 CREATE TABLE fave_msg_status (_id INTEGER PRIMARY KEY, msg TEXT, next_retry INTEGER, num_retries INTEGER);
|
