Commit ef391eac authored by James Simmons's avatar James Simmons Committed by Greg Kroah-Hartman

staging: lustre: lnet: change lnet_md_t to proper structure

Change lnet_md_t from typedef to proper structure.
Signed-off-by: default avatarJames Simmons <uja.ornl@yahoo.com>
Reviewed-on: https://review.whamcloud.com/20831Reviewed-by: default avatarOlaf Weber <olaf@sgi.com>
Reviewed-by: default avatarDoug Oucharek <doug.s.oucharek@intel.com>
Reviewed-by: default avatarDmitry Eremin <dmitry.eremin@intel.com>
Reviewed-by: default avatarOleg Drokin <oleg.drokin@intel.com>
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent d9331056
...@@ -125,11 +125,11 @@ int LNetMEUnlink(struct lnet_handle_me current_in); ...@@ -125,11 +125,11 @@ int LNetMEUnlink(struct lnet_handle_me current_in);
* @{ * @{
*/ */
int LNetMDAttach(struct lnet_handle_me current_in, int LNetMDAttach(struct lnet_handle_me current_in,
lnet_md_t md_in, struct lnet_md md_in,
lnet_unlink_t unlink_in, lnet_unlink_t unlink_in,
struct lnet_handle_md *md_handle_out); struct lnet_handle_md *md_handle_out);
int LNetMDBind(lnet_md_t md_in, int LNetMDBind(struct lnet_md md_in,
lnet_unlink_t unlink_in, lnet_unlink_t unlink_in,
struct lnet_handle_md *md_handle_out); struct lnet_handle_md *md_handle_out);
......
...@@ -194,7 +194,7 @@ lnet_eq_free(struct lnet_eq *eq) ...@@ -194,7 +194,7 @@ lnet_eq_free(struct lnet_eq *eq)
} }
static inline struct lnet_libmd * static inline struct lnet_libmd *
lnet_md_alloc(lnet_md_t *umd) lnet_md_alloc(struct lnet_md *umd)
{ {
struct lnet_libmd *md; struct lnet_libmd *md;
unsigned int size; unsigned int size;
...@@ -626,7 +626,7 @@ void lnet_copy_kiov2iter(struct iov_iter *to, ...@@ -626,7 +626,7 @@ void lnet_copy_kiov2iter(struct iov_iter *to,
void lnet_me_unlink(struct lnet_me *me); void lnet_me_unlink(struct lnet_me *me);
void lnet_md_unlink(struct lnet_libmd *md); void lnet_md_unlink(struct lnet_libmd *md);
void lnet_md_deconstruct(struct lnet_libmd *lmd, lnet_md_t *umd); void lnet_md_deconstruct(struct lnet_libmd *lmd, struct lnet_md *umd);
void lnet_register_lnd(struct lnet_lnd *lnd); void lnet_register_lnd(struct lnet_lnd *lnd);
void lnet_unregister_lnd(struct lnet_lnd *lnd); void lnet_unregister_lnd(struct lnet_lnd *lnd);
......
...@@ -377,7 +377,7 @@ typedef enum { ...@@ -377,7 +377,7 @@ typedef enum {
* Defines the visible parts of a memory descriptor. Values of this type * Defines the visible parts of a memory descriptor. Values of this type
* are used to initialize memory descriptors. * are used to initialize memory descriptors.
*/ */
typedef struct { struct lnet_md {
/** /**
* Specify the memory region associated with the memory descriptor. * Specify the memory region associated with the memory descriptor.
* If the options field has: * If the options field has:
...@@ -471,7 +471,7 @@ typedef struct { ...@@ -471,7 +471,7 @@ typedef struct {
* descriptor are not logged. * descriptor are not logged.
*/ */
struct lnet_handle_eq eq_handle; struct lnet_handle_eq eq_handle;
} lnet_md_t; };
/* /*
* Max Transfer Unit (minimum supported everywhere). * Max Transfer Unit (minimum supported everywhere).
...@@ -485,29 +485,29 @@ typedef struct { ...@@ -485,29 +485,29 @@ typedef struct {
#define LNET_MAX_IOV 256 #define LNET_MAX_IOV 256
/** /**
* Options for the MD structure. See lnet_md_t::options. * Options for the MD structure. See lnet_md::options.
*/ */
#define LNET_MD_OP_PUT (1 << 0) #define LNET_MD_OP_PUT (1 << 0)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_OP_GET (1 << 1) #define LNET_MD_OP_GET (1 << 1)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_MANAGE_REMOTE (1 << 2) #define LNET_MD_MANAGE_REMOTE (1 << 2)
/* unused (1 << 3) */ /* unused (1 << 3) */
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_TRUNCATE (1 << 4) #define LNET_MD_TRUNCATE (1 << 4)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_ACK_DISABLE (1 << 5) #define LNET_MD_ACK_DISABLE (1 << 5)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_IOVEC (1 << 6) #define LNET_MD_IOVEC (1 << 6)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_MAX_SIZE (1 << 7) #define LNET_MD_MAX_SIZE (1 << 7)
/** See lnet_md_t::options. */ /** See lnet_md::options. */
#define LNET_MD_KIOV (1 << 8) #define LNET_MD_KIOV (1 << 8)
/* For compatibility with Cray Portals */ /* For compatibility with Cray Portals */
#define LNET_MD_PHYS 0 #define LNET_MD_PHYS 0
/** Infinite threshold on MD operations. See lnet_md_t::threshold */ /** Infinite threshold on MD operations. See lnet_md::threshold */
#define LNET_MD_THRESH_INF (-1) #define LNET_MD_THRESH_INF (-1)
/* NB lustre portals uses struct iovec internally! */ /* NB lustre portals uses struct iovec internally! */
...@@ -591,7 +591,7 @@ typedef struct { ...@@ -591,7 +591,7 @@ typedef struct {
* The length (in bytes) of the data that was manipulated by the * The length (in bytes) of the data that was manipulated by the
* operation. For truncated operations, the manipulated length will be * operation. For truncated operations, the manipulated length will be
* the number of bytes specified by the MD (possibly with an offset, * the number of bytes specified by the MD (possibly with an offset,
* see lnet_md_t). For all other operations, the manipulated length * see lnet_md). For all other operations, the manipulated length
* will be the length of the requested operation, i.e. rlength. * will be the length of the requested operation, i.e. rlength.
*/ */
unsigned int mlength; unsigned int mlength;
...@@ -605,7 +605,7 @@ typedef struct { ...@@ -605,7 +605,7 @@ typedef struct {
* been processed. In particular, the threshold field in md will * been processed. In particular, the threshold field in md will
* reflect the value of the threshold after the operation occurred. * reflect the value of the threshold after the operation occurred.
*/ */
lnet_md_t md; struct lnet_md md;
/** /**
* 64 bits of out-of-band user data. Only valid for LNET_EVENT_PUT. * 64 bits of out-of-band user data. Only valid for LNET_EVENT_PUT.
* \see LNetPut * \see LNetPut
...@@ -627,7 +627,7 @@ typedef struct { ...@@ -627,7 +627,7 @@ typedef struct {
* The displacement (in bytes) into the memory region that the * The displacement (in bytes) into the memory region that the
* operation used. The offset can be determined by the operation for * operation used. The offset can be determined by the operation for
* a remote managed MD or by the local MD. * a remote managed MD or by the local MD.
* \see lnet_md_t::options * \see lnet_md::options
*/ */
unsigned int offset; unsigned int offset;
/** /**
...@@ -660,7 +660,7 @@ typedef void (*lnet_eq_handler_t)(lnet_event_t *event); ...@@ -660,7 +660,7 @@ typedef void (*lnet_eq_handler_t)(lnet_event_t *event);
* operation completes (i.e., when the data has been written to a MD of the * operation completes (i.e., when the data has been written to a MD of the
* target process). * target process).
* *
* \see lnet_md_t::options for the discussion on LNET_MD_ACK_DISABLE by which * \see lnet_md::options for the discussion on LNET_MD_ACK_DISABLE by which
* acknowledgments can be disabled for a MD. * acknowledgments can be disabled for a MD.
*/ */
typedef enum { typedef enum {
......
...@@ -903,7 +903,7 @@ lnet_ping_info_setup(struct lnet_ping_info **ppinfo, ...@@ -903,7 +903,7 @@ lnet_ping_info_setup(struct lnet_ping_info **ppinfo,
{ {
lnet_process_id_t id = {LNET_NID_ANY, LNET_PID_ANY}; lnet_process_id_t id = {LNET_NID_ANY, LNET_PID_ANY};
struct lnet_handle_me me_handle; struct lnet_handle_me me_handle;
lnet_md_t md = { NULL }; struct lnet_md md = { NULL };
int rc, rc2; int rc, rc2;
if (set_eq) { if (set_eq) {
...@@ -2134,7 +2134,7 @@ static int lnet_ping(lnet_process_id_t id, int timeout_ms, ...@@ -2134,7 +2134,7 @@ static int lnet_ping(lnet_process_id_t id, int timeout_ms,
struct lnet_handle_eq eqh; struct lnet_handle_eq eqh;
struct lnet_handle_md mdh; struct lnet_handle_md mdh;
lnet_event_t event; lnet_event_t event;
lnet_md_t md = { NULL }; struct lnet_md md = { NULL };
int which; int which;
int unlinked = 0; int unlinked = 0;
int replied = 0; int replied = 0;
......
...@@ -84,7 +84,7 @@ lnet_md_unlink(struct lnet_libmd *md) ...@@ -84,7 +84,7 @@ lnet_md_unlink(struct lnet_libmd *md)
} }
static int static int
lnet_md_build(struct lnet_libmd *lmd, lnet_md_t *umd, int unlink) lnet_md_build(struct lnet_libmd *lmd, struct lnet_md *umd, int unlink)
{ {
int i; int i;
unsigned int niov; unsigned int niov;
...@@ -204,7 +204,7 @@ lnet_md_link(struct lnet_libmd *md, struct lnet_handle_eq eq_handle, int cpt) ...@@ -204,7 +204,7 @@ lnet_md_link(struct lnet_libmd *md, struct lnet_handle_eq eq_handle, int cpt)
/* must be called with lnet_res_lock held */ /* must be called with lnet_res_lock held */
void void
lnet_md_deconstruct(struct lnet_libmd *lmd, lnet_md_t *umd) lnet_md_deconstruct(struct lnet_libmd *lmd, struct lnet_md *umd)
{ {
/* NB this doesn't copy out all the iov entries so when a /* NB this doesn't copy out all the iov entries so when a
* discontiguous MD is copied out, the target gets to know the * discontiguous MD is copied out, the target gets to know the
...@@ -223,7 +223,7 @@ lnet_md_deconstruct(struct lnet_libmd *lmd, lnet_md_t *umd) ...@@ -223,7 +223,7 @@ lnet_md_deconstruct(struct lnet_libmd *lmd, lnet_md_t *umd)
} }
static int static int
lnet_md_validate(lnet_md_t *umd) lnet_md_validate(struct lnet_md *umd)
{ {
if (!umd->start && umd->length) { if (!umd->start && umd->length) {
CERROR("MD start pointer can not be NULL with length %u\n", CERROR("MD start pointer can not be NULL with length %u\n",
...@@ -267,7 +267,7 @@ lnet_md_validate(lnet_md_t *umd) ...@@ -267,7 +267,7 @@ lnet_md_validate(lnet_md_t *umd)
* a MD. * a MD.
*/ */
int int
LNetMDAttach(struct lnet_handle_me meh, lnet_md_t umd, LNetMDAttach(struct lnet_handle_me meh, struct lnet_md umd,
lnet_unlink_t unlink, struct lnet_handle_md *handle) lnet_unlink_t unlink, struct lnet_handle_md *handle)
{ {
LIST_HEAD(matches); LIST_HEAD(matches);
...@@ -350,7 +350,7 @@ EXPORT_SYMBOL(LNetMDAttach); ...@@ -350,7 +350,7 @@ EXPORT_SYMBOL(LNetMDAttach);
* LNetInvalidateHandle() on it. * LNetInvalidateHandle() on it.
*/ */
int int
LNetMDBind(lnet_md_t umd, lnet_unlink_t unlink, LNetMDBind(struct lnet_md umd, lnet_unlink_t unlink,
struct lnet_handle_md *handle) struct lnet_handle_md *handle)
{ {
struct lnet_libmd *md; struct lnet_libmd *md;
......
...@@ -905,7 +905,7 @@ lnet_create_rc_data_locked(struct lnet_peer *gateway) ...@@ -905,7 +905,7 @@ lnet_create_rc_data_locked(struct lnet_peer *gateway)
{ {
struct lnet_rc_data *rcd = NULL; struct lnet_rc_data *rcd = NULL;
struct lnet_ping_info *pi; struct lnet_ping_info *pi;
lnet_md_t md; struct lnet_md md;
int rc; int rc;
int i; int i;
......
...@@ -359,7 +359,7 @@ srpc_post_passive_rdma(int portal, int local, __u64 matchbits, void *buf, ...@@ -359,7 +359,7 @@ srpc_post_passive_rdma(int portal, int local, __u64 matchbits, void *buf,
struct lnet_handle_md *mdh, struct srpc_event *ev) struct lnet_handle_md *mdh, struct srpc_event *ev)
{ {
int rc; int rc;
lnet_md_t md; struct lnet_md md;
struct lnet_handle_me meh; struct lnet_handle_me meh;
rc = LNetMEAttach(portal, peer, matchbits, 0, LNET_UNLINK, rc = LNetMEAttach(portal, peer, matchbits, 0, LNET_UNLINK,
...@@ -398,7 +398,7 @@ srpc_post_active_rdma(int portal, __u64 matchbits, void *buf, int len, ...@@ -398,7 +398,7 @@ srpc_post_active_rdma(int portal, __u64 matchbits, void *buf, int len,
struct lnet_handle_md *mdh, struct srpc_event *ev) struct lnet_handle_md *mdh, struct srpc_event *ev)
{ {
int rc; int rc;
lnet_md_t md; struct lnet_md md;
md.user_ptr = ev; md.user_ptr = ev;
md.start = buf; md.start = buf;
......
...@@ -49,7 +49,7 @@ static int ptl_send_buf(struct lnet_handle_md *mdh, void *base, int len, ...@@ -49,7 +49,7 @@ static int ptl_send_buf(struct lnet_handle_md *mdh, void *base, int len,
unsigned int offset) unsigned int offset)
{ {
int rc; int rc;
lnet_md_t md; struct lnet_md md;
LASSERT(portal != 0); LASSERT(portal != 0);
CDEBUG(D_INFO, "conn=%p id %s\n", conn, libcfs_id2str(conn->c_peer)); CDEBUG(D_INFO, "conn=%p id %s\n", conn, libcfs_id2str(conn->c_peer));
...@@ -116,7 +116,7 @@ static int ptlrpc_register_bulk(struct ptlrpc_request *req) ...@@ -116,7 +116,7 @@ static int ptlrpc_register_bulk(struct ptlrpc_request *req)
int total_md; int total_md;
u64 mbits; u64 mbits;
struct lnet_handle_me me_h; struct lnet_handle_me me_h;
lnet_md_t md; struct lnet_md md;
if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_GET_NET)) if (OBD_FAIL_CHECK(OBD_FAIL_PTLRPC_BULK_GET_NET))
return 0; return 0;
...@@ -473,7 +473,7 @@ int ptl_send_rpc(struct ptlrpc_request *request, int noreply) ...@@ -473,7 +473,7 @@ int ptl_send_rpc(struct ptlrpc_request *request, int noreply)
int mpflag = 0; int mpflag = 0;
struct ptlrpc_connection *connection; struct ptlrpc_connection *connection;
struct lnet_handle_me reply_me_h; struct lnet_handle_me reply_me_h;
lnet_md_t reply_md; struct lnet_md reply_md;
struct obd_import *imp = request->rq_import; struct obd_import *imp = request->rq_import;
struct obd_device *obd = imp->imp_obd; struct obd_device *obd = imp->imp_obd;
...@@ -721,7 +721,7 @@ int ptlrpc_register_rqbd(struct ptlrpc_request_buffer_desc *rqbd) ...@@ -721,7 +721,7 @@ int ptlrpc_register_rqbd(struct ptlrpc_request_buffer_desc *rqbd)
struct ptlrpc_service *service = rqbd->rqbd_svcpt->scp_service; struct ptlrpc_service *service = rqbd->rqbd_svcpt->scp_service;
static lnet_process_id_t match_id = {LNET_NID_ANY, LNET_PID_ANY}; static lnet_process_id_t match_id = {LNET_NID_ANY, LNET_PID_ANY};
int rc; int rc;
lnet_md_t md; struct lnet_md md;
struct lnet_handle_me me_h; struct lnet_handle_me me_h;
CDEBUG(D_NET, "LNetMEAttach: portal %d\n", CDEBUG(D_NET, "LNetMEAttach: portal %d\n",
......
...@@ -40,7 +40,7 @@ ...@@ -40,7 +40,7 @@
#include "ptlrpc_internal.h" #include "ptlrpc_internal.h"
void ptlrpc_fill_bulk_md(lnet_md_t *md, struct ptlrpc_bulk_desc *desc, void ptlrpc_fill_bulk_md(struct lnet_md *md, struct ptlrpc_bulk_desc *desc,
int mdidx) int mdidx)
{ {
int offset = mdidx * LNET_MAX_IOV; int offset = mdidx * LNET_MAX_IOV;
......
...@@ -234,7 +234,7 @@ extern struct ptlrpc_nrs_pol_conf nrs_conf_fifo; ...@@ -234,7 +234,7 @@ extern struct ptlrpc_nrs_pol_conf nrs_conf_fifo;
int ptlrpc_expire_one_request(struct ptlrpc_request *req, int async_unlink); int ptlrpc_expire_one_request(struct ptlrpc_request *req, int async_unlink);
/* pers.c */ /* pers.c */
void ptlrpc_fill_bulk_md(lnet_md_t *md, struct ptlrpc_bulk_desc *desc, void ptlrpc_fill_bulk_md(struct lnet_md *md, struct ptlrpc_bulk_desc *desc,
int mdcnt); int mdcnt);
/* pack_generic.c */ /* pack_generic.c */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment