| /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()
124 transfer_pb2.Chunk(
146 transfer_pb2.Chunk(
149 transfer_pb2.Chunk(
171 transfer_pb2.Chunk(
174 transfer_pb2.Chunk(
206 transfer_pb2.Chunk(
210 transfer_pb2.Chunk(
[all …]
|
| /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()
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()
222 Chunk c1 = DecodeChunk(ctx_.responses().back()); in TEST_F()
232 Chunk(ProtocolVersion::kLegacy, Chunk::Type::kParametersContinue) in TEST_F()
[all …]
|
| D | client_test.cc | 33 using internal::Chunk;
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()
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()
168 EncodeChunk(Chunk(ProtocolVersion::kLegacy, Chunk::Type::kData) in TEST_F()
177 Chunk c1 = DecodeChunk(payloads[1]); in TEST_F()
[all …]
|
| D | context.cc | 43 last_chunk_sent_ == Chunk::Type::kStartAck) { in HandleEvent()
132 Chunk start_chunk(desired_protocol_version_, Chunk::Type::kStart); in InitiateTransferAsClient()
189 Chunk chunk(ProtocolVersion::kLegacy, Chunk::Type::kStart); in SendInitialLegacyTransmitChunk()
255 void Context::SetTransferParameters(Chunk& parameters) { in SetTransferParameters()
269 Chunk::Type type = Chunk::Type::kParametersRetransmit; in SendTransferParameters()
273 type = Chunk::Type::kStart; in SendTransferParameters()
277 type = Chunk::Type::kParametersRetransmit; in SendTransferParameters()
280 type = Chunk::Type::kParametersContinue; in SendTransferParameters()
284 Chunk parameters(configured_protocol_version_, type); in SendTransferParameters()
314 void Context::EncodeAndSendChunk(const Chunk& chunk) { in EncodeAndSendChunk()
[all …]
|
| /external/pigweed/pw_transfer/java/test/dev/pigweed/pw_transfer/ |
| D | TransferClientTest.java | 83 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()
157 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 2).setRemainingBytes(0)); in legacy_read_empty()
181 receiveReadChunks(newLegacyChunk(Chunk.Type.DATA, 123) in legacy_read_severalChunks()
185 newLegacyChunk(Chunk.Type.DATA, 123).setOffset(10).setData(range(10, 30))); in legacy_read_severalChunks()
[all …]
|
| /external/pigweed/pw_transfer/integration_test/ |
| D | proxy_test.py | 23 from pw_transfer.chunk import Chunk, ProtocolVersion
139 Chunk(ProtocolVersion.VERSION_TWO, Chunk.Type.START),
160 Chunk(ProtocolVersion.VERSION_TWO, Chunk.Type.DATA, data=b'1')
280 Chunk(ProtocolVersion.VERSION_TWO, Chunk.Type.DATA, data=b'1')
338 Chunk(
340 Chunk.Type.DATA,
346 Chunk(
348 Chunk.Type.DATA,
354 Chunk(
356 Chunk.Type.DATA,
[all …]
|
| /external/pigweed/pw_multibuf/public/pw_multibuf/ |
| D | chunk.h | 47 class Chunk {
49 Chunk() = delete;
51 Chunk(Chunk&) = delete;
52 Chunk& operator=(Chunk&) = delete;
53 Chunk(Chunk&&) = delete;
54 Chunk& operator=(Chunk&&) = delete;
89 [[nodiscard]] bool CanMerge(const Chunk& next_chunk) const;
174 Chunk(ChunkRegionTracker* region_tracker, ByteSpan span) in Chunk() function
185 void InsertAfterInRegionList(Chunk* new_chunk);
186 void InsertBeforeInRegionList(Chunk* new_chunk);
[all …]
|
| D | multibuf.h | 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&;
42 using value_type = Chunk;
44 using reference = Chunk&;
45 using pointer = Chunk*;
76 constexpr iterator(Chunk* chunk) : chunk_(chunk) {} in iterator()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Target/AArch64/ |
| D | AArch64ExpandImm.cpp | 31 static bool canUseOrr(uint64_t Chunk, uint64_t &Encoding) { in canUseOrr() argument
32 Chunk = (Chunk << 48) | (Chunk << 32) | (Chunk << 16) | Chunk; in canUseOrr()
34 return AArch64_AM::processLogicalImmediate(Chunk, 64, Encoding); in canUseOrr()
55 for (CountMap::const_iterator Chunk = Counts.begin(), End = Counts.end(); in tryToreplicateChunks() local
56 Chunk != End; ++Chunk) { in tryToreplicateChunks()
57 const uint64_t ChunkVal = Chunk->first; in tryToreplicateChunks()
58 const unsigned Count = Chunk->second; in tryToreplicateChunks()
108 static bool isStartChunk(uint64_t Chunk) { in isStartChunk() argument
109 if (Chunk == 0 || Chunk == std::numeric_limits<uint64_t>::max()) in isStartChunk()
112 return isMask_64(~Chunk); in isStartChunk()
[all …]
|
| /external/skia/src/utils/ |
| D | SkBitSet.h | 25 , fChunks((Chunk*)sk_calloc_throw(NumChunksFor(fSize) * sizeof(Chunk))) {} in SkBitSet()
46 return 0 == memcmp(fChunks.get(), that.fChunks.get(), sizeof(Chunk) * numChunks);
61 Chunk* chunks = fChunks.get(); in set()
63 std::memset(chunks, 0xFF, sizeof(Chunk) * numChunks); in set()
74 Chunk* chunks = fChunks.get(); in reset()
76 std::memset(chunks, 0, sizeof(Chunk) * numChunks); in reset()
91 const Chunk* chunks = fChunks.get(); in forEachSetIndex()
94 if (Chunk chunk = chunks[i]) { // There are set bits in forEachSetIndex()
109 const Chunk* chunks = fChunks.get(); in findFirst()
112 if (Chunk chunk = chunks[i]) { // There are set bits in findFirst()
[all …]
|
| /external/webrtc/net/dcsctp/packet/chunk/ |
| D | chunk.h | 35 class Chunk {
37 Chunk() {} in Chunk() function
38 virtual ~Chunk() = default;
41 Chunk(Chunk&& other) = default;
42 Chunk& operator=(Chunk&& other) = default;
43 Chunk(const Chunk&) = delete;
44 Chunk& operator=(const Chunk&) = delete;
|
| /external/swiftshader/third_party/llvm-16.0/llvm/lib/Target/AArch64/ |
| D | AArch64ExpandImm.cpp | 30 static bool canUseOrr(uint64_t Chunk, uint64_t &Encoding) { in canUseOrr() argument
31 Chunk = (Chunk << 48) | (Chunk << 32) | (Chunk << 16) | Chunk; in canUseOrr()
33 return AArch64_AM::processLogicalImmediate(Chunk, 64, Encoding); in canUseOrr()
54 for (const auto &Chunk : Counts) { in tryToreplicateChunks() local
55 const uint64_t ChunkVal = Chunk.first; in tryToreplicateChunks()
56 const unsigned Count = Chunk.second; in tryToreplicateChunks()
106 static bool isStartChunk(uint64_t Chunk) { in isStartChunk() argument
107 if (Chunk == 0 || Chunk == std::numeric_limits<uint64_t>::max()) in isStartChunk()
110 return isMask_64(~Chunk); in isStartChunk()
116 static bool isEndChunk(uint64_t Chunk) { in isEndChunk() argument
[all …]
|
| /external/pigweed/pw_multibuf/ |
| D | chunk.cc | 45 bool Chunk::CanMerge(const Chunk& next_chunk) const { in CanMerge()
50 bool Chunk::Merge(OwnedChunk& next_chunk_owned) { in Merge()
54 Chunk* next_chunk = std::move(next_chunk_owned).Take(); in Merge()
68 void Chunk::InsertAfterInRegionList(Chunk* new_chunk) in InsertAfterInRegionList()
78 void Chunk::InsertBeforeInRegionList(Chunk* new_chunk) in InsertBeforeInRegionList()
88 void Chunk::RemoveFromRegionList() in RemoveFromRegionList()
106 Chunk* chunk = new (memory) Chunk(this, Region()); in CreateFirstChunk()
110 void Chunk::Free() { in Free()
140 bool Chunk::ClaimPrefix(size_t bytes_to_claim) { in ClaimPrefix()
157 Chunk* prev = prev_in_region_; in ClaimPrefix()
[all …]
|
| D | multibuf.cc | 26 Chunk* removed = first_; in Release()
41 return std::all_of(Chunks().begin(), Chunks().end(), [](const Chunk& c) { in empty()
48 for (const Chunk& chunk : Chunks()) { in ContiguousSpan()
107 Chunk* remainder = pos.chunk()->next_in_buf_; in TruncateAfter()
199 Chunk* last_front_chunk = nullptr; in TakePrefix()
202 Chunk* new_chunk_ptr = &*new_chunk; in TakePrefix()
218 Chunk* last_front_bit_ptr = std::move(*last_front_bit).Take(); in TakePrefix()
243 Chunk* new_chunk = std::move(chunk).Take(); in push_front()
244 Chunk* old_first = first_; in push_front()
251 Chunk* new_chunk = std::move(chunk).Take(); in push_back()
[all …]
|
| /external/pigweed/pw_transfer/ts/ |
| 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());
74 sentChunks.forEach((chunk: Chunk) => {
79 sentChunks.forEach((chunk: Chunk) => {
97 function enqueueServerResponses(method: MethodStub, responses: Chunk[][]) {
120 ): Chunk {
121 const chunk = new Chunk();
214 expect(sentChunks[1].getType()).toEqual(Chunk.Type.PARAMETERS_CONTINUE);
253 const chunk = new Chunk();
[all …]
|
| D | transfer.ts | 16 import { Chunk } from 'pigweedjs/protos/pw_transfer/transfer_pb';
95 protected sendChunk: (chunk: Chunk) => void,
107 protected abstract get initialChunk(): Chunk;
110 protected abstract handleDataChunk(chunk: Chunk): void;
158 const chunk = new Chunk();
161 chunk.setType(Chunk.Type.COMPLETION);
190 handleChunk(chunk: Chunk): void {
237 sendChunk: (chunk: Chunk) => void,
254 return this.transferParameters(Chunk.Type.START);
258 private transferParameters(type: any, update = true): Chunk {
[all …]
|
| /external/pigweed/pw_transfer/public/pw_transfer/internal/ |
| D | chunk.h | 26 class Chunk {
28 using Type = transfer::pwpb::Chunk::Type;
39 friend class Chunk;
71 constexpr Chunk(ProtocolVersion version, Type type) in Chunk() function
72 : Chunk(version, std::optional<Type>(type)) {} in Chunk()
75 static Result<Chunk> Parse(ConstByteSpan message);
78 static Chunk Final(ProtocolVersion version, in Final()
81 return Chunk(version, Type::kCompletion) in Final()
98 constexpr Chunk& set_session_id(uint32_t session_id) { in set_session_id()
103 constexpr Chunk& set_desired_session_id(uint32_t session_id) { in set_desired_session_id()
[all …]
|
| /external/scudo/standalone/ |
| D | wrappers_cpp.cpp | 39 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::New); in operator new()
44 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::NewArray); in operator new[]()
50 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::New); in operator new()
56 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::NewArray); in operator new[]()
61 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::New, in operator new()
67 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::NewArray, in operator new[]()
74 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::New, in operator new()
81 void *Ptr = Allocator.allocate(size, scudo::Chunk::Origin::NewArray, in operator new[]()
89 Allocator.deallocate(ptr, scudo::Chunk::Origin::New); in operator delete()
93 Allocator.deallocate(ptr, scudo::Chunk::Origin::NewArray); in operator delete[]()
[all …]
|
| D | combined.h | 72 Chunk::UnpackedHeader Header; in recycle()
73 Chunk::loadHeader(Allocator.Cookie, Ptr, &Header); in recycle()
74 if (UNLIKELY(Header.State != Chunk::State::Quarantined)) in recycle()
77 Header.State = Chunk::State::Available; in recycle()
78 Chunk::storeHeader(Allocator.Cookie, Ptr, &Header); in recycle()
91 sizeof(QuarantineBatch) + Chunk::getHeaderSize()); in allocate()
98 Chunk::getHeaderSize()); in allocate()
99 Chunk::UnpackedHeader Header = {}; in allocate()
100 Header.ClassId = QuarantineClassId & Chunk::ClassIdMask; in allocate()
102 Header.State = Chunk::State::Allocated; in allocate()
[all …]
|
| /external/scudo/standalone/tests/ |
| D | chunk_test.cpp | 15 static constexpr scudo::uptr HeaderSize = scudo::Chunk::getHeaderSize();
27 scudo::Chunk::UnpackedHeader Header = {}; in TEST()
31 scudo::Chunk::storeHeader(Cookie, P, &Header); in TEST()
33 scudo::Chunk::loadHeader(Cookie, P, &Header); in TEST()
34 EXPECT_TRUE(scudo::Chunk::isValid(Cookie, P, &Header)); in TEST()
35 EXPECT_FALSE(scudo::Chunk::isValid(InvalidCookie, P, &Header)); in TEST()
36 EXPECT_DEATH(scudo::Chunk::loadHeader(InvalidCookie, P, &Header), ""); in TEST()
43 scudo::Chunk::UnpackedHeader Header = {}; in TEST()
47 scudo::Chunk::storeHeader(Cookie, P, &Header); in TEST()
49 scudo::Chunk::loadHeader(Cookie, P, &Header); in TEST()
[all …]
|
| /external/pigweed/pw_transfer/java/main/dev/pigweed/pw_transfer/ |
| D | VersionedChunk.java | 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()
122 builder.setType(Chunk.Type.START); in fromMessage()
124 builder.setType(Chunk.Type.DATA); in fromMessage()
126 builder.setType(Chunk.Type.COMPLETION); in fromMessage()
128 builder.setType(Chunk.Type.PARAMETERS_RETRANSMIT); in fromMessage()
137 builder.setType(Chunk.Type.COMPLETION); in fromMessage()
177 builder().setVersion(desiredVersion).setType(Chunk.Type.START).setResourceId(resourceId); in createInitialChunk()
186 public Chunk toMessage() { in toMessage()
[all …]
|
| /external/clang/lib/Sema/ |
| D | CodeCompleteConsumer.cpp | 81 CodeCompletionString::Chunk::Chunk(ChunkKind Kind, const char *Text) in Chunk() function in CodeCompletionString::Chunk
155 CodeCompletionString::Chunk
156 CodeCompletionString::Chunk::CreateText(const char *Text) { in CreateText()
157 return Chunk(CK_Text, Text); in CreateText()
160 CodeCompletionString::Chunk
161 CodeCompletionString::Chunk::CreateOptional(CodeCompletionString *Optional) { in CreateOptional()
162 Chunk Result; in CreateOptional()
168 CodeCompletionString::Chunk
169 CodeCompletionString::Chunk::CreatePlaceholder(const char *Placeholder) { in CreatePlaceholder()
170 return Chunk(CK_Placeholder, Placeholder); in CreatePlaceholder()
[all …]
|
| /external/pigweed/pw_transfer/py/pw_transfer/ |
| D | chunk.py | 45 _ChunkType = transfer_pb2.Chunk.Type
48 class Chunk: class
75 Type = transfer_pb2.Chunk.Type
133 def from_message(cls, message: transfer_pb2.Chunk) -> Chunk: argument
149 chunk_type = Chunk.Type.START
151 chunk_type = Chunk.Type.DATA
153 chunk_type = Chunk.Type.PARAMETERS_RETRANSMIT
205 def to_message(self) -> transfer_pb2.Chunk:
207 message = transfer_pb2.Chunk(
272 self.type is Chunk.Type.PARAMETERS_RETRANSMIT
[all …]
|
| /external/perfetto/include/perfetto/ext/tracing/core/ |
| D | shared_memory_abi.h | 362 class Chunk {
364 Chunk(); // Constructs an invalid chunk.
368 Chunk(const Chunk&) = delete;
369 Chunk operator=(const Chunk&) = delete;
370 Chunk(Chunk&&) noexcept;
371 Chunk& operator=(Chunk&&);
444 Chunk(uint8_t* begin, uint16_t size, uint8_t chunk_idx);
535 Chunk TryAcquireChunkForWriting(size_t page_idx, in TryAcquireChunkForWriting()
543 Chunk TryAcquireChunkForReading(size_t page_idx, size_t chunk_idx) { in TryAcquireChunkForReading()
550 Chunk GetChunkUnchecked(size_t page_idx,
[all …]
|
| /external/googleapis/google/ai/generativelanguage/v1beta/ |
| D | retriever_service.proto | 135 // Creates a `Chunk`.
136 rpc CreateChunk(CreateChunkRequest) returns (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) {
170 // Batch update `Chunk`s.
179 // Deletes a `Chunk`.
187 // Batch delete `Chunk`s.
[all …]
|