| /tools/apksig/src/test/java/com/android/apksig/util/ |
| D | DataSinkTestBase.java | 49 T sink = c.getDataSink(); in testConsumeFromArray() local
51 sink.consume(input, 2, 3); // "cde" in testConsumeFromArray()
52 sink.consume(input, 0, 1); // "a" in testConsumeFromArray()
53 assertContentsEquals("cdea", sink); in testConsumeFromArray()
56 sink.consume(input, 0, 0); in testConsumeFromArray()
57 sink.consume(input, 1, 0); in testConsumeFromArray()
58 sink.consume(input, input.length - 2, 0); in testConsumeFromArray()
59 sink.consume(input, input.length - 1, 0); in testConsumeFromArray()
60 sink.consume(input, input.length, 0); in testConsumeFromArray()
63 assertConsumeArrayThrowsIOOB(sink, input, -1, 0); in testConsumeFromArray()
[all …]
|
| D | InMemoryDataSinkDataSourceTest.java | 30 ReadableDataSink sink = DataSinks.newInMemoryDataSink(); in createDataSource() local
31 sink.consume(contents, 0, contents.length); in createDataSource()
32 return CloseableWithDataSource.of(sink); in createDataSource()
|
| /tools/netsim/rust/daemon/src/grpc_server/ |
| D | frontend.rs | 27 fn get_version(&mut self, ctx: RpcContext<'_>, req: Empty, sink: UnarySink<VersionResponse>) { in get_version()
30 let f = sink in get_version()
41 sink: grpcio::UnarySink<netsim_proto::frontend::ListDeviceResponse>, in list_device()
44 Ok(response) => sink.success(response), in list_device()
47 sink.fail(RpcStatus::with_message(RpcStatusCode::INTERNAL, e)) in list_device()
63 fn reset(&mut self, ctx: grpcio::RpcContext, _req: Empty, sink: grpcio::UnarySink<Empty>) { in reset()
65 Ok(_) => sink.success(Empty::new()), in reset()
68 sink.fail(RpcStatus::with_message(RpcStatusCode::INTERNAL, e)) in reset()
|
| D | backend.rs | 80 sink: ::grpcio::DuplexSink<PacketResponse>, in stream_packets()
91 register_transport(result.chip_id, Box::new(RustGrpcTransport { sink })); in stream_packets()
|
| /tools/netsim/rust/proto/src/ |
| D | frontend_grpc.rs | 426 sink: ::grpcio::UnarySink<super::frontend::VersionResponse>, in get_version()
428 grpcio::unimplemented_call!(ctx, sink) in get_version()
434 sink: ::grpcio::UnarySink<super::frontend::CreateDeviceResponse>, in create_device()
436 grpcio::unimplemented_call!(ctx, sink) in create_device()
442 sink: ::grpcio::UnarySink<super::empty::Empty>, in delete_chip()
444 grpcio::unimplemented_call!(ctx, sink) in delete_chip()
450 sink: ::grpcio::UnarySink<super::empty::Empty>, in patch_device()
452 grpcio::unimplemented_call!(ctx, sink) in patch_device()
458 sink: ::grpcio::UnarySink<super::empty::Empty>, in reset()
460 grpcio::unimplemented_call!(ctx, sink) in reset()
[all …]
|
| D | packet_streamer_grpc.rs | 69 sink: ::grpcio::DuplexSink<super::packet_streamer::PacketResponse>, in stream_packets()
71 grpcio::unimplemented_call!(ctx, sink) in stream_packets()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/util/ |
| D | TeeDataSink.java | 36 for (DataSink sink : mSinks) { in consume()
37 sink.consume(buf, offset, length); in consume()
|
| D | ByteArrayDataSink.java | 124 public void feed(long offset, long size, DataSink sink) throws IOException { in feed() argument
128 sink.consume(mArray, (int) offset, (int) size); in feed()
186 public void feed(long offset, long size, DataSink sink) throws IOException { in feed() argument
190 sink.consume(mArray, (int) (mSliceOffset + offset), (int) size); in feed()
|
| D | ChainedDataSource.java | 43 public void feed(long offset, long size, DataSink sink) throws IOException { in feed() argument
58 src.feed(offset, size, sink); in feed()
63 src.feed(offset, remaining, sink); in feed()
|
| D | ByteBufferDataSource.java | 83 public void feed(long offset, long size, DataSink sink) throws IOException { in feed() argument
87 sink.consume(getByteBuffer(offset, (int) size)); in feed()
|
| D | FileChannelDataSource.java | 93 public void feed(long offset, long size, DataSink sink) throws IOException { in feed() argument
119 sink.consume(buf); in feed()
|
| /tools/netsim/rust/daemon/src/transport/ |
| D | grpc.rs | 54 pub sink: grpcio::DuplexSink<PacketResponse>, field
71 let _ = self.sink.send((response, WriteFlags::default())).await; in response()
|
| /tools/apksig/src/test/java/com/android/apksig/internal/util/ |
| D | ChainedDataSourceTest.java | 54 ReadableDataSink sink = DataSinks.newInMemoryDataSink(size); in feedAllPossibleRanges() local
55 mChain.feed(begin, size, sink); in feedAllPossibleRanges()
58 sink.getByteBuffer(0, size)); in feedAllPossibleRanges()
|
| /tools/netsim/rust/daemon/ |
| D | Cargo.toml | 36 futures-channel = { version = "0.3.30", features = ["sink"] }
38 futures-util = { version = "0.3.30", default-features = false, features = ["sink"] }
|
| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/utils/ |
| D | CloseableDelegateByteSource.java | 129 public long copyTo(@Nonnull ByteSink sink) throws IOException { in copyTo() argument
130 return get().copyTo(sink); in copyTo()
|
| /tools/apksig/src/main/java/com/android/apksig/internal/zip/ |
| D | LocalFileRecord.java | 379 DataSink sink) throws IOException, ZipFormatException { in outputUncompressedData() argument
383 try (InflateSinkAdapter inflateAdapter = new InflateSinkAdapter(sink)) { in outputUncompressedData()
399 lfhSection.feed(dataStartOffsetInArchive, mDataSize, sink); in outputUncompressedData()
421 DataSink sink) throws ZipFormatException, IOException { in outputUncompressedData() argument
434 lfhRecord.outputUncompressedData(source, sink); in outputUncompressedData()
|
| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/ |
| D | LazyDelegateByteSource.java | 123 public long copyTo(@Nonnull ByteSink sink) throws IOException { in copyTo() argument
124 return get().copyTo(sink); in copyTo()
|
| /tools/netsim/rust/frontend/src/ |
| D | netsim_test_server.rs | 25 sink: UnarySink<VersionResponse>, in get_version()
31 let f = sink in get_version()
|
| /tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/sign/ |
| D | ZFileDataSource.java | 101 public void feed(long offset, long size, @Nonnull DataSink sink) throws IOException { in feed() argument
118 sink.consume(buf, 0, readSize); in feed()
|
| /tools/apksig/src/main/java/com/android/apksig/util/ |
| D | DataSource.java | 69 void feed(long offset, long size, DataSink sink) throws IOException; in feed() argument
|
| /tools/netsim/rust/daemon/src/wireless/ |
| D | uwb.rs | 16 use futures::{channel::mpsc::UnboundedSender, sink::SinkExt, StreamExt};
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/ |
| D | bt_test_utils.py | 1077 def is_a2dp_connected(sink, source): argument
1089 devices = sink.droid.bluetoothA2dpSinkGetConnectedDevices()
1091 sink.log.info("A2dp Connected device {}".format(device["name"]))
|