Home
last modified time | relevance | path

Searched defs:channel (Results 1 – 25 of 2189) sorted by relevance

12345678910>>...88

/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/
DJimfsFileChannelTest.java73 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 …]
DJimfsAsynchronousFileChannelTest.java60 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/openthread/tests/toranj/cli/
Dtest-602-channel-manager-channel-select.py62 channel = 24 variable
105 channel = 11 variable
117 channel = 25 variable
124 channel = 12 variable
134 channel = 25 variable
143 channel = 11 variable
155 channel = 11 variable
163 channel = 12 variable
188 channel = 25 variable
196 channel = 11 variable
[all …]
Dtest-601-channel-manager-channel-change.py116 channel = 11 variable
128 channel = 13 variable
134 channel = 14 variable
142 channel = 15 variable
145 channel = 16 variable
157 channel = 18 variable
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/
DSelectBufferedChannelTest.kt16 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 …]
DSelectRendezvousChannelTest.kt17 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/
DStackTraceRecoveryChannelsTest.kt20 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/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/
DHttp2PingHandlerTest.java57 EmbeddedChannel channel = new EmbeddedChannel(slowChecker); in register_withoutProtocol_Fails() local
63 EmbeddedChannel channel = createChannelWithoutProtocol(fastChecker); in register_withIncompleteProtocol_doesNotPing() local
73 EmbeddedChannel channel = createHttp1Channel(fastChecker); in register_withHttp1Protocol_doesNotPing() local
83 EmbeddedChannel channel = createHttp2Channel(slowChecker); in register_WithHttp2Protocol_pingsImmediately() local
94 EmbeddedChannel channel = createHttp2Channel(fastChecker); in unregister_stopsRunning() local
114 EmbeddedChannel channel = createHttp2Channel(fastChecker, catcher); in ignoredPingsResultInOneChannelException() local
126 EmbeddedChannel channel = createHttp2Channel(fastChecker, catcher); in respondedToPingsResultInNoAction() local
142 EmbeddedChannel channel = createHttp2Channel(fastChecker, catcher); in nonAckPingsResultInOneChannelException() local
159 EmbeddedChannel channel = createHttp2Channel(fastChecker, catcher, new FailingWriter()); in failedWriteResultsInOneChannelException() local
168 EmbeddedChannel channel = createHttp2Channel(fastChecker, catcher); in ackPingsAreNotForwardedToOtherHandlers() local
[all …]
/external/webrtc/audio/voip/
Dvoip_core.cc134 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/
DChannelUndeliveredElementFailureTest.kt25 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 …]
DBasicOperationsTest.kt40 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
DChannelReceiveCatchingTest.kt13 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
DChannelUndeliveredElementTest.kt15 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/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/
Dares-test-init.cc48 ares_channel channel = nullptr; in TEST() local
94 ares_channel channel = nullptr; in TEST_F() local
129 ares_channel channel; in TEST_F() local
183 ares_channel channel = nullptr; in TEST_F() local
235 ares_channel channel = nullptr; in TEST_F() local
243 ares_channel channel = nullptr; in TEST_F() local
251 ares_channel channel; in TEST_F() local
303 ares_channel channel = nullptr; in TEST() local
343 ares_channel channel = nullptr; variable
371 ares_channel channel = nullptr; variable
[all …]
/external/trusty/arm-trusted-firmware/lib/debugfs/
Ddev.c37 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/arm-trusted-firmware/lib/debugfs/
Ddev.c37 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/
DChannelBuildersFlowTest.kt14 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/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxChannel.kt34 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/webrtc/modules/audio_coding/neteq/
Dsync_buffer_unittest.cc28 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/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/
DNettyClientLogger.java57 public void debug(Channel channel, Supplier<String> msgSupplier) { in debug()
68 public void debug(Channel channel, Supplier<String> msgSupplier, Throwable t) { in debug()
83 public void warn(Channel channel, Supplier<String> msgSupplier) { in warn()
94 public void error(Channel channel, Supplier<String> msgSupplier, Throwable t) { in error()
109 public void error(Channel channel, Supplier<String> msgSupplier) { in error()
120 public void warn(Channel channel, Supplier<String> msgSupplier, Throwable t) { in warn()
135 public void trace(Channel channel, Supplier<String> msgSupplier) { in trace()
144 private String prependChannelInfo(Supplier<String> msgSupplier, Channel channel) { in prependChannelInfo()
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/utils/
DNettyUtilsTest.java78 Channel channel = null; in newSslHandler_sslEngineShouldBeConfigured() local
236 Channel channel = Mockito.mock(Channel.class); in closedChannelMessage_with_nullChannelAttribute() local
245 Channel channel = null; in closedChannelMessage_with_nullChannel() local
254 Channel channel = mock(Channel.class); in closedChannelMessage_with_nullParentChannel() local
266 Channel channel = mock(Channel.class); in closedChannelMessage_with_nullParentChannelAttribute() local
280 Channel channel = mock(Channel.class); in decorateException_with_TimeoutException() local
292 Channel channel = mock(Channel.class); in decorateException_with_TimeoutException_noMsg() local
303 Channel channel = mock(Channel.class); in decorateException_with_IllegalStateException() local
315 Channel channel = mock(Channel.class); in decorateException_with_IllegalStateException_noMsg() local
326 Channel channel = mock(Channel.class); in decorateException_with_ReadTimeoutException() local
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
DIdleConnectionCountingChannelPool.java94 public Future<Void> release(Channel channel) { in release()
99 public Future<Void> release(Channel channel, Promise<Void> promise) { in release()
126 private void addUpdateIdleCountOnCloseListener(Channel channel) { in addUpdateIdleCountOnCloseListener()
133 private void channelAcquired(Channel channel) { in channelAcquired()
160 private Future<?> channelReleased(Channel channel) { in channelReleased()
188 private void channelClosed(Channel channel) { in channelClosed()
209 private ChannelIdleState getChannelIdleState(Channel channel) { in getChannelIdleState()
213 private void setChannelIdleState(Channel channel, ChannelIdleState newState) { in setChannelIdleState()
/external/webrtc/modules/audio_processing/aec3/
Dblock.h46 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()
/external/perfetto/src/base/threading/
Dchannel_unittest.cc64 Channel<int> channel(1); in TEST() local
82 Channel<int> channel(2); in TEST() local
108 Channel<int> channel(1); in TEST() local
123 Channel<std::unique_ptr<int>> channel(1); in TEST() local
142 Channel<int> channel(1); in TEST() local
152 Channel<int> channel(1); in TEST() local
162 Channel<int> channel(1); in TEST() local
174 Channel<int> channel(1); in TEST() local
/external/mesa3d/src/asahi/lib/
Dagx_border.c27 struct channel { struct
33 static struct channel argument
34 get_channel_info(enum pipe_format format, unsigned channel) in get_channel_info()
119 pack_channel(uint32_t value, enum pipe_format format, unsigned channel) in pack_channel()

12345678910>>...88