| /external/pigweed/pw_transfer/ |
| D | transfer_test.cc | 42 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 …]
|
| D | client_test.cc | 33 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 …]
|
| D | context.cc | 43 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 …]
|
| /external/pigweed/pw_transfer/py/tests/ |
| D | transfer_test.py | 60 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 …]
|
| /external/pigweed/pw_transfer/java/main/dev/pigweed/pw_transfer/ |
| D | VersionedChunk.java | 25 * 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 …]
|
| /external/mesa3d/src/amd/common/ |
| D | ac_rgp.c | 155 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 …]
|
| /external/pigweed/pw_transfer/ts/ |
| D | transfer.ts | 16 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 …]
|
| D | transfer_test.ts | 30 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 …]
|
| /external/curl/lib/ |
| D | bufq.c | 33 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 void chunk_reset(struct buf_chunk *chunk) in chunk_reset() argument
50 chunk->next = NULL; in chunk_reset()
51 chunk->r_offset = chunk->w_offset = 0; in chunk_reset()
54 static size_t chunk_append(struct buf_chunk *chunk, in chunk_append() argument
[all …]
|
| /external/pigweed/pw_transfer/py/pw_transfer/ |
| D | transfer.py | 26 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 …]
|
| D | chunk.py | 14 """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 …]
|
| /external/curl/tests/data/ |
| D | test1112 | 26 Long chunk of data that couldn't possibly be sent in the time allotted.
27 Long chunk of data that couldn't possibly be sent in the time allotted.
28 Long chunk of data that couldn't possibly be sent in the time allotted.
29 Long chunk of data that couldn't possibly be sent in the time allotted.
30 Long chunk of data that couldn't possibly be sent in the time allotted.
31 Long chunk of data that couldn't possibly be sent in the time allotted.
32 Long chunk of data that couldn't possibly be sent in the time allotted.
33 Long chunk of data that couldn't possibly be sent in the time allotted.
34 Long chunk of data that couldn't possibly be sent in the time allotted.
35 Long chunk of data that couldn't possibly be sent in the time allotted.
[all …]
|
| D | test1086 | 26 Long chunk of data that couldn't possibly be sent in the time allotted.
27 Long chunk of data that couldn't possibly be sent in the time allotted.
28 Long chunk of data that couldn't possibly be sent in the time allotted.
29 Long chunk of data that couldn't possibly be sent in the time allotted.
30 Long chunk of data that couldn't possibly be sent in the time allotted.
31 Long chunk of data that couldn't possibly be sent in the time allotted.
32 Long chunk of data that couldn't possibly be sent in the time allotted.
33 Long chunk of data that couldn't possibly be sent in the time allotted.
34 Long chunk of data that couldn't possibly be sent in the time allotted.
35 Long chunk of data that couldn't possibly be sent in the time allotted.
[all …]
|
| /external/pigweed/pw_multibuf/ |
| D | chunk_test.cc | 15 #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 …]
|
| D | multibuf.cc | 26 Chunk* removed = first_; in Release()
34 for (const auto& chunk : *this) { in size_bytes()
35 len += chunk.size(); in size_bytes()
41 return std::all_of(Chunks().begin(), Chunks().end(), [](const Chunk& c) { in empty()
48 for (const Chunk& chunk : Chunks()) { in ContiguousSpan() local
49 if (chunk.empty()) { in ContiguousSpan()
53 contiguous = chunk; in ContiguousSpan()
54 } else if (contiguous.data() + contiguous.size() == chunk.data()) { in ContiguousSpan()
55 contiguous = {contiguous.data(), contiguous.size() + chunk.size()}; in ContiguousSpan()
60 // Return either the one non-empty chunk or an empty span. in ContiguousSpan()
[all …]
|
| /external/webrtc/net/dcsctp/packet/ |
| D | BUILD.gn | 162 rtc_library("chunk") {
177 "chunk/abort_chunk.cc",
178 "chunk/abort_chunk.h",
179 "chunk/chunk.cc",
180 "chunk/chunk.h",
181 "chunk/cookie_ack_chunk.cc",
182 "chunk/cookie_ack_chunk.h",
183 "chunk/cookie_echo_chunk.cc",
184 "chunk/cookie_echo_chunk.h",
185 "chunk/data_chunk.cc",
[all …]
|
| /external/perfetto/src/tracing/core/ |
| D | shared_memory_abi_unittest.cc | 27 using Chunk = SharedMemoryABI::Chunk; typedef
86 Chunk chunks[14]; in TEST_P()
89 Chunk& chunk = chunks[chunk_idx]; in TEST_P() local
105 chunk = abi.TryAcquireChunkForWriting(page_idx, chunk_idx, &header); in TEST_P()
106 ASSERT_TRUE(chunk.is_valid()); in TEST_P()
110 // Check chunk bounds. in TEST_P()
114 ASSERT_EQ(expected_chunk_size, chunk.size()); in TEST_P()
116 chunk.payload_size()); in TEST_P()
117 ASSERT_GT(chunk.begin(), page_start); in TEST_P()
118 ASSERT_GT(chunk.begin(), last_chunk_begin); in TEST_P()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_btree_reader_test.cc | 62 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 …]
|
| /external/angle/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_btree_reader_test.cc | 62 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 …]
|
| /external/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_btree_reader_test.cc | 62 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 …]
|
| /external/cronet/stable/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_btree_reader_test.cc | 62 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 …]
|
| /external/cronet/tot/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_rep_btree_reader_test.cc | 62 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 …]
|
| /external/trusty/lk/lib/heap/miniheap/ |
| D | miniheap.c | 86 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 …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/gprpp/ |
| D | chunked_vector.h | 33 // Expectation is that most usage will fit in one chunk, sometimes two will be
39 // One chunk of allocated memory.
40 struct Chunk { struct
41 Chunk() = default;
42 Chunk* next = nullptr; argument
93 Chunk* chunk = first_; in PopBack() local
94 while (chunk->next != append_) { in PopBack()
95 chunk = chunk->next; in PopBack()
97 append_ = chunk; in PopBack()
107 Chunk* chunk = first_; in Clear() local
[all …]
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | chunked_vector.h | 33 // Expectation is that most usage will fit in one chunk, sometimes two will be
39 // One chunk of allocated memory.
40 struct Chunk { struct
41 Chunk() = default;
42 Chunk* next = nullptr; argument
93 Chunk* chunk = first_; in PopBack() local
94 while (chunk->next != append_) { in PopBack()
95 chunk = chunk->next; in PopBack()
97 append_ = chunk; in PopBack()
107 Chunk* chunk = first_; in Clear() local
[all …]
|