Home
last modified time | relevance | path

Searched refs:mChannel (Results 1 – 7 of 7) sorted by relevance

/tools/apksig/src/main/java/com/android/apksig/internal/util/
DFileChannelDataSource.java34 private final FileChannel mChannel; field in FileChannelDataSource
44 mChannel = channel; in FileChannelDataSource()
63 mChannel = channel; in FileChannelDataSource()
72 return mChannel.size(); in size()
89 return new FileChannelDataSource(mChannel, mOffset + offset, size); in slice()
108 synchronized (mChannel) { in feed()
109 mChannel.position(chunkOffsetInFile); in feed()
111 int read = mChannel.read(buf); in feed()
146 synchronized (mChannel) { in copyTo()
147 mChannel.position(offsetInFile); in copyTo()
[all …]
/tools/tradefederation/core/src/com/android/tradefed/service/
DTradefedFeatureClient.java41 private ManagedChannel mChannel; field in TradefedFeatureClient
44 mChannel = in TradefedFeatureClient()
49 mBlockingStub = TradefedInformationGrpc.newBlockingStub(mChannel); in TradefedFeatureClient()
73 if (mChannel == null) { in triggerFeature()
118 if (mChannel != null) { in close()
119 mChannel.shutdown(); in close()
/tools/tradefederation/core/src/com/android/tradefed/invoker/shard/
DConfigurableGrpcDynamicShardingClient.java39 private ManagedChannel mChannel; field in ConfigurableGrpcDynamicShardingClient
47 mChannel = channel; in ConfigurableGrpcDynamicShardingClient()
85 mChannel = channel; in ConfigurableGrpcDynamicShardingClient()
/tools/tradefederation/core/javatests/com/android/tradefed/cache/remote/
DByteStreamDownloaderTest.java53 private ManagedChannel mChannel; field in ByteStreamDownloaderTest
64 mChannel = InProcessChannelBuilder.forName(mFakeServerName).directExecutor().build(); in setUp()
69 mChannel.shutdown().awaitTermination(5, TimeUnit.SECONDS); in tearDown()
136 return new ByteStreamDownloader(INSTANCE, mChannel, null, Duration.ofSeconds(5)); in newDownloader()
DRemoteCacheClientTest.java65 private ManagedChannel mChannel; field in RemoteCacheClientTest
108 mChannel = InProcessChannelBuilder.forName(mFakeServerName).directExecutor().build(); in setUp()
115 mChannel.shutdown().awaitTermination(5, TimeUnit.SECONDS); in tearDown()
204 return new RemoteCacheClient(mWorkFolder, INSTANCE, mChannel, null, downloader); in newClient()
/tools/tradefederation/core/common_util/com/android/tradefed/cache/remote/
DByteStreamDownloader.java46 private final Channel mChannel; field in ByteStreamDownloader
58 mChannel = channel; in ByteStreamDownloader()
145 return ByteStreamGrpc.newStub(mChannel)
DRemoteCacheClient.java53 private final ManagedChannel mChannel; field in RemoteCacheClient
65 mChannel = channel; in RemoteCacheClient()
176 ActionCacheGrpc.newFutureStub(mChannel) in acFutureStub()