Motr
M0
|
#include "lib/tlist.h"
#include "lib/lockers.h"
#include "lib/bob.h"
#include "conf/confc.h"
#include "conf/rconfc.h"
#include "sm/sm.h"
#include "fop/fom.h"
#include "layout/layout.h"
#include "ha/epoch.h"
#include "rpc/session.h"
Go to the source code of this file.
Data Structures | |
struct | m0_reqh |
struct | m0_reqh_init_args |
Macros | |
#define | __MOTR_REQH_REQH_H__ |
#define | M0_REQH_INIT(reqh, ...) |
Enumerations | |
enum | { DEFAULT_ADDB2_RECORD_SIZE = 128ULL << 20, MIN_ADDB2_RECORD_SIZE = 10ULL << 20, MAX_ADDB2_RECORD_SIZE = 10ULL << 30, DEFAULT_CLIENT_ADDB2_RECORD_SIZE = 128ULL << 20 } |
enum | m0_reqh_states { M0_REQH_ST_INIT, M0_REQH_ST_NORMAL, M0_REQH_ST_DRAIN, M0_REQH_ST_SVCS_STOP, M0_REQH_ST_STOPPED, M0_REQH_ST_NR } |
Functions | |
M0_LOCKERS_DECLARE (M0_EXTERN, m0_reqh, 256) | |
M0_INTERNAL int | m0_reqh_init (struct m0_reqh *reqh, const struct m0_reqh_init_args *reqh_args) |
M0_INTERNAL bool | m0_reqh_invariant (const struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_fini (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_be_init (struct m0_reqh *reqh, struct m0_be_seg *seg) |
M0_INTERNAL void | m0_reqh_be_fini (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_layouts_cleanup (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_addb2_init (struct m0_reqh *reqh, const char *location, uint64_t key, bool mkfs, bool force, m0_bcount_t size) |
M0_INTERNAL void | m0_reqh_addb2_fini (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_addb2_submit (struct m0_reqh *reqh, struct m0_addb2_trace_obj *tobj) |
M0_INTERNAL int | m0_reqh_state_get (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_fop_allow (struct m0_reqh *reqh, struct m0_fop *fop) |
M0_INTERNAL int | m0_reqh_fop_handle (struct m0_reqh *reqh, struct m0_fop *fop) |
M0_INTERNAL void | m0_reqh_idle_wait (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_idle_wait_for (struct m0_reqh *reqh, struct m0_reqh_service *service) |
M0_INTERNAL void | m0_reqh_start (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_services_state_count (struct m0_reqh *reqh, int state) |
M0_INTERNAL void | m0_reqh_services_prepare_to_stop (struct m0_reqh *reqh, unsigned level) |
M0_INTERNAL void | m0_reqh_shutdown (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_shutdown_wait (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_services_terminate (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_pre_storage_fini_svcs_stop (struct m0_reqh *reqh) |
M0_INTERNAL void | m0_reqh_post_storage_fini_svcs_stop (struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqhs_init (void) |
M0_INTERNAL void | m0_reqhs_fini (void) |
M0_INTERNAL uint64_t | m0_reqh_nr_localities (const struct m0_reqh *reqh) |
M0_INTERNAL int | m0_reqh_conf_setup (struct m0_reqh *reqh, struct m0_confc_args *args) |
M0_TL_DESCR_DECLARE (m0_reqh_svc, M0_EXTERN) | |
M0_TL_DECLARE (m0_reqh_svc, M0_INTERNAL, struct m0_reqh_service) | |
M0_BOB_DECLARE (M0_EXTERN, m0_reqh_service) | |
M0_TL_DESCR_DECLARE (m0_reqh_rpc_mach, extern) | |
M0_TL_DECLARE (m0_reqh_rpc_mach,, struct m0_rpc_machine) | |
M0_INTERNAL int | m0_reqh_mdpool_layout_build (struct m0_reqh *reqh) |
M0_INTERNAL struct m0_rpc_session * | m0_reqh_mdpool_service_index_to_session (const struct m0_reqh *reqh, const struct m0_fid *gob_fid, uint32_t index) |
M0_INTERNAL struct m0_confc * | m0_reqh2confc (struct m0_reqh *reqh) |
M0_INTERNAL struct m0_fid * | m0_reqh2profile (struct m0_reqh *reqh) |