25 #ifndef __MOTR_DTM0_SERVICE_H__ 26 #define __MOTR_DTM0_SERVICE_H__ 72 const char *remote_ep,
76 struct m0_fid *remote_srv);
80 const struct m0_fid *remote_srv);
M0_INTERNAL struct m0_dtm0_service * m0_dtm0_service_find(const struct m0_reqh *reqh)
struct m0_be_queue * dos_ut_queue
M0_INTERNAL struct m0_rpc_session * m0_dtm0_service_process_session_get(struct m0_reqh_service *s, const struct m0_fid *remote_srv)
M0_INTERNAL bool m0_dtm0_is_a_persistent_dtm(struct m0_reqh_service *service)
M0_INTERNAL bool m0_dtm0_in_ut(void)
struct m0_be_dtm0_log * dos_log
enum m0_dtm0_service_origin dos_origin
M0_INTERNAL int m0_dtm0_service_process_connect(struct m0_reqh_service *s, struct m0_fid *remote_srv, const char *remote_ep, bool async)
M0_INTERNAL int m0_dtm0_stype_init(void)
struct m0_dtm0_clk_src dos_clk_src
M0_INTERNAL struct m0_dtm0_service * m0_dtm0_fom2service(struct m0_fom *fom)
struct m0_reqh_service_type dtm0_service_type
M0_INTERNAL bool m0_dtm0_is_a_volatile_dtm(struct m0_reqh_service *service)
struct m0_tl dos_processes
static struct m0_net_test_service svc
static struct m0_addb2_source * s
static struct m0_reqh_service * service[REQH_IN_UT_MAX]
struct m0_reqh_service dos_generic
M0_INTERNAL void m0_dtm_client_service_stop(struct m0_reqh_service *svc)
M0_INTERNAL void m0_dtm0_stype_fini(void)
M0_INTERNAL int m0_dtm_client_service_start(struct m0_reqh *reqh, struct m0_fid *cli_srv_fid, struct m0_reqh_service **out)
M0_INTERNAL int m0_dtm0_service_process_disconnect(struct m0_reqh_service *s, struct m0_fid *remote_srv)