| /third_party/node/deps/cares/src/lib/ |
| D | ares_init.c | 129 static ares_status_t init_by_defaults(ares_channel_t *channel) in init_by_defaults() argument
140 if (!(channel->optmask & ARES_OPT_FLAGS)) { in init_by_defaults()
141 channel->flags = ARES_FLAG_EDNS; in init_by_defaults()
143 if (channel->ednspsz == 0) { in init_by_defaults()
144 channel->ednspsz = EDNSPACKETSZ; in init_by_defaults()
147 if (channel->timeout == 0) { in init_by_defaults()
148 channel->timeout = DEFAULT_TIMEOUT; in init_by_defaults()
151 if (channel->tries == 0) { in init_by_defaults()
152 channel->tries = DEFAULT_TRIES; in init_by_defaults()
155 if (channel->ndots == 0) { in init_by_defaults()
[all …]
|
| D | ares_options.c | 56 static struct in_addr *ares_save_opt_servers(ares_channel_t *channel, in ares_save_opt_servers() argument
61 ares_malloc_zero(ares__slist_len(channel->servers) * sizeof(*out)); in ares_save_opt_servers()
69 for (snode = ares__slist_node_first(channel->servers); snode != NULL; in ares_save_opt_servers()
85 int ares_save_options(ares_channel_t *channel, struct ares_options *options, in ares_save_options() argument
107 if (!ARES_CONFIG_CHECK(channel)) { in ares_save_options()
111 if (channel->optmask & ARES_OPT_FLAGS) { in ares_save_options()
112 options->flags = (int)channel->flags; in ares_save_options()
117 if (channel->optmask & ARES_OPT_TIMEOUTMS) { in ares_save_options()
118 options->timeout = (int)channel->timeout; in ares_save_options()
121 if (channel->optmask & ARES_OPT_TRIES) { in ares_save_options()
[all …]
|
| D | ares__socket.c | 62 ares_ssize_t ares__socket_recvfrom(ares_channel_t *channel, ares_socket_t s, in ares__socket_recvfrom() argument
67 if (channel->sock_funcs && channel->sock_funcs->arecvfrom) { in ares__socket_recvfrom()
68 return channel->sock_funcs->arecvfrom(s, data, data_len, flags, from, in ares__socket_recvfrom()
69 from_len, channel->sock_func_cb_data); in ares__socket_recvfrom()
80 ares_ssize_t ares__socket_recv(ares_channel_t *channel, ares_socket_t s, in ares__socket_recv() argument
83 if (channel->sock_funcs && channel->sock_funcs->arecvfrom) { in ares__socket_recv()
84 return channel->sock_funcs->arecvfrom(s, data, data_len, 0, 0, 0, in ares__socket_recv()
85 channel->sock_func_cb_data); in ares__socket_recv()
173 ares_channel_t *channel = server->channel; in configure_socket() local
176 if (channel->sock_funcs && channel->sock_funcs->asocket) { in configure_socket()
[all …]
|
| D | ares_destroy.c | 35 void ares_destroy(ares_channel_t *channel) in ares_destroy() argument
40 if (channel == NULL) { in ares_destroy()
45 ares__channel_lock(channel); in ares_destroy()
48 node = ares__llist_node_first(channel->all_queries); in ares_destroy()
60 ares_queue_notify_empty(channel); in ares_destroy()
66 assert(ares__llist_len(channel->all_queries) == 0); in ares_destroy()
67 assert(ares__htable_szvp_num_keys(channel->queries_by_qid) == 0); in ares_destroy()
68 assert(ares__slist_len(channel->queries_by_timeout) == 0); in ares_destroy()
71 ares__destroy_servers_state(channel); in ares_destroy()
74 assert(ares__htable_asvp_num_keys(channel->connnode_by_socket) == 0); in ares_destroy()
[all …]
|
| D | ares_process.c | 54 static void write_tcp_data(ares_channel_t *channel, fd_set *write_fds,
56 static void read_packets(ares_channel_t *channel, fd_set *read_fds,
58 static void process_timeouts(ares_channel_t *channel, struct timeval *now);
59 static ares_status_t process_answer(ares_channel_t *channel,
70 static void end_query(ares_channel_t *channel, struct query *query,
77 const ares_channel_t *channel = server->channel; in server_increment_failures() local
79 node = ares__slist_node_find(channel->servers, server); in server_increment_failures()
90 const ares_channel_t *channel = server->channel; in server_set_good() local
96 node = ares__slist_node_find(channel->servers, server); in server_set_good()
139 static void processfds(ares_channel_t *channel, fd_set *read_fds, in processfds() argument
[all …]
|
| D | ares_send.c | 40 static unsigned short generate_unique_qid(ares_channel_t *channel) in generate_unique_qid() argument
45 id = ares__generate_new_id(channel->rand_state); in generate_unique_qid()
46 } while (ares__htable_szvp_get(channel->queries_by_qid, id, NULL)); in generate_unique_qid()
51 ares_status_t ares_send_ex(ares_channel_t *channel, const unsigned char *qbuf, in ares_send_ex() argument
59 unsigned short id = generate_unique_qid(channel); in ares_send_ex()
68 if (ares__slist_len(channel->servers) == 0) { in ares_send_ex()
74 status = ares_qcache_fetch(channel, &now, qbuf, qlen, &abuf, &alen); in ares_send_ex()
91 query->channel = channel; in ares_send_ex()
116 packetsz = (channel->flags & ARES_FLAG_EDNS) ? channel->ednspsz : PACKETSZ; in ares_send_ex()
117 query->using_tcp = (channel->flags & ARES_FLAG_USEVC) || qlen > packetsz; in ares_send_ex()
[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 …]
|
| D | mix.c | 39 unsigned channel, nchannels, padding; in calc_linear_integer_volume() local
46 for (channel = 0; channel < nchannels; channel++) in calc_linear_integer_volume()
47 … linear[channel] = (int32_t) lrint(pa_sw_volume_to_linear(volume->values[channel]) * 0x10000); in calc_linear_integer_volume()
49 for (padding = 0; padding < VOLUME_PADDING; padding++, channel++) in calc_linear_integer_volume()
50 linear[channel] = linear[padding]; in calc_linear_integer_volume()
54 unsigned channel, nchannels, padding; in calc_linear_float_volume() local
61 for (channel = 0; channel < nchannels; channel++) in calc_linear_float_volume()
62 linear[channel] = (float) pa_sw_volume_to_linear(volume->values[channel]); in calc_linear_float_volume()
64 for (padding = 0; padding < VOLUME_PADDING; padding++, channel++) in calc_linear_float_volume()
65 linear[channel] = linear[padding]; in calc_linear_float_volume()
[all …]
|
| /third_party/python/Lib/test/ |
| D | test_smtpd.py | 50 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
53 channel.socket.queue_recv(line)
54 channel.handle_read()
81 def send_data(self, channel, data, enable_SMTPUTF8=False): argument
83 channel.socket.queue_recv(line)
84 channel.handle_read()
99 channel = smtpd.SMTPChannel(server, conn, addr, decode_data=True)
101 self.send_data(channel, b'From: test\n\nhello\n')
115 channel = smtpd.SMTPChannel(server, conn, addr)
117 self.send_data(channel, b'From: test\n\nh\xc3\xa9llo\xff\n')
[all …]
|
| /third_party/curl/tests/data/ |
| D | test571 | 53 rtp: part 2 channel 1 size 10
54 rtp: part 2 channel 0 size 500
55 rtp: part 2 channel 0 size 196
56 rtp: part 2 channel 0 size 124
57 rtp: part 2 channel 0 size 824
58 rtp: part 2 channel 0 size 18 size_err -6
59 rtp: part 3 channel 1 size 10
60 rtp: part 3 channel 0 size 50
61 rtp: part 4 channel 0 size 798
62 rtp: part 4 channel 0 size 42
[all …]
|
| /third_party/node/lib/internal/child_process/ |
| D | serialization.js | 55 initMessageChannel(channel) { argument
56 channel[kMessageBuffer] = [];
57 channel[kMessageBufferSize] = 0;
58 channel.buffering = false;
61 *parseChannelMessages(channel, readData) { argument
64 ArrayPrototypePush(channel[kMessageBuffer], readData);
65 channel[kMessageBufferSize] += readData.length;
68 let messageBufferHead = channel[kMessageBuffer][0];
79 if (channel[kMessageBufferSize] < fullMessageSize) break;
81 const concatenatedBuffer = channel[kMessageBuffer].length === 1 ?
[all …]
|
| /third_party/node/test/fixtures/wpt/streams/transferable/ |
| D | transfer-with-messageport.window.js | 40 const channel = new MessageChannel();
42 { stream, port2: channel.port2 },
43 [stream, channel.port2],
49 const channel = new MessageChannel();
51 { stream, port2: channel.port2 },
52 [channel.port2, stream],
58 const channel = new MessageChannel();
60 { port1: channel.port1, stream, port2: channel.port2 },
61 [channel.port1, stream, channel.port2],
67 const channel = new MessageChannel();
[all …]
|
| /third_party/libdrm/tegra/ |
| D | channel.c | 42 struct drm_tegra_channel *channel; in drm_tegra_channel_open() local
67 channel = calloc(1, sizeof(*channel)); in drm_tegra_channel_open()
68 if (!channel) in drm_tegra_channel_open()
71 channel->drm = drm; in drm_tegra_channel_open()
78 free(channel); in drm_tegra_channel_open()
82 channel->context = args.context; in drm_tegra_channel_open()
83 channel->version = args.version; in drm_tegra_channel_open()
84 channel->capabilities = args.capabilities; in drm_tegra_channel_open()
85 channel->class = class; in drm_tegra_channel_open()
87 switch (channel->version) { in drm_tegra_channel_open()
[all …]
|
| /third_party/ffmpeg/libavcodec/ |
| D | aptxdec.c | 85 static void aptx_decode_channel(Channel *channel, int32_t samples[4]) in aptx_decode_channel() argument
90 subband_samples[subband] = channel->prediction[subband].previous_reconstructed_sample; in aptx_decode_channel()
91 aptx_qmf_tree_synthesis(&channel->qmf, subband_samples, samples); in aptx_decode_channel()
94 static void aptx_unpack_codeword(Channel *channel, uint16_t codeword) in aptx_unpack_codeword() argument
96 channel->quantize[0].quantized_sample = sign_extend(codeword >> 0, 7); in aptx_unpack_codeword()
97 channel->quantize[1].quantized_sample = sign_extend(codeword >> 7, 4); in aptx_unpack_codeword()
98 channel->quantize[2].quantized_sample = sign_extend(codeword >> 11, 2); in aptx_unpack_codeword()
99 channel->quantize[3].quantized_sample = sign_extend(codeword >> 13, 3); in aptx_unpack_codeword()
100 channel->quantize[3].quantized_sample = (channel->quantize[3].quantized_sample & ~1) in aptx_unpack_codeword()
101 | aptx_quantized_parity(channel); in aptx_unpack_codeword()
[all …]
|
| D | aptxenc.c | 140 static void aptx_encode_channel(Channel *channel, int32_t samples[4], int hd) in aptx_encode_channel() argument
144 aptx_qmf_tree_analysis(&channel->qmf, samples, subband_samples); in aptx_encode_channel()
145 ff_aptx_generate_dither(channel); in aptx_encode_channel()
147 …int32_t diff = av_clip_intp2(subband_samples[subband] - channel->prediction[subband].predicted_sam… in aptx_encode_channel()
148 aptx_quantize_difference(&channel->quantize[subband], diff, in aptx_encode_channel()
149 channel->dither[subband], in aptx_encode_channel()
150 channel->invert_quantize[subband].quantization_factor, in aptx_encode_channel()
173 static uint16_t aptx_pack_codeword(Channel *channel) in aptx_pack_codeword() argument
175 int32_t parity = aptx_quantized_parity(channel); in aptx_pack_codeword()
176 return (((channel->quantize[3].quantized_sample & 0x06) | parity) << 13) in aptx_pack_codeword()
[all …]
|
| D | adpcm.c | 1106 for (int channel = 0; channel < channels; channel++) { in adpcm_decode_frame()
1107 ADPCMChannelStatus *cs = &c->status[channel]; in adpcm_decode_frame()
1131 channel, cs->step_index); in adpcm_decode_frame()
1135 samples = samples_p[channel]; in adpcm_decode_frame()
1234 for (int channel = 0; channel < avctx->ch_layout.nb_channels; channel++) { in adpcm_decode_frame()
1235 samples = samples_p[channel]; in adpcm_decode_frame()
1239 channel, block_predictor); in adpcm_decode_frame()
1242 c->status[channel].coeff1 = ff_adpcm_AdaptCoeff1[block_predictor]; in adpcm_decode_frame()
1243 c->status[channel].coeff2 = ff_adpcm_AdaptCoeff2[block_predictor]; in adpcm_decode_frame()
1244 c->status[channel].idelta = sign_extend(bytestream2_get_le16u(&gb), 16); in adpcm_decode_frame()
[all …]
|
| /third_party/node/doc/api/ |
| D | diagnostics_channel.md | 53 // Get a reusable channel object
54 const channel = diagnostics_channel.channel('my-channel');
60 // Subscribe to the channel
61 diagnostics_channel.subscribe('my-channel', onMessage);
63 // Check if the channel has an active subscriber
64 if (channel.hasSubscribers) {
65 // Publish data to the channel
66 channel.publish({
71 // Unsubscribe from the channel
72 diagnostics_channel.unsubscribe('my-channel', onMessage);
[all …]
|
| /third_party/mesa3d/src/util/format/ |
| D | u_format_pack.py | 75 for channel in channels:
76 if channel.type == VOID:
77 if channel.size:
78 print(' unsigned %s:%u;' % (channel.name, channel.size))
79 elif channel.type == UNSIGNED:
80 print(' unsigned %s:%u;' % (channel.name, channel.size))
81 elif channel.type in (SIGNED, FIXED):
82 print(' int %s:%u;' % (channel.name, channel.size))
83 elif channel.type == FLOAT:
84 if channel.size == 64:
[all …]
|
| D | u_format_parse.py | 129 for channel in self.le_channels:
130 channel.shift = le_shift
131 le_shift += channel.size
175 for channel in reversed(self.be_channels):
176 channel.shift = be_shift
177 be_shift += channel.size
199 for channel in self.le_channels:
200 size += channel.size
205 for channel in self.le_channels:
206 if channel.size:
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| D | driver_macsec_qca.c | 520 u32 *channel) in macsec_qca_lookup_channel() argument
527 *channel = i; in macsec_qca_lookup_channel()
538 u32 channel) in macsec_qca_register_channel() argument
540 os_memcpy(&map[channel].sci, sci, sizeof(struct ieee802_1x_mka_sci)); in macsec_qca_register_channel()
546 u32 *channel) in macsec_qca_lookup_receive_channel() argument
549 channel); in macsec_qca_lookup_receive_channel()
555 u32 channel) in macsec_qca_register_receive_channel() argument
558 channel); in macsec_qca_register_receive_channel()
564 u32 *channel) in macsec_qca_lookup_transmit_channel() argument
567 channel); in macsec_qca_lookup_transmit_channel()
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| D | driver_macsec_qca.c | 498 u32 *channel) in macsec_qca_lookup_channel() argument
505 *channel = i; in macsec_qca_lookup_channel()
516 u32 channel) in macsec_qca_register_channel() argument
518 os_memcpy(&map[channel].sci, sci, sizeof(struct ieee802_1x_mka_sci)); in macsec_qca_register_channel()
524 u32 *channel) in macsec_qca_lookup_receive_channel() argument
527 channel); in macsec_qca_lookup_receive_channel()
533 u32 channel) in macsec_qca_register_receive_channel() argument
536 channel); in macsec_qca_register_receive_channel()
542 u32 *channel) in macsec_qca_lookup_transmit_channel() argument
545 channel); in macsec_qca_lookup_transmit_channel()
[all …]
|
| /third_party/node/deps/openssl/openssl/crypto/ |
| D | trace.c | 40 static long trace_ctrl(BIO *channel, int cmd, long argl, void *argp);
64 static int trace_write(BIO *channel, in trace_write() argument
67 struct trace_data_st *ctx = BIO_get_data(channel); in trace_write()
75 static int trace_puts(BIO *channel, const char *str) in trace_puts() argument
79 if (trace_write(channel, str, strlen(str), &written)) in trace_puts()
85 static long trace_ctrl(BIO *channel, int cmd, long argl, void *argp) in trace_ctrl() argument
87 struct trace_data_st *ctx = BIO_get_data(channel); in trace_ctrl()
101 static int trace_free(BIO *channel) in trace_free() argument
103 if (channel == NULL) in trace_free()
105 OPENSSL_free(BIO_get_data(channel)); in trace_free()
[all …]
|
| /third_party/openssl/crypto/ |
| D | trace.c | 40 static long trace_ctrl(BIO *channel, int cmd, long argl, void *argp);
64 static int trace_write(BIO *channel, in trace_write() argument
67 struct trace_data_st *ctx = BIO_get_data(channel); in trace_write()
75 static int trace_puts(BIO *channel, const char *str) in trace_puts() argument
79 if (trace_write(channel, str, strlen(str), &written)) in trace_puts()
85 static long trace_ctrl(BIO *channel, int cmd, long argl, void *argp) in trace_ctrl() argument
87 struct trace_data_st *ctx = BIO_get_data(channel); in trace_ctrl()
101 static int trace_free(BIO *channel) in trace_free() argument
103 if (channel == NULL) in trace_free()
105 OPENSSL_free(BIO_get_data(channel)); in trace_free()
[all …]
|
| /third_party/alsa-lib/src/conf/cards/ |
| D | Echo_Echo3G.conf | 81 { slave 0 channel 0 }
82 { slave 0 channel 1 }
83 { slave 1 channel 0 }
84 { slave 1 channel 1 }
125 { slave 0 channel 0 }
126 { slave 0 channel 1 }
127 { slave 1 channel 0 }
128 { slave 1 channel 1 }
129 { slave 2 channel 0 }
170 { slave 0 channel 0 }
[all …]
|
| /third_party/e2fsprogs/ |
| D | 0022-unix_io.c-fix-deadlock-problem-in-unix_write_blk64.patch | 13 3 unix_write_blk64 (channel=0xaaaaf5c98e60, block=2, count=4, buf=0xaaaaf5c9d170) at unix_io.c:1092
19 9 0x0000aaaadcc3bc5c in e2fsck_handle_write_error (channel=<optimized out>, block=262152, count=<o…
21 …in reuse_cache (block=262206, cache=0xaaaaf5c98f80, data=0xaaaaf5c98f30, channel=0xaaaaf5c98e60) a…
22 11 unix_write_blk64 (channel=0xaaaaf5c98e60, block=262206, count=<optimized out>, buf=<optimized ou…
42 static errcode_t raw_read_blk(io_channel channel,
55 - if (channel->read_error)
56 + if (channel->read_error) {
59 retval = (channel->read_error)(channel, block, count, buf,
67 static errcode_t raw_write_blk(io_channel channel,
80 - if (channel->write_error)
[all …]
|