| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | compression_filter.cc | 251 auto compression_algorithm = in MakeCallPromise() local
254 [compression_algorithm, in MakeCallPromise()
256 return CompressMessage(std::move(message), compression_algorithm); in MakeCallPromise()
305 auto* compression_algorithm = in MakeCallPromise() local
308 [this, compression_algorithm](ServerMetadataHandle md) { in MakeCallPromise()
314 *compression_algorithm = HandleOutgoingMetadata(*md); in MakeCallPromise()
318 [compression_algorithm, in MakeCallPromise()
320 return CompressMessage(std::move(message), *compression_algorithm); in MakeCallPromise()
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| H A D | grpc_channel.cc | 114 if (rpc_options->compression_algorithm() == "deflate") { in GetChannelArguments()
119 << rpc_options->compression_algorithm() in GetChannelArguments()
121 } else if (rpc_options->compression_algorithm() == "gzip") { in GetChannelArguments()
126 << rpc_options->compression_algorithm() in GetChannelArguments()
128 } else if (!rpc_options->compression_algorithm().empty()) { in GetChannelArguments()
130 << rpc_options->compression_algorithm(); in GetChannelArguments()
|
| /aosp_15_r20/system/core/fs_mgr/libsnapshot/libsnapshot_cow/ |
| H A D | parser_v2.cpp | 228 if (header_.compression_algorithm == kCowCompressNone) { in Translate()
229 header_.compression_algorithm = v2_op.compression; in Translate()
230 } else if (header_.compression_algorithm != v2_op.compression) { in Translate()
232 << " previously saw " << header_.compression_algorithm << ", got " in Translate()
|
| H A D | writer_v3.cpp | 114 header_.compression_algorithm = kCowCompressNone; in SetupHeaders()
136 header_.compression_algorithm = *algorithm; in ParseOptions()
|
| /aosp_15_r20/external/grpc-grpc/test/core/compression/ |
| H A D | message_compress_fuzzer.cc | 37 const auto compression_algorithm = in LLVMFuzzerTestOneInput() local
49 grpc_msg_compress(compression_algorithm, &input_buffer, &output_buffer); in LLVMFuzzerTestOneInput()
|
| H A D | message_decompress_fuzzer.cc | 37 const auto compression_algorithm = in LLVMFuzzerTestOneInput() local
49 grpc_msg_decompress(compression_algorithm, &input_buffer, &output_buffer); in LLVMFuzzerTestOneInput()
|
| /aosp_15_r20/external/grpc-grpc/src/ruby/ext/grpc/ |
| H A D | rb_compression_options.c | 109 grpc_compression_algorithm compression_algorithm = 0; in grpc_rb_compression_options_disable_compression_algorithm_internal() local
114 compression_algorithm = in grpc_rb_compression_options_disable_compression_algorithm_internal()
118 compression_algorithm); in grpc_rb_compression_options_disable_compression_algorithm_internal()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | server_context.h | 257 grpc_compression_algorithm compression_algorithm() const { in compression_algorithm() function
583 using ServerContextBase::compression_algorithm;
625 using ServerContextBase::compression_algorithm;
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | server_context.h | 257 grpc_compression_algorithm compression_algorithm() const { in compression_algorithm() function
583 using ServerContextBase::compression_algorithm;
625 using ServerContextBase::compression_algorithm;
|
| /aosp_15_r20/external/grpc-grpc/include/grpcpp/ |
| H A D | server_context.h | 257 grpc_compression_algorithm compression_algorithm() const { in compression_algorithm() function
588 using ServerContextBase::compression_algorithm;
630 using ServerContextBase::compression_algorithm;
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/ |
| H A D | _server.py | 131 compression_algorithm: Optional[grpc.Compression]
148 self.compression_algorithm = None
189 if state.compression_algorithm:
192 state.compression_algorithm
369 self._state.compression_algorithm = compression
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 241 grpc_compression_algorithm compression_algorithm) GPR_ATTRIBUTE_NOINLINE;
243 grpc_compression_algorithm compression_algorithm) GPR_ATTRIBUTE_NOINLINE;
464 const grpc_compression_algorithm compression_algorithm = in ProcessIncomingInitialMetadata() local
468 .IsSet(compression_algorithm))) { in ProcessIncomingInitialMetadata()
470 HandleCompressionAlgorithmDisabled(compression_algorithm); in ProcessIncomingInitialMetadata()
474 if (GPR_UNLIKELY(!encodings_accepted_by_peer_.IsSet(compression_algorithm))) { in ProcessIncomingInitialMetadata()
476 HandleCompressionAlgorithmNotAccepted(compression_algorithm); in ProcessIncomingInitialMetadata()
482 grpc_compression_algorithm compression_algorithm) { in HandleCompressionAlgorithmNotAccepted() argument
484 grpc_compression_algorithm_name(compression_algorithm, &algo_name); in HandleCompressionAlgorithmNotAccepted()
493 grpc_compression_algorithm compression_algorithm) { in HandleCompressionAlgorithmDisabled() argument
[all …]
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/surface/ |
| H A D | call.cc | 244 grpc_compression_algorithm compression_algorithm) GPR_ATTRIBUTE_NOINLINE;
246 grpc_compression_algorithm compression_algorithm) GPR_ATTRIBUTE_NOINLINE;
466 const grpc_compression_algorithm compression_algorithm = in ProcessIncomingInitialMetadata() local
470 .IsSet(compression_algorithm))) { in ProcessIncomingInitialMetadata()
472 HandleCompressionAlgorithmDisabled(compression_algorithm); in ProcessIncomingInitialMetadata()
476 if (GPR_UNLIKELY(!encodings_accepted_by_peer_.IsSet(compression_algorithm))) { in ProcessIncomingInitialMetadata()
478 HandleCompressionAlgorithmNotAccepted(compression_algorithm); in ProcessIncomingInitialMetadata()
484 grpc_compression_algorithm compression_algorithm) { in HandleCompressionAlgorithmNotAccepted() argument
486 grpc_compression_algorithm_name(compression_algorithm, &algo_name); in HandleCompressionAlgorithmNotAccepted()
495 grpc_compression_algorithm compression_algorithm) { in HandleCompressionAlgorithmDisabled() argument
[all …]
|
| /aosp_15_r20/system/core/fs_mgr/libsnapshot/ |
| H A D | snapshot.cpp | 428 status->set_compression_algorithm(cow_creator->compression_algorithm); in CreateSnapshot()
3457 std::string compression_algorithm; in CreateUpdateSnapshots() local
3460 compression_algorithm = dap_metadata.vabc_compression_param(); in CreateUpdateSnapshots()
3462 if (compression_algorithm.empty()) { in CreateUpdateSnapshots()
3464 compression_algorithm = "gz"; in CreateUpdateSnapshots()
3466 LOG(INFO) << "using compression algorithm: " << compression_algorithm in CreateUpdateSnapshots()
3480 .compression_algorithm = compression_algorithm, in CreateUpdateSnapshots()
3797 options.compression = it->second.compression_algorithm(); in InitializeUpdateSnapshots()
3909 cow_options.compression = status.compression_algorithm(); in OpenCompressedSnapshotWriter()
4044 ss << " compression: " << status.compression_algorithm() << std::endl; in Dump()
|
| H A D | partition_cow_creator.h | 61 std::string compression_algorithm; member
|
| H A D | snapshot_test.cpp | 545 cow_creator.compression_algorithm = FLAGS_compression_method; in TEST_F()
547 cow_creator.compression_algorithm = "none"; in TEST_F()
572 ASSERT_EQ(status.compression_algorithm(), cow_creator.compression_algorithm); in TEST_F()
754 ASSERT_EQ(status.compression_algorithm(), FLAGS_compression_method); in TEST_F()
756 ASSERT_EQ(status.compression_algorithm(), ""); in TEST_F()
2344 .compression_algorithm = snapuserd_required_ ? FLAGS_compression_method : "", in TEST_F()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot_init/android_recovery_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot/android_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot_init/android_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot_nobinder/android_recovery_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot_static/android_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/out/soong/.intermediates/system/core/fs_mgr/libsnapshot/libsnapshot_init/android_ramdisk_arm64_armv8-2a_cortex-a55_static/gen/proto/android/snapshot/ |
| D | snapshot.pb.h | 324 const std::string& compression_algorithm() const; in Swap()
329 void set_allocated_compression_algorithm(std::string* compression_algorithm); in Swap()
1325 inline const std::string& SnapshotStatus::compression_algorithm() const { in compression_algorithm() function
1356 inline void SnapshotStatus::set_allocated_compression_algorithm(std::string* compression_algorithm)… in set_allocated_compression_algorithm() argument
1357 _impl_.compression_algorithm_.SetAllocated(compression_algorithm, GetArenaForAllocation()); in set_allocated_compression_algorithm()
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| H A D | server.pyx.pxi | 61 self.compression_algorithm = None
101 _augment_metadata(_IMMUTABLE_EMPTY_METADATA, self.compression_algorithm),
158 _augment_metadata(tuple(metadata), self._rpc_state.compression_algorithm),
233 self._rpc_state.compression_algorithm = compression
|
| H A D | server.pxd.pxi | 35 cdef object compression_algorithm
|
| /aosp_15_r20/system/core/fs_mgr/libsnapshot/include/libsnapshot/ |
| H A D | cow_format.h | 115 uint32_t compression_algorithm; member
|