if (ep_param_mask & DAT_EP_FIELD_RECV_EVD_HANDLE) {
if (ep_param->recv_evd_handle != NULL &&
- (DAPL_BAD_HANDLE(ep_param->recv_evd_handle, DAPL_MAGIC_EVD)
- || !((DAPL_EVD *) ep_param->recv_evd_handle)->
- evd_flags & DAT_EVD_DTO_FLAG))
+ ((DAPL_BAD_HANDLE(ep_param->recv_evd_handle, DAPL_MAGIC_EVD) ||
+ (((DAPL_EVD *)ep_param->recv_evd_handle)->evd_flags & DAT_EVD_DTO_FLAG)) == 0))
{
dat_status =
DAT_ERROR(DAT_INVALID_PARAMETER, DAT_INVALID_ARG3);
dapls_cm_acquire(conn);
/* create CM_ID, bind to local device, create QP */
- if (rdma_create_id
- (g_cm_events, &conn->cm_id, (void *)conn, RDMA_PS_TCP)) {
+ if (rdma_create_id(g_cm_events, &conn->cm_id, (void *)conn, RDMA_PS_TCP)) {
dapls_cm_release(conn);
return (dapl_convert_errno(errno, "rdma_create_id"));
}
/* open identifies the local device; per DAT specification */
/* Get family and address then set port to consumer's ServiceID */
dapl_os_memcpy(&addr, &ia_ptr->hca_ptr->hca_address, sizeof(addr));
- ((struct sockaddr_in *)&addr)->sin_port = SID_TO_PORT(ServiceID);
+ addr.sin6_port = SID_TO_PORT(ServiceID);
if (rdma_bind_addr(conn->cm_id, (struct sockaddr *)&addr)) {
if ((errno == EBUSY) || (errno == EADDRINUSE) ||