/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 …]
|