| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/glacier/ |
| concurrent.py | 43 def __init__(self, part_size=DEFAULT_PART_SIZE, num_threads=10):
44 self._part_size = part_size
51 part_size = self._part_size
53 part_size = min_part_size_required
56 "size of: %s", self._part_size, part_size)
57 total_parts = int(math.ceil(total_size / float(part_size)))
58 return total_parts, part_size
68 def _add_work_items_to_queue(self, total_parts, worker_queue, part_size):
71 worker_queue.put((i, part_size))
86 def __init__(self, api, vault_name, part_size=DEFAULT_PART_SIZE
[all...] |
| writer.py | 43 This instance will call send_fn(part_data) as needed in part_size pieces,
44 except for the final part which may be shorter than part_size. Make sure to
49 def __init__(self, part_size, send_fn):
50 self.part_size = part_size
60 while self._buffer_size > self.part_size:
67 if len(data) > self.part_size:
68 self._buffer = [data[self.part_size:]]
74 part = data[:self.part_size]
89 def __init__(self, vault, upload_id, part_size, chunk_size=_ONE_MEGABYTE)
[all...] |
| vault.py | 112 def create_archive_writer(self, part_size=DefaultPartSize,
121 :type part_size: int
122 :param part_size: The part size for the multipart upload.
132 part_size,
134 return Writer(self, response['UploadId'], part_size=part_size)
159 part_size = self.DefaultPartSize
163 part_size = minimum_part_size(file_size, part_size)
170 part_size=part_size
[all...] |
| utils.py | 59 part_size = _MEGABYTE
65 while part_size < min_part_size:
66 part_size = math.ldexp(_MEGABYTE, power)
68 part_size = int(part_size)
70 part_size = default_part_size
71 return part_size
|
| layer1.py | [all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
| test_writer.py | 49 def partify(data, part_size):
51 start = i * part_size
52 part = data[start:start + part_size]
59 def calculate_mock_vault_calls(data, part_size, chunk_size):
62 for i, data_part in enumerate(partify(data, part_size)):
63 start = i * part_size
96 self.part_size = 4 # power of 2
99 self.vault, upload_id, self.part_size, self.chunk_size)
108 data, self.part_size, self.chunk_size)
189 self.part_size = 4 # power of
[all...] |
| test_concurrent.py | 69 total_parts, part_size = uploader._calculate_required_part_size(
72 self.assertEqual(part_size, 4 * 1024 * 1024)
78 part_size=too_small)
79 total_parts, part_size = uploader._calculate_required_part_size(
83 self.assertEqual(part_size, 4 * 1024 * 1024)
|
| test_vault.py | 74 description=mock.ANY, part_size=self.vault.DefaultPartSize)
86 description=mock.ANY, part_size=self.vault.DefaultPartSize)
100 description=mock.ANY, part_size=expected_part_size)
170 part_size=1024 * 1024 * 1024 * 8)
172 part_size=1024 * 1024 * 1024 * 8)
|
| test_layer2.py | 278 part_size = 4
281 'PartSizeInBytes': part_size,
295 self.vault, sentinel.upload_id, part_size, sentinel.file_obj,
|
| /external/webrtc/webrtc/base/ |
| multipart_unittest.cc | 57 size_t part_size = local
62 EXPECT_EQ(part_size, size);
68 part_size +=
70 part_size += stream_size;
77 EXPECT_EQ(part_size, size);
87 part_size += multipart.GetEndPartSize();
90 EXPECT_EQ(part_size, size);
|
| multipart.cc | 181 size_t part_size, part_offset = 0; local
183 if (!parts_[i]->GetSize(&part_size)) {
186 if (part_offset + part_size > position) {
199 part_offset += part_size;
212 size_t part_size, total_size = 0; local
214 if (!parts_[i]->GetSize(&part_size)) {
217 total_size += part_size;
229 size_t part_size, total_size = 0; local
231 if (!parts_[i]->GetAvailable(&part_size)) {
234 total_size += part_size;
[all...] |
| /system/update_engine/payload_generator/ |
| ab_generator_unittest.cc | 63 const size_t part_size = part_num_blocks * kBlockSize; local
66 part_data.resize(part_size);
71 for (uint32_t i = 0; i < part_size; i++)
74 ASSERT_EQ(part_size, part_data.size());
75 ASSERT_TRUE(utils::WriteFile(part_path.c_str(), part_data.data(), part_size));
216 const size_t part_size = part_num_blocks * kBlockSize; local
219 part_data.resize(part_size);
224 for (uint32_t i = 0; i < part_size; i++)
227 ASSERT_EQ(part_size, part_data.size());
228 ASSERT_TRUE(utils::WriteFile(part_path.c_str(), part_data.data(), part_size));
[all...] |
| /external/vboot_reference/cgpt/ |
| cgpt_find.c | 44 uint64_t part_size; local
50 part_size = LBA_SIZE * (entry->ending_lba - entry->starting_lba + 1);
51 if (params->matchoffset + params->matchlen > part_size) {
|
| /external/autotest/client/site_tests/hardware_Badblocks/ |
| hardware_Badblocks.py | 168 part_size = utils.get_disk_size(dev)
169 logging.info('Partition size (bytes): %s', part_size)
|
| /external/opencv3/3rdparty/libwebp/enc/ |
| syntax.c | 257 const size_t part_size = VP8BitWriterSize(enc->parts_ + p); local
258 if (part_size >= VP8_MAX_PARTITION_SIZE) {
261 buf[3 * p + 0] = (part_size >> 0) & 0xff;
262 buf[3 * p + 1] = (part_size >> 8) & 0xff;
263 buf[3 * p + 2] = (part_size >> 16) & 0xff;
|
| /external/vboot_reference/firmware/lib/ |
| vboot_kernel.c | 41 uint64_t part_start, part_size; local
143 GptNextKernelEntry(&gpt, &part_start, &part_size)) {
155 part_start, part_size));
166 shpart->sector_count = part_size;
179 part_start, part_size, &stream)) {
|
| /external/webp/src/enc/ |
| syntax.c | 253 const size_t part_size = VP8BitWriterSize(enc->parts_ + p); local
254 if (part_size >= VP8_MAX_PARTITION_SIZE) {
257 buf[3 * p + 0] = (part_size >> 0) & 0xff;
258 buf[3 * p + 1] = (part_size >> 8) & 0xff;
259 buf[3 * p + 2] = (part_size >> 16) & 0xff;
|
| /external/webp/src/dec/ |
| idec.c | 365 const size_t part_size = br->buf_end_ - br->buf_; local
370 assert(part_size <= mem->part0_size_);
371 if (part_size == 0) { // can't have zero-size partition #0
376 uint8_t* const part0_buf = (uint8_t*)WebPSafeMalloc(1ULL, part_size);
380 memcpy(part0_buf, br->buf_, part_size);
382 VP8BitReaderSetBuffer(br, part0_buf, part_size);
386 mem->start_ += part_size;
|
| /system/update_engine/payload_consumer/ |
| delta_performer.cc | 138 uint64_t part_size = fd->BlockDevSize(); local
139 if (!part_size || part_size <= data_size)
151 if (fd->BlkIoctl(request, data_size, part_size - data_size, &error) &&
156 << (part_size - data_size) / 1024 << " KiB using ioctl("
[all...] |
| /external/opencv3/modules/cudaobjdetect/src/ |
| hog.cpp | 216 static int numPartsWithin(int size, int part_size, int stride)
218 return (size - part_size + stride) / stride;
221 static Size numPartsWithin(Size size, Size part_size, Size stride)
223 return Size(numPartsWithin(size.width, part_size.width, stride.width),
224 numPartsWithin(size.height, part_size.height, stride.height));
[all...] |
| /external/opencv3/modules/objdetect/src/ |
| hog.cpp | 68 static int numPartsWithin(int size, int part_size, int stride)
70 return (size - part_size + stride) / stride;
73 static Size numPartsWithin(cv::Size size, cv::Size part_size,
76 return Size(numPartsWithin(size.width, part_size.width, stride.width),
77 numPartsWithin(size.height, part_size.height, stride.height));
[all...] |
