at.c File Reference
#include "lib/trace.h"#include "lib/memory.h"#include "lib/errno.h"#include "lib/chan.h"#include "lib/vec.h"#include "sm/sm.h"#include "net/net.h"#include "rpc/session.h"#include "rpc/bulk.h"#include "rpc/rpc_machine.h"#include "rpc/conn.h"#include "fop/fom.h"#include "fop/fop.h"#include "rpc/at.h"
Include dependency graph for at.c:
Go to the source code of this file.
Data Structures | |
| struct | rpc_at_bulk |
Macros | |
| #define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_RPC |
Functions | |
| M0_TL_DESCR_DECLARE (rpcbulk, M0_EXTERN) | |
| M0_TL_DECLARE (rpcbulk, M0_INTERNAL, struct m0_rpc_bulk_buf) | |
| static struct rpc_at_bulk * | rpc_at_bulk (const struct m0_rpc_at_buf *ab) |
| static m0_bcount_t | rpc_at_bulk_cutoff (const struct m0_rpc_conn *conn) |
| static struct m0_net_domain * | rpc_at_bulk_ndom (const struct rpc_at_bulk *atbulk) |
| static struct m0_rpc_conn * | fom_conn (const struct m0_fom *fom) |
| static uint64_t | rpc_at_bulk_segs_nr (const struct rpc_at_bulk *atbulk, m0_bcount_t data_size, m0_bcount_t *seg_size) |
| static int | rpc_at_bulk_nb_alloc (struct m0_rpc_at_buf *ab, uint64_t size) |
| static void | rpc_at_bulk_nb_free (struct rpc_at_bulk *atbulk) |
| static int | rpc_at_bulk_init (struct m0_rpc_at_buf *ab, const struct m0_rpc_conn *conn) |
| static void | rpc_at_bulk_store_del (struct m0_rpc_bulk *rbulk) |
| static enum m0_net_queue_type | rpc_at_bulk_qtype (struct m0_rpc_bulk *rbulk) |
| static void | rpc_at_bulk_fini (struct rpc_at_bulk *atbulk) |
| static int | rpc_at_bulk_csend (struct m0_rpc_at_buf *ab, const struct m0_buf *buf) |
| static int | rpc_at_bulk_srecv (struct m0_rpc_at_buf *ab, struct m0_fom *fom) |
| static int | rpc_at_bulk_srecv_rc (const struct m0_rpc_at_buf *ab, struct m0_buf *buf) |
| static int | rpc_at_bulk_crecv (struct m0_rpc_at_buf *ab, uint32_t len) |
| static void | rpc_at_ssend_ast_cb (struct m0_sm_group *grp, struct m0_sm_ast *ast) |
| static bool | rpc_at_ssend_complete_cb (struct m0_clink *clink) |
| static int | rpc_at_bulk_ssend (struct m0_rpc_at_buf *in, struct m0_rpc_at_buf *out, struct m0_buf *buf, struct m0_fom *fom) |
| M0_INTERNAL int | m0_rpc_at_get (const struct m0_rpc_at_buf *ab, struct m0_buf *buf) |
| M0_INTERNAL int | m0_rpc_at_load (struct m0_rpc_at_buf *ab, struct m0_fom *fom, int next_phase) |
| M0_INTERNAL void | m0_rpc_at_init (struct m0_rpc_at_buf *ab) |
| M0_INTERNAL void | m0_rpc_at_fini (struct m0_rpc_at_buf *ab) |
| M0_INTERNAL int | m0_rpc_at_add (struct m0_rpc_at_buf *ab, const struct m0_buf *buf, const struct m0_rpc_conn *conn) |
| M0_INTERNAL bool | m0_rpc_at_is_set (const struct m0_rpc_at_buf *ab) |
| M0_INTERNAL int | m0_rpc_at_recv (struct m0_rpc_at_buf *ab, const struct m0_rpc_conn *conn, uint32_t len, bool force_bulk) |
| M0_INTERNAL int | m0_rpc_at_reply (struct m0_rpc_at_buf *in, struct m0_rpc_at_buf *out, struct m0_buf *repbuf, struct m0_fom *fom, int next_phase) |
| M0_INTERNAL int | m0_rpc_at_reply_rc (struct m0_rpc_at_buf *out) |
| M0_INTERNAL int | m0_rpc_at_rep_get (struct m0_rpc_at_buf *sent, struct m0_rpc_at_buf *rcvd, struct m0_buf *out) |
| M0_INTERNAL bool | m0_rpc_at_rep_is_bulk (const struct m0_rpc_at_buf *rcvd, uint64_t *len) |
| M0_INTERNAL int | m0_rpc_at_rep2inline (struct m0_rpc_at_buf *sent, struct m0_rpc_at_buf *rcvd) |
| M0_INTERNAL void | m0_rpc_at_detach (struct m0_rpc_at_buf *ab) |
| M0_INTERNAL uint64_t | m0_rpc_at_len (const struct m0_rpc_at_buf *ab) |
