Searched refs:next_chunk (Results 1 – 19 of 19) sorted by relevance
336 const ChunkRecord& next_chunk = *GetChunkRecordAt(next_chunk_ptr); in DeleteNextChunksFor() local339 next_chunk_ptr - begin() + next_chunk.size, next_chunk.is_valid()); in DeleteNextChunksFor()345 if (PERFETTO_UNLIKELY(!next_chunk.is_valid())) { in DeleteNextChunksFor()355 if (PERFETTO_LIKELY(!next_chunk.is_padding)) { in DeleteNextChunksFor()356 ChunkMeta::Key key(next_chunk); in DeleteNextChunksFor()365 bytes_overwritten += next_chunk.size; in DeleteNextChunksFor()373 next_chunk_ptr - begin(), next_chunk_ptr - begin() + next_chunk.size, in DeleteNextChunksFor()377 padding_bytes_cleared += next_chunk.size; in DeleteNextChunksFor()380 next_chunk_ptr += next_chunk.size; in DeleteNextChunksFor()
13 fn next_chunk(buf: &mut MultiBuf) -> &[u8]; in next_chunk() function38 pub fn next_chunk(buf: &mut MultiBuf) -> &[u8] { in next_chunk() function
36 auto chunk = next_chunk(buf); in put()
1080 status, body = request.next_chunk(http=http)1092 status, body = request.next_chunk(http=http)1098 status, body = request.next_chunk(http=http)1104 status, body = request.next_chunk(http=http)1145 status, body = request.next_chunk(http=http)1157 status, body = request.next_chunk(http=http)1163 status, body = request.next_chunk(http=http)1249 status, body = request.next_chunk(http=http)1264 status, body = request.next_chunk(http=http)1354 status, body = request.next_chunk(http=http)[all …]
472 status, done = download.next_chunk()480 status, done = download.next_chunk()508 status, done = download.next_chunk()518 status, done = download.next_chunk()539 status, done = download.next_chunk()549 status, done = download.next_chunk()559 status, done = download.next_chunk()572 status, done = download.next_chunk(num_retries=4)605 status, done = download.next_chunk(num_retries=3)619 status, done = download.next_chunk(num_retries=3)[all …]
31 …ad object and flag it as a resumable upload. You then repeatedly call `next_chunk()` on the [`goog…38 status, response = request.next_chunk()52 … is retryable, the upload can be resumed by continuing to call request.next_chunk(), but subsequen…67 # Call next_chunk() again, but use an exponential backoff for repeated errors.
262 fn next_chunk(buf: &mut MultiBuf) -> &[u8];298 # fn next_chunk(buf: &mut MultiBuf) -> &[u8];320 pub fn next_chunk(buf: &mut MultiBuf) -> &[u8] {348 In blobstore.cc we're able to call the Rust `next_chunk` function, exposed to371 auto chunk = next_chunk(buf);394 # fn next_chunk(buf: &mut MultiBuf) -> &[u8];411 # pub fn next_chunk(buf: &mut MultiBuf) -> &[u8] {517 # fn next_chunk(buf: &mut MultiBuf) -> &[u8];537 # pub fn next_chunk(buf: &mut MultiBuf) -> &[u8] {617 # auto chunk = next_chunk(buf);
38 # fn next_chunk(buf: &mut MultiBuf) -> &[u8];65 `use super::next_chunk` except re-exported to C++. The parent module will either
46 fn next_chunk(buf: &mut MultiBuf) -> &[u8];
308 uptr next_chunk = frontier->back(); in FloodFillTag() local310 LsanMetadata m(next_chunk); in FloodFillTag()311 ScanRangeForPointers(next_chunk, next_chunk + m.requested_size(), frontier, in FloodFillTag()
107 WebPChunk* next_chunk = ChunkSearchNextInList(first->next_, tag); in ChunkSearchList() local108 if (next_chunk == NULL) break; in ChunkSearchList()109 first = next_chunk; in ChunkSearchList()
374 uptr next_chunk = frontier->back(); in FloodFillTag() local376 LsanMetadata m(next_chunk); in FloodFillTag()377 ScanRangeForPointers(next_chunk, next_chunk + m.requested_size(), frontier, in FloodFillTag()
1741 #define next_chunk(p) ((mchunkptr)( ((char*)(p)) + ((p)->head & ~INUSE_BITS))) macro1745 #define next_pinuse(p) ((next_chunk(p)->head) & PINUSE_BIT)2660 assert(is_mmapped(p) || pinuse(p) || next_chunk(prev_chunk(p)) == p); in do_check_inuse_chunk()2781 q = next_chunk(p); in do_check_smallbin()2847 q = next_chunk(q); in traverse_and_check()2907 q = next_chunk(q); in internal_mallinfo()2945 q = next_chunk(q); in internal_malloc_stats()3563 mchunkptr mn = next_chunk(mem2chunk(m)); in sys_alloc()4487 mn = next_chunk(mem2chunk(m)); in init_user_mstate()
2273 #define next_chunk(p) ((mchunkptr)( ((char*)(p)) + ((p)->head & ~FLAG_BITS))) macro2277 #define next_pinuse(p) ((next_chunk(p)->head) & PINUSE_BIT)3272 assert(is_mmapped(p) || pinuse(p) || next_chunk(prev_chunk(p)) == p); in do_check_inuse_chunk()3393 q = next_chunk(p); in do_check_smallbin()3459 q = next_chunk(q); in traverse_and_check()3521 q = next_chunk(q); in internal_mallinfo()3563 q = next_chunk(q); in internal_malloc_stats()4216 mchunkptr mn = next_chunk(mem2chunk(m)); in sys_alloc()5146 mchunkptr next = next_chunk(p); in internal_bulk_free()5182 mchunkptr next = next_chunk(q); in internal_inspect_all()[all …]
687 def next_chunk(self, num_retries=0): member in MediaIoBaseDownload862 _, body = self.next_chunk(http=http, num_retries=num_retries)914 def next_chunk(self, http=None, num_retries=0): member in HttpRequest
205 googleapiclient.http.HttpRequest.next_chunk googleapiclient.http.HttpRequest-class.html#next_chunk241 …oogleapiclient.http.MediaIoBaseDownload.next_chunk googleapiclient.http.MediaIoBaseDownload-class.…
97 fn next_chunk(buf: &mut MultiBuf) -> &[u8];165 `use super::next_chunk` except re-exported to C++. The parent module will either
5020 goto next_chunk;5633 goto next_chunk;5647 goto next_chunk;5698 next_chunk: