| /external/arm-trusted-firmware/lib/debugfs/ |
| D | dev.c | 37 chan_t *channel = NULL; in create_new_channel() local
42 channel = &fdset[i]; in create_new_channel()
43 channel->index = index; in create_new_channel()
48 return channel; in create_new_channel()
68 static int channel_to_fd(chan_t *channel) in channel_to_fd() argument
70 return (channel == NULL) ? -1 : (channel - fdset); in channel_to_fd()
142 static void channel_clear(chan_t *channel) in channel_clear() argument
144 channel->offset = 0; in channel_clear()
145 channel->qid = 0; in channel_clear()
146 channel->index = NODEV; in channel_clear()
[all …]
|
| /external/u-boot/drivers/dma/ |
| D | MCD_dmaApi.c | 46 static void MCD_resmActions(int channel);
308 int MCD_dmaStatus(int channel) in MCD_dmaStatus() argument
312 if ((channel < 0) || (channel >= NCHANNELS)) in MCD_dmaStatus()
315 tcrValue = MCD_dmaBar->taskControl[channel]; in MCD_dmaStatus()
318 if (MCD_chStatus[channel] == MCD_RUNNING in MCD_dmaStatus()
319 || MCD_chStatus[channel] == MCD_IDLE) in MCD_dmaStatus()
320 MCD_chStatus[channel] = MCD_DONE; in MCD_dmaStatus()
324 if (MCD_chStatus[channel] == MCD_RUNNING in MCD_dmaStatus()
325 || MCD_chStatus[channel] == MCD_IDLE) { in MCD_dmaStatus()
329 if ((MCD_dmaBar->ptdDebug >> channel) & 0x1) in MCD_dmaStatus()
[all …]
|
| D | apbh_dma.c | 30 int mxs_dma_validate_chan(int channel) in mxs_dma_validate_chan() argument
34 if ((channel < 0) || (channel >= MXS_MAX_DMA_CHANNELS)) in mxs_dma_validate_chan()
37 pchan = mxs_dma_channels + channel; in mxs_dma_validate_chan()
66 static int mxs_dma_read_semaphore(int channel) in mxs_dma_read_semaphore() argument
73 ret = mxs_dma_validate_chan(channel); in mxs_dma_read_semaphore()
77 tmp = readl(&apbh_regs->ch[channel].hw_apbh_ch_sema); in mxs_dma_read_semaphore()
109 static int mxs_dma_enable(int channel) in mxs_dma_enable() argument
118 ret = mxs_dma_validate_chan(channel); in mxs_dma_enable()
122 pchan = mxs_dma_channels + channel; in mxs_dma_enable()
137 sem = mxs_dma_read_semaphore(channel); in mxs_dma_enable()
[all …]
|
| /external/webrtc/talk/media/webrtc/ |
| D | fakewebrtcvoiceengine.h | 55 #define WEBRTC_CHECK_CHANNEL(channel) \ argument
56 if (channels_.find(channel) == channels_.end()) return -1;
226 uint32_t GetLocalSSRC(int channel) { in GetLocalSSRC() argument
227 return channels_[channel]->send_ssrc; in GetLocalSSRC()
229 bool GetPlayout(int channel) { in GetPlayout() argument
230 return channels_[channel]->playout; in GetPlayout()
232 bool GetSend(int channel) { in GetSend() argument
233 return channels_[channel]->send; in GetSend()
235 bool GetVAD(int channel) { in GetVAD() argument
236 return channels_[channel]->vad; in GetVAD()
[all …]
|
| /external/webrtc/webrtc/test/ |
| D | mock_voice_engine.h | 67 MOCK_METHOD3(SetRxNsStatus, int(int channel, bool enable, NsModes mode));
68 MOCK_METHOD3(GetRxNsStatus, int(int channel, bool& enabled, NsModes& mode));
69 MOCK_METHOD3(SetRxAgcStatus, int(int channel, bool enable, AgcModes mode));
70 MOCK_METHOD3(GetRxAgcStatus, int(int channel, bool& enabled, AgcModes& mode));
71 MOCK_METHOD2(SetRxAgcConfig, int(int channel, AgcConfig config));
72 MOCK_METHOD2(GetRxAgcConfig, int(int channel, AgcConfig& config));
74 int(int channel, VoERxVadCallback& observer));
75 MOCK_METHOD1(DeRegisterRxVadObserver, int(int channel));
76 MOCK_METHOD1(VoiceActivityIndicator, int(int channel));
109 MOCK_METHOD1(DeleteChannel, int(int channel));
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | BasicOperationsTest.kt | 45 val channel = kind.create() in <lambda>() constant
46 channel.invokeOnClose { in <lambda>()
52 channel.offer(42) in <lambda>()
54 channel.close(AssertionError()) in <lambda>()
62 val channel = kind.create() in <lambda>() constant
63 channel.close() in <lambda>()
64 channel.invokeOnClose { expect(2) } in <lambda>()
65 assertFailsWith<IllegalStateException> { channel.invokeOnClose { expect(3) } } in <lambda>()
72 val channel = kind.create() in <lambda>() constant
73 channel.invokeOnClose { expect(3) } in <lambda>()
[all …]
|
| D | ChannelReceiveOrClosedTest.kt | 13 val channel = Channel<Throwable>() in <lambda>() constant
15 channel.send(TestException1()) in <lambda>()
16 channel.close(TestException2()) in <lambda>()
19 val element = channel.receiveOrClosed() in <lambda>()
23 val closed = channel.receiveOrClosed() in <lambda>()
31 val channel = Channel<Int?>() in <lambda>() constant
34 channel.send(1) in <lambda>()
36 channel.send(null) in <lambda>()
39 channel.close() in <lambda>()
43 val element = channel.receiveOrClosed() in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 14 val channel = produce { in <lambda>() constant
19 val flow = channel.consumeAsFlow() in <lambda>()
26 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
32 val flow = channel.consumeAsFlow() in <lambda>()
35 assertTrue(channel.isClosedForReceive) in <lambda>()
41 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
47 val flow = channel.consumeAsFlow() in <lambda>()
54 val channel = produce { send("OK") } in <lambda>() constant
55 val flow = channel.consumeAsFlow() in <lambda>()
56 assertSame(channel, flow.produceIn(this)) in <lambda>()
[all …]
|
| /external/e2fsprogs/lib/ext2fs/ |
| D | io_manager.c | 23 errcode_t io_channel_set_options(io_channel channel, const char *opts) in io_channel_set_options() argument
28 EXT2_CHECK_MAGIC(channel, EXT2_ET_MAGIC_IO_CHANNEL); in io_channel_set_options()
33 if (!channel->manager->set_option) in io_channel_set_options()
51 retval = (channel->manager->set_option)(channel, ptr, arg); in io_channel_set_options()
60 errcode_t io_channel_write_byte(io_channel channel, unsigned long offset, in io_channel_write_byte() argument
63 EXT2_CHECK_MAGIC(channel, EXT2_ET_MAGIC_IO_CHANNEL); in io_channel_write_byte()
65 if (channel->manager->write_byte) in io_channel_write_byte()
66 return channel->manager->write_byte(channel, offset, in io_channel_write_byte()
72 errcode_t io_channel_read_blk64(io_channel channel, unsigned long long block, in io_channel_read_blk64() argument
75 EXT2_CHECK_MAGIC(channel, EXT2_ET_MAGIC_IO_CHANNEL); in io_channel_read_blk64()
[all …]
|
| D | unix_io.c | 115 static errcode_t unix_get_stats(io_channel channel, io_stats *stats) in unix_get_stats() argument
121 EXT2_CHECK_MAGIC(channel, EXT2_ET_MAGIC_IO_CHANNEL); in unix_get_stats()
122 data = (struct unix_private_data *) channel->private_data; in unix_get_stats()
157 static errcode_t raw_read_blk(io_channel channel, in raw_read_blk() argument
169 size = (count < 0) ? -count : count * channel->block_size; in raw_read_blk()
171 location = ((ext2_loff_t) block * channel->block_size) + data->offset; in raw_read_blk()
183 if ((channel->align == 0) || in raw_read_blk()
184 (IS_ALIGNED(buf, channel->align) && in raw_read_blk()
185 IS_ALIGNED(size, channel->align))) { in raw_read_blk()
194 ((channel->align == 0) || in raw_read_blk()
[all …]
|
| D | inode_io.c | 50 static errcode_t inode_open(const char *name, int flags, io_channel *channel);
51 static errcode_t inode_close(io_channel channel);
52 static errcode_t inode_set_blksize(io_channel channel, int blksize);
53 static errcode_t inode_read_blk(io_channel channel, unsigned long block,
55 static errcode_t inode_write_blk(io_channel channel, unsigned long block,
57 static errcode_t inode_flush(io_channel channel);
58 static errcode_t inode_write_byte(io_channel channel, unsigned long offset,
60 static errcode_t inode_read_blk64(io_channel channel,
62 static errcode_t inode_write_blk64(io_channel channel,
114 static errcode_t inode_open(const char *name, int flags, io_channel *channel) in inode_open() argument
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/ |
| D | SelectArrayChannelTest.kt | 17 val channel = Channel<String>(1) in <lambda>() constant
20 assertEquals("OK", channel.receive()) in <lambda>()
26 channel.onSend("OK") { in <lambda>()
36 val channel = Channel<String>(1) in <lambda>() constant
39 assertEquals("OK", channel.receive()) in <lambda>()
45 channel.onSend("OK") { in <lambda>()
58 val channel = Channel<String>(1) in <lambda>() constant
60 channel.onSend("OK") { in <lambda>()
66 channel.onReceive { v -> in <lambda>()
77 val channel = Channel<String>(1) in <lambda>() constant
[all …]
|
| D | SelectRendezvousChannelTest.kt | 18 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
21 assertEquals("OK", channel.receive()) in <lambda>()
27 channel.onSend("OK") { in <lambda>()
37 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
40 assertEquals("OK", channel.receive()) in <lambda>()
46 channel.onSend("OK") { in <lambda>()
59 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
61 channel.onSend("OK") { in <lambda>()
72 assertEquals("CHK", channel.receive()) in <lambda>()
78 channel.send("CHK") in <lambda>()
[all …]
|
| /external/webrtc/webrtc/modules/audio_coding/neteq/ |
| D | sync_buffer_unittest.cc | 27 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
29 EXPECT_EQ(0, sync_buffer[channel][i]); in TEST()
58 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
60 new_data[channel][i] = i; in TEST()
71 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
73 EXPECT_EQ(new_data[channel][i], in TEST()
74 sync_buffer[channel][sync_buffer.next_index() + i]); in TEST()
83 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
85 EXPECT_EQ(0, sync_buffer[channel][i]); in TEST()
98 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
[all …]
|
| D | audio_multi_vector_unittest.cc | 88 for (size_t channel = 0; channel < num_channels_; ++channel) { in TEST_P() local
90 vec[channel][i] = static_cast<int16_t>(i); in TEST_P()
92 const AudioVector& audio_vec = vec[channel]; in TEST_P()
109 for (size_t channel = 0; channel < vec.Channels(); ++channel) { in TEST_P() local
111 EXPECT_EQ(static_cast<int16_t>((channel + 1) * 100 + i), vec[channel][i]); in TEST_P()
112 EXPECT_EQ(vec[channel][i], vec_copy[channel][i]); in TEST_P()
141 for (size_t channel = 0; channel < num_channels_; ++channel) { in TEST_P() local
143 vec1[channel][i] = static_cast<int16_t>(i + 100 * channel); in TEST_P()
144 vec2[channel][i] = in TEST_P()
145 static_cast<int16_t>(i + 100 * channel + array_length()); in TEST_P()
[all …]
|
| /external/ImageMagick/MagickCore/ |
| D | statistic.c | 137 channel[CompositePixelChannel]; member
197 pixels[i][j].channel[k]=0.0; in AcquirePixelThreadSet()
230 distance+=color_1->channel[i]-(double) color_2->channel[i]; in IntensityCompare()
576 evaluate_pixel[j].channel[k]=0.0; in EvaluateImages()
595 PixelChannel channel = GetPixelChannelChannel(image,i); in EvaluateImages() local
596 PixelTrait traits = GetPixelChannelTraits(next,channel); in EvaluateImages()
597 PixelTrait evaluate_traits = GetPixelChannelTraits(image,channel); in EvaluateImages()
603 evaluate_pixel[j].channel[i]=ApplyEvaluateOperator( in EvaluateImages()
604 random_info[id],GetPixelChannel(next,channel,p),op, in EvaluateImages()
605 evaluate_pixel[j].channel[i]); in EvaluateImages()
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_smtpd.py | 44 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
47 channel.socket.queue_recv(line)
48 channel.handle_read()
75 def send_data(self, channel, data, enable_SMTPUTF8=False): argument
77 channel.socket.queue_recv(line)
78 channel.handle_read()
93 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
95 self.send_data(channel, b'From: test\n\nhello\n')
109 channel = smtpd.SMTPChannel(server, conn, addr)
111 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | channel.cc | 85 grpc_channel* channel; in grpc_channel_create_with_builder() local
93 reinterpret_cast<void**>(&channel)); in grpc_channel_create_with_builder()
100 return channel; in grpc_channel_create_with_builder()
103 channel->target = target; in grpc_channel_create_with_builder()
104 channel->is_client = grpc_channel_stack_type_is_client(channel_stack_type); in grpc_channel_create_with_builder()
112 gpr_mu_init(&channel->registered_call_mu); in grpc_channel_create_with_builder()
113 channel->registered_calls = nullptr; in grpc_channel_create_with_builder()
116 &channel->call_size_estimate, in grpc_channel_create_with_builder()
117 (gpr_atm)CHANNEL_STACK_FROM_CHANNEL(channel)->call_stack_size + in grpc_channel_create_with_builder()
120 grpc_compression_options_init(&channel->compression_options); in grpc_channel_create_with_builder()
[all …]
|
| /external/webrtc/webrtc/voice_engine/ |
| D | voe_rtp_rtcp_impl.cc | 48 int VoERTP_RTCPImpl::SetLocalSSRC(int channel, unsigned int ssrc) { in SetLocalSSRC() argument
50 "SetLocalSSRC(channel=%d, %lu)", channel, ssrc); in SetLocalSSRC()
55 voe::ChannelOwner ch = _shared->channel_manager().GetChannel(channel); in SetLocalSSRC()
56 voe::Channel* channelPtr = ch.channel(); in SetLocalSSRC()
65 int VoERTP_RTCPImpl::GetLocalSSRC(int channel, unsigned int& ssrc) { in GetLocalSSRC() argument
70 voe::ChannelOwner ch = _shared->channel_manager().GetChannel(channel); in GetLocalSSRC()
71 voe::Channel* channelPtr = ch.channel(); in GetLocalSSRC()
80 int VoERTP_RTCPImpl::GetRemoteSSRC(int channel, unsigned int& ssrc) { in GetRemoteSSRC() argument
85 voe::ChannelOwner ch = _shared->channel_manager().GetChannel(channel); in GetRemoteSSRC()
86 voe::Channel* channelPtr = ch.channel(); in GetRemoteSSRC()
[all …]
|
| /external/tensorflow/tensorflow/lite/kernels/internal/optimized/integer_ops/ |
| D | pooling.h | 102 int channel = 0; in MaxPool() local
104 for (; channel <= tranche_depth - 16; channel += 16) { in MaxPool()
105 int8x16_t acc_reg = vld1q_s8(acc + channel); in MaxPool()
109 vst1q_s8(acc + channel, acc_reg); in MaxPool()
112 for (; channel <= tranche_depth - 8; channel += 8) { in MaxPool()
113 int8x8_t acc_reg = vld1_s8(acc + channel); in MaxPool()
117 vst1_s8(acc + channel, acc_reg); in MaxPool()
120 for (; channel < tranche_depth; ++channel) { in MaxPool()
121 acc[channel] = std::max(acc[channel], *input_channel_ptr++); in MaxPool()
128 int channel = 0; in MaxPool() local
[all …]
|
| /external/antlr/runtime/Ruby/lib/antlr3/template/ |
| D | group-file-lexer.rb | 119 channel = ANTLR3::DEFAULT_CHANNEL
128 @state.channel = channel
143 channel = ANTLR3::DEFAULT_CHANNEL
152 @state.channel = channel
167 channel = ANTLR3::DEFAULT_CHANNEL
176 @state.channel = channel
191 channel = ANTLR3::DEFAULT_CHANNEL
200 @state.channel = channel
215 channel = ANTLR3::DEFAULT_CHANNEL
224 @state.channel = channel
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | ChannelTest.cs | 50 var channel = new Channel("localhost", ChannelCredentials.Insecure); in State_IdleAfterCreation()
51 Assert.AreEqual(ChannelState.Idle, channel.State); in State_IdleAfterCreation()
52 channel.ShutdownAsync().Wait(); in State_IdleAfterCreation()
58 var channel = new Channel("localhost", ChannelCredentials.Insecure); in WaitForStateChangedAsync_InvalidArgument()
59 …Assert.ThrowsAsync(typeof(ArgumentException), async () => await channel.WaitForStateChangedAsync(C… in WaitForStateChangedAsync_InvalidArgument()
60 channel.ShutdownAsync().Wait(); in WaitForStateChangedAsync_InvalidArgument()
66 var channel = new Channel("127.0.0.1", ChannelCredentials.Insecure); in ResolvedTarget()
67 Assert.IsTrue(channel.ResolvedTarget.Contains("127.0.0.1")); in ResolvedTarget()
68 channel.ShutdownAsync().Wait(); in ResolvedTarget()
74 var channel = new Channel("localhost", ChannelCredentials.Insecure); in Shutdown_AllowedOnlyOnce()
[all …]
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | channel.c | 46 void free_grpc_channel_wrapper(grpc_channel_wrapper* channel, bool free_channel) { in free_grpc_channel_wrapper() argument
48 grpc_channel_destroy(channel->wrapped); in free_grpc_channel_wrapper()
49 channel->wrapped = NULL; in free_grpc_channel_wrapper()
51 free(channel->target); in free_grpc_channel_wrapper()
52 free(channel->args_hashstr); in free_grpc_channel_wrapper()
53 free(channel->creds_hashstr); in free_grpc_channel_wrapper()
54 free(channel->key); in free_grpc_channel_wrapper()
55 channel->target = NULL; in free_grpc_channel_wrapper()
56 channel->args_hashstr = NULL; in free_grpc_channel_wrapper()
57 channel->creds_hashstr = NULL; in free_grpc_channel_wrapper()
[all …]
|
| /external/u-boot/arch/x86/cpu/quark/ |
| D | mrc_util.c | 126 void training_message(uint8_t channel, uint8_t rank, uint8_t byte_lane) in training_message() argument
129 DPF(D_INFO, "CH%01X RK%01X BL%01X\n", channel, rank, byte_lane); in training_message()
137 void set_rcvn(uint8_t channel, uint8_t rank, in set_rcvn() argument
147 channel, rank, byte_lane, pi_count); in set_rcvn()
155 channel * DDRIODQ_CH_OFFSET; in set_rcvn()
171 channel * DDRIODQ_CH_OFFSET); in set_rcvn()
182 channel * DDRIODQ_CH_OFFSET; in set_rcvn()
200 training_message(channel, rank, byte_lane); in set_rcvn()
213 uint32_t get_rcvn(uint8_t channel, uint8_t rank, uint8_t byte_lane) in get_rcvn() argument
227 channel * DDRIODQ_CH_OFFSET; in get_rcvn()
[all …]
|
| /external/curl/tests/data/ |
| D | test571 | 52 rtp: part 2 channel 1 size 10
53 rtp: part 2 channel 0 size 500
54 rtp: part 2 channel 0 size 196
55 rtp: part 2 channel 0 size 124
56 rtp: part 2 channel 0 size 824
57 rtp: part 3 channel 1 size 10
58 rtp: part 3 channel 0 size 50
59 rtp: part 4 channel 0 size 798
60 rtp: part 4 channel 0 size 42
61 rtp: part 4 channel 1 size 30
[all …]
|