| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsFileChannelTest.java | 73 private static FileChannel channel(RegularFile file, OpenOption... options) throws IOException { in channel() method in JimfsFileChannelTest
82 FileChannel channel = channel(regularFile(10), READ); in testPosition() local
91 FileChannel channel = channel(file, READ); in testSize() local
102 FileChannel channel = channel(file, READ); in testRead() local
132 FileChannel channel = channel(file, WRITE); in testWrite() local
157 FileChannel channel = channel(file, WRITE, APPEND); in testAppend() local
191 FileChannel channel = channel(file, READ); in testTransferTo() local
201 FileChannel channel = channel(file, WRITE); in testTransferFrom() local
211 FileChannel channel = channel(file, WRITE); in testTruncate() local
230 FileChannel channel = in testFileTimeUpdates() local
[all …]
|
| D | JimfsAsynchronousFileChannelTest.java | 60 private static JimfsAsynchronousFileChannel channel( in channel() method in JimfsAsynchronousFileChannelTest
62 JimfsFileChannel channel = in channel() local
78 JimfsAsynchronousFileChannel channel = channel(file, executor, READ, WRITE); in testAsyncChannel() local
104 JimfsAsynchronousFileChannel channel = channel(file, executor, READ, WRITE); in testClosedChannel() local
122 JimfsAsynchronousFileChannel channel = channel(file, executor, READ, WRITE); in testAsyncClose_write() local
156 JimfsAsynchronousFileChannel channel = channel(file, executor, READ, WRITE); in testAsyncClose_read() local
184 private static void checkAsyncRead(AsynchronousFileChannel channel) throws Throwable { in checkAsyncRead()
207 private static void checkAsyncLock(AsynchronousFileChannel channel) throws Throwable { in checkAsyncLock()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/ |
| D | SelectBufferedChannelTest.kt | 16 val channel = Channel<String>(1) in <lambda>() constant
35 val channel = Channel<String>(1) in <lambda>() constant
57 val channel = Channel<String>(1) in <lambda>() constant
76 val channel = Channel<String>(1) in <lambda>() constant
98 val channel = Channel<String>(1) in <lambda>() constant
113 val channel = Channel<String>(1) in <lambda>() constant
131 val channel = Channel<String>(1) in <lambda>() constant
161 val channel = Channel<String>(1) in <lambda>() constant
180 val channel = Channel<String>(1) in <lambda>() constant
194 val channel = Channel<String>(1) in <lambda>() constant
[all …]
|
| D | SelectRendezvousChannelTest.kt | 17 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
36 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
58 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
84 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
102 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
122 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
145 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
171 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
190 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
204 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryChannelsTest.kt | 20 val channel = Channel<Int>() in <lambda>() constant
35 val channel = Channel<Int>() in <lambda>() constant
42 val channel = Channel<Int>() in <lambda>() constant
49 val channel = Channel<Int>() in <lambda>() constant
86 val channel = Channel<Int>() in <lambda>() constant
98 val channel = Channel<Int>() in <lambda>() constant
109 val channel = Channel<Int>() in <lambda>() constant
122 val channel = Channel<Int>() in <lambda>() constant
|
| /external/webrtc/audio/voip/ |
| D | voip_core.cc | 134 rtc::scoped_refptr<AudioChannel> channel = in CreateChannel() local
158 rtc::scoped_refptr<AudioChannel> channel; in ReleaseChannel() local
198 rtc::scoped_refptr<AudioChannel> channel; in GetChannel() local
225 rtc::scoped_refptr<AudioChannel>& channel = kv.second; in UpdateAudioTransportWithSenders() local
273 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in StartSend() local
288 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in StopSend() local
301 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in StartPlayout() local
335 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in StopPlayout() local
349 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in ReceivedRTPPacket() local
363 rtc::scoped_refptr<AudioChannel> channel = GetChannel(channel_id); in ReceivedRTCPPacket() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ChannelUndeliveredElementFailureTest.kt | 25 val channel = Channel(onUndeliveredElement = onCancelFail) in isElementCancelException() constant
35 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
48 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
59 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
74 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
85 val channel = Channel(onUndeliveredElement = onCancelFail) in testReceiveOrClosedSelectCancelledFail() constant
100 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
111 val channel = Channel(1, onUndeliveredElement = onCancelFail) constant
141 val channel = Channel<Int>(1, BufferOverflow.DROP_OLDEST, onUndeliveredElement = { in <lambda>() constant
153 val channel = Channel<Int>(2, BufferOverflow.DROP_LATEST, onUndeliveredElement = { in <lambda>() constant
[all …]
|
| D | BasicOperationsTest.kt | 40 val channel = kind.create<Int>() in <lambda>() constant
57 val channel = kind.create<Int>() in <lambda>() constant
67 val channel = kind.create<Int>() in <lambda>() constant
79 val channel = kind.create<Int>() in <lambda>() constant
104 val channel = Channel<Int>() in <lambda>() constant
130 val channel = kind.create<Int>() in <lambda>() constant
157 val channel = kind.create<Int>() in <lambda>() constant
176 val channel = kind.create<Int>() in <lambda>() constant
196 val channel = kind.create<Int>() in <lambda>() constant
207 val channel = kind.create<Int>() in <lambda>() constant
|
| D | ChannelReceiveCatchingTest.kt | 13 val channel = Channel<Throwable>() in <lambda>() constant
32 val channel = Channel<Int?>() in <lambda>() constant
76 val channel = Channel<UInt>() in <lambda>() constant
98 val channel = Channel<Boolean>() in <lambda>() constant
114 val channel = Channel<ChannelResult<UInt>>() in <lambda>() constant
137 val channel = Channel<String>(1) in <lambda>() constant
|
| D | ChannelUndeliveredElementTest.kt | 15 val channel = kind.create<Resource> { it.cancel() } in <lambda>() constant
30 val channel = Channel<Resource> { it.cancel() } in <lambda>() constant
43 val channel = Channel<Resource>(1) { it.cancel() } in <lambda>() constant
61 val channel = Channel<Resource>(Channel.UNLIMITED) { it.cancel() } in <lambda>() constant
75 val channel = Channel<Resource>(Channel.CONFLATED) { it.cancel() } in <lambda>() constant
93 val channel = kind.create<Resource> { it.cancel() } in <lambda>() constant
129 val channel = Channel<Unit> { in <lambda>() constant
150 val channel = Channel<Int>( in <lambda>() constant
193 val channel = Channel<Int>(capacity, BufferOverflow.DROP_LATEST, onUndeliveredElement = { in <lambda>() constant
|
| /external/arm-trusted-firmware/lib/debugfs/ |
| D | dev.c | 37 chan_t *channel = NULL; in create_new_channel() local
68 static int channel_to_fd(chan_t *channel) in channel_to_fd()
142 static void channel_clear(chan_t *channel) in channel_clear()
154 void channel_close(chan_t *channel) in channel_close()
167 int buf_to_channel(chan_t *channel, void *dst, void *src, int nbytes, long len) in buf_to_channel()
197 chan_t *channel; in mount_point_to_channel() local
235 chan_t *channel; in devattach() local
263 chan_t *mnt, *channel; in path_to_channel() local
348 chan_t *devclone(chan_t *channel, chan_t *new_channel) in devclone()
376 int devwalk(chan_t *channel, const char *name, const dirtab_t *tab, in devwalk()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 14 val channel = produce { in <lambda>() constant
26 val channel = produce { in <lambda>() constant
38 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
53 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
67 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
80 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
93 val channel = produce { send("OK") } in <lambda>() constant
102 val channel = produce { send("OK") } in <lambda>() constant
112 val channel = produce { in <lambda>() constant
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/ |
| D | ares-test-init.cc | 48 ares_channel channel = nullptr; in TEST() local
92 ares_channel channel = nullptr; in TEST_F() local
126 ares_channel channel; in TEST_F() local
178 ares_channel channel = nullptr; in TEST_F() local
230 ares_channel channel = nullptr; in TEST_F() local
238 ares_channel channel = nullptr; in TEST_F() local
246 ares_channel channel; in TEST_F() local
296 ares_channel channel = nullptr; in TEST() local
336 ares_channel channel = nullptr; variable
364 ares_channel channel = nullptr; variable
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxChannel.kt | 34 val channel = SubscriptionChannel<T>() in collect() constant
41 val channel = SubscriptionChannel<T>() in toChannel() constant
83 val channel = SubscriptionChannel<T>() constant
91 val channel = SubscriptionChannel<T>() constant
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | channel.h | 126 const grpc_channel* channel) { in grpc_channel_compression_options()
131 grpc_channel* channel) { in grpc_channel_get_channel_stack()
136 grpc_channel* channel) { in grpc_channel_get_channelz_node()
141 inline void grpc_channel_internal_ref(grpc_channel* channel, in grpc_channel_internal_ref()
145 inline void grpc_channel_internal_unref(grpc_channel* channel, in grpc_channel_internal_unref()
149 #define GRPC_CHANNEL_INTERNAL_REF(channel, reason) \ argument
151 #define GRPC_CHANNEL_INTERNAL_UNREF(channel, reason) \ argument
154 inline void grpc_channel_internal_ref(grpc_channel* channel) { in grpc_channel_internal_ref()
157 inline void grpc_channel_internal_unref(grpc_channel* channel) { in grpc_channel_internal_unref()
160 #define GRPC_CHANNEL_INTERNAL_REF(channel, reason) \ argument
[all …]
|
| /external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/ |
| D | LoadBalancerGrpc.java | 65 public static LoadBalancerStub newStub(io.grpc.Channel channel) { in newStub()
73 io.grpc.Channel channel) { in newBlockingStub()
81 io.grpc.Channel channel) { in newFutureStub()
115 private LoadBalancerStub(io.grpc.Channel channel) { in LoadBalancerStub()
119 private LoadBalancerStub(io.grpc.Channel channel, in LoadBalancerStub()
125 protected LoadBalancerStub build(io.grpc.Channel channel, in build()
145 private LoadBalancerBlockingStub(io.grpc.Channel channel) { in LoadBalancerBlockingStub()
149 private LoadBalancerBlockingStub(io.grpc.Channel channel, in LoadBalancerBlockingStub()
155 protected LoadBalancerBlockingStub build(io.grpc.Channel channel, in build()
164 private LoadBalancerFutureStub(io.grpc.Channel channel) { in LoadBalancerFutureStub()
[all …]
|
| /external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/ |
| D | HandshakerServiceGrpc.java | 65 public static HandshakerServiceStub newStub(io.grpc.Channel channel) { in newStub()
73 io.grpc.Channel channel) { in newBlockingStub()
81 io.grpc.Channel channel) { in newFutureStub()
120 private HandshakerServiceStub(io.grpc.Channel channel) { in HandshakerServiceStub()
124 private HandshakerServiceStub(io.grpc.Channel channel, in HandshakerServiceStub()
130 protected HandshakerServiceStub build(io.grpc.Channel channel, in build()
155 private HandshakerServiceBlockingStub(io.grpc.Channel channel) { in HandshakerServiceBlockingStub()
159 private HandshakerServiceBlockingStub(io.grpc.Channel channel, in HandshakerServiceBlockingStub()
165 protected HandshakerServiceBlockingStub build(io.grpc.Channel channel, in build()
174 private HandshakerServiceFutureStub(io.grpc.Channel channel) { in HandshakerServiceFutureStub()
[all …]
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/ |
| D | ServerReflectionGrpc.java | 65 public static ServerReflectionStub newStub(io.grpc.Channel channel) { in newStub()
73 io.grpc.Channel channel) { in newBlockingStub()
81 io.grpc.Channel channel) { in newFutureStub()
116 private ServerReflectionStub(io.grpc.Channel channel) { in ServerReflectionStub()
120 private ServerReflectionStub(io.grpc.Channel channel, in ServerReflectionStub()
126 protected ServerReflectionStub build(io.grpc.Channel channel, in build()
147 private ServerReflectionBlockingStub(io.grpc.Channel channel) { in ServerReflectionBlockingStub()
151 private ServerReflectionBlockingStub(io.grpc.Channel channel, in ServerReflectionBlockingStub()
157 protected ServerReflectionBlockingStub build(io.grpc.Channel channel, in build()
166 private ServerReflectionFutureStub(io.grpc.Channel channel) { in ServerReflectionFutureStub()
[all …]
|
| /external/webrtc/modules/audio_coding/neteq/ |
| D | sync_buffer_unittest.cc | 28 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
59 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
72 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
84 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
99 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
113 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
119 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
132 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
160 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
167 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
|
| /external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/ |
| D | DynamicServiceGrpc.java | 68 public static DynamicServiceStub newStub(io.grpc.Channel channel) { in newStub()
76 io.grpc.Channel channel) { in newBlockingStub()
84 io.grpc.Channel channel) { in newFutureStub()
124 private DynamicServiceStub(io.grpc.Channel channel) { in DynamicServiceStub()
128 private DynamicServiceStub(io.grpc.Channel channel, in DynamicServiceStub()
134 protected DynamicServiceStub build(io.grpc.Channel channel, in build()
157 private DynamicServiceBlockingStub(io.grpc.Channel channel) { in DynamicServiceBlockingStub()
161 private DynamicServiceBlockingStub(io.grpc.Channel channel, in DynamicServiceBlockingStub()
167 protected DynamicServiceBlockingStub build(io.grpc.Channel channel, in build()
189 private DynamicServiceFutureStub(io.grpc.Channel channel) { in DynamicServiceFutureStub()
[all …]
|
| D | AnotherDynamicServiceGrpc.java | 68 public static AnotherDynamicServiceStub newStub(io.grpc.Channel channel) { in newStub()
76 io.grpc.Channel channel) { in newBlockingStub()
84 io.grpc.Channel channel) { in newFutureStub()
124 private AnotherDynamicServiceStub(io.grpc.Channel channel) { in AnotherDynamicServiceStub()
128 private AnotherDynamicServiceStub(io.grpc.Channel channel, in AnotherDynamicServiceStub()
134 protected AnotherDynamicServiceStub build(io.grpc.Channel channel, in build()
157 private AnotherDynamicServiceBlockingStub(io.grpc.Channel channel) { in AnotherDynamicServiceBlockingStub()
161 private AnotherDynamicServiceBlockingStub(io.grpc.Channel channel, in AnotherDynamicServiceBlockingStub()
167 protected AnotherDynamicServiceBlockingStub build(io.grpc.Channel channel, in build()
189 private AnotherDynamicServiceFutureStub(io.grpc.Channel channel) { in AnotherDynamicServiceFutureStub()
[all …]
|
| D | ReflectableServiceGrpc.java | 65 public static ReflectableServiceStub newStub(io.grpc.Channel channel) { in newStub()
73 io.grpc.Channel channel) { in newBlockingStub()
81 io.grpc.Channel channel) { in newFutureStub()
112 private ReflectableServiceStub(io.grpc.Channel channel) { in ReflectableServiceStub()
116 private ReflectableServiceStub(io.grpc.Channel channel, in ReflectableServiceStub()
122 protected ReflectableServiceStub build(io.grpc.Channel channel, in build()
139 private ReflectableServiceBlockingStub(io.grpc.Channel channel) { in ReflectableServiceBlockingStub()
143 private ReflectableServiceBlockingStub(io.grpc.Channel channel, in ReflectableServiceBlockingStub()
149 protected ReflectableServiceBlockingStub build(io.grpc.Channel channel, in build()
165 private ReflectableServiceFutureStub(io.grpc.Channel channel) { in ReflectableServiceFutureStub()
[all …]
|
| /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
| D | UnimplementedServiceGrpc.java | 69 public static UnimplementedServiceStub newStub(io.grpc.Channel channel) { in newStub()
77 io.grpc.Channel channel) { in newBlockingStub()
85 io.grpc.Channel channel) { in newFutureStub()
127 private UnimplementedServiceStub(io.grpc.Channel channel) { in UnimplementedServiceStub()
131 private UnimplementedServiceStub(io.grpc.Channel channel, in UnimplementedServiceStub()
137 protected UnimplementedServiceStub build(io.grpc.Channel channel, in build()
161 private UnimplementedServiceBlockingStub(io.grpc.Channel channel) { in UnimplementedServiceBlockingStub()
165 private UnimplementedServiceBlockingStub(io.grpc.Channel channel, in UnimplementedServiceBlockingStub()
171 protected UnimplementedServiceBlockingStub build(io.grpc.Channel channel, in build()
194 private UnimplementedServiceFutureStub(io.grpc.Channel channel) { in UnimplementedServiceFutureStub()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
| D | ReportQpsScenarioServiceGrpc.java | 65 public static ReportQpsScenarioServiceStub newStub(io.grpc.Channel channel) { in newStub()
73 io.grpc.Channel channel) { in newBlockingStub()
81 io.grpc.Channel channel) { in newFutureStub()
115 private ReportQpsScenarioServiceStub(io.grpc.Channel channel) { in ReportQpsScenarioServiceStub()
119 private ReportQpsScenarioServiceStub(io.grpc.Channel channel, in ReportQpsScenarioServiceStub()
125 protected ReportQpsScenarioServiceStub build(io.grpc.Channel channel, in build()
145 private ReportQpsScenarioServiceBlockingStub(io.grpc.Channel channel) { in ReportQpsScenarioServiceBlockingStub()
149 private ReportQpsScenarioServiceBlockingStub(io.grpc.Channel channel, in ReportQpsScenarioServiceBlockingStub()
155 protected ReportQpsScenarioServiceBlockingStub build(io.grpc.Channel channel, in build()
174 private ReportQpsScenarioServiceFutureStub(io.grpc.Channel channel) { in ReportQpsScenarioServiceFutureStub()
[all …]
|
| /external/webrtc/modules/audio_processing/aec3/ |
| D | block.h | 46 auto begin(int band, int channel) { in begin()
50 auto begin(int band, int channel) const { in begin()
54 auto end(int band, int channel) { return begin(band, channel) + kBlockSize; } in end()
56 auto end(int band, int channel) const { in end()
61 rtc::ArrayView<float, kBlockSize> View(int band, int channel) { in View()
66 rtc::ArrayView<const float, kBlockSize> View(int band, int channel) const { in View()
81 int GetIndex(int band, int channel) const { in GetIndex()
|