mercury_private.h

Go to the documentation of this file.

/*
 * Copyright (C) 2013 Argonne National Laboratory, Department of Energy,
 *                    UChicago Argonne, LLC and The HDF Group.
 * All rights reserved.
 *
 * The full copyright notice, including terms governing use, modification,
 * and redistribution, is contained in the COPYING file that can be
 * found at the root of the source code distribution tree.
 */

#ifndef MERCURY_PRIVATE_H
#define MERCURY_PRIVATE_H

#include "mercury_types.h"

/* TODO temp includes */
#include "mercury_request.h"
#include "mercury_list.h"
#include "mercury_thread_condition.h"
#include "mercury_thread_mutex.h"
#include "mercury_atomic.h"

struct hg_handle {
 hg_id_t id; /* Request ID */
 hg_uint32_t cookie; /* Cookie unique to every RPC call */
 na_addr_t addr; /* Address of the RPC source/dest */
 na_tag_t tag; /* Tag used for request and response */

// void *in_struct; /* Input structure */
 void *out_struct_ptr; /* Reference to output structure */

 void *in_buf; /* Send buffer for response */
 na_size_t in_buf_size; /* Send buffer size */
 void *extra_in_buf; /* Extra send buffer */
 na_size_t extra_in_buf_size; /* Extra send buffer size */
 hg_bulk_t extra_in_handle;
 hg_request_object_t *in_request; /* TODO gone when switched to CB */

 void *out_buf; /* Recv buffer for request */
 na_size_t out_buf_size; /* Recv buffer size */
 void *extra_out_buf; /* Extra recv buffer */
 na_size_t extra_out_buf_size; /* Extra recv buffer size */
 hg_request_object_t *out_request; /* TODO gone when switched to CB */

 hg_list_entry_t *processing_entry; /* Entry in processing list */

 hg_atomic_int32_t ref_count;

 hg_bool_t local;
 hg_bool_t processed;
 hg_thread_mutex_t processed_mutex;
 hg_thread_cond_t processed_cond;
};

struct hg_info {
 hg_proc_cb_t in_proc_cb; /* Input serial/deserial callback */
 hg_proc_cb_t out_proc_cb; /* Output serial/deserial callback */
 hg_rpc_cb_t rpc_cb; /* RPC callback */
};

#ifdef __cplusplus
extern "C" {
#endif

HG_EXPORT struct hg_handle *
hg_handle_new(void);

HG_EXPORT void
hg_handle_free(struct hg_handle *);

#ifdef __cplusplus
}
#endif

#endif /* MERCURY_PRIVATE_H */