| /third_party/gstreamer/gstplugins_bad/ext/webrtc/ |
| D | webrtcdatachannel.c | 142 construct_open_packet (GstWebRTCDataChannel * channel) in construct_open_packet() argument
145 gsize label_len = strlen (channel->label); in construct_open_packet()
146 gsize proto_len = strlen (channel->protocol); in construct_open_packet()
157 * | Message Type | Channel Type | Priority | in construct_open_packet()
178 if (!channel->ordered) in construct_open_packet()
180 if (channel->max_retransmits != -1) { in construct_open_packet()
182 reliability_param = channel->max_retransmits; in construct_open_packet()
184 if (channel->max_packet_lifetime != -1) { in construct_open_packet()
186 reliability_param = channel->max_packet_lifetime; in construct_open_packet()
189 priority = priority_type_to_uint (channel->priority); in construct_open_packet()
[all …]
|
| /third_party/glib/glib/ |
| D | giowin32.c | 106 GIOChannel channel; member
130 gboolean needs_close; /* If the channel has been closed while
134 guint thread_id; /* If non-NULL the channel has or has
166 GIOChannel *channel; member
270 g_io_channel_win32_init (GIOWin32Channel *channel) in g_io_channel_win32_init() argument
272 channel->debug = g_io_win32_get_debug_flag (); in g_io_channel_win32_init()
274 InitializeCriticalSection (&channel->mutex); in g_io_channel_win32_init()
275 channel->running = FALSE; in g_io_channel_win32_init()
276 channel->needs_close = FALSE; in g_io_channel_win32_init()
277 channel->thread_id = 0; in g_io_channel_win32_init()
[all …]
|
| D | giochannel.c | 4 * giochannel.c: IO Channel abstraction
59 * pipes and sockets. Alternatively, a channel can be created for a
78 * g_io_add_watch_full() increments a channel's reference count.
85 * g_io_channel_write(), and g_io_channel_seek() on the same channel.
91 * A data structure representing an IO Channel. The fields should be
98 * @io_read: reads raw bytes from the channel. This is called from
100 * read raw bytes from the channel. Encoding and buffering
102 * @io_write: writes raw bytes to the channel. This is called from
104 * write raw bytes to the channel. Encoding and buffering
106 * @io_seek: (optional) seeks the channel. This is called from
[all …]
|
| D | giochannel.h | 110 GString *read_buf; /* Raw data from the channel */
111 GString *encoded_read_buf; /* Channel data converted to UTF-8 */
119 guint close_on_unref : 1; /* Close the channel on final unref */
133 GIOStatus (*io_read) (GIOChannel *channel,
138 GIOStatus (*io_write) (GIOChannel *channel,
143 GIOStatus (*io_seek) (GIOChannel *channel,
147 GIOStatus (*io_close) (GIOChannel *channel,
149 GSource* (*io_create_watch) (GIOChannel *channel,
151 void (*io_free) (GIOChannel *channel);
152 GIOStatus (*io_set_flags) (GIOChannel *channel,
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | ChannelTest.cs | 33 …Assert.Throws(typeof(ArgumentNullException), () => new Channel(null, ChannelCredentials.Insecure)); in Constructor_RejectsInvalidParams()
44 …Assert.Throws(typeof(ArgumentException), () => new Channel("127.0.0.1", ChannelCredentials.Insecur… in Constructor_RejectsDuplicateOptions()
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()
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | svolume_c.c | 32 unsigned channel; in pa_volume_u8_c() local
34 for (channel = 0; length; length--) { in pa_volume_u8_c()
35 int32_t t = pa_mult_s16_volume(*samples - 0x80, volumes[channel]); in pa_volume_u8_c()
40 if (PA_UNLIKELY(++channel >= channels)) in pa_volume_u8_c()
41 channel = 0; in pa_volume_u8_c()
46 unsigned channel; in pa_volume_alaw_c() local
48 for (channel = 0; length; length--) { in pa_volume_alaw_c()
49 int32_t t = pa_mult_s16_volume(st_alaw2linear16(*samples), volumes[channel]); in pa_volume_alaw_c()
54 if (PA_UNLIKELY(++channel >= channels)) in pa_volume_alaw_c()
55 channel = 0; in pa_volume_alaw_c()
[all …]
|
| /third_party/grpc/src/php/ext/grpc/ |
| D | channel.c | 20 * class Channel
21 * @see https://github.com/grpc/grpc/tree/master/src/php/ext/grpc/channel.c
24 #include "channel.h"
52 void free_grpc_channel_wrapper(grpc_channel_wrapper* channel, bool free_channel) { in free_grpc_channel_wrapper() argument
54 grpc_channel_destroy(channel->wrapped); in free_grpc_channel_wrapper()
55 channel->wrapped = NULL; in free_grpc_channel_wrapper()
57 free(channel->target); in free_grpc_channel_wrapper()
58 free(channel->args_hashstr); in free_grpc_channel_wrapper()
59 free(channel->creds_hashstr); in free_grpc_channel_wrapper()
60 free(channel->key); in free_grpc_channel_wrapper()
[all …]
|
| /third_party/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 | 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 …]
|
| /third_party/python/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 …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/fork/ |
| D | methods.py | 41 channel = grpc.secure_channel(target, channel_credentials)
43 channel = grpc.insecure_channel(target)
44 return channel
150 def _async_unary_same_channel(channel): argument
156 'Child should not be able to re-use channel after fork')
160 stub = test_pb2_grpc.TestServiceStub(channel)
168 def _async_unary_new_channel(channel, args): argument
176 stub = test_pb2_grpc.TestServiceStub(channel)
184 def _blocking_unary_same_channel(channel): argument
190 'Child should not be able to re-use channel after fork')
[all …]
|
| /third_party/grpc/src/core/lib/surface/ |
| D | channel.cc | 21 #include "src/core/lib/surface/channel.h"
33 #include "src/core/lib/channel/channel_args.h"
34 #include "src/core/lib/channel/channel_trace.h"
35 #include "src/core/lib/channel/channelz.h"
36 #include "src/core/lib/channel/channelz_registry.h"
67 grpc_channel* channel; in grpc_channel_create_with_builder() local
75 reinterpret_cast<void**>(&channel)); in grpc_channel_create_with_builder()
77 gpr_log(GPR_ERROR, "channel stack builder failed: %s", in grpc_channel_create_with_builder()
82 return channel; in grpc_channel_create_with_builder()
84 channel->target = target; in grpc_channel_create_with_builder()
[all …]
|
| D | channel.h | 26 #include "src/core/lib/channel/channel_stack.h"
27 #include "src/core/lib/channel/channel_stack_builder.h"
28 #include "src/core/lib/channel/channelz.h"
41 void grpc_channel_destroy_internal(grpc_channel* channel);
56 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
60 /** Get a (borrowed) pointer to this channels underlying channel stack */
61 grpc_channel_stack* grpc_channel_get_channel_stack(grpc_channel* channel);
64 grpc_channel* channel);
66 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel);
67 void grpc_channel_update_call_size_estimate(grpc_channel* channel, size_t size);
[all …]
|
| /third_party/boost/boost/log/sources/ |
| D | channel_logger.hpp | 12 * The header contains implementation of a logger with channel support.
26 #include <boost/log/keywords/channel.hpp>
43 //! Narrow-char logger with channel support
50 features< channel< ChannelT > >
58 explicit channel_logger(ChannelT const& channel) : base_type(keywords::channel = channel) in channel_logger() argument
65 //! Narrow-char thread-safe logger with channel support
72 features< channel< ChannelT > >
80 explicit channel_logger_mt(ChannelT const& channel) : base_type(keywords::channel = channel) in channel_logger_mt() argument
91 //! Wide-char logger with channel support
98 features< channel< ChannelT > >
[all …]
|
| /third_party/cares/test/ |
| D | ares-test-init.cc | 48 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 …]
|
| /third_party/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 …]
|
| /third_party/cares/ |
| D | ares_process.c | 65 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 …]
|
| D | ares_init.c | 68 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 …]
|
| /third_party/node/deps/cares/src/ |
| D | ares_process.c | 65 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 …]
|
| D | ares_init.c | 68 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 …]
|
| /third_party/grpc/src/php/tests/unit_tests/ |
| D | ChannelTest.php | 28 if (!empty($this->channel)) {
29 $this->channel->close();
35 $this->channel = new Grpc\Channel('localhost:50000',
37 $this->assertSame('Grpc\Channel', get_class($this->channel));
42 new Grpc\Channel('localhost:50033',
48 $this->channel = new Grpc\Channel('localhost:50001',
50 $state = $this->channel->getConnectivityState();
56 $this->channel = new Grpc\Channel('localhost:50002',
58 $state = $this->channel->getConnectivityState(123);
64 $this->channel = new Grpc\Channel('localhost:50003',
[all …]
|
| /third_party/grpc/src/php/lib/Grpc/ |
| D | BaseStub.php | 30 private $channel; variable in Grpc\\BaseStub
42 …* @param Channel|InterceptorChannel $channel An already created Channel or InterceptorChannel obje…
44 public function __construct($hostname, $opts, $channel = null) argument
69 // If the grpc_call_invoker is defined, use the channel created by the call invoker.
70 $this->channel = $this->call_invoker->createChannelFactory($hostname, $channel_opts);
74 if ($channel) {
75 if (!is_a($channel, 'Grpc\Channel') &&
76 !is_a($channel, 'Grpc\Internal\InterceptorChannel')) {
77 throw new \Exception('The channel argument is not a Channel object '.
79 'Interceptor::intercept($channel, Interceptor|Interceptor[] $interceptors)');
[all …]
|
| /third_party/ffmpeg/libavcodec/ |
| D | aptxdec.c | 80 static void aptx_decode_channel(Channel *channel, int32_t samples[4]) in aptx_decode_channel() argument
85 subband_samples[subband] = channel->prediction[subband].previous_reconstructed_sample; in aptx_decode_channel()
86 aptx_qmf_tree_synthesis(&channel->qmf, subband_samples, samples); in aptx_decode_channel()
89 static void aptx_unpack_codeword(Channel *channel, uint16_t codeword) in aptx_unpack_codeword() argument
91 channel->quantize[0].quantized_sample = sign_extend(codeword >> 0, 7); in aptx_unpack_codeword()
92 channel->quantize[1].quantized_sample = sign_extend(codeword >> 7, 4); in aptx_unpack_codeword()
93 channel->quantize[2].quantized_sample = sign_extend(codeword >> 11, 2); in aptx_unpack_codeword()
94 channel->quantize[3].quantized_sample = sign_extend(codeword >> 13, 3); in aptx_unpack_codeword()
95 channel->quantize[3].quantized_sample = (channel->quantize[3].quantized_sample & ~1) in aptx_unpack_codeword()
96 | aptx_quantized_parity(channel); in aptx_unpack_codeword()
[all …]
|
| /third_party/gstreamer/gstplugins_good/sys/v4l2/ |
| D | tuner.c | 50 * <listitem>Selection of a current #GstTunerChannel. The current channel
53 * <listitem>The #GstTunerNorm for the channel. The norm chooses the
54 * interpretation of the incoming signal for the current channel. For example,
57 * <listitem>Channel frequency. If the current channel has the ability to tune
109 * GstTuner::channel-changed: in gst_tuner_default_init()
111 * @channel: The new configured channel. in gst_tuner_default_init()
116 g_signal_new ("channel-changed", in gst_tuner_default_init()
139 * @channel: The current #GstTunerChannel in gst_tuner_default_init()
198 * @tuner: the #GstTuner (a #GstElement) that owns the channel.
199 * @channel: the channel to tune to.
[all …]
|
| /third_party/grpc/src/objective-c/tests/UnitTests/ |
| D | ChannelTests.m | 45 GRPCPooledChannel *channel = [[GRPCPooledChannel alloc] initWithChannelConfiguration:config];
47 GRPCWrappedCall *wrappedCall = [channel wrappedCallWithPath:kDummyPath
50 XCTAssertNotNil(channel.wrappedChannel);
59 GRPCPooledChannel *channel =
65 wrappedCall = [channel wrappedCallWithPath:kDummyPath completionQueue:cq callOptions:options];
66 XCTAssertNotNil(channel.wrappedChannel);
68 // Unref and ref channel immediately; expect using the same raw channel.
69 wrappedChannel = channel.wrappedChannel;
72 wrappedCall = [channel wrappedCallWithPath:kDummyPath completionQueue:cq callOptions:options];
73 XCTAssertEqual(channel.wrappedChannel, wrappedChannel);
[all …]
|