m_wr = (struct ibv_send_wr *)(m_qp->wr_buf + (DAT_MCM_WR * wr_idx));
while ((m_wr->wr_id != m_wr->wr.atomic.swap) && (--poll_cnt));
- mlog(0, " wr_id %p poll_cnt %d\n", m_wr->wr.atomic.swap, poll_cnt);
+ mlog(1, " wr_id %p poll_cnt %d\n", m_wr->wr.atomic.swap, poll_cnt);
if (m_wr->wr_id == m_wr->wr.atomic.swap) {
char *sbuf = (char*)m_wr->sg_list->addr;
wc.vendor_err = ret;
mix_dto_event(m_qp->ib_qp->send_cq->cq_context, &wc, 1);
}
- mlog(0, " - wr_id %p posted\n", m_wr->wr_id);
+ mlog(1, " - wr_id %p posted\n", m_wr->wr_id);
m_wr->wr_id = 0;
posted++;
if (++m_qp->wr_tl == m_qp->wr_end)
m_qp->wr_tl = 0;
} else {
*data = *data + 1;
- mlog(0, " wr_id %p, data not ready, %d WR's pending, wr_hd=%d\n", pmsg->wr.wr_id, *data, wr_idx);
+ mlog(1, " wr_id %p, data not ready, %d WR's pending, wr_hd=%d\n", pmsg->wr.wr_id, *data, wr_idx);
}
#else
wr_enqueued--;
} else {
*data = *data + wr_enqueued;
- mlog(0, " wr_id %p, data not ready, %d WR's pending, wr_hd=%d\n", pmsg->wr.wr_id, *data, wr_idx);
+ mlog(1, " wr_id %p, data not ready, %d WR's pending, wr_hd=%d\n", pmsg->wr.wr_id, *data, wr_idx);
break;
}
}