Motr
M0
|
#include <item.h>
Data Fields | |
m0_bcount_t(* | rito_payload_size )(const struct m0_rpc_item *item) |
bool(* | rito_eq )(const struct m0_rpc_item *i1, const struct m0_rpc_item *i2) |
void(* | rito_io_coalesce )(struct m0_rpc_item *head, struct m0_list *list, uint64_t size) |
int(* | rito_encode )(const struct m0_rpc_item_type *item_type, struct m0_rpc_item *item, struct m0_bufvec_cursor *cur) |
int(* | rito_decode )(const struct m0_rpc_item_type *item_type, struct m0_rpc_item **item, struct m0_bufvec_cursor *cur) |
bool(* | rito_try_merge )(struct m0_rpc_item *container, struct m0_rpc_item *component, m0_bcount_t limit) |
void(* | rito_item_get )(struct m0_rpc_item *item) |
void(* | rito_item_put )(struct m0_rpc_item *item) |
int(* | rito_deliver )(struct m0_rpc_machine *rpcmach, struct m0_rpc_item *item) |
For default implementations of these interfaces for fops
int(* rito_decode) (const struct m0_rpc_item_type *item_type, struct m0_rpc_item **item, struct m0_bufvec_cursor *cur) |
Create in memory item from serialised representation of item
int(* rito_deliver) (struct m0_rpc_machine *rpcmach, struct m0_rpc_item *item) |
This method is called on receiver side when RPC layer processed the item of this type and wants to deliver it to the upper layer. If this method is NULL, the default action is to call m0_reqh_fop_handle().
int(* rito_encode) (const struct m0_rpc_item_type *item_type, struct m0_rpc_item *item, struct m0_bufvec_cursor *cur) |
Serialises item at location given by cur.
bool(* rito_eq) (const struct m0_rpc_item *i1, const struct m0_rpc_item *i2) |
void(* rito_io_coalesce) (struct m0_rpc_item *head, struct m0_list *list, uint64_t size) |
void(* rito_item_get) (struct m0_rpc_item *item) |
RPC item type specific routine that will take reference on the item. For fops, this routine is almost always set to m0_fop_item_get().
void(* rito_item_put) (struct m0_rpc_item *item) |
RPC item type specific routine that will drop reference on the item. For fops, this routine is almost always set to m0_fop_item_put().
m0_bcount_t(* rito_payload_size) (const struct m0_rpc_item *item) |
bool(* rito_try_merge) (struct m0_rpc_item *container, struct m0_rpc_item *component, m0_bcount_t limit) |