[svn-r24122] more transactions/read contexts

 - include 2 examples for using transactions
 - IOD calls at server side still need to be updated

1 files changed, 0 insertions, 54 deletions

diff --git a/src/H5VLiod_server.c b/src/H5VLiod_server.c
index 77fba12..9bcbc5d 100644
--- a/src/H5VLiod_server.c
+++ b/src/H5VLiod_server.c
@@ -60,8 +60,6 @@ H5VLiod_start_handler(MPI_Comm comm, MPI_Info UNUSED info)
                              file_create_in_t, file_create_out_t);
     MERCURY_HANDLER_REGISTER("file_open", H5VL_iod_server_file_open, 
                              file_open_in_t, file_open_out_t);
-    MERCURY_HANDLER_REGISTER("file_flush", H5VL_iod_server_file_flush, 
-                             file_flush_in_t, ret_t);
     MERCURY_HANDLER_REGISTER("file_close", H5VL_iod_server_file_close, 
                              file_close_in_t, ret_t);
 
@@ -463,58 +461,6 @@ done:
 
 
 /*-------------------------------------------------------------------------
- * Function:	H5VL_iod_server_file_flush
- *
- * Purpose:	Function shipper registered call for File Flush.
- *              Inserts the real worker routine into the Async Engine.
- *
- * Return:	Success:	HG_SUCCESS 
- *		Failure:	Negative
- *
- * Programmer:  Mohamad Chaarawi
- *              January, 2013
- *
- *-------------------------------------------------------------------------
- */
-int
-H5VL_iod_server_file_flush(hg_handle_t handle)
-{
-    op_data_t *op_data = NULL;
-    file_flush_in_t *input = NULL;
-    int ret_value = HG_SUCCESS;
-
-    FUNC_ENTER_NOAPI_NOINIT
-
-    if(NULL == (op_data = (op_data_t *)H5MM_malloc(sizeof(op_data_t))))
-	HGOTO_ERROR(H5E_SYM, H5E_NOSPACE, HG_FAIL, "can't allocate axe op_data struct");
-
-    if(NULL == (input = (file_flush_in_t *) H5MM_malloc(sizeof(file_flush_in_t))))
-	HGOTO_ERROR(H5E_FILE, H5E_NOSPACE, HG_FAIL, "can't allocate input struct for decoding");
-
-    if(HG_FAIL == HG_Handler_get_input(handle, input))
-	HGOTO_ERROR(H5E_FILE, H5E_CANTGET, HG_FAIL, "can't get input parameters");
-
-    if(NULL == engine)
-        HGOTO_ERROR(H5E_SYM, H5E_CANTINIT, HG_FAIL, "AXE engine not started");
-
-    if(input->axe_info.count && 
-       H5VL__iod_server_finish_axe_tasks(engine, input->axe_info.start_range,  
-                                         input->axe_info.count) < 0)
-        HGOTO_ERROR(H5E_SYM, H5E_CANTINIT, HG_FAIL, "Unable to cleanup AXE tasks");
-
-    op_data->hg_handle = handle;
-    op_data->input = (void *)input;
-
-    if (AXE_SUCCEED != AXEcreate_barrier_task(engine, input->axe_info.axe_id,
-                                              H5VL_iod_server_file_flush_cb, op_data, NULL))
-        HGOTO_ERROR(H5E_FILE, H5E_CANTINIT, HG_FAIL, "can't insert task into async engine");
-
-done:
-    FUNC_LEAVE_NOAPI(ret_value)
-} /* end H5VL_iod_server_file_flush() */
-
-
-/*-------------------------------------------------------------------------
  * Function:	H5VL_iod_server_file_close
  *
  * Purpose:	Function shipper registered call for File Close.