diff --git a/drivers/infiniband/hw/rxe/rxe.c b/drivers/infiniband/hw/rxe/rxe.c index a9109fcdcf5a..52bd5c9197a9 100644 --- a/drivers/infiniband/hw/rxe/rxe.c +++ b/drivers/infiniband/hw/rxe/rxe.c @@ -68,11 +68,6 @@ module_param_named(default_mtu, rxe_default_mtu, int, 0644); MODULE_PARM_DESC(default_mtu, "default rxe port mtu"); -int rxe_bypass_arbiter; -module_param_named(bypass_arbiter, rxe_bypass_arbiter, int, 0644); -MODULE_PARM_DESC(bypass_arbiter, - "do not arbitrate for network send"); - /* free resources for all ports on a device */ static void rxe_cleanup_ports(struct rxe_dev *rxe) { diff --git a/drivers/infiniband/hw/rxe/rxe_arbiter.c b/drivers/infiniband/hw/rxe/rxe_arbiter.c index a705fd812596..3322472dfec1 100644 --- a/drivers/infiniband/hw/rxe/rxe_arbiter.c +++ b/drivers/infiniband/hw/rxe/rxe_arbiter.c @@ -52,8 +52,8 @@ static inline void account_skb(struct rxe_dev *rxe, struct rxe_qp *qp, } } -int xmit_one_packet(struct rxe_dev *rxe, struct rxe_qp *qp, - struct sk_buff *skb) +static int xmit_one_packet(struct rxe_dev *rxe, struct rxe_qp *qp, + struct sk_buff *skb) { int err; struct timespec time; diff --git a/drivers/infiniband/hw/rxe/rxe_loc.h b/drivers/infiniband/hw/rxe/rxe_loc.h index 8225f85c4e32..4c30a4ec0cdd 100644 --- a/drivers/infiniband/hw/rxe/rxe_loc.h +++ b/drivers/infiniband/hw/rxe/rxe_loc.h @@ -235,9 +235,6 @@ extern struct ib_dma_mapping_ops rxe_dma_mapping_ops; void rxe_release(struct kref *kref); -int xmit_one_packet(struct rxe_dev *rxe, struct rxe_qp *qp, - struct sk_buff *skb); - void arbiter_skb_queue(struct rxe_dev *rxe, struct rxe_qp *qp, struct sk_buff *skb); diff --git a/drivers/infiniband/hw/rxe/rxe_param.h b/drivers/infiniband/hw/rxe/rxe_param.h index 1f21286db0f3..02552f38bda6 100644 --- a/drivers/infiniband/hw/rxe/rxe_param.h +++ b/drivers/infiniband/hw/rxe/rxe_param.h @@ -203,6 +203,5 @@ extern int rxe_max_skb_per_qp; extern int rxe_max_req_comp_gap; extern int rxe_max_pkt_per_ack; extern int rxe_default_mtu; -extern int rxe_bypass_arbiter; #endif /* RXE_PARAM_H */ diff --git a/drivers/infiniband/hw/rxe/rxe_req.c b/drivers/infiniband/hw/rxe/rxe_req.c index b22e4a9fd003..9752eb795033 100644 --- a/drivers/infiniband/hw/rxe/rxe_req.c +++ b/drivers/infiniband/hw/rxe/rxe_req.c @@ -694,11 +694,7 @@ int rxe_requester(void *arg) update_state(qp, wqe, pkt, payload); - if (rxe_bypass_arbiter) - xmit_one_packet(to_rdev(qp->ibqp.device), qp, PKT_TO_SKB(pkt)); - else - arbiter_skb_queue(to_rdev(qp->ibqp.device), qp, - PKT_TO_SKB(pkt)); + arbiter_skb_queue(to_rdev(qp->ibqp.device), qp, PKT_TO_SKB(pkt)); if (mask & RXE_END_MASK) goto complete; diff --git a/drivers/infiniband/hw/rxe/rxe_resp.c b/drivers/infiniband/hw/rxe/rxe_resp.c index 0a22ae95d44f..bf814cf0f52b 100644 --- a/drivers/infiniband/hw/rxe/rxe_resp.c +++ b/drivers/infiniband/hw/rxe/rxe_resp.c @@ -748,10 +748,7 @@ static enum resp_states read_reply(struct rxe_qp *qp, *buf = rxe_icrc_pkt(pkt); - if (rxe_bypass_arbiter) - xmit_one_packet(rxe, qp, skb); - else - arbiter_skb_queue(rxe, qp, skb); + arbiter_skb_queue(rxe, qp, skb); if (res->read.resid > 0) { state = RESPST_DONE; @@ -927,10 +924,7 @@ static int send_ack(struct rxe_qp *qp, struct rxe_pkt_info *pkt, *buf = rxe_icrc_pkt(ack); - if (rxe_bypass_arbiter) - xmit_one_packet(rxe, qp, skb); - else - arbiter_skb_queue(rxe, qp, skb); + arbiter_skb_queue(rxe, qp, skb); err1: return err; @@ -978,10 +972,7 @@ static int send_atomic_ack(struct rxe_qp *qp, struct rxe_pkt_info *pkt, pr_warn("Could not clone atomic response\n"); } - if (rxe_bypass_arbiter) - xmit_one_packet(rxe, qp, skb_copy); - else - arbiter_skb_queue(rxe, qp, skb_copy); + arbiter_skb_queue(rxe, qp, skb_copy); out: return rc; @@ -1123,12 +1114,8 @@ static enum resp_states duplicate_request(struct rxe_qp *qp, bth_set_psn(SKB_TO_PKT(skb_copy), qp->resp.psn - 1); /* Resend the result. */ - if (rxe_bypass_arbiter) - xmit_one_packet(to_rdev(qp->ibqp.device), qp, - skb_copy); - else - arbiter_skb_queue(to_rdev(qp->ibqp.device), qp, - skb_copy); + arbiter_skb_queue(to_rdev(qp->ibqp.device), qp, + skb_copy); } /* Resource not found. Class D error. Drop the request. */