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 */