Motr
M0
|
#include "lib/chan.h"
#include "fop/fom_simple.h"
#include "rpc/conn.h"
#include "rpc/session.h"
#include "sm/sm.h"
#include "conf/obj.h"
#include "cm/sw.h"
#include "cm/ag.h"
Go to the source code of this file.
Data Structures | |
struct | m0_cm_proxy |
struct | m0_cm_proxy_in_count |
struct | m0_cm_proxy_sw_onwire |
Macros | |
#define | __MOTR_CM_PROXY_H__ |
Enumerations | |
enum | m0_proxy_state { M0_PX_INIT, M0_PX_READY, M0_PX_ACTIVE, M0_PX_COMPLETE, M0_PX_STOP, M0_PX_FAILED } |
Functions | |
M0_INTERNAL int | m0_cm_proxy_init (struct m0_cm_proxy *proxy, uint64_t px_id, struct m0_cm_ag_id *lo, struct m0_cm_ag_id *hi, const char *endpoint) |
M0_INTERNAL void | m0_cm_proxy_add (struct m0_cm *cm, struct m0_cm_proxy *pxy) |
M0_INTERNAL void | m0_cm_proxy_del (struct m0_cm *cm, struct m0_cm_proxy *pxy) |
M0_INTERNAL struct m0_cm_proxy * | m0_cm_proxy_locate (struct m0_cm *cm, const char *addr) |
M0_INTERNAL int | m0_cm_proxy_update (struct m0_cm_proxy *pxy, struct m0_cm_sw *in_interval, struct m0_cm_sw *out_interval, uint32_t px_status, m0_time_t px_epoch) |
M0_INTERNAL int | m0_cm_proxy_remote_update (struct m0_cm_proxy *proxy, struct m0_cm_sw *in_interval, struct m0_cm_sw *out_interval) |
M0_INTERNAL void | m0_cm_proxy_cp_add (struct m0_cm_proxy *pxy, struct m0_cm_cp *cp) |
M0_INTERNAL uint64_t | m0_cm_proxy_nr (struct m0_cm *cm) |
M0_INTERNAL bool | m0_cm_proxy_agid_is_in_sw (struct m0_cm_proxy *pxy, struct m0_cm_ag_id *id) |
M0_INTERNAL void | m0_cm_proxy_fini (struct m0_cm_proxy *pxy) |
M0_INTERNAL bool | m0_cm_proxy_is_done (const struct m0_cm_proxy *pxy) |
M0_INTERNAL void | m0_cm_proxy_pending_cps_wakeup (struct m0_cm *cm) |
M0_INTERNAL void | m0_cm_proxy_event_handle_register (struct m0_cm_proxy *pxy, struct m0_conf_obj *svc_obj) |
M0_INTERNAL bool | m0_cm_proxy_is_locked (struct m0_cm_proxy *pxy) |
M0_INTERNAL void | m0_cm_proxy_lock (struct m0_cm_proxy *pxy) |
M0_INTERNAL void | m0_cm_proxy_unlock (struct m0_cm_proxy *pxy) |
M0_INTERNAL bool | m0_cm_proxies_ready (const struct m0_cm *cm) |
M0_INTERNAL int | m0_cm_proxy_in_count_alloc (struct m0_cm_proxy_in_count *pcount, uint32_t nr_proxies) |
M0_INTERNAL void | m0_cm_proxy_in_count_free (struct m0_cm_proxy_in_count *pcount) |
M0_INTERNAL bool | m0_cm_proxy_is_updated (struct m0_cm_proxy *proxy, struct m0_cm_sw *in_interval) |
M0_INTERNAL void | m0_cm_proxies_sent_reset (struct m0_cm *cm) |
M0_TL_DESCR_DECLARE (proxy, M0_EXTERN) | |
M0_TL_DECLARE (proxy, M0_INTERNAL, struct m0_cm_proxy) | |
M0_TL_DESCR_DECLARE (proxy_fail, M0_EXTERN) | |
M0_TL_DECLARE (proxy_fail, M0_INTERNAL, struct m0_cm_proxy) | |
M0_TL_DESCR_DECLARE (proxy_cp, M0_EXTERN) | |
M0_TL_DECLARE (proxy_cp, M0_INTERNAL, struct m0_cm_cp) | |