| /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 | SelectArrayChannelTest.kt | 17 val channel = Channel<String>(1) in <lambda>() constant
36 val channel = Channel<String>(1) in <lambda>() constant
58 val channel = Channel<String>(1) in <lambda>() constant
77 val channel = Channel<String>(1) in <lambda>() constant
99 val channel = Channel<String>(1) in <lambda>() constant
114 val channel = Channel<String>(1) in <lambda>() constant
132 val channel = Channel<String>(1) in <lambda>() constant
162 val channel = Channel<String>(1) in <lambda>() constant
181 val channel = Channel<String>(1) in <lambda>() constant
195 val channel = Channel<String>(1) in <lambda>() constant
[all …]
|
| D | SelectRendezvousChannelTest.kt | 18 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
37 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
59 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
85 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
103 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
123 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
146 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
172 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
191 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
205 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
[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
132 val channel = broadcast { 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
56 val channel = Channel<Int>() in <lambda>() constant
94 val channel = Channel<Int>() in <lambda>() constant
106 val channel = Channel<Int>() in <lambda>() constant
117 val channel = Channel<Int>() in <lambda>() constant
130 val channel = Channel<Int>() in <lambda>() constant
|
| /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 <lambda>() constant
100 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
111 val channel = Channel(onUndeliveredElement = onCancelFail) in testReceiveOrClosedSelectCancelledFail() constant
126 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
137 val channel = Channel(1, onUndeliveredElement = onCancelFail) constant
|
| D | BasicOperationsTest.kt | 45 val channel = kind.create<Int>() in <lambda>() constant
62 val channel = kind.create<Int>() in <lambda>() constant
72 val channel = kind.create<Int>() in <lambda>() constant
84 val channel = kind.create<Int>() in <lambda>() constant
94 val channel = kind.create<Int>() in <lambda>() constant
111 val channel = kind.create<Int>() in <lambda>() constant
135 val channel = kind.create<Int>() in <lambda>() constant
162 val channel = kind.create<Int>() in <lambda>() constant
187 val channel = kind.create<Int>() in <lambda>() constant
198 val channel = kind.create<Int>() in <lambda>() constant
|
| D | ChannelReceiveOrClosedTest.kt | 13 val channel = Channel<Throwable>() in <lambda>() constant
31 val channel = Channel<Int?>() in <lambda>() constant
69 val channel = Channel<UInt>() in <lambda>() constant
91 val channel = Channel<Boolean>() in <lambda>() constant
106 val channel = Channel<ValueOrClosed<UInt>>() in <lambda>() constant
126 val channel = Channel<String>(1) 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/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/webrtc/audio/voip/ |
| D | voip_core.cc | 122 absl::optional<ChannelId> channel; in CreateChannel() local
152 void VoipCore::ReleaseChannel(ChannelId channel) { in ReleaseChannel()
169 rtc::scoped_refptr<AudioChannel> VoipCore::GetChannel(ChannelId channel) { in GetChannel()
197 rtc::scoped_refptr<AudioChannel>& channel = kv.second; in UpdateAudioTransportWithSenders() local
239 bool VoipCore::StartSend(ChannelId channel) { in StartSend()
250 bool VoipCore::StopSend(ChannelId channel) { in StopSend()
261 bool VoipCore::StartPlayout(ChannelId channel) { in StartPlayout()
282 bool VoipCore::StopPlayout(ChannelId channel) { in StopPlayout()
294 rtc::scoped_refptr<AudioChannel>& channel = kv.second; in StopPlayout() local
311 void VoipCore::ReceivedRTPPacket(ChannelId channel, in ReceivedRTPPacket()
[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/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/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/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | channel.h | 125 const grpc_channel* channel) { in grpc_channel_compression_options()
130 grpc_channel* channel) { in grpc_channel_get_channel_stack()
135 grpc_channel* channel) { in grpc_channel_get_channelz_node()
140 inline void grpc_channel_internal_ref(grpc_channel* channel, in grpc_channel_internal_ref()
144 inline void grpc_channel_internal_unref(grpc_channel* channel, in grpc_channel_internal_unref()
148 #define GRPC_CHANNEL_INTERNAL_REF(channel, reason) \ argument
150 #define GRPC_CHANNEL_INTERNAL_UNREF(channel, reason) \ argument
153 inline void grpc_channel_internal_ref(grpc_channel* channel) { in grpc_channel_internal_ref()
156 inline void grpc_channel_internal_unref(grpc_channel* channel) { in grpc_channel_internal_unref()
159 #define GRPC_CHANNEL_INTERNAL_REF(channel, reason) \ argument
[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 | 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 …]
|
| 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 …]
|
| /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/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/src/php/lib/Grpc/ |
| D | BaseStub.php | 30 private $channel; variable in Grpc\\BaseStub
44 public function __construct($hostname, $opts, $channel = null)
251 private function _GrpcUnaryUnary($channel)
288 private function _GrpcStreamUnary($channel)
324 private function _GrpcUnaryStream($channel)
361 private function _GrpcStreamStream($channel)
398 private function _UnaryUnaryCallFactory($channel)
427 private function _UnaryStreamCallFactory($channel)
456 private function _StreamUnaryCallFactory($channel)
483 private function _StreamStreamCallFactory($channel)
|
| /external/grpc-grpc/src/php/tests/unit_tests/ |
| D | CallInvokerTest.php | 56 public function __construct($hostname, $opts, $channel = null)
84 private $channel; variable in CallInvokerUpdateChannel
95 public function UnaryCall($channel, $method, $deserialize, $options) {
99 public function ClientStreamingCall($channel, $method, $deserialize, $options) {
103 public function ServerStreamingCall($channel, $method, $deserialize, $options) {
107 public function BidiStreamingCall($channel, $method, $deserialize, $options) {
115 private $channel; variable in CallInvokerChangeRequest
125 public function UnaryCall($channel, $method, $deserialize, $options) {
129 public function ClientStreamingCall($channel, $method, $deserialize, $options) {
133 public function ServerStreamingCall($channel, $method, $deserialize, $options) {
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/ |
| D | ares_process.c | 123 static void processfds(ares_channel channel, in processfds()
139 void ares_process(ares_channel channel, fd_set *read_fds, fd_set *write_fds) in ares_process()
147 void ares_process_fd(ares_channel channel, in ares_process_fd()
182 static ares_ssize_t socket_writev(ares_channel channel, ares_socket_t s, const struct iovec * vec, … in socket_writev()
190 static ares_ssize_t socket_write(ares_channel channel, ares_socket_t s, const void * data, size_t l… in socket_write()
205 static void write_tcp_data(ares_channel channel, in write_tcp_data()
297 static void advance_tcp_send_queue(ares_channel channel, int whichserver, in advance_tcp_send_queue()
326 static ares_ssize_t socket_recvfrom(ares_channel channel, in socket_recvfrom()
346 static ares_ssize_t socket_recv(ares_channel channel, in socket_recv()
362 static void read_tcp_data(ares_channel channel, fd_set *read_fds, in read_tcp_data()
[all …]
|