fds.events = event;
fds.revents = 0;
ret = poll(&fds, 1, 0);
- dapl_log(DAPL_DBG_TYPE_CM, " dapl_poll: fd=%d ret=%d, evnts=0x%x\n",
+ dapl_log(DAPL_DBG_TYPE_THREAD, " dapl_poll: fd=%d ret=%d, evnts=0x%x\n",
s, ret, fds.revents);
if (ret == 0)
return 0;
{
int ret;
- dapl_dbg_log(DAPL_DBG_TYPE_CM, " dapl_select: sleep, fds=%d\n",
+ dapl_dbg_log(DAPL_DBG_TYPE_THREAD, " dapl_select: sleep, fds=%d\n",
set->index);
ret = poll(set->set, set->index, time_ms);
- dapl_dbg_log(DAPL_DBG_TYPE_CM, " dapl_select: wakeup, ret=0x%x\n", ret);
+ dapl_dbg_log(DAPL_DBG_TYPE_THREAD, " dapl_select: wakeup, ret=0x%x\n", ret);
return ret;
}
#endif
{
DAPL_EP *ep = (DAPL_EP *)ep_handle;
dp_ib_cm_handle_t cm;
+ union dcm_addr *ucm_ia = (union dcm_addr *) r_addr;
+
+ dapl_log(DAPL_DBG_TYPE_CM, " UCM connect -> AF %d LID 0x%x QPN 0x%x GID"
+ " 0x" F64x ":" F64x " port %d ep_map %s sl %d qt %d\n",
+ ucm_ia->ib.family, ntohl(ucm_ia->ib.qpn), ntohs(ucm_ia->ib.lid),
+ (unsigned long long)ntohll(*(uint64_t*)&ucm_ia->ib.gid[0]),
+ (unsigned long long)ntohll(*(uint64_t*)&ucm_ia->ib.gid[8]),
+ ntohs(ucm_ia->ib.port), ucm_ia->ib.sl, ucm_ia->ib.qp_type);
/* create CM object, initialize SRC info from EP */
cm = dapls_ib_cm_create(ep);