Home
last modified time | relevance | path

Searched full:chunk (Results 1 – 25 of 8011) sorted by relevance

12345678910>>...321

/aosp_15_r20/external/pigweed/pw_transfer/
H A Dtransfer_test.cc42 using internal::Chunk;
157 EncodeChunk(Chunk(ProtocolVersion::kLegacy, Chunk::Type::kStart) in TEST_F()
169 Chunk c0 = DecodeChunk(ctx_.responses()[0]); in TEST_F()
170 Chunk c1 = DecodeChunk(ctx_.responses()[1]); in TEST_F()
172 // First chunk should have all the read data. in TEST_F()
179 // Second chunk should be empty and set remaining_bytes = 0. in TEST_F()
186 EncodeChunk(Chunk::Final(ProtocolVersion::kLegacy, 3, OkStatus()))); in TEST_F()
195 EncodeChunk(Chunk(ProtocolVersion::kLegacy, Chunk::Type::kStart) in TEST_F()
206 Chunk c0 = DecodeChunk(ctx_.responses().back()); in TEST_F()
215 Chunk(ProtocolVersion::kLegacy, Chunk::Type::kParametersContinue) in TEST_F()
[all …]
H A Dclient_test.cc33 using internal::Chunk;
97 // First transfer parameters chunk is sent. in TEST_F()
103 Chunk c0 = DecodeChunk(payloads[0]); in TEST_F()
108 EXPECT_EQ(c0.type(), Chunk::Type::kStart); in TEST_F()
111 EncodeChunk(Chunk(ProtocolVersion::kLegacy, Chunk::Type::kData) in TEST_F()
120 Chunk c1 = DecodeChunk(payloads.back()); in TEST_F()
144 // First transfer parameters chunk is sent. in TEST_F()
150 Chunk c0 = DecodeChunk(payloads[0]); in TEST_F()
155 EXPECT_EQ(c0.type(), Chunk::Type::kStart); in TEST_F()
159 EncodeChunk(Chunk(ProtocolVersion::kLegacy, Chunk::Type::kData) in TEST_F()
[all …]
H A Dcontext.cc43 last_chunk_sent_ == Chunk::Type::kStartAck) { in HandleEvent()
44 // The client is retrying its initial chunk as the response may not in HandleEvent()
72 HandleChunkEvent(event.chunk); in HandleEvent()
113 // initial chunk. in InitiateTransferAsClient()
132 Chunk start_chunk(desired_protocol_version_, Chunk::Type::kStart); in InitiateTransferAsClient()
138 // Parameters should still be set on the initial chunk for backwards in InitiateTransferAsClient()
189 Chunk chunk(ProtocolVersion::kLegacy, Chunk::Type::kStart); in SendInitialLegacyTransmitChunk() local
190 chunk.set_session_id(resource_id_); in SendInitialLegacyTransmitChunk()
192 EncodeAndSendChunk(chunk); in SendInitialLegacyTransmitChunk()
209 // A transfer always begins with a window size of one chunk, set during in UpdateTransferParameters()
[all …]
/aosp_15_r20/external/pigweed/pw_transfer/py/tests/
H A Dtransfer_test.py60 self._sent_chunks: list[transfer_pb2.Chunk] = []
64 self, method: _Method, responses: Iterable[Iterable[transfer_pb2.Chunk]] argument
99 chunk = transfer_pb2.Chunk()
100 chunk.MergeFromString(packet.payload)
101 self._sent_chunks.append(chunk)
111 for chunk in self._sent_chunks:
112 data.extend(chunk.data)
124 transfer_pb2.Chunk(
146 transfer_pb2.Chunk(
149 transfer_pb2.Chunk(
[all …]
/aosp_15_r20/external/mesa3d/src/amd/common/
H A Dac_rgp.c155 static void ac_sqtt_fill_cpu_info(struct sqtt_file_chunk_cpu_info *chunk) in ac_sqtt_fill_cpu_info() argument
162 chunk->header.chunk_id.type = SQTT_FILE_CHUNK_TYPE_CPU_INFO; in ac_sqtt_fill_cpu_info()
163 chunk->header.chunk_id.index = 0; in ac_sqtt_fill_cpu_info()
164 chunk->header.major_version = 0; in ac_sqtt_fill_cpu_info()
165 chunk->header.minor_version = 0; in ac_sqtt_fill_cpu_info()
166 chunk->header.size_in_bytes = sizeof(*chunk); in ac_sqtt_fill_cpu_info()
168 chunk->cpu_timestamp_freq = 1000000000; /* tick set to 1ns */ in ac_sqtt_fill_cpu_info()
170 strncpy((char *)chunk->vendor_id, "Unknown", sizeof(chunk->vendor_id)); in ac_sqtt_fill_cpu_info()
171 strncpy((char *)chunk->processor_brand, "Unknown", sizeof(chunk->processor_brand)); in ac_sqtt_fill_cpu_info()
172 chunk->clock_speed = 0; in ac_sqtt_fill_cpu_info()
[all …]
/aosp_15_r20/external/curl/lib/
H A Dbufq.c33 static bool chunk_is_empty(const struct buf_chunk *chunk) in chunk_is_empty() argument
35 return chunk->r_offset >= chunk->w_offset; in chunk_is_empty()
38 static bool chunk_is_full(const struct buf_chunk *chunk) in chunk_is_full() argument
40 return chunk->w_offset >= chunk->dlen; in chunk_is_full()
43 static size_t chunk_len(const struct buf_chunk *chunk) in chunk_len() argument
45 return chunk->w_offset - chunk->r_offset; in chunk_len()
48 static size_t chunk_space(const struct buf_chunk *chunk) in chunk_space() argument
50 return chunk->dlen - chunk->w_offset; in chunk_space()
53 static void chunk_reset(struct buf_chunk *chunk) in chunk_reset() argument
55 chunk->next = NULL; in chunk_reset()
[all …]
/aosp_15_r20/external/pigweed/pw_transfer/py/pw_transfer/
H A Dtransfer.py26 from pw_transfer.chunk import Chunk, ProtocolVersion
102 # Waiting for the other end to send a chunk.
126 send_chunk: Callable[[Chunk], None], argument
152 # proceed to waiting for a chunk.
159 self._last_chunk: Chunk | None = None
171 """Sends the initial chunk of the transfer."""
185 initial_chunk = Chunk(
187 Chunk.Type.START,
198 # on the opening chunk, in case the server only runs legacy.
220 def _set_initial_chunk_fields(self, chunk: Chunk) -> None: argument
[all …]
H A Dchunk.py14 """Protocol version-aware chunk message wrapper."""
45 _ChunkType = transfer_pb2.Chunk.Type
48 class Chunk: class
49 """A chunk exchanged in a pw_transfer stream.
51 Wraps the generated protobuf Chunk class with protocol-aware field encoding
55 protocol_version: Version of the transfer protocol with which the chunk
57 chunk_type: Type of the chunk within the protocol.
58 session_id: ID for the transfer session to which the chunk belongs.
59 desired_session_id: For a v2 START chunk, the client-assigned session ID
61 resource_id: For a v2 START chunk, ID of the resource to transfer.
[all …]
/aosp_15_r20/external/pigweed/pw_transfer/ts/
H A Dtransfer.ts16 import { Chunk } from 'pigweedjs/protos/pw_transfer/transfer_pb';
95 protected sendChunk: (chunk: Chunk) => void,
106 /** Returns the initial chunk to notify the server of the transfer. */
107 protected abstract get initialChunk(): Chunk;
109 /** Handles a chunk that contains or requests data. */
110 protected abstract handleDataChunk(chunk: Chunk): void;
115 /** Handles a timeout while waiting for a chunk. */
131 /** Sends the initial chunk of the transfer. */
151 /** Ends the transfer without sending a completion chunk */
156 /** Ends the transfer and sends a completion chunk */
[all …]
H A Dtransfer_test.ts30 import { Chunk } from 'pigweedjs/protos/pw_transfer/transfer_pb';
42 let sentChunks: Chunk[];
61 const chunk = Chunk.deserializeBinary(packet.getPayload_asU8()); constant
62 sentChunks.push(chunk);
74 sentChunks.forEach((chunk: Chunk) => {
75 length += chunk.getData().length;
79 sentChunks.forEach((chunk: Chunk) => {
80 data.set(chunk.getData() as Uint8Array, offset);
81 offset += chunk.getData().length;
97 function enqueueServerResponses(method: MethodStub, responses: Chunk[][]) {
[all …]
/aosp_15_r20/external/pigweed/pw_transfer/java/test/dev/pigweed/pw_transfer/
H A DTransferClientTest.java83 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 1) in legacy_read_singleChunk_successful()
102 .containsExactly(newLegacyChunk(Chunk.Type.PARAMETERS_CONTINUE, 1) in legacy_read_failedPreconditionError_aborts()
123 newLegacyChunk(Chunk.Type.DATA, 0) in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks()
127 newLegacyChunk(Chunk.Type.DATA, 3) in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks()
132 newLegacyChunk(Chunk.Type.DATA, 1) in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks()
136 newLegacyChunk(Chunk.Type.DATA, 2) in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks()
143 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 1) in legacy_read_singleChunk_ignoresUnknownIdOrWriteChunks()
155 lastChunks(); // Discard initial chunk (tested elsewhere) in legacy_read_empty()
157 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 2).setRemainingBytes(0)); in legacy_read_empty()
181 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 123) in legacy_read_severalChunks()
[all …]
/aosp_15_r20/external/pigweed/pw_multibuf/
H A Dchunk_test.cc15 #include "pw_multibuf/chunk.h"
42 static_assert(std::ranges::contiguous_range<Chunk>);
47 TEST(Chunk, IsImplicitlyConvertibleToSpan) { in TEST() argument
49 std::optional<OwnedChunk> chunk = in TEST() local
52 ASSERT_TRUE(chunk.has_value()); in TEST()
53 // ``Chunk`` should convert to ``ByteSpan``. in TEST()
54 TakesSpan(**chunk); in TEST()
67 auto& chunk = *chunk_opt; in TEST() local
69 EXPECT_EQ(chunk.size(), kArbitraryChunkSize); in TEST()
71 chunk.Release(); in TEST()
[all …]
/aosp_15_r20/external/pigweed/pw_transfer/java/main/dev/pigweed/pw_transfer/
H A DVersionedChunk.java25 * Abstraction of the Chunk proto that supports different protocol versions.
34 public abstract Chunk.Type type(); in type()
71 public abstract Builder setType(Chunk.Type type); in setType()
102 public static VersionedChunk fromMessage(Chunk chunk, Map<Integer, Integer> legacyIdToSessionId) { in fromMessage() argument
106 if (chunk.hasProtocolVersion()) { in fromMessage()
107 if (chunk.getProtocolVersion() < ProtocolVersion.values().length) { in fromMessage()
108 version = ProtocolVersion.values()[chunk.getProtocolVersion()]; in fromMessage()
112 } else if (chunk.hasSessionId()) { in fromMessage()
119 if (chunk.hasType()) { in fromMessage()
120 builder.setType(chunk.getType()); in fromMessage()
[all …]
/aosp_15_r20/external/trusty/lk/lib/heap/miniheap/
Dminiheap.c86 static void dump_free_chunk(struct free_heap_chunk *chunk) in dump_free_chunk() argument
88 …INFO, "\t\tbase %p, end 0x%" PRIxVADDR ", len 0x%zx\n", chunk, (vaddr_t)chunk + chunk->len, chunk-… in dump_free_chunk()
99 struct free_heap_chunk *chunk; in miniheap_dump() local
100 list_for_every_entry(&theheap.free_list, chunk, struct free_heap_chunk, node) { in miniheap_dump()
101 dump_free_chunk(chunk); in miniheap_dump()
107 // try to insert this free chunk into the free list, consuming the chunk by merging it with
108 // nearby ones if possible. Returns base of whatever chunk it became in the list.
109 static struct free_heap_chunk *heap_insert_free_chunk(struct free_heap_chunk *chunk) in heap_insert_free_chunk() argument
112 vaddr_t chunk_end = (vaddr_t)chunk + chunk->len; in heap_insert_free_chunk()
115 LTRACEF("chunk ptr %p, size 0x%zx\n", chunk, chunk->len); in heap_insert_free_chunk()
[all …]
/aosp_15_r20/external/libpng/contrib/tools/
H A Dpngfix.c92 /* Chunk tags (copied from pngpriv.h) */
97 /* Constants for known chunk types. */
130 /* Is the chunk critical? */
131 #define CRITICAL(chunk) (((chunk) & PNG_U32(32,0,0,0)) == 0) argument
134 #define SAFE_TO_COPY(chunk) (((chunk) & PNG_U32(0,0,0,32)) != 0) argument
544 * the parser below where length+chunk-name is read and chunk-name used to in crc_init_4()
557 /* Bit whacking approach to chunk name validation that is intended to avoid in chunk_type_valid()
739 /* Return true if this chunk is to be skipped according to the --strip in skip_chunk_type()
795 * whether the safe-to-copy bit is set in the chunk type. in skip_chunk_type()
812 struct chunk;
[all …]
/aosp_15_r20/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/docs/doc/reference/com/google/android/exoplayer2/testutil/
H A DFakeChunkSource.html133 <dd><code><a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.exoplay…
138 implements <a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.exopla…
139 …="block">Fake <a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.ex…
218 …etNextChunk(long,long,java.util.List,com.google.android.exoplayer2.source.chunk.ChunkHolder)">getN…
220 …/a>&lt;? extends <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
221 …<a href="../source/chunk/ChunkHolder.html" title="class in com.google.android.exoplayer2.source.ch…
223 <div class="block">Returns the next chunk to load.</div>
229 …/a>&lt;? extends <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
231 …valuates whether <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
244 …chunk.Chunk)">onChunkLoadCompleted</a></span>&#8203;(<a href="../source/chunk/Chunk.html" title="c…
[all …]
/aosp_15_r20/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/docs/doc/reference/com/google/android/exoplayer2/testutil/
H A DFakeChunkSource.html133 <dd><code><a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.exoplay…
138 implements <a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.exopla…
139 …="block">Fake <a href="../source/chunk/ChunkSource.html" title="interface in com.google.android.ex…
218 …etNextChunk(long,long,java.util.List,com.google.android.exoplayer2.source.chunk.ChunkHolder)">getN…
220 …/a>&lt;? extends <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
221 …<a href="../source/chunk/ChunkHolder.html" title="class in com.google.android.exoplayer2.source.ch…
223 <div class="block">Returns the next chunk to load.</div>
229 …/a>&lt;? extends <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
231 …valuates whether <a href="../source/chunk/MediaChunk.html" title="class in com.google.android.exop…
244 …chunk.Chunk)">onChunkLoadCompleted</a></span>&#8203;(<a href="../source/chunk/Chunk.html" title="c…
[all …]
/aosp_15_r20/external/perfetto/src/tracing/core/
H A Dtrace_writer_impl_unittest.cc98 SharedMemoryABI::Chunk& chunk) const { in CopyPayloadAndApplyPatches()
99 std::vector<uint8_t> copy(chunk.payload_begin(), in CopyPayloadAndApplyPatches()
100 chunk.payload_begin() + chunk.payload_size()); in CopyPayloadAndApplyPatches()
101 ChunkHeader::Packets p = chunk.header()->packets.load(); in CopyPayloadAndApplyPatches()
103 auto it = patches_.find(PatchKey{chunk.header()->writer_id.load(), in CopyPayloadAndApplyPatches()
104 chunk.header()->chunk_id.load()}); in CopyPayloadAndApplyPatches()
140 ADD_FAILURE() << "Page " << page_idx << " chunk " << chunk_idx in GetPacketsFromShmemAndPatches()
144 SharedMemoryABI::Chunk chunk = in GetPacketsFromShmemAndPatches() local
146 if (!chunk.is_valid()) in GetPacketsFromShmemAndPatches()
148 ChunkHeader::Packets p = chunk.header()->packets.load(); in GetPacketsFromShmemAndPatches()
[all …]
/aosp_15_r20/external/pigweed/pw_multibuf/public/pw_multibuf/
H A Dmultibuf.h19 #include "pw_multibuf/chunk.h"
27 /// A `Chunk`-oriented view of a `MultiBuf`.
30 using element_type = Chunk;
31 using value_type = Chunk;
32 using pointer = Chunk*;
33 using reference = Chunk&;
34 using const_pointer = const Chunk*;
36 using const_reference = const Chunk&;
39 /// A `std::forward_iterator` over the `Chunk`s of a `MultiBuf`.
42 using value_type = Chunk;
[all …]
H A Dchunk.h30 /// A `Chunk` is similar to a `ByteSpan`, but is aware of its underlying memory
36 /// communications buffers, allocators can create properly-aligned `Chunk`
42 /// to reserve bytes for footers, and then pass the `Chunk` to the user to fill
47 class Chunk {
49 Chunk() = delete;
51 Chunk(Chunk&) = delete;
52 Chunk& operator=(Chunk&) = delete;
53 Chunk(Chunk&&) = delete;
54 Chunk& operator=(Chunk&&) = delete;
85 /// Returns if `next_chunk` is mergeable into the end of this `Chunk`.
[all …]
/aosp_15_r20/external/mesa3d/src/util/perf/
H A Du_trace.c73 * A "chunk" of trace-events and corresponding timestamp buffer. As
83 /* The number of traces this chunk contains so far: */
108 bool last; /* this chunk is last in batch */
109 bool eof; /* this chunk is last in frame, unless frame_nr is set */
116 * one chunk should be designated to free the data.
129 struct u_trace_chunk *chunk,
162 struct u_trace_chunk *chunk, in print_txt_event() argument
222 struct u_trace_chunk *chunk, in print_csv_event() argument
289 struct u_trace_chunk *chunk, in print_json_event() argument
347 struct u_trace_chunk *chunk = ptr; in free_chunk() local
[all …]
/aosp_15_r20/external/googleapis/google/ai/generativelanguage/v1beta/
H A Dretriever_service.proto135 // Creates a `Chunk`.
136 rpc CreateChunk(CreateChunkRequest) returns (Chunk) {
139 body: "chunk"
141 option (google.api.method_signature) = "parent,chunk";
144 // Batch create `Chunk`s.
153 // Gets information about a specific `Chunk`.
154 rpc GetChunk(GetChunkRequest) returns (Chunk) {
161 // Updates a `Chunk`.
162 rpc UpdateChunk(UpdateChunkRequest) returns (Chunk) {
164 patch: "/v1beta/{chunk.name=corpora/*/documents/*/chunks/*}"
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/
Dcord_rep_btree_reader_test.cc62 absl::string_view chunk = reader.Init(node); in TEST() local
63 EXPECT_THAT(chunk, Eq(data.substr(0, chunk.length()))); in TEST()
65 remaining -= chunk.length(); in TEST()
70 chunk = reader.Next(); in TEST()
71 EXPECT_THAT(chunk, Eq(data.substr(offset, chunk.length()))); in TEST()
73 remaining -= chunk.length(); in TEST()
100 absl::string_view chunk = reader.Init(node); in TEST() local
101 remaining -= chunk.length(); in TEST()
103 chunk = reader.Skip(skip1); in TEST()
105 ASSERT_THAT(chunk, Eq(data.substr(offset + skip1, chunk.length()))); in TEST()
[all …]
/aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/strings/internal/
H A Dcord_rep_btree_reader_test.cc62 absl::string_view chunk = reader.Init(node); in TEST() local
63 EXPECT_THAT(chunk, Eq(data.substr(0, chunk.length()))); in TEST()
65 remaining -= chunk.length(); in TEST()
70 chunk = reader.Next(); in TEST()
71 EXPECT_THAT(chunk, Eq(data.substr(offset, chunk.length()))); in TEST()
73 remaining -= chunk.length(); in TEST()
100 absl::string_view chunk = reader.Init(node); in TEST() local
101 remaining -= chunk.length(); in TEST()
103 chunk = reader.Skip(skip1); in TEST()
105 ASSERT_THAT(chunk, Eq(data.substr(offset + skip1, chunk.length()))); in TEST()
[all …]
/aosp_15_r20/external/webrtc/third_party/abseil-cpp/absl/strings/internal/
H A Dcord_rep_btree_reader_test.cc62 absl::string_view chunk = reader.Init(node); in TEST() local
63 EXPECT_THAT(chunk, Eq(data.substr(0, chunk.length()))); in TEST()
65 remaining -= chunk.length(); in TEST()
70 chunk = reader.Next(); in TEST()
71 EXPECT_THAT(chunk, Eq(data.substr(offset, chunk.length()))); in TEST()
73 remaining -= chunk.length(); in TEST()
100 absl::string_view chunk = reader.Init(node); in TEST() local
101 remaining -= chunk.length(); in TEST()
103 chunk = reader.Skip(skip1); in TEST()
105 ASSERT_THAT(chunk, Eq(data.substr(offset + skip1, chunk.length()))); in TEST()
[all …]

12345678910>>...321