| /linux/net/ipv4/ |
| H A D | inet_connection_sock.c | 920 struct request_sock *nreq; in inet_reqsk_clone() local
922 nreq = kmem_cache_alloc(req->rsk_ops->slab, GFP_ATOMIC | __GFP_NOWARN); in inet_reqsk_clone()
923 if (!nreq) { in inet_reqsk_clone()
932 nreq_sk = req_to_sk(nreq); in inet_reqsk_clone()
947 nreq->rsk_listener = sk; in inet_reqsk_clone()
952 if (sk->sk_protocol == IPPROTO_TCP && tcp_rsk(nreq)->tfo_listener) in inet_reqsk_clone()
953 rcu_assign_pointer(tcp_sk(nreq->sk)->fastopen_rsk, nreq); in inet_reqsk_clone()
955 return nreq; in inet_reqsk_clone()
1027 struct request_sock *nreq = NULL, *oreq = req; in reqsk_timer_handler() local
1041 nreq = inet_reqsk_clone(req, nsk); in reqsk_timer_handler()
[all …]
|
| /linux/drivers/infiniband/hw/mlx5/ |
| H A D | wr.c | 29 int mlx5r_wq_overflow(struct mlx5_ib_wq *wq, int nreq, struct ib_cq *ib_cq) in mlx5r_wq_overflow() argument
35 if (likely(cur + nreq < wq->max_post)) in mlx5r_wq_overflow()
43 return cur + nreq >= wq->max_post; in mlx5r_wq_overflow()
726 int *size, void **cur_edge, int nreq, __be32 general_id, in mlx5r_begin_wqe() argument
729 if (unlikely(mlx5r_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq))) in mlx5r_begin_wqe()
751 void **cur_edge, int nreq) in begin_wqe() argument
753 return mlx5r_begin_wqe(qp, seg, ctrl, idx, size, cur_edge, nreq, in begin_wqe()
760 u64 wr_id, int nreq, u8 fence, u32 mlx5_opcode) in mlx5r_finish_wqe() argument
773 qp->sq.wqe_head[idx] = qp->sq.head + nreq; in mlx5r_finish_wqe()
815 void **cur_edge, unsigned int *idx, int nreq, in handle_psv() argument
[all …]
|
| H A D | wr.h | 94 int mlx5r_wq_overflow(struct mlx5_ib_wq *wq, int nreq, struct ib_cq *ib_cq);
97 int *size, void **cur_edge, int nreq, __be32 general_id,
101 u64 wr_id, int nreq, u8 fence, u32 mlx5_opcode);
102 void mlx5r_ring_db(struct mlx5_ib_qp *qp, unsigned int nreq,
|
| /linux/fs/smb/smbdirect/ |
| H A D | connect.c | 382 struct smbdirect_negotiate_req *nreq = NULL; in smbdirect_connect_negotiate_start() local
428 nreq = (struct smbdirect_negotiate_req *)send_io->packet; in smbdirect_connect_negotiate_start()
429 nreq->min_version = cpu_to_le16(SMBDIRECT_V1); in smbdirect_connect_negotiate_start()
430 nreq->max_version = cpu_to_le16(SMBDIRECT_V1); in smbdirect_connect_negotiate_start()
431 nreq->reserved = 0; in smbdirect_connect_negotiate_start()
432 nreq->credits_requested = cpu_to_le16(sp->send_credit_target); in smbdirect_connect_negotiate_start()
433 nreq->preferred_send_size = cpu_to_le32(sp->max_send_size); in smbdirect_connect_negotiate_start()
434 nreq->max_receive_size = cpu_to_le32(sp->max_recv_size); in smbdirect_connect_negotiate_start()
435 nreq->max_fragmented_size = cpu_to_le32(sp->max_fragmented_recv_size); in smbdirect_connect_negotiate_start()
440 le16_to_cpu(nreq->min_version), in smbdirect_connect_negotiate_start()
[all …]
|
| H A D | accept.c | 295 struct smbdirect_negotiate_req *nreq; in smbdirect_accept_negotiate_recv_work() local
347 nreq = (struct smbdirect_negotiate_req *)recv_io->packet; in smbdirect_accept_negotiate_recv_work()
348 min_version = le16_to_cpu(nreq->min_version); in smbdirect_accept_negotiate_recv_work()
349 max_version = le16_to_cpu(nreq->max_version); in smbdirect_accept_negotiate_recv_work()
350 credits_requested = le16_to_cpu(nreq->credits_requested); in smbdirect_accept_negotiate_recv_work()
351 preferred_send_size = le32_to_cpu(nreq->preferred_send_size); in smbdirect_accept_negotiate_recv_work()
352 max_receive_size = le32_to_cpu(nreq->max_receive_size); in smbdirect_accept_negotiate_recv_work()
353 max_fragmented_size = le32_to_cpu(nreq->max_fragmented_size); in smbdirect_accept_negotiate_recv_work()
358 le16_to_cpu(nreq->min_version), in smbdirect_accept_negotiate_recv_work()
360 le16_to_cpu(nreq->max_version), in smbdirect_accept_negotiate_recv_work()
[all …]
|
| /linux/drivers/infiniband/hw/mthca/ |
| H A D | mthca_qp.c | 1568 static inline int mthca_wq_overflow(struct mthca_wq *wq, int nreq, in mthca_wq_overflow() argument
1575 if (likely(cur + nreq < wq->max)) in mthca_wq_overflow()
1583 return cur + nreq >= wq->max; in mthca_wq_overflow()
1634 int nreq; in mthca_tavor_post_send() local
1655 for (nreq = 0; wr; ++nreq, wr = wr->next) { in mthca_tavor_post_send()
1656 if (mthca_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq)) { in mthca_tavor_post_send()
1660 qp->sq.max, nreq); in mthca_tavor_post_send()
1789 cpu_to_be32((nreq ? 0 : MTHCA_NEXT_DBD) | size | in mthca_tavor_post_send()
1793 if (!nreq) { in mthca_tavor_post_send()
1806 if (likely(nreq)) { in mthca_tavor_post_send()
[all …]
|
| H A D | mthca_srq.c | 493 int nreq; in mthca_tavor_post_srq_recv() local
502 for (nreq = 0; wr; wr = wr->next) { in mthca_tavor_post_srq_recv()
543 ++nreq; in mthca_tavor_post_srq_recv()
544 if (unlikely(nreq == MTHCA_TAVOR_MAX_WQES_PER_RECV_DB)) { in mthca_tavor_post_srq_recv()
545 nreq = 0; in mthca_tavor_post_srq_recv()
561 if (likely(nreq)) { in mthca_tavor_post_srq_recv()
568 mthca_write64(first_ind << srq->wqe_shift, (srq->srqn << 8) | nreq, in mthca_tavor_post_srq_recv()
586 int nreq; in mthca_arbel_post_srq_recv() local
592 for (nreq = 0; wr; ++nreq, wr = wr->next) { in mthca_arbel_post_srq_recv()
627 if (likely(nreq)) { in mthca_arbel_post_srq_recv()
[all …]
|
| /linux/fs/nfs/ |
| H A D | pnfs_nfs.c | 414 unsigned int nreq = 0; in pnfs_bucket_alloc_ds_commits() local
426 nreq++; in pnfs_bucket_alloc_ds_commits()
430 return nreq; in pnfs_bucket_alloc_ds_commits()
435 return nreq; in pnfs_bucket_alloc_ds_commits()
470 unsigned int nreq = 0; in pnfs_generic_commit_pagelist() local
481 nreq++; in pnfs_generic_commit_pagelist()
484 nreq += pnfs_alloc_ds_commits_list(&list, fl_cinfo, cinfo); in pnfs_generic_commit_pagelist()
485 if (nreq == 0) in pnfs_generic_commit_pagelist()
|
| /linux/drivers/usb/gadget/function/ |
| H A D | uvc_video.c | 504 unsigned int nreq; in uvc_video_prep_requests() local
522 nreq = DIV_ROUND_UP(video->interval, interval_duration); in uvc_video_prep_requests()
524 header_size = nreq * UVCG_REQUEST_HEADER_LEN; in uvc_video_prep_requests()
526 req_size = DIV_ROUND_UP(video->imagesize + header_size, nreq); in uvc_video_prep_requests()
543 video->uvc_num_requests = nreq + UVCG_REQ_MAX_ZERO_COUNT; in uvc_video_prep_requests()
544 video->reqs_per_frame = nreq; in uvc_video_prep_requests()
|
| /linux/crypto/ |
| H A D | api.c | 729 struct crypto_async_request *nreq; in crypto_request_clone() local
731 nreq = kmemdup(req, total, gfp); in crypto_request_clone()
732 if (!nreq) { in crypto_request_clone()
737 nreq->flags &= ~CRYPTO_TFM_REQ_ON_STACK; in crypto_request_clone()
738 return nreq; in crypto_request_clone()
|
| /linux/drivers/dma/ |
| H A D | bcm-sba-raid.c | 289 struct sba_request *nreq; in sba_free_chained_requests() local
295 list_for_each_entry(nreq, &req->next, next) in sba_free_chained_requests()
296 _sba_free_request(sba, nreq); in sba_free_chained_requests()
412 struct sba_request *nreq, *first = req->first; in sba_process_received_request() local
434 list_for_each_entry(nreq, &first->next, next) in sba_process_received_request()
435 _sba_free_request(sba, nreq); in sba_process_received_request()
520 struct sba_request *req, *nreq; in sba_tx_submit() local
532 list_for_each_entry(nreq, &req->next, next) in sba_tx_submit()
533 _sba_pending_request(sba, nreq); in sba_tx_submit()
|
| H A D | arm-dma350.c | 196 int nreq; member
561 dmac->nreq = FIELD_GET(DMA_CFG_NUM_TRIGGER_IN, reg); in d350_probe()
563 dev_dbg(dev, "DMA-350 r%dp%d with %d channels, %d requests\n", r, p, dmac->nchan, dmac->nreq); in d350_probe()
|
| /linux/drivers/crypto/rockchip/ |
| H A D | rk3288_crypto.h | 223 unsigned long nreq; member
|
| H A D | rk3288_crypto_skcipher.c | 322 rkc->nreq++; in rk_cipher_run()
|
| /linux/drivers/infiniband/hw/hns/ |
| H A D | hns_roce_hw_v2.c | 705 u32 nreq; in hns_roce_v2_post_send() local
713 nreq = 0; in hns_roce_v2_post_send()
719 for (nreq = 0; wr; ++nreq, wr = wr->next) { in hns_roce_v2_post_send()
720 if (hns_roce_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq)) { in hns_roce_v2_post_send()
726 wqe_idx = (qp->sq.head + nreq) & (qp->sq.wqe_cnt - 1); in hns_roce_v2_post_send()
739 ~(((qp->sq.head + nreq) >> ilog2(qp->sq.wqe_cnt)) & 0x1); in hns_roce_v2_post_send()
759 if (likely(nreq)) { in hns_roce_v2_post_send()
760 qp->sq.head += nreq; in hns_roce_v2_post_send()
763 if (nreq == 1 && !ret && in hns_roce_v2_post_send()
833 u32 wqe_idx, nreq, max_sge; in hns_roce_v2_post_recv() local
[all …]
|
| /linux/drivers/net/ethernet/mellanox/mlx4/ |
| H A D | main.c | 2960 int nreq = min3(dev->caps.num_ports * in mlx4_enable_msi_x() local
2966 nreq = min_t(int, nreq, msi_x); in mlx4_enable_msi_x()
2968 entries = kzalloc_objs(*entries, nreq); in mlx4_enable_msi_x()
2972 for (i = 0; i < nreq; ++i) in mlx4_enable_msi_x()
2975 nreq = pci_enable_msix_range(dev->persist->pdev, entries, 2, in mlx4_enable_msi_x()
2976 nreq); in mlx4_enable_msi_x()
2978 if (nreq < 0 || nreq < MLX4_EQ_ASYNC) { in mlx4_enable_msi_x()
2983 dev->caps.num_comp_vectors = nreq - 1; in mlx4_enable_msi_x()
|
| /linux/drivers/nvme/host/ |
| H A D | apple.c | 827 struct nvme_request *nreq = nvme_req(req); in apple_nvme_init_request() local
830 nreq->ctrl = &anv->ctrl; in apple_nvme_init_request()
831 nreq->cmd = &iod->cmd; in apple_nvme_init_request()
|
| H A D | fc.c | 89 struct nvme_request nreq; /* member
2423 op->nreq.flags |= NVME_REQ_CANCELLED; in nvme_fc_terminate_exchange()
|
| /linux/drivers/usb/isp1760/ |
| H A D | isp1760-udc.c | 841 struct isp1760_request *req, *nreq; in isp1760_ep_disable() local
868 list_for_each_entry_safe(req, nreq, &req_list, queue) { in isp1760_ep_disable()
|
| /linux/drivers/infiniband/hw/hfi1/ |
| H A D | tid_rdma.c | 5199 struct tid_rdma_request *req, *nreq; in make_tid_rdma_ack() local
5273 nreq = ack_to_tid_req(&qp->s_ack_queue[next]); in make_tid_rdma_ack()
5274 if (!nreq->comp_seg || nreq->ack_seg == nreq->comp_seg) in make_tid_rdma_ack()
|
| /linux/fs/ceph/ |
| H A D | mds_client.c | 4544 struct ceph_mds_request *req, *nreq; in replay_unsafe_requests() local
4550 list_for_each_entry_safe(req, nreq, &session->s_unsafe, r_unsafe_item) in replay_unsafe_requests()
|