diff --git a/Testing/unit/hg/test_bulk.c b/Testing/unit/hg/test_bulk.c index 2fb93a0a..08739695 100644 --- a/Testing/unit/hg/test_bulk.c +++ b/Testing/unit/hg/test_bulk.c @@ -457,42 +457,48 @@ main(int argc, char *argv[]) *************************************************************************/ #ifndef HG_HAS_XDR + /* BMI has issues with those tests */ + if (strcmp(HG_Class_get_name(info.hg_class), "bmi") != 0) { + /* Create bulk info */ + hg_ret = hg_test_bulk_create( + info.hg_class, 1024, buf_size / 1024, &bulk_info); + HG_TEST_CHECK_HG_ERROR(error, hg_ret, + "hg_test_bulk_create() failed (%s)", HG_Error_to_string(hg_ret)); - /* Create bulk info */ - hg_ret = - hg_test_bulk_create(info.hg_class, 1024, buf_size / 1024, &bulk_info); - HG_TEST_CHECK_HG_ERROR(error, hg_ret, "hg_test_bulk_create() failed (%s)", - HG_Error_to_string(hg_ret)); - - /* Over-segmented bulk test (size BUFSIZE, offsets 0, 0) */ - HG_TEST("over-segmented RPC bulk (size BUFSIZE, offsets 0, 0)"); - hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, - hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, bulk_info.bulk_handle, - buf_size, 0, 0, info.request); - HG_TEST_CHECK_HG_ERROR(error, hg_ret, "hg_test_bulk_forward() failed (%s)", - HG_Error_to_string(hg_ret)); - HG_PASSED(); + /* Over-segmented bulk test (size BUFSIZE, offsets 0, 0) */ + HG_TEST("over-segmented RPC bulk (size BUFSIZE, offsets 0, 0)"); + hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, + hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, + bulk_info.bulk_handle, buf_size, 0, 0, info.request); + HG_TEST_CHECK_HG_ERROR(error, hg_ret, + "hg_test_bulk_forward() failed (%s)", HG_Error_to_string(hg_ret)); + HG_PASSED(); - /* Over-segmented bulk test (size BUFSIZE/4, offsets BUFSIZE/2 + 1, 0) */ - HG_TEST( - "over-segmented RPC bulk (size BUFSIZE/4, offsets BUFSIZE/2 + 1, 0)"); - hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, - hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, bulk_info.bulk_handle, - buf_size / 4, buf_size / 2 + 1, 0, info.request); - HG_TEST_CHECK_HG_ERROR(error, hg_ret, "hg_test_bulk_forward() failed (%s)", - HG_Error_to_string(hg_ret)); - HG_PASSED(); + /* Over-segmented bulk test (size BUFSIZE/4, offsets BUFSIZE/2 + 1, 0) + */ + HG_TEST("over-segmented RPC bulk (size BUFSIZE/4, offsets BUFSIZE/2 + " + "1, 0)"); + hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, + hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, + bulk_info.bulk_handle, buf_size / 4, buf_size / 2 + 1, 0, + info.request); + HG_TEST_CHECK_HG_ERROR(error, hg_ret, + "hg_test_bulk_forward() failed (%s)", HG_Error_to_string(hg_ret)); + HG_PASSED(); - /* Over-segmented bulk test (size BUFSIZE/8, offsets BUFSIZE/2 + 1, - * BUFSIZE/4) */ - HG_TEST("over-segmented RPC bulk (size BUFSIZE/8, offsets BUFSIZE/2 + 1," + /* Over-segmented bulk test (size BUFSIZE/8, offsets BUFSIZE/2 + 1, + * BUFSIZE/4) */ + HG_TEST( + "over-segmented RPC bulk (size BUFSIZE/8, offsets BUFSIZE/2 + 1," "BUFSIZE/4)"); - hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, - hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, bulk_info.bulk_handle, - buf_size / 8, buf_size / 2 + 1, buf_size / 4, info.request); - HG_TEST_CHECK_HG_ERROR(error, hg_ret, "hg_test_bulk_forward() failed (%s)", - HG_Error_to_string(hg_ret)); - HG_PASSED(); + hg_ret = hg_test_bulk_forward(info.handles[0], info.target_addr, + hg_test_bulk_write_id_g, hg_test_bulk_forward_cb, + bulk_info.bulk_handle, buf_size / 8, buf_size / 2 + 1, buf_size / 4, + info.request); + HG_TEST_CHECK_HG_ERROR(error, hg_ret, + "hg_test_bulk_forward() failed (%s)", HG_Error_to_string(hg_ret)); + HG_PASSED(); + } #endif /* Destroy bulk info */