#include "lib/vec.h"
#include "lib/tlist.h"
#include "lib/mutex.h"
#include "lib/chan.h"
#include "net/net.h"
#include "xcode/xcode.h"
Go to the source code of this file.
|
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) |
|
◆ __MOTR_RPC_BULK_H__
#define __MOTR_RPC_BULK_H__ |