SOL_RDS
if (level != SOL_RDS) {
if (level != SOL_RDS)
err = put_cmsg(msghdr, SOL_RDS, RDS_CMSG_RDMA_STATUS,
err = put_cmsg(msghdr, SOL_RDS, RDS_CMSG_CONG_UPDATE,
ret = put_cmsg(msg, SOL_RDS, RDS_CMSG_RDMA_DEST,
ret = put_cmsg(msg, SOL_RDS, RDS_CMSG_RXPATH_LATENCY,
if (put_cmsg(msg, SOL_RDS, RDS_CMSG_ZCOPY_COMPLETION, sizeof(*done),
if (cmsg->cmsg_level != SOL_RDS)
if (cmsg->cmsg_level != SOL_RDS)
if (cmsg->cmsg_level != SOL_RDS)
cm->cmsg_level = SOL_RDS;
if (cmsg->cmsg_level == SOL_RDS &&
EXPECT_EQ(-1, getsockopt(self->fd, SOL_RDS, SO_RDS_TRANSPORT, buf,
EXPECT_EQ(-1, getsockopt(self->fd, SOL_RDS, RDS_INFO_COUNTERS, NULL,
getsockopt(self->fd, SOL_RDS, RDS_INFO_COUNTERS, NULL, &need);
ret = getsockopt(self->fd, SOL_RDS, RDS_INFO_COUNTERS, buf, &len);
getsockopt(self->fd, SOL_RDS, RDS_INFO_COUNTERS, NULL, &need);
EXPECT_EQ(-1, getsockopt(self->fd, SOL_RDS, RDS_INFO_COUNTERS, small,
ASSERT_EQ(0, getsockopt(self->fd, SOL_RDS, RDS_RECVERR, &val, &len));
ASSERT_EQ(0, setsockopt(self->fd, SOL_RDS, RDS_RECVERR, &val, len));
ASSERT_EQ(0, getsockopt(self->fd, SOL_RDS, RDS_RECVERR, &val, &len));
EXPECT_EQ(-1, getsockopt(self->fd, SOL_RDS, RDS_RECVERR, buf, &len));
ASSERT_EQ(0, getsockopt(self->fd, SOL_RDS, SO_RDS_TRANSPORT, &val,