-Bottom: c93d236ca31c4be364371bb05930f374530864e6
-Top: e8b5bb1cf92f403d8767fc1d61cb8c538da64fe3
+Bottom: 0e56d97e8e6ce359a7d2f4979f99fcc197cb8302
+Top: b4ceef9d5c09998f0ae526f1c77ac77af9ee95e1
Author: Sean Hefty <sean.hefty@intel.com>
Date: 2011-04-01 16:03:40 -0700
---
diff --git a/src/acm.c b/src/acm.c
-index 7c6cd11..53a8e7b 100644
+index fe42498..8719074 100644
--- a/src/acm.c
+++ b/src/acm.c
-@@ -450,20 +450,30 @@ acm_alloc_send(struct acm_ep *ep, struct acm_dest *dest, size_t size)
+@@ -449,20 +449,30 @@ acm_alloc_send(struct acm_ep *ep, struct acm_dest *dest, size_t size)
msg->mr = ibv_reg_mr(ep->port->dev->pd, msg->data, size, 0);
if (!msg->mr) {
acm_log(0, "ERROR - failed to register send buffer\n");
msg->wr.wr.ud.remote_qpn = dest->remote_qpn;
msg->wr.wr.ud.remote_qkey = ACM_QKEY;
-@@ -472,7 +482,10 @@ acm_alloc_send(struct acm_ep *ep, struct acm_dest *dest, size_t size)
+@@ -471,7 +481,10 @@ acm_alloc_send(struct acm_ep *ep, struct acm_dest *dest, size_t size)
msg->sge.addr = (uintptr_t) msg->data;
acm_log(2, "%p\n", msg);
return msg;
free(msg);
return NULL;
}
-@@ -491,6 +504,8 @@ acm_init_send_req(struct acm_send_msg *msg, void *context,
+@@ -490,6 +503,8 @@ acm_init_send_req(struct acm_send_msg *msg, void *context,
static void acm_free_send(struct acm_send_msg *msg)
{
acm_log(2, "%p\n", msg);
ibv_dereg_mr(msg->mr);
acm_put_dest(msg->dest);
free(msg);
-@@ -775,7 +790,6 @@ static uint8_t
+@@ -774,7 +789,6 @@ static uint8_t
acm_record_acm_route(struct acm_ep *ep, struct acm_dest *dest)
{
int i;
acm_log(2, "\n");
for (i = 0; i < MAX_EP_MC; i++) {
-@@ -790,18 +804,8 @@ acm_record_acm_route(struct acm_ep *ep, struct acm_dest *dest)
+@@ -789,18 +803,8 @@ acm_record_acm_route(struct acm_ep *ep, struct acm_dest *dest)
dest->path = ep->mc_dest[i].path;
dest->path.dgid = dest->av.grh.dgid;
dest->path.dlid = htons(dest->av.dlid);
}
static void acm_init_path_query(struct ib_sa_mad *mad)
-@@ -1097,15 +1101,6 @@ acm_dest_sa_resp(struct acm_send_msg *msg, struct ibv_wc *wc, struct acm_mad *ma
+@@ -1096,15 +1100,6 @@ acm_dest_sa_resp(struct acm_send_msg *msg, struct ibv_wc *wc, struct acm_mad *ma
if (!status) {
memcpy(&dest->path, sa_mad->data, sizeof(dest->path));
acm_init_path_av(msg->ep->port, dest);
dest->state = ACM_READY;
} else {
dest->state = ACM_INIT;
-@@ -1165,7 +1160,6 @@ acm_process_addr_req(struct acm_ep *ep, struct ibv_wc *wc, struct acm_mad *mad)
+@@ -1164,7 +1159,6 @@ acm_process_addr_req(struct acm_ep *ep, struct ibv_wc *wc, struct acm_mad *mad)
break;
acm_log(2, "src service has new qp, resetting\n");