PRINTK("get_stripe, sector %lu\n", sector);
- md_spin_lock_irq(&conf->device_lock);
+ spin_lock_irq(&conf->device_lock);
do {
if (conf->buffer_size == 0 ||
if (sh)
atomic_inc(&sh->count);
- md_spin_unlock_irq(&conf->device_lock);
+ spin_unlock_irq(&conf->device_lock);
return sh;
}
return;
}
- md_spin_lock_irqsave(&conf->device_lock, flags);
+ spin_lock_irqsave(&conf->device_lock, flags);
if (!uptodate)
md_error(conf->mddev, bh->b_bdev);
clear_buffer_locked(bh);
set_bit(STRIPE_HANDLE, &sh->state);
__release_stripe(conf, sh);
- md_spin_unlock_irqrestore(&conf->device_lock, flags);
+ spin_unlock_irqrestore(&conf->device_lock, flags);
}
return bh;
}
-static int raid5_error (mddev_t *mddev, kdev_t dev)
+static int error (mddev_t *mddev, kdev_t dev)
{
raid5_conf_t *conf = (raid5_conf_t *) mddev->private;
mdp_super_t *sb = mddev->sb;
struct disk_info *disk;
int i;
- PRINTK("raid5_error called\n");
+ PRINTK("raid5: error called\n");
for (i = 0, disk = conf->disks; i < conf->raid_disks; i++, disk++) {
if (kdev_same(disk->dev, dev)) {
spin_unlock_irq(&conf->device_lock);
}
-static int raid5_make_request (mddev_t *mddev, int rw, struct buffer_head * bh)
+static int make_request (mddev_t *mddev, int rw, struct buffer_head * bh)
{
raid5_conf_t *conf = (raid5_conf_t *) mddev->private;
const unsigned int raid_disks = conf->raid_disks;
new_sector = raid5_compute_sector(bh->b_rsector,
raid_disks, data_disks, &dd_idx, &pd_idx, conf);
- PRINTK("raid5_make_request, sector %lu\n", new_sector);
+ PRINTK("raid5: make_request, sector %lu\n", new_sector);
sh = get_active_stripe(conf, new_sector, bh->b_size, read_ahead);
if (sh) {
sh->pd_idx = pd_idx;
return 0;
}
-static int raid5_sync_request (mddev_t *mddev, unsigned long sector_nr)
+static int sync_request (mddev_t *mddev, unsigned long sector_nr)
{
raid5_conf_t *conf = (raid5_conf_t *) mddev->private;
struct stripe_head *sh;
mddev->sb_dirty = 0;
md_update_sb(mddev);
}
- md_spin_lock_irq(&conf->device_lock);
+ spin_lock_irq(&conf->device_lock);
while (1) {
struct list_head *first;
atomic_inc(&sh->count);
if (atomic_read(&sh->count)!= 1)
BUG();
- md_spin_unlock_irq(&conf->device_lock);
+ spin_unlock_irq(&conf->device_lock);
handled++;
handle_stripe(sh);
release_stripe(sh);
- md_spin_lock_irq(&conf->device_lock);
+ spin_lock_irq(&conf->device_lock);
}
PRINTK("%d stripes handled\n", handled);
- md_spin_unlock_irq(&conf->device_lock);
+ spin_unlock_irq(&conf->device_lock);
PRINTK("--- raid5d inactive\n");
}
printk("raid5: resync finished.\n");
}
-static int raid5_run (mddev_t *mddev)
+static int run (mddev_t *mddev)
{
raid5_conf_t *conf;
int i, j, raid_disk, memory;
mdp_disk_t *desc;
mdk_rdev_t *rdev;
struct disk_info *disk;
- struct md_list_head *tmp;
+ struct list_head *tmp;
int start_recovery = 0;
MOD_INC_USE_COUNT;
memset (conf, 0, sizeof (*conf));
conf->mddev = mddev;
- if ((conf->stripe_hashtbl = (struct stripe_head **) md__get_free_pages(GFP_ATOMIC, HASH_PAGES_ORDER)) == NULL)
+ if ((conf->stripe_hashtbl = (struct stripe_head **) __get_free_pages(GFP_ATOMIC, HASH_PAGES_ORDER)) == NULL)
goto abort;
memset(conf->stripe_hashtbl, 0, HASH_PAGES * PAGE_SIZE);
- conf->device_lock = MD_SPIN_LOCK_UNLOCKED;
- md_init_waitqueue_head(&conf->wait_for_stripe);
+ conf->device_lock = SPIN_LOCK_UNLOCKED;
+ init_waitqueue_head(&conf->wait_for_stripe);
INIT_LIST_HEAD(&conf->handle_list);
INIT_LIST_HEAD(&conf->delayed_list);
INIT_LIST_HEAD(&conf->inactive_list);
conf->plug_tq.routine = &raid5_unplug_device;
conf->plug_tq.data = conf;
- PRINTK("raid5_run(md%d) called.\n", mdidx(mddev));
+ PRINTK("raid5: run(md%d) called.\n", mdidx(mddev));
ITERATE_RDEV(mddev,rdev,tmp) {
/*
return -EIO;
}
-static int raid5_stop_resync (mddev_t *mddev)
+static int stop_resync (mddev_t *mddev)
{
raid5_conf_t *conf = mddev_to_conf(mddev);
mdk_thread_t *thread = conf->resync_thread;
return 0;
}
-static int raid5_restart_resync (mddev_t *mddev)
+static int restart_resync (mddev_t *mddev)
{
raid5_conf_t *conf = mddev_to_conf(mddev);
}
-static int raid5_stop (mddev_t *mddev)
+static int stop (mddev_t *mddev)
{
raid5_conf_t *conf = (raid5_conf_t *) mddev->private;
struct stripe_head *sh;
int i;
- md_spin_lock_irq(&conf->device_lock);
+ spin_lock_irq(&conf->device_lock);
for (i = 0; i < NR_HASH; i++) {
sh = conf->stripe_hashtbl[i];
for (; sh; sh = sh->hash_next) {
print_sh(sh);
}
}
- md_spin_unlock_irq(&conf->device_lock);
+ spin_unlock_irq(&conf->device_lock);
PRINTK("--- raid5d inactive\n");
}
#endif
-static int raid5_status (char *page, mddev_t *mddev)
+static int status (char *page, mddev_t *mddev)
{
raid5_conf_t *conf = (raid5_conf_t *) mddev->private;
mdp_super_t *sb = mddev->sb;
}
}
-static int raid5_diskop(mddev_t *mddev, mdp_disk_t **d, int state)
+static int diskop(mddev_t *mddev, mdp_disk_t **d, int state)
{
int err = 0;
int i, failed_disk=-1, spare_disk=-1, removed_disk=-1, added_disk=-1;
mdk_rdev_t *spare_rdev, *failed_rdev;
print_raid5_conf(conf);
- md_spin_lock_irq(&conf->device_lock);
+ spin_lock_irq(&conf->device_lock);
/*
* find the disk ...
*/
goto abort;
}
abort:
- md_spin_unlock_irq(&conf->device_lock);
+ spin_unlock_irq(&conf->device_lock);
print_raid5_conf(conf);
return err;
}
static mdk_personality_t raid5_personality=
{
name: "raid5",
- make_request: raid5_make_request,
- run: raid5_run,
- stop: raid5_stop,
- status: raid5_status,
- error_handler: raid5_error,
- diskop: raid5_diskop,
- stop_resync: raid5_stop_resync,
- restart_resync: raid5_restart_resync,
- sync_request: raid5_sync_request
+ make_request: make_request,
+ run: run,
+ stop: stop,
+ status: status,
+ error_handler: error,
+ diskop: diskop,
+ stop_resync: stop_resync,
+ restart_resync: restart_resync,
+ sync_request: sync_request
};
-static int md__init raid5_init (void)
+static int __init raid5_init (void)
{
return register_md_personality (RAID5, &raid5_personality);
}