rm_ha.h

Go to the documentation of this file.

/* -*- C -*- */
/*
 * Copyright (c) 2015-2020 Seagate Technology LLC and/or its Affiliates
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * For any questions about this software or licensing,
 * please email opensource@seagate.com or cortx-questions@seagate.com.
 *
 */


#pragma once

#ifndef __MOTR_RM_RM_HA_H__
#define __MOTR_RM_RM_HA_H__

#include "lib/chan.h"   /* m0_clink */
#include "sm/sm.h"
#include "conf/confc.h" /* m0_confc_ctx, m0_confc */
#include "conf/diter.h" /* m0_conf_diter */

enum m0_rm_ha_subscriber_state {
        RM_HA_SBSCR_INIT,
        RM_HA_SBSCR_FS_OPEN,
        RM_HA_SBSCR_DITER_SEARCH,
        RM_HA_SBSCR_FAILURE,
        RM_HA_SBSCR_FINAL
};

struct m0_rm_ha_tracker {
        struct m0_clink         rht_clink;
        struct m0_clink          rht_conf_exp;
        char                   *rht_ep;
        enum m0_ha_obj_state    rht_state;
};

struct m0_rm_ha_subscriber {
        struct m0_sm             rhs_sm;       
        struct m0_confc         *rhs_confc;    
        struct m0_rm_ha_tracker *rhs_tracker;  
        struct m0_confc_ctx      rhs_cctx;     
        struct m0_conf_obj      *rhs_dir_root; 
        struct m0_conf_diter     rhs_diter;    
        struct m0_clink          rhs_clink;    
        struct m0_sm_ast         rhs_ast;      
};

struct m0_rm_ha_event {
        struct m0_queue_link     rhe_link;
        enum m0_ha_obj_state     rhe_state;
        struct m0_rm_ha_tracker *rhe_tracker;
};

M0_INTERNAL void m0_rm_ha_tracker_init(struct m0_rm_ha_tracker *tracker,
                                       m0_chan_cb_t             cb);
M0_INTERNAL void m0_rm_ha_tracker_fini(struct m0_rm_ha_tracker *tracker);

M0_INTERNAL int m0_rm_ha_subscriber_init(struct m0_rm_ha_subscriber *sbscr,
                                         struct m0_sm_group         *grp,
                                         struct m0_confc            *confc,
                                         const char                 *rem_ep,
                                         struct m0_rm_ha_tracker    *tracker);

M0_INTERNAL void m0_rm_ha_subscribe(struct m0_rm_ha_subscriber *sbscr);

M0_INTERNAL void m0_rm_ha_subscriber_fini(struct m0_rm_ha_subscriber *sbscr);

M0_INTERNAL int m0_rm_ha_subscribe_sync(struct m0_confc         *confc,
                                        const char              *rem_ep,
                                        struct m0_rm_ha_tracker *tracker);

M0_INTERNAL void m0_rm_ha_unsubscribe(struct m0_rm_ha_tracker *tracker);

M0_INTERNAL void m0_rm_ha_unsubscribe_lock(struct m0_rm_ha_tracker *tracker);

#endif /* __MOTR_RM_RM_HA_H__ */

/*
 *  Local variables:
 *  c-indentation-style: "K&R"
 *  c-basic-offset: 8
 *  tab-width: 8
 *  fill-column: 80
 *  scroll-step: 1
 *  End:
 */
/*
 * vim: tabstop=8 shiftwidth=8 noexpandtab textwidth=80 nowrap
 */