Commit edb39c9d authored by Goldwyn Rodrigues's avatar Goldwyn Rodrigues

Introduce md_cluster_operations to handle cluster functions

This allows dynamic registering of cluster hooks.
Signed-off-by: default avatarGoldwyn Rodrigues <rgoldwyn@suse.com>
parent 47741b7c
...@@ -13,6 +13,7 @@ ...@@ -13,6 +13,7 @@
#include <linux/dlm.h> #include <linux/dlm.h>
#include <linux/sched.h> #include <linux/sched.h>
#include "md.h" #include "md.h"
#include "md-cluster.h"
#define LVB_SIZE 64 #define LVB_SIZE 64
...@@ -113,15 +114,32 @@ static void lockres_free(struct dlm_lock_resource *res) ...@@ -113,15 +114,32 @@ static void lockres_free(struct dlm_lock_resource *res)
kfree(res); kfree(res);
} }
static int join(struct mddev *mddev, int nodes)
{
return 0;
}
static int leave(struct mddev *mddev)
{
return 0;
}
static struct md_cluster_operations cluster_ops = {
.join = join,
.leave = leave,
};
static int __init cluster_init(void) static int __init cluster_init(void)
{ {
pr_warn("md-cluster: EXPERIMENTAL. Use with caution\n"); pr_warn("md-cluster: EXPERIMENTAL. Use with caution\n");
pr_info("Registering Cluster MD functions\n"); pr_info("Registering Cluster MD functions\n");
register_md_cluster_operations(&cluster_ops, THIS_MODULE);
return 0; return 0;
} }
static void cluster_exit(void) static void cluster_exit(void)
{ {
unregister_md_cluster_operations();
} }
module_init(cluster_init); module_init(cluster_init);
......
#ifndef _MD_CLUSTER_H
#define _MD_CLUSTER_H
#include "md.h"
struct mddev;
struct md_cluster_operations {
int (*join)(struct mddev *mddev);
int (*leave)(struct mddev *mddev);
};
#endif /* _MD_CLUSTER_H */
...@@ -53,6 +53,7 @@ ...@@ -53,6 +53,7 @@
#include <linux/slab.h> #include <linux/slab.h>
#include "md.h" #include "md.h"
#include "bitmap.h" #include "bitmap.h"
#include "md-cluster.h"
#ifndef MODULE #ifndef MODULE
static void autostart_arrays(int part); static void autostart_arrays(int part);
...@@ -66,6 +67,10 @@ static void autostart_arrays(int part); ...@@ -66,6 +67,10 @@ static void autostart_arrays(int part);
static LIST_HEAD(pers_list); static LIST_HEAD(pers_list);
static DEFINE_SPINLOCK(pers_lock); static DEFINE_SPINLOCK(pers_lock);
struct md_cluster_operations *md_cluster_ops;
struct module *md_cluster_mod;
EXPORT_SYMBOL(md_cluster_mod);
static DECLARE_WAIT_QUEUE_HEAD(resync_wait); static DECLARE_WAIT_QUEUE_HEAD(resync_wait);
static struct workqueue_struct *md_wq; static struct workqueue_struct *md_wq;
static struct workqueue_struct *md_misc_wq; static struct workqueue_struct *md_misc_wq;
...@@ -7231,6 +7236,53 @@ int unregister_md_personality(struct md_personality *p) ...@@ -7231,6 +7236,53 @@ int unregister_md_personality(struct md_personality *p)
} }
EXPORT_SYMBOL(unregister_md_personality); EXPORT_SYMBOL(unregister_md_personality);
int register_md_cluster_operations(struct md_cluster_operations *ops, struct module *module)
{
if (md_cluster_ops != NULL)
return -EALREADY;
spin_lock(&pers_lock);
md_cluster_ops = ops;
md_cluster_mod = module;
spin_unlock(&pers_lock);
return 0;
}
EXPORT_SYMBOL(register_md_cluster_operations);
int unregister_md_cluster_operations(void)
{
spin_lock(&pers_lock);
md_cluster_ops = NULL;
spin_unlock(&pers_lock);
return 0;
}
EXPORT_SYMBOL(unregister_md_cluster_operations);
int md_setup_cluster(struct mddev *mddev, int nodes)
{
int err;
err = request_module("md-cluster");
if (err) {
pr_err("md-cluster module not found.\n");
return err;
}
spin_lock(&pers_lock);
if (!md_cluster_ops || !try_module_get(md_cluster_mod)) {
spin_unlock(&pers_lock);
return -ENOENT;
}
spin_unlock(&pers_lock);
return md_cluster_ops->join(mddev);
}
void md_cluster_stop(struct mddev *mddev)
{
md_cluster_ops->leave(mddev);
module_put(md_cluster_mod);
}
static int is_mddev_idle(struct mddev *mddev, int init) static int is_mddev_idle(struct mddev *mddev, int init)
{ {
struct md_rdev *rdev; struct md_rdev *rdev;
......
...@@ -23,6 +23,7 @@ ...@@ -23,6 +23,7 @@
#include <linux/timer.h> #include <linux/timer.h>
#include <linux/wait.h> #include <linux/wait.h>
#include <linux/workqueue.h> #include <linux/workqueue.h>
#include "md-cluster.h"
#define MaxSector (~(sector_t)0) #define MaxSector (~(sector_t)0)
...@@ -608,6 +609,11 @@ static inline void safe_put_page(struct page *p) ...@@ -608,6 +609,11 @@ static inline void safe_put_page(struct page *p)
extern int register_md_personality(struct md_personality *p); extern int register_md_personality(struct md_personality *p);
extern int unregister_md_personality(struct md_personality *p); extern int unregister_md_personality(struct md_personality *p);
extern int register_md_cluster_operations(struct md_cluster_operations *ops,
struct module *module);
extern int unregister_md_cluster_operations(void);
extern int md_setup_cluster(struct mddev *mddev, int nodes);
extern void md_cluster_stop(struct mddev *mddev);
extern struct md_thread *md_register_thread( extern struct md_thread *md_register_thread(
void (*run)(struct md_thread *thread), void (*run)(struct md_thread *thread),
struct mddev *mddev, struct mddev *mddev,
...@@ -669,4 +675,5 @@ static inline void rdev_dec_pending(struct md_rdev *rdev, struct mddev *mddev) ...@@ -669,4 +675,5 @@ static inline void rdev_dec_pending(struct md_rdev *rdev, struct mddev *mddev)
} }
} }
extern struct md_cluster_operations *md_cluster_ops;
#endif /* _MD_MD_H */ #endif /* _MD_MD_H */
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment