ret = scif_get_nodeIDs(NULL, 0, &tp->self.node);
if (ret < 0) {
- dapl_log(1, " scif_get_nodeIDs() failed with error %d\n", errno);
+ dapl_log(1, " scif_get_nodeIDs() failed with error %s\n", strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," SCIF node_id: %d\n", (uint16_t)tp->self.node);
/* Create an endpoint for MPXYD to connect back */
listen_ep = scif_open();
if (listen_ep < 0) {
- dapl_log(1, "scif_open() failed with error %d\n", errno);
+ dapl_log(1, "scif_open() failed with error %s\n", strerror(errno));
return -1;
}
listen_port = scif_bind(listen_ep, 0);
if (listen_port < 0) {
- dapl_log(1, "scif_listen() failed with error %d\n", errno);
+ dapl_log(1, "scif_listen() failed with error %s\n", strerror(errno));
return -1;
}
ret = scif_listen(listen_ep, 1);
if (ret < 0) {
- dapl_log(1, "scif_listen() failed with error %d\n", errno);
+ dapl_log(1, "scif_listen() failed with error %s\n", strerror(errno));
return -1;
}
tp->scif_ep = scif_open();
if (tp->scif_ep < 0) {
- dapl_log(1, "scif_open() failed with error %d\n", errno);
+ dapl_log(1, "scif_open() failed with error %s\n", strerror(errno));
return -1;
}
ret = scif_connect(tp->scif_ep, &tp->peer);
len = sizeof(listen_port);
ret = scif_send(tp->scif_ep, &listen_port, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", tp->scif_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", tp->scif_ep, ret, len, strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent port number on SCIF EP\n");
ret = scif_accept(listen_ep, &tp->peer_un, &tp->scif_un_ep, SCIF_ACCEPT_SYNC);
if (ret < 0) {
- dapl_log(1, "scif_accept() for un_ep failed with error %d\n", errno);
+ dapl_log(1, "scif_accept() for un_ep failed with error %s\n", strerror(errno));
return -1;
}
ret = scif_close(listen_ep);
if (ret < 0) {
- dapl_log(1, "scif_close() failed with error %d\n", errno);
+ dapl_log(1, "scif_close() failed with error %d\n", strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION, "Connected to node 0 for unsolicited messages, ep=%d \n", tp->scif_un_ep);
len = sizeof(dat_mix_open_t);
ret = scif_send(tp->scif_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", tp->scif_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", tp->scif_ep, ret, len, strerror(errno));
+ return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
msg.hdr.status = 1; /* make sure we update status from response */
ret = scif_recv(tp->scif_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", tp->scif_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", tp->scif_ep, ret, len, strerror(errno));
return -1;
}
len = sizeof(dat_mix_listen_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
/* listen response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_LISTEN ||
len = sizeof(dat_mix_hdr_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.op));
/* listen free response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.ver != DAT_MIX_VER || msg.op != MIX_LISTEN_FREE ||
len = sizeof(dat_mix_mr_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
len = sizeof(dat_mix_hdr_t);
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_MR_CREATE ||
len = sizeof(dat_mix_mr_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
len = sizeof(dat_mix_hdr_t);
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_MR_FREE ||
len = sizeof(dat_mix_qp_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
/* wait for response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_QP_CREATE ||
len = sizeof(dat_mix_hdr_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.op));
/* response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.ver != DAT_MIX_VER || msg.op != MIX_QP_FREE ||
len = sizeof(dat_mix_cq_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
/* wait for response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_CQ_CREATE ||
len = sizeof(dat_mix_hdr_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.op));
/* response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.ver != DAT_MIX_VER || msg.op != MIX_CQ_FREE ||
len = sizeof(dat_mix_dto_comp_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
/* response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_CQ_POLL ||
len = sizeof(dat_mix_send_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
for (i=0; i < wr->num_sge && (msg.hdr.flags & MIX_OP_INLINE); i++) {
i, wr->sg_list[i].addr, wr->sg_list[i].length, mix_ep);
ret = scif_send(mix_ep, (void*)wr->sg_list[i].addr, wr->sg_list[i].length, SCIF_SEND_BLOCK);
if (ret != wr->sg_list[i].length)
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n",
- mix_ep, ret, wr->sg_list[i].length);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n",
+ mix_ep, ret, wr->sg_list[i].length, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent MIX_SEND on SCIF EP %d, len=%d\n", mix_ep, txlen);
return 0;
len = sizeof(dat_mix_cm_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
len = sizeof(dat_mix_cm_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
len = sizeof(dat_mix_cm_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
/* wait for response */
ret = scif_recv(mix_ep, &msg, len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: rcv on new_ep %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
if (msg.hdr.ver != DAT_MIX_VER || msg.hdr.op != MIX_CM_REQ ||
len = sizeof(dat_mix_cm_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
len = sizeof(dat_mix_cm_t);
ret = scif_send(mix_ep, &msg, len, SCIF_SEND_BLOCK);
if (ret != len) {
- dapl_log(1, " ERR: send on %d, ret %d, exp %d\n", mix_ep, ret, len);
+ dapl_log(1, " ERR: send on %d, ret %d, exp %d, error %s\n", mix_ep, ret, len, strerror(errno));
}
dapl_log(DAPL_DBG_TYPE_EXTENSION," Sent %s request on SCIF EP\n", mix_op_str(msg.hdr.op));
}
len = sizeof(dat_mix_cm_event_t) - sizeof(dat_mix_hdr_t);
ret = scif_recv(scif_ep, ((char*)pmsg + sizeof(dat_mix_hdr_t)), len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d\n", ret, len);
+ dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d, error %s\n", ret, len, strerror(errno));
return ret;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION,
len = sizeof(dat_mix_dto_comp_t) - sizeof(dat_mix_hdr_t);
ret = scif_recv(scif_ep, ((char*)pmsg + sizeof(dat_mix_hdr_t)), len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d\n", ret, len);
+ dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d, error %s\n", ret, len, strerror(errno));
return ret;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION,
len = sizeof(dat_mix_cm_t) - sizeof(dat_mix_hdr_t);
ret = scif_recv(scif_ep, ((char*)pmsg + sizeof(dat_mix_hdr_t)), len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d\n", ret, len);
+ dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d, error %s\n", ret, len, strerror(errno));
return ret;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION,
len = sizeof(dat_mix_cm_t) - sizeof(dat_mix_hdr_t);
ret = scif_recv(scif_ep, ((char*)pmsg + sizeof(dat_mix_hdr_t)), len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d\n", ret, len);
+ dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d, error %s\n", ret, len, strerror(errno));
return ret;
}
len = sizeof(dat_mix_cm_t) - sizeof(dat_mix_hdr_t);
ret = scif_recv(scif_ep, ((char*)pmsg + sizeof(dat_mix_hdr_t)), len, SCIF_RECV_BLOCK);
if (ret != len) {
- dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d\n", ret, len);
+ dapl_log(DAPL_DBG_TYPE_ERR, " ERR: ret %d, exp %d, error %s\n", ret, len, strerror(errno));
return ret;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION,
ret = scif_recv(scif_ep, phdr, len, SCIF_RECV_BLOCK);
if ((ret != len) || (phdr->ver != DAT_MIX_VER) || phdr->flags != MIX_OP_REQ) {
dapl_log(DAPL_DBG_TYPE_ERR,
- " ERR: rcv on scif_ep %d, ret %d, exp %d, VER=%d flgs=%d\n",
- scif_ep, ret, len, phdr->ver, phdr->flags);
+ " ERR: rcv on scif_ep %d, ret %d, exp %d, VER=%d flgs=%d, error %s\n",
+ scif_ep, ret, len, phdr->ver, phdr->flags, strerror(errno));
return -1;
}
dapl_log(DAPL_DBG_TYPE_EXTENSION, " ver %d, op %d, flags %d\n", phdr->ver, phdr->op, phdr->flags);