dtest: dat_evd_query for correct size

Signed-off by: Arlin Davis <ardavis@ichips.intel.com>

diff --git a/test/dtest/dtest.c b/test/dtest/dtest.c
index 9f0f253c7d545600ab3f833f1b8d058f5ebdfa96..314dcdf0c41468ecb9dea7f907de7bdcbc5f095c 100755 (executable)
--- a/test/dtest/dtest.c
+++ b/test/dtest/dtest.c
@@ -1758,6 +1758,7 @@ DAT_RETURN
 create_events(void)
 {
     DAT_RETURN ret;
+    DAT_EVD_PARAM param;
 
     /* create CNO */
     if (use_cno) {
@@ -1814,7 +1815,7 @@ create_events(void)
 
     /* create dto SND EVD, with CNO if use_cno was set */
     ret = dat_evd_create( h_ia,
-                         MSG_BUF_COUNT+MAX_RDMA_RD+burst*2,
+                         (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2,
                          h_dto_cno,
                          DAT_EVD_DTO_FLAG,
                          &h_dto_req_evd  );
@@ -1842,6 +1843,26 @@ create_events(void)
         LOGPRINTF("%d dto_rcv_evd created %p\n", getpid(), h_dto_rcv_evd );
     }
 
+    /* query DTO req EVD and check size */
+    ret = dat_evd_query( h_dto_req_evd,
+                          DAT_EVD_FIELD_EVD_QLEN,
+                          &param  );
+    if(ret != DAT_SUCCESS) {
+         fprintf(stderr, "%d Error dat_evd_query request evd: %s\n",
+                            getpid(),DT_RetToString(ret));
+         return (ret);
+    }
+    else if (param.evd_qlen < (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2) {
+         fprintf(stderr, "%d Error dat_evd qsize too small: %d < %d\n",
+                 getpid(), param.evd_qlen, 
+                 (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2);
+         return (ret);
+    }
+  
+    LOGPRINTF("%d dto_req_evd QLEN - requested %d and actual %d\n", 
+              getpid(), (MSG_BUF_COUNT+MAX_RDMA_RD+burst)*2,
+              param.evd_qlen);
+
     return DAT_SUCCESS;
 }