Motr  M0
bulk.h File Reference
#include "lib/vec.h"
#include "lib/tlist.h"
#include "lib/mutex.h"
#include "lib/chan.h"
#include "net/net.h"
#include "xcode/xcode.h"
Include dependency graph for bulk.h:

Go to the source code of this file.

Data Structures

struct  m0_rpc_bulk_buf
 
struct  m0_rpc_bulk
 

Macros

#define __MOTR_RPC_BULK_H__
 

Enumerations

enum  m0_rpc_bulk_op_states { M0_RPC_BULK_OP_INITIATE, M0_RPC_BULK_OP_FINISH }
 
enum  { M0_RPC_BULK_NETBUF_ALLOCATED = (1 << 0), M0_RPC_BULK_NETBUF_REGISTERED = (1 << 1), M0_RPC_BULK_NETBUF_QUEUED = (1 << 2), M0_RPC_BULK_TMO = 60 }
 
enum  m0_rpc_bulk_op_type { M0_RPC_BULK_STORE = (1 << 0), M0_RPC_BULK_LOAD = (1 << 1) }
 

Functions

M0_INTERNAL int m0_rpc_bulk_buf_add (struct m0_rpc_bulk *rbulk, uint32_t segs_nr, m0_bcount_t length, struct m0_net_domain *netdom, struct m0_net_buffer *nb, struct m0_rpc_bulk_buf **out)
 
M0_INTERNAL int m0_rpc_bulk_buf_databuf_add (struct m0_rpc_bulk_buf *rbuf, void *buf, m0_bcount_t count, m0_bindex_t index, struct m0_net_domain *netdom)
 
M0_INTERNAL void m0_rpc_bulk_init (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL void m0_rpc_bulk_buflist_empty (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL void m0_rpc_bulk_fini (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL void m0_rpc_bulk_qtype (struct m0_rpc_bulk *rbulk, enum m0_net_queue_type q)
 
M0_INTERNAL int m0_rpc_bulk_store (struct m0_rpc_bulk *rbulk, const struct m0_rpc_conn *conn, struct m0_net_buf_desc_data *to_desc, const struct m0_net_buffer_callbacks *bulk_cb)
 
M0_INTERNAL int m0_rpc_bulk_load (struct m0_rpc_bulk *rbulk, const struct m0_rpc_conn *conn, struct m0_net_buf_desc_data *from_desc, const struct m0_net_buffer_callbacks *bulk_cb)
 
M0_INTERNAL void m0_rpc_bulk_store_del (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL size_t m0_rpc_bulk_store_del_unqueued (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL void m0_rpc_bulk_default_cb (const struct m0_net_buffer_event *evt)
 
M0_INTERNAL size_t m0_rpc_bulk_buf_length (struct m0_rpc_bulk *rbulk)
 
M0_INTERNAL bool m0_rpc_bulk_is_empty (struct m0_rpc_bulk *rbulk)
 

Variables

enum m0_rpc_bulk_op_states M0_XCA_ENUM
 
const struct m0_net_buffer_callbacks m0_rpc__buf_bulk_cb
 

Macro Definition Documentation

◆ __MOTR_RPC_BULK_H__

#define __MOTR_RPC_BULK_H__

Definition at line 26 of file bulk.h.