Refresh of dsocket

diff --git a/src/rsocket.c b/src/rsocket.c
index 56f6f39b907ed62a93d39a70fdeab47222101e02..7dc5409e31171caeb7365076d6cf90945209bc98 100644 (file)
--- a/src/rsocket.c
+++ b/src/rsocket.c
@@ -1040,7 +1040,6 @@ int rsocket(int domain, int type, int protocol)
                rs->cm_id->route.addr.src_addr.sa_family = domain;
                index = rs->cm_id->channel->fd;
        } else {
-printf("rsocket DGRAM\n");
                ret = ds_init(rs, domain);
                if (ret)
                        goto err;
@@ -1887,6 +1886,9 @@ static void ds_poll_cqs(struct rsocket *rs)
        int ret, cnt;
 
        qp = rs->qp_list;
+       if (!qp)
+               return;
+
        do {
                cnt = 0;
                do {