Motr
M0
|
#include "lib/trace.h"
#include "lib/chan.h"
#include "lib/memory.h"
#include "lib/errno.h"
#include "lib/finject.h"
#include "module/instance.h"
#include "ha/failvec.h"
#include "ha/msg.h"
#include "ha/link.h"
#include "ha/note.h"
#include "pool/pool_machine.h"
#include "pool/pool.h"
#include "reqh/reqh.h"
#include "fid/fid.h"
Go to the source code of this file.
Data Structures | |
struct | ha_fvec_handler_request |
Macros | |
#define | M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA |
Functions | |
static uint32_t | fvec_rep_msg_vec_len (const struct m0_ha_msg *msg) |
static const struct m0_cookie * | fvec_msg_cookie_get (const struct m0_ha_msg *msg) |
static const struct m0_ha_note * | fvec_rep_msg_to_note (const struct m0_ha_msg *msg) |
static const struct m0_fid * | fvec_msg_to_pool (const struct m0_ha_msg *msg) |
static uint32_t | fvec_msg_type (const struct m0_ha_msg *msg) |
M0_TL_DESCR_DEFINE (ha_fvreq, "failure-vec-req", static, struct ha_fvec_handler_request, fhr_tlink, fhr_magic, 20, 21) | |
M0_TL_DEFINE (ha_fvreq, static, struct ha_fvec_handler_request) | |
static void | ha_fvec_handler_msg (struct m0_ha_handler *hh, struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg, uint64_t tag, void *data) |
M0_INTERNAL int | m0_ha_fvec_handler_init (struct m0_ha_fvec_handler *hfh, struct m0_ha_dispatcher *hd) |
M0_INTERNAL void | m0_ha_fvec_handler_fini (struct m0_ha_fvec_handler *hfh) |
M0_INTERNAL int | m0_ha_fvec_handler_add (struct m0_ha_fvec_handler *hfh, const struct m0_fid *pool_fid, struct m0_poolmach *pool_mach, struct m0_chan *chan, struct m0_cookie *cookie) |
M0_INTERNAL void | m0_ha_fvec_rep_handler (struct m0_ha_fvec_handler *hfh, const struct m0_ha_msg *msg) |
M0_INTERNAL void | m0_ha_fvec_req_handler (struct m0_ha_fvec_handler *hfh, const struct m0_ha_msg *msg, struct m0_ha_link *hl) |
M0_INTERNAL int | m0_ha_failvec_fetch (const struct m0_fid *pool_fid, struct m0_poolmach *pmach, struct m0_chan *chan) |
static void | ha_ut_fvec_reply_populate (struct m0_ha_msg *msg) |
static void | ha_msg_fvec_build (struct m0_ha_msg *msg, const struct m0_fid *pool_fid, struct m0_ha_link *hl) |
M0_INTERNAL int | m0_ha_msg_fvec_send (const struct m0_fid *pool_fid, const struct m0_cookie *cookie, struct m0_ha_link *hl, uint32_t type) |
|
static |
|
static |
|
static |
|
static |
|
static |
|
static |
M0_INTERNAL int m0_ha_failvec_fetch | ( | const struct m0_fid * | pool_fid, |
struct m0_poolmach * | pmach, | ||
struct m0_chan * | chan | ||
) |
M0_INTERNAL int m0_ha_fvec_handler_add | ( | struct m0_ha_fvec_handler * | hfh, |
const struct m0_fid * | pool_fid, | ||
struct m0_poolmach * | pool_mach, | ||
struct m0_chan * | chan, | ||
struct m0_cookie * | cookie | ||
) |
M0_INTERNAL void m0_ha_fvec_handler_fini | ( | struct m0_ha_fvec_handler * | hfh | ) |
M0_INTERNAL int m0_ha_fvec_handler_init | ( | struct m0_ha_fvec_handler * | hfh, |
struct m0_ha_dispatcher * | hd | ||
) |
M0_INTERNAL void m0_ha_fvec_rep_handler | ( | struct m0_ha_fvec_handler * | hfh, |
const struct m0_ha_msg * | msg | ||
) |
M0_INTERNAL void m0_ha_fvec_req_handler | ( | struct m0_ha_fvec_handler * | hfh, |
const struct m0_ha_msg * | msg, | ||
struct m0_ha_link * | hl | ||
) |
M0_INTERNAL int m0_ha_msg_fvec_send | ( | const struct m0_fid * | pool_fid, |
const struct m0_cookie * | req_cookie, | ||
struct m0_ha_link * | hl, | ||
uint32_t | type | ||
) |
M0_TL_DEFINE | ( | ha_fvreq | , |
static | , | ||
struct ha_fvec_handler_request | |||
) |
M0_TL_DESCR_DEFINE | ( | ha_fvreq | , |
"failure-vec-req" | , | ||
static | , | ||
struct ha_fvec_handler_request | , | ||
fhr_tlink | , | ||
fhr_magic | , | ||
20 | , | ||
21 | |||
) |