Home
last modified time | relevance | path

Searched refs:qs (Results 1 – 25 of 127) sorted by relevance

123456

/src/crypto/openssl/ssl/quic/
H A Dquic_stream_map.c19 static void shutdown_flush_done(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs);
278 static ossl_unused int qsm_send_part_permits_gc(const QUIC_STREAM *qs) in qsm_send_part_permits_gc() argument
280 switch (qs->send_state) { in qsm_send_part_permits_gc()
290 static int qsm_ready_for_gc(QUIC_STREAM_MAP *qsm, QUIC_STREAM *qs) in qsm_ready_for_gc() argument
298 assert(!qs->deleted in qsm_ready_for_gc()
299 || !ossl_quic_stream_has_send(qs) in qsm_ready_for_gc()
300 || ossl_quic_stream_send_is_reset(qs) in qsm_ready_for_gc()
301 || ossl_quic_stream_send_get_final_size(qs, NULL)); in qsm_ready_for_gc()
303 return qs->deleted in qsm_ready_for_gc()
304 && (!ossl_quic_stream_has_recv(qs) in qsm_ready_for_gc()
[all …]
H A Dquic_tserver.c260 QUIC_STREAM *qs; in ossl_quic_tserver_read() local
262 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_read()
264 if (qs == NULL) { in ossl_quic_tserver_read()
282 if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ in ossl_quic_tserver_read()
283 || !ossl_quic_stream_has_recv_buffer(qs)) in ossl_quic_tserver_read()
286 if (!ossl_quic_rstream_read(qs->rstream, buf, buf_len, in ossl_quic_tserver_read()
301 if (!ossl_quic_rxfc_on_retire(&qs->rxfc, *bytes_read, in ossl_quic_tserver_read()
308 qs); in ossl_quic_tserver_read()
311 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_read()
318 QUIC_STREAM *qs; in ossl_quic_tserver_has_read_ended() local
[all …]
H A Dquic_impl.c30 static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs);
2088 QUIC_STREAM *qs; member
2104 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
2106 if (args->qs == NULL) in quic_wait_for_stream()
2107 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
2110 if (args->qs != NULL) in quic_wait_for_stream()
2122 QUIC_STREAM *qs; in qc_wait_for_default_xso_for_read() local
2145 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(qc->ch), in qc_wait_for_default_xso_for_read()
2147 if (qs == NULL) in qc_wait_for_default_xso_for_read()
2148 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(qc->ch), in qc_wait_for_default_xso_for_read()
[all …]
H A Dquic_channel.c3741 static int ch_init_new_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs, in ch_init_new_stream() argument
3745 int server_init = ossl_quic_stream_is_server_init(qs); in ch_init_new_stream()
3747 int is_uni = !ossl_quic_stream_is_bidi(qs); in ch_init_new_stream()
3750 if ((qs->sstream = ossl_quic_sstream_new(INIT_APP_BUF_LEN)) == NULL) in ch_init_new_stream()
3754 if ((qs->rstream = ossl_quic_rstream_new(NULL, NULL, 0)) == NULL) in ch_init_new_stream()
3758 if (!ossl_quic_txfc_init(&qs->txfc, &ch->conn_txfc)) in ch_init_new_stream()
3777 ossl_quic_txfc_bump_cwm(&qs->txfc, cwm); in ch_init_new_stream()
3791 if (!ossl_quic_rxfc_init(&qs->rxfc, &ch->conn_rxfc, in ch_init_new_stream()
3800 ossl_quic_sstream_free(qs->sstream); in ch_init_new_stream()
3801 qs->sstream = NULL; in ch_init_new_stream()
[all …]
/src/sys/dev/cxgb/
H A Dcxgb_sge.c228 #define TXQ_LOCK_ASSERT(qs) mtx_assert(&(qs)->lock, MA_OWNED) argument
229 #define TXQ_TRYLOCK(qs) mtx_trylock(&(qs)->lock) argument
230 #define TXQ_LOCK(qs) mtx_lock(&(qs)->lock) argument
231 #define TXQ_UNLOCK(qs) mtx_unlock(&(qs)->lock) argument
232 #define TXQ_RING_EMPTY(qs) drbr_empty((qs)->port->ifp, (qs)->txq[TXQ_ETH].txq_mr) argument
233 #define TXQ_RING_NEEDS_ENQUEUE(qs) \ argument
234 drbr_needs_enqueue((qs)->port->ifp, (qs)->txq[TXQ_ETH].txq_mr)
235 #define TXQ_RING_FLUSH(qs) drbr_flush((qs)->port->ifp, (qs)->txq[TXQ_ETH].txq_mr) argument
236 #define TXQ_RING_DEQUEUE_COND(qs, func, arg) \ argument
237 drbr_dequeue_cond((qs)->port->ifp, (qs)->txq[TXQ_ETH].txq_mr, func, arg)
[all …]
H A Dcxgb_adapter.h294 struct sge_qset qs[SGE_QSETS]; member
506 void t3_free_tx_desc(struct sge_qset *qs, int n, int qid);
512 int t3_get_desc(const struct sge_qset *qs, unsigned int qnum, unsigned int idx,
514 void t3_update_qset_coalesce(struct sge_qset *qs, const struct qset_params *p);
556 int cxgb_debugnet_encap(struct sge_qset *qs, struct mbuf **m);
557 int cxgb_debugnet_poll_rx(adapter_t *adap, struct sge_qset *qs);
558 int cxgb_debugnet_poll_tx(struct sge_qset *qs);
H A Dcxgb_main.c939 NULL, t3_intr_msix, &sc->sge.qs[i], &tag); in cxgb_setup_interrupts()
1099 struct sge_qset *qs = &sc->sge.qs[i]; in cxgb_port_detach() local
1100 struct sge_txq *txq = &qs->txq[TXQ_ETH]; in cxgb_port_detach()
1275 while (adap->sge.qs[0].rspq.offload_pkts < init_cnt + n) { in await_mgmt_replies()
1289 unsigned long cnt = adap->sge.qs[0].rspq.offload_pkts; in init_tp_parity()
1682 struct sge_qset *qs = &sc->sge.qs[i]; in cxgb_init_locked() local
1683 struct sge_txq *txq = &qs->txq[TXQ_ETH]; in cxgb_init_locked()
1685 callout_reset_on(&txq->txq_watchdog, hz, cxgb_tx_watchdog, qs, in cxgb_init_locked()
1816 q = &adp->sge.qs[p->first_qset + i]; in cxgb_set_lro()
2204 drops += sc->sge.qs[i].txq[TXQ_ETH].txq_mr->br_drops; in cxgb_get_counter()
[all …]
/src/sys/dev/vnic/
H A Dnicvf_queues.c432 struct queue_set *qs; in nicvf_free_rbdr() local
439 qs = nic->qs; in nicvf_free_rbdr()
441 if ((qs == NULL) || (rbdr == NULL)) in nicvf_free_rbdr()
497 for (idx = 0; idx < qs->rbdr_len; idx++) { in nicvf_free_rbdr()
528 struct queue_set *qs; in nicvf_refill_rbdr() local
541 qs = nic->qs; in nicvf_refill_rbdr()
552 if (qcount >= (qs->rbdr_len - 1)) { in nicvf_refill_rbdr()
556 refill_rb_cnt = qs->rbdr_len - qcount - 1; in nicvf_refill_rbdr()
645 rq = &nic->qs->rq[rq_idx]; in nicvf_rcv_pkt_handler()
703 sq = &nic->qs->sq[cqe_tx->sq_idx]; in nicvf_snd_pkt_handler()
[all …]
H A Dnicvf_main.c246 if (nic->qs->rq_cnt > 1) in nicvf_attach()
537 rq_idx < nic->qs->rq_cnt; rq_idx++) { in nicvf_if_ioctl()
538 rq = &nic->qs->rq[rq_idx]; in nicvf_if_ioctl()
558 struct queue_set *qs = nic->qs; in nicvf_if_init_locked() local
597 for (qidx = 0; qidx < qs->cq_cnt; qidx++) in nicvf_if_init_locked()
601 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) in nicvf_if_init_locked()
634 struct queue_set *qs = nic->qs; in nicvf_if_transmit() local
640 if (__predict_false(qs == NULL)) { in nicvf_if_transmit()
647 qidx = mbuf->m_pkthdr.flowid % qs->sq_cnt; in nicvf_if_transmit()
649 qidx = curcpu % qs->sq_cnt; in nicvf_if_transmit()
[all …]
/src/sys/dev/qat_c2xxx/
H A Dqat.c1240 const struct qat_session *qs) in qat_crypto_load_cipher_session() argument
1249 mode = qs->qs_cipher_mode; in qat_crypto_load_cipher_session()
1253 algo = qs->qs_cipher_algo; in qat_crypto_load_cipher_session()
1265 algo = qs->qs_cipher_algo; in qat_crypto_load_cipher_session()
1278 const struct qat_session *qs, const struct qat_sym_hash_def **hash_def) in qat_crypto_load_auth_session() argument
1282 switch (qs->qs_auth_algo) { in qat_crypto_load_auth_session()
1299 panic("unhandled auth algorithm %d", qs->qs_auth_algo); in qat_crypto_load_auth_session()
1304 return HW_AUTH_CONFIG_BUILD(qs->qs_auth_mode, in qat_crypto_load_auth_session()
1310 struct qat_session *qs; member
1373 struct qat_session *qs; in qat_crypto_load_buf_cb() local
[all …]
H A Dqat_hw15.c528 struct qat_session *qs, struct fw_cipher_hdr *cipher_hdr, in qat_hw15_crypto_setup_cipher_desc() argument
534 cipher_hdr->key_sz = qs->qs_cipher_klen / 8; in qat_hw15_crypto_setup_cipher_desc()
543 return sizeof(struct hw_cipher_config) + qs->qs_cipher_klen; in qat_hw15_crypto_setup_cipher_desc()
548 const struct qat_session *qs, const struct cryptop *crp, in qat_hw15_crypto_setup_cipher_config() argument
554 cipher_config->val = qat_crypto_load_cipher_session(desc, qs); in qat_hw15_crypto_setup_cipher_config()
561 key = qs->qs_cipher_key; in qat_hw15_crypto_setup_cipher_config()
562 memcpy(cipher_key, key, qs->qs_cipher_klen); in qat_hw15_crypto_setup_cipher_config()
567 struct qat_session *qs, struct fw_auth_hdr *auth_hdr, in qat_hw15_crypto_setup_auth_desc() argument
573 (void)qat_crypto_load_auth_session(desc, qs, &hash_def); in qat_hw15_crypto_setup_auth_desc()
612 const struct qat_session *qs, const struct cryptop *crp, in qat_hw15_crypto_setup_auth_setup() argument
[all …]
/src/sbin/pfctl/
H A Dpfctl_qstats.c457 struct queue_stats *qs; local
464 qs = &a->qstats;
465 n = qs->avgn;
469 b = qs->data.cbq_stats.xmit_cnt.bytes;
470 p = qs->data.cbq_stats.xmit_cnt.packets;
473 b = qs->data.priq_stats.xmitcnt.bytes;
474 p = qs->data.priq_stats.xmitcnt.packets;
477 b = qs->data.hfsc_stats.xmit_cnt.bytes;
478 p = qs->data.hfsc_stats.xmit_cnt.packets;
481 b = qs->data.fairq_stats.xmit_cnt.bytes;
[all …]
/src/crypto/openssl/include/internal/
H A Dquic_stream_map.h681 QUIC_STREAM *qs);
696 QUIC_STREAM *qs);
710 QUIC_STREAM *qs);
724 QUIC_STREAM *qs,
741 QUIC_STREAM *qs);
756 QUIC_STREAM *qs,
766 QUIC_STREAM *qs);
776 QUIC_STREAM *qs);
785 QUIC_STREAM *qs,
795 QUIC_STREAM *qs);
[all …]
/src/crypto/krb5/src/kadmin/dbutil/
H A Dtdumputil.c105 char *s = NULL, *qs = NULL; in writequoted() local
120 qs = qquote(&fl, s); in writequoted()
121 if (qs == NULL) { in writequoted()
125 ret = fprintf(h->fh, "%c%s%c", fl.quotechar, qs, fl.quotechar); in writequoted()
131 free(qs); in writequoted()
/src/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/aggs/
H A Dtst.aggpackbanner.ksh64 dtrace -qs /dev/stdin -x encoding=utf8 <<EOF
68 dtrace -qs /dev/stdin -x encoding=ascii -x aggzoom <<EOF
72 dtrace -qs /dev/stdin -x encoding=utf8 -x aggzoom <<EOF
/src/sys/dev/ciss/
H A Dcissvar.h303 struct ciss_qstat *qs = &(sc)->ciss_qstat[qname]; \
305 qs->q_length++; \
306 if (qs->q_length > qs->q_max) \
307 qs->q_max = qs->q_length; \
/src/crypto/openssh/regress/
H A Dagent-pkcs11-cert.sh18 $SSHKEYGEN -qs $OBJ/ca -I "ecdsa_key" -n $USER -z 1 ${SSH_SOFTHSM_DIR}/EC.pub ||
20 $SSHKEYGEN -qs $OBJ/ca -I "rsa_key" -n $USER -z 2 ${SSH_SOFTHSM_DIR}/RSA.pub ||
22 $SSHKEYGEN -qs $OBJ/ca -I "ca_ca" -n $USER -z 3 $OBJ/ca.pub ||
43 p11_ssh_add -qs ${TEST_SSH_PKCS11} \
/src/contrib/mandoc/
H A Dcgi.c206 parse_query_string(struct req *req, const char *qs) in parse_query_string() argument
219 while (*qs != '\0') { in parse_query_string()
223 keysz = strcspn(qs, "=;&"); in parse_query_string()
224 key = mandoc_strndup(qs, keysz); in parse_query_string()
225 qs += keysz; in parse_query_string()
226 if (*qs != '=') in parse_query_string()
231 valsz = strcspn(++qs, ";&"); in parse_query_string()
232 val = mandoc_strndup(qs, valsz); in parse_query_string()
233 qs += valsz; in parse_query_string()
286 if (*qs != '\0') in parse_query_string()
[all …]
/src/sys/dev/aac/
H A Daacvar.h515 struct aac_qstat *qs; \
517 qs = &(sc)->aac_qstat[qname]; \
519 qs->q_length++; \
520 if (qs->q_length > qs->q_max) \
521 qs->q_max = qs->q_length; \
/src/sys/dev/aacraid/
H A Daacraid_var.h549 struct aac_qstat *qs; \
551 qs = &(sc)->aac_qstat[qname]; \
553 qs->q_length++; \
554 if (qs->q_length > qs->q_max) \
555 qs->q_max = qs->q_length; \
/src/sys/dev/mfi/
H A Dmfivar.h460 struct mfi_qstat *qs; \
462 qs = &(sc)->mfi_qstat[qname]; \
463 qs->q_length++; \
464 if (qs->q_length > qs->q_max) \
465 qs->q_max = qs->q_length; \
/src/contrib/unbound/dnstap/
H A Ddnstap.c350 struct sockaddr_storage *qs, in dt_msg_fill_net() argument
359 log_assert(qs->ss_family == AF_INET6 || qs->ss_family == AF_INET); in dt_msg_fill_net()
360 if (qs->ss_family == AF_INET6) { in dt_msg_fill_net()
361 struct sockaddr_in6 *q = (struct sockaddr_in6 *) qs; in dt_msg_fill_net()
375 } else if (qs->ss_family == AF_INET) { in dt_msg_fill_net()
376 struct sockaddr_in *q = (struct sockaddr_in *) qs; in dt_msg_fill_net()
/src/tools/tools/netmap/
H A Dnmreplay.c1123 struct _qs *qs = &bp[i].q; in main() local
1125 qs->burst = 128; in main()
1126 qs->c_delay.optarg = "0"; in main()
1127 qs->c_delay.run = null_run_fn; in main()
1128 qs->c_loss.optarg = "0"; in main()
1129 qs->c_loss.run = null_run_fn; in main()
1130 qs->c_bw.optarg = "0"; in main()
1131 qs->c_bw.run = null_run_fn; in main()
1246 struct _qs *qs = &bp[i].q; in main() local
1247 err += cmd_apply(delay_cfg, d[i], qs, &qs->c_delay); in main()
[all …]
/src/contrib/unbound/ipset/
H A Dipset.c230 const char *ds, *qs; in ipset_check_zones_for_rrset() local
250 qs = NULL; in ipset_check_zones_for_rrset()
260 qs = qname + (qlen - plen); in ipset_check_zones_for_rrset()
263 || (qs && strncasecmp(p->str, qs, plen) == 0)) { in ipset_check_zones_for_rrset()
/src/contrib/less/
H A Dfilename.c411 char *qs; in fcomplete() local
448 qs = lglob(fpat); in fcomplete()
449 uqs = shell_unquote(qs); in fcomplete()
455 free(qs); in fcomplete()
456 qs = NULL; in fcomplete()
460 return (qs); in fcomplete()

123456