Home
last modified time | relevance | path

Searched refs:channel (Results 1 – 25 of 3008) sorted by relevance

12345678910>>...121

/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
83 assertEquals(0, channel.position()); in testPosition()
84 assertSame(channel, channel.position(100)); in testPosition()
85 assertEquals(100, channel.position()); in testPosition()
91 FileChannel channel = channel(file, READ); in testSize() local
93 assertEquals(10, channel.size()); in testSize()
96 assertEquals(100, channel.size()); in testSize()
102 FileChannel channel = channel(file, READ); in testRead() local
103 assertEquals(0, channel.position()); in testRead()
[all …]
/external/arm-trusted-firmware/lib/debugfs/
Ddev.c37 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/rust/crates/grpcio-sys/grpc/third_party/cares/cares/
Dares_init.c68 static int init_by_options(ares_channel channel,
71 static int init_by_environment(ares_channel channel);
72 static int init_by_resolv_conf(ares_channel channel);
73 static int init_by_defaults(ares_channel channel);
79 static int set_search(ares_channel channel, const char *str);
80 static int set_options(ares_channel channel, const char *str);
92 static int config_domain(ares_channel channel, char *str);
93 static int config_lookup(ares_channel channel, const char *str,
113 ares_channel channel; in ares_init_options() local
135 channel = ares_malloc(sizeof(struct ares_channeldata)); in ares_init_options()
[all …]
Dares_process.c65 static void write_tcp_data(ares_channel channel, fd_set *write_fds,
67 static void read_tcp_data(ares_channel channel, fd_set *read_fds,
69 static void read_udp_packets(ares_channel channel, fd_set *read_fds,
71 static void advance_tcp_send_queue(ares_channel channel, int whichserver,
73 static void process_timeouts(ares_channel channel, struct timeval *now);
74 static void process_broken_connections(ares_channel channel,
76 static void process_answer(ares_channel channel, unsigned char *abuf,
79 static void handle_error(ares_channel channel, int whichserver,
81 static void skip_server(ares_channel channel, struct query *query,
83 static void next_server(ares_channel channel, struct query *query,
[all …]
Dares_destroy.c43 void ares_destroy(ares_channel channel) in ares_destroy() argument
50 if (!channel) in ares_destroy()
53 list_head = &(channel->all_queries); in ares_destroy()
65 assert(ares__is_list_empty(&(channel->all_queries))); in ares_destroy()
68 assert(ares__is_list_empty(&(channel->queries_by_qid[i]))); in ares_destroy()
72 assert(ares__is_list_empty(&(channel->queries_by_timeout[i]))); in ares_destroy()
76 ares__destroy_servers_state(channel); in ares_destroy()
78 if (channel->domains) { in ares_destroy()
79 for (i = 0; i < channel->ndomains; i++) in ares_destroy()
80 ares_free(channel->domains[i]); in ares_destroy()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/
DChannelBuildersFlowTest.kt14 val channel = produce { in <lambda>() constant
19 val flow = channel.consumeAsFlow() in <lambda>()
26 val channel = produce { in <lambda>() constant
31 val flow = channel.receiveAsFlow() in <lambda>()
38 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
44 val flow = channel.consumeAsFlow() in <lambda>()
47 assertTrue(channel.isClosedForReceive) in <lambda>()
53 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
59 val flow = channel.receiveAsFlow() in <lambda>()
67 val channel = produce(NonCancellable) { // otherwise failure will cancel scope as well in <lambda>() constant
[all …]
/external/usrsctp/programs/
Drtcweb.c79 struct channel { struct
91 struct channel channels[NUMBER_OF_CHANNELS]; argument
92 struct channel *i_stream_channel[NUMBER_OF_STREAMS];
93 struct channel *o_stream_channel[NUMBER_OF_STREAMS];
166 struct channel *channel; in init_peer_connection() local
175 channel = &(pc->channels[i]); in init_peer_connection()
176 channel->id = i; in init_peer_connection()
177 channel->state = DATA_CHANNEL_CLOSED; in init_peer_connection()
178 channel->pr_policy = SCTP_PR_SCTP_NONE; in init_peer_connection()
179 channel->pr_value = 0; in init_peer_connection()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/
DSelectArrayChannelTest.kt17 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 …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DBasicOperationsTest.kt45 val channel = kind.create<Int>() 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<Int>() 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<Int>() in <lambda>() constant
73 channel.invokeOnClose { expect(3) } in <lambda>()
[all …]
DChannelReceiveOrClosedTest.kt13 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/webrtc/modules/audio_processing/aec3/
Dframe_blocker.cc25 for (auto& channel : band) { in FrameBlocker() local
26 channel.reserve(kBlockSize); in FrameBlocker()
27 RTC_DCHECK(channel.empty()); in FrameBlocker()
43 for (size_t channel = 0; channel < num_channels_; ++channel) { in InsertSubFrameAndExtractBlock() local
44 RTC_DCHECK_GE(kBlockSize - 16, buffer_[band][channel].size()); in InsertSubFrameAndExtractBlock()
45 RTC_DCHECK_EQ(kBlockSize, (*block)[band][channel].size()); in InsertSubFrameAndExtractBlock()
46 RTC_DCHECK_EQ(kSubFrameLength, sub_frame[band][channel].size()); in InsertSubFrameAndExtractBlock()
47 const int samples_to_block = kBlockSize - buffer_[band][channel].size(); in InsertSubFrameAndExtractBlock()
48 (*block)[band][channel].clear(); in InsertSubFrameAndExtractBlock()
49 (*block)[band][channel].insert((*block)[band][channel].begin(), in InsertSubFrameAndExtractBlock()
[all …]
Dblock_framer.cc42 for (size_t channel = 0; channel < num_channels_; ++channel) { in InsertBlock() local
43 RTC_DCHECK_EQ(kBlockSize, block[band][channel].size()); in InsertBlock()
44 RTC_DCHECK_EQ(0, buffer_[band][channel].size()); in InsertBlock()
46 buffer_[band][channel].insert(buffer_[band][channel].begin(), in InsertBlock()
47 block[band][channel].begin(), in InsertBlock()
48 block[band][channel].end()); in InsertBlock()
62 for (size_t channel = 0; channel < num_channels_; ++channel) { in InsertBlockAndExtractSubFrame() local
64 buffer_[band][channel].size() + kBlockSize); in InsertBlockAndExtractSubFrame()
65 RTC_DCHECK_EQ(kBlockSize, block[band][channel].size()); in InsertBlockAndExtractSubFrame()
66 RTC_DCHECK_GE(kBlockSize, buffer_[band][channel].size()); in InsertBlockAndExtractSubFrame()
[all …]
/external/e2fsprogs/lib/ext2fs/
Dio_manager.c23 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 …]
Dunix_io.c115 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 …]
/external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/
Dares-test-init.cc48 ares_channel channel = nullptr; in TEST() local
49 EXPECT_EQ(ARES_SUCCESS, ares_init(&channel)); in TEST()
50 EXPECT_NE(nullptr, channel); in TEST()
51 ares_destroy(channel); in TEST()
92 ares_channel channel = nullptr; in TEST_F() local
93 EXPECT_EQ(ARES_SUCCESS, ares_init_options(&channel, &opts, optmask)); in TEST_F()
94 EXPECT_NE(nullptr, channel); in TEST_F()
97 EXPECT_EQ(ARES_SUCCESS, ares_dup(&channel2, channel)); in TEST_F()
121 ares_destroy(channel); in TEST_F()
126 ares_channel channel; in TEST_F() local
[all …]
/external/webrtc/modules/audio_coding/neteq/
Daudio_multi_vector_unittest.cc81 for (size_t channel = 0; channel < num_channels_; ++channel) { in TEST_P() local
83 vec[channel][i] = static_cast<int16_t>(i); in TEST_P()
85 const AudioVector& audio_vec = vec[channel]; in TEST_P()
102 for (size_t channel = 0; channel < vec.Channels(); ++channel) { in TEST_P() local
104 EXPECT_EQ(static_cast<int16_t>((channel + 1) * 100 + i), vec[channel][i]); in TEST_P()
105 EXPECT_EQ(vec[channel][i], vec_copy[channel][i]); in TEST_P()
134 for (size_t channel = 0; channel < num_channels_; ++channel) { in TEST_P() local
136 vec1[channel][i] = static_cast<int16_t>(i + 100 * channel); in TEST_P()
137 vec2[channel][i] = in TEST_P()
138 static_cast<int16_t>(i + 100 * channel + array_length()); in TEST_P()
[all …]
Dsync_buffer_unittest.cc28 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
30 EXPECT_EQ(0, sync_buffer[channel][i]); in TEST()
59 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
61 new_data[channel][i] = rtc::checked_cast<int16_t>(i); in TEST()
72 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
74 EXPECT_EQ(new_data[channel][i], in TEST()
75 sync_buffer[channel][sync_buffer.next_index() + i]); in TEST()
84 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
86 EXPECT_EQ(0, sync_buffer[channel][i]); in TEST()
99 for (size_t channel = 0; channel < kChannels; ++channel) { in TEST() local
[all …]
Dbackground_noise.cc43 for (size_t channel = 0; channel < num_channels_; ++channel) { in Reset() local
44 channel_parameters_[channel].Reset(); in Reset()
132 size_t channel, in GenerateBackgroundNoise() argument
144 memcpy(noise_samples - kNoiseLpcOrder, FilterState(channel), in GenerateBackgroundNoise()
148 if (ScaleShift(channel) > 1) { in GenerateBackgroundNoise()
149 dc_offset = 1 << (ScaleShift(channel) - 1); in GenerateBackgroundNoise()
154 Scale(channel), dc_offset, in GenerateBackgroundNoise()
155 ScaleShift(channel), num_noise_samples); in GenerateBackgroundNoise()
158 Filter(channel), kNoiseLpcOrder + 1, in GenerateBackgroundNoise()
162 channel, in GenerateBackgroundNoise()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DStackTraceRecoveryChannelsTest.kt20 val channel = Channel<Int>() in <lambda>() constant
23 channel.close(RecoverableTestException()) in <lambda>()
27 channelReceive(channel) in <lambda>()
35 val channel = Channel<Int>() in <lambda>() constant
36 channel.close(RecoverableTestException()) in <lambda>()
37 channelReceive(channel) in <lambda>()
42 val channel = Channel<Int>() in <lambda>() constant
43 channel.close(RecoverableTestException()) in <lambda>()
44 channelReceiveOrNull(channel) in <lambda>()
49 val channel = Channel<Int>() in <lambda>() constant
[all …]
/external/grpc-grpc/src/core/lib/surface/
Dchannel.cc85 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/python/cpython3/Lib/test/
Dtest_smtpd.py45 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
48 channel.socket.queue_recv(line)
49 channel.handle_read()
76 def send_data(self, channel, data, enable_SMTPUTF8=False): argument
78 channel.socket.queue_recv(line)
79 channel.handle_read()
94 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
96 self.send_data(channel, b'From: test\n\nhello\n')
110 channel = smtpd.SMTPChannel(server, conn, addr)
112 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dchannel.h42 void grpc_channel_destroy_internal(grpc_channel* channel);
57 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
62 grpc_channel_stack* grpc_channel_get_channel_stack(grpc_channel* channel);
65 grpc_channel* channel);
67 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel);
68 void grpc_channel_update_call_size_estimate(grpc_channel* channel, size_t size);
125 const grpc_channel* channel) { in grpc_channel_compression_options() argument
126 return channel->compression_options; in grpc_channel_compression_options()
130 grpc_channel* channel) { in grpc_channel_get_channel_stack() argument
131 return CHANNEL_STACK_FROM_CHANNEL(channel); in grpc_channel_get_channel_stack()
[all …]
/external/ImageMagick/MagickCore/
Dstatistic.c137 channel[MaxPixelChannels]; member
198 pixels[i][j].channel[k]=0.0; in AcquirePixelThreadSet()
231 distance+=color_1->channel[i]-(double) color_2->channel[i]; in IntensityCompare()
624 evaluate_pixel[j].channel[i]=0.0; in EvaluateImages()
627 PixelChannel channel = GetPixelChannelChannel(image,i); in EvaluateImages() local
628 PixelTrait traits = GetPixelChannelTraits(next,channel); in EvaluateImages()
629 PixelTrait evaluate_traits = GetPixelChannelTraits(image,channel); in EvaluateImages()
634 evaluate_pixel[j].channel[i]=ApplyEvaluateOperator( in EvaluateImages()
635 random_info[id],GetPixelChannel(next,channel,p[j]),op, in EvaluateImages()
636 evaluate_pixel[j].channel[i]); in EvaluateImages()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DChannelTest.cs50 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/antlr/runtime/Ruby/lib/antlr3/template/
Dgroup-file-lexer.rb119 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 …]

12345678910>>...121