dtestx: allow scale up to 1000 EP's

Signed-off-by: Arlin Davis <arlin.r.davis@intel.com>

diff --git a/test/dtest/dtestx.c b/test/dtest/dtestx.c
index 8b3294ab704273daaf4179187550ef6cdbc6788d..931c86070ff623bfcc35edc111d194e260866580 100755 (executable)
--- a/test/dtest/dtestx.c
+++ b/test/dtest/dtestx.c
@@ -143,7 +143,7 @@ int disconnect_ep(void);
 #define RCV_RDMA_BUF_INDEX     1
 #define SEND_BUF_INDEX         2
 #define RECV_BUF_INDEX         3
-#define MAX_EP_COUNT           8
+#define MAX_EP_COUNT           1000
 #define MAX_AH_COUNT           (MAX_EP_COUNT * 2)
 
 DAT_VADDR *atomic_buf;
@@ -520,8 +520,8 @@ send_msg(void *data,
                if (ud_test) {
                        /* 
                         * single QP - ep[0] and ah[0] for client and server
-                        * multi QP  - ep[i]->ah[i] for client, to 0
-                        *             ep[0]->ah[i] for server, to all
+                        * multi QP  - ep[i]->ah[i] for client, i to i
+                        *             ep[0]->ah[i] for server, 0 to all
                         */
                        if (multi_eps) {
                                ah_idx = i;
@@ -704,7 +704,10 @@ void process_conn(int idx)
        }
 
        if (ia_attr.extension_version >= 209) {
-               /* Destroy CM resources for AH resolution */
+               LOGPRINTF("%s EP_L[%d]=%p -> cm %p CM_FREE\n",
+                          ext_event->type == DAT_IB_UD_PASSIVE_REMOTE_AH ?
+                         "PASSIVE":"ACTIVE ", ep_l, ep[ep_l],
+                         ext_event->context.as_ptr);
                dat_ib_ud_cm_free(ep[ep_l], ext_event->context.as_ptr);
        }
 
@@ -723,7 +726,7 @@ int connect_ep(char *hostname, struct sockaddr *ser_sa)
        DAT_DTO_COOKIE cookie;
        DAT_CONN_QUAL conn_qual;
        DAT_BOOLEAN in, out;
-       int i, ii, pdata, ctx;
+       int i, ii, pdata, ctx, qdepth = REG_MEM_COUNT;
        DAT_DTO_COMPLETION_EVENT_DATA *dto_event =
            &event.event_data.dto_completion_event_data;
 
@@ -762,8 +765,10 @@ int connect_ep(char *hostname, struct sockaddr *ser_sa)
        }
        ep_attr.qos = 0;
        ep_attr.recv_completion_flags = 0;
-       ep_attr.max_recv_dtos = eps * 10;
-       ep_attr.max_request_dtos = eps * 10;
+       if (ud_test && !multi_eps)
+               qdepth = eps * REG_MEM_COUNT;
+       ep_attr.max_recv_dtos = qdepth;
+       ep_attr.max_request_dtos = qdepth;
        ep_attr.max_recv_iov = 1;
        ep_attr.max_request_iov = 1;
        ep_attr.request_completion_flags = DAT_COMPLETION_DEFAULT_FLAG;
@@ -1548,7 +1553,7 @@ int main(int argc, char **argv)
                switch (rc) {
                case 'u':
                        ud_test = 1;
-                       eps = MAX_EP_COUNT / 2;
+                       eps = 4;
                        break;
                case 'm':
                        multi_eps = 1;