From 27f9f0c106662cc7b41bcb747495860a1b6c7133 Mon Sep 17 00:00:00 2001 From: Steve Wise Date: Tue, 2 May 2006 21:33:35 +0000 Subject: [PATCH] r6873: Transaction test change to comply with the iWARP MPA protocol's "Connection Startup Rules". Signed-off-by: Steve Wise Signed-off-by: James Lentini --- test/dapltest/test/dapl_transaction_test.c | 68 ++++++++++++++++------ 1 file changed, 51 insertions(+), 17 deletions(-) diff --git a/test/dapltest/test/dapl_transaction_test.c b/test/dapltest/test/dapl_transaction_test.c index 42f08e4..b01baa0 100644 --- a/test/dapltest/test/dapl_transaction_test.c +++ b/test/dapltest/test/dapl_transaction_test.c @@ -972,38 +972,42 @@ retry: } /* end foreach op */ /* - * Send our memory info (synchronously) + * Send our memory info. The client performs the first send to comply + * with the iWARP MPA protocol's "Connection Startup Rules". */ DT_Tdep_PT_Debug (1,(phead,"Test[" F64x "]: Sending %s Memory Info\n", test_ptr->base_port, test_ptr->is_server ? "Server" : "Client")); - /* post the send buffer */ - if (!DT_post_send_buffer (phead, + if (!test_ptr->is_server ) { + + /* post the send buffer */ + if (!DT_post_send_buffer (phead, test_ptr->ep_context[i].ep_handle, test_ptr->ep_context[i].bp, RMI_SEND_BUFFER_ID, buff_size)) - { - /* error message printed by DT_post_send_buffer */ - goto test_failure; - } - /* reap the send and verify it */ - dto_cookie.as_64 = LZERO; - dto_cookie.as_ptr = - (DAT_PVOID) DT_Bpool_GetBuffer ( - test_ptr->ep_context[i].bp, - RMI_SEND_BUFFER_ID); - if (!DT_dto_event_wait (phead, test_ptr->reqt_evd_hdl, &dto_stat) || - !DT_dto_check ( phead, + { + /* error message printed by DT_post_send_buffer */ + goto test_failure; + } + /* reap the send and verify it */ + dto_cookie.as_64 = LZERO; + dto_cookie.as_ptr = + (DAT_PVOID) DT_Bpool_GetBuffer ( + test_ptr->ep_context[i].bp, + RMI_SEND_BUFFER_ID); + if (!DT_dto_event_wait (phead, test_ptr->reqt_evd_hdl, &dto_stat) || + !DT_dto_check ( phead, &dto_stat, test_ptr->ep_context[i].ep_handle, buff_size, dto_cookie, test_ptr->is_server ? "Client_Mem_Info_Send" : "Server_Mem_Info_Send")) - { - goto test_failure; + { + goto test_failure; + } } /* @@ -1029,6 +1033,36 @@ retry: goto test_failure; } + if (test_ptr->is_server ) { + /* post the send buffer */ + if (!DT_post_send_buffer (phead, + test_ptr->ep_context[i].ep_handle, + test_ptr->ep_context[i].bp, + RMI_SEND_BUFFER_ID, + buff_size)) + { + /* error message printed by DT_post_send_buffer */ + goto test_failure; + } + /* reap the send and verify it */ + dto_cookie.as_64 = LZERO; + dto_cookie.as_ptr = + (DAT_PVOID) DT_Bpool_GetBuffer ( + test_ptr->ep_context[i].bp, + RMI_SEND_BUFFER_ID); + if (!DT_dto_event_wait (phead, test_ptr->reqt_evd_hdl, &dto_stat) || + !DT_dto_check ( phead, + &dto_stat, + test_ptr->ep_context[i].ep_handle, + buff_size, + dto_cookie, + test_ptr->is_server ? "Client_Mem_Info_Send" + : "Server_Mem_Info_Send")) + { + goto test_failure; + } + } + /* * Extract what we need */ -- 2.41.0