aoeblk.c 6.0 KB
Newer Older
E
Ed L. Cashin 已提交
1
/* Copyright (c) 2006 Coraid, Inc.  See COPYING for GPL terms. */
L
Linus Torvalds 已提交
2 3 4 5 6 7 8 9 10 11 12 13 14
/*
 * aoeblk.c
 * block device routines
 */

#include <linux/hdreg.h>
#include <linux/blkdev.h>
#include <linux/fs.h>
#include <linux/ioctl.h>
#include <linux/genhd.h>
#include <linux/netdevice.h>
#include "aoe.h"

15
static struct kmem_cache *buf_pool_cache;
L
Linus Torvalds 已提交
16 17 18 19 20 21 22 23

static ssize_t aoedisk_show_state(struct gendisk * disk, char *page)
{
	struct aoedev *d = disk->private_data;

	return snprintf(page, PAGE_SIZE,
			"%s%s\n",
			(d->flags & DEVFL_UP) ? "up" : "down",
24 25 26
			(d->flags & DEVFL_PAUSE) ? ",paused" :
			(d->nopen && !(d->flags & DEVFL_UP)) ? ",closewait" : "");
	/* I'd rather see nopen exported so we can ditch closewait */
L
Linus Torvalds 已提交
27 28 29 30 31 32 33 34 35 36 37 38 39 40
}
static ssize_t aoedisk_show_mac(struct gendisk * disk, char *page)
{
	struct aoedev *d = disk->private_data;

	return snprintf(page, PAGE_SIZE, "%012llx\n",
			(unsigned long long)mac_addr(d->addr));
}
static ssize_t aoedisk_show_netif(struct gendisk * disk, char *page)
{
	struct aoedev *d = disk->private_data;

	return snprintf(page, PAGE_SIZE, "%s\n", d->ifp->name);
}
41 42 43 44 45 46 47
/* firmware version */
static ssize_t aoedisk_show_fwver(struct gendisk * disk, char *page)
{
	struct aoedev *d = disk->private_data;

	return snprintf(page, PAGE_SIZE, "0x%04x\n", (unsigned int) d->fw_ver);
}
L
Linus Torvalds 已提交
48 49 50 51 52 53 54 55 56 57 58 59 60

static struct disk_attribute disk_attr_state = {
	.attr = {.name = "state", .mode = S_IRUGO },
	.show = aoedisk_show_state
};
static struct disk_attribute disk_attr_mac = {
	.attr = {.name = "mac", .mode = S_IRUGO },
	.show = aoedisk_show_mac
};
static struct disk_attribute disk_attr_netif = {
	.attr = {.name = "netif", .mode = S_IRUGO },
	.show = aoedisk_show_netif
};
61 62 63 64
static struct disk_attribute disk_attr_fwver = {
	.attr = {.name = "firmware-version", .mode = S_IRUGO },
	.show = aoedisk_show_fwver
};
L
Linus Torvalds 已提交
65

66 67 68 69 70
static struct attribute *aoe_attrs[] = {
	&disk_attr_state.attr,
	&disk_attr_mac.attr,
	&disk_attr_netif.attr,
	&disk_attr_fwver.attr,
71
	NULL
72 73 74 75 76 77 78
};

static const struct attribute_group attr_group = {
	.attrs = aoe_attrs,
};

static int
L
Linus Torvalds 已提交
79 80
aoedisk_add_sysfs(struct aoedev *d)
{
81
	return sysfs_create_group(&d->gd->kobj, &attr_group);
L
Linus Torvalds 已提交
82 83 84 85
}
void
aoedisk_rm_sysfs(struct aoedev *d)
{
86
	sysfs_remove_group(&d->gd->kobj, &attr_group);
L
Linus Torvalds 已提交
87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116
}

static int
aoeblk_open(struct inode *inode, struct file *filp)
{
	struct aoedev *d;
	ulong flags;

	d = inode->i_bdev->bd_disk->private_data;

	spin_lock_irqsave(&d->lock, flags);
	if (d->flags & DEVFL_UP) {
		d->nopen++;
		spin_unlock_irqrestore(&d->lock, flags);
		return 0;
	}
	spin_unlock_irqrestore(&d->lock, flags);
	return -ENODEV;
}

static int
aoeblk_release(struct inode *inode, struct file *filp)
{
	struct aoedev *d;
	ulong flags;

	d = inode->i_bdev->bd_disk->private_data;

	spin_lock_irqsave(&d->lock, flags);

117
	if (--d->nopen == 0) {
L
Linus Torvalds 已提交
118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139
		spin_unlock_irqrestore(&d->lock, flags);
		aoecmd_cfg(d->aoemajor, d->aoeminor);
		return 0;
	}
	spin_unlock_irqrestore(&d->lock, flags);

	return 0;
}

static int
aoeblk_make_request(request_queue_t *q, struct bio *bio)
{
	struct aoedev *d;
	struct buf *buf;
	struct sk_buff *sl;
	ulong flags;

	blk_queue_bounce(q, &bio);

	d = bio->bi_bdev->bd_disk->private_data;
	buf = mempool_alloc(d->bufpool, GFP_NOIO);
	if (buf == NULL) {
E
Ed L. Cashin 已提交
140
		printk(KERN_INFO "aoe: buf allocation failure\n");
L
Linus Torvalds 已提交
141 142 143 144 145
		bio_endio(bio, bio->bi_size, -ENOMEM);
		return 0;
	}
	memset(buf, 0, sizeof(*buf));
	INIT_LIST_HEAD(&buf->bufs);
146
	buf->start_time = jiffies;
L
Linus Torvalds 已提交
147 148 149
	buf->bio = bio;
	buf->resid = bio->bi_size;
	buf->sector = bio->bi_sector;
E
Ed L. Cashin 已提交
150 151
	buf->bv = &bio->bi_io_vec[bio->bi_idx];
	WARN_ON(buf->bv->bv_len == 0);
L
Linus Torvalds 已提交
152 153 154 155 156 157
	buf->bv_resid = buf->bv->bv_len;
	buf->bufaddr = page_address(buf->bv->bv_page) + buf->bv->bv_offset;

	spin_lock_irqsave(&d->lock, flags);

	if ((d->flags & DEVFL_UP) == 0) {
E
Ed L. Cashin 已提交
158 159
		printk(KERN_INFO "aoe: device %ld.%ld is not up\n",
			d->aoemajor, d->aoeminor);
L
Linus Torvalds 已提交
160 161 162 163 164 165 166 167
		spin_unlock_irqrestore(&d->lock, flags);
		mempool_free(buf, d->bufpool);
		bio_endio(bio, bio->bi_size, -ENXIO);
		return 0;
	}

	list_add_tail(&buf->bufs, &d->bufq);

168
	aoecmd_work(d);
169 170
	sl = d->sendq_hd;
	d->sendq_hd = d->sendq_tl = NULL;
L
Linus Torvalds 已提交
171 172 173

	spin_unlock_irqrestore(&d->lock, flags);
	aoenet_xmit(sl);
174

L
Linus Torvalds 已提交
175 176 177 178
	return 0;
}

static int
179
aoeblk_getgeo(struct block_device *bdev, struct hd_geometry *geo)
L
Linus Torvalds 已提交
180
{
181
	struct aoedev *d = bdev->bd_disk->private_data;
L
Linus Torvalds 已提交
182 183

	if ((d->flags & DEVFL_UP) == 0) {
E
Ed L. Cashin 已提交
184
		printk(KERN_ERR "aoe: disk not up\n");
L
Linus Torvalds 已提交
185 186 187
		return -ENODEV;
	}

188 189 190 191
	geo->cylinders = d->geo.cylinders;
	geo->heads = d->geo.heads;
	geo->sectors = d->geo.sectors;
	return 0;
L
Linus Torvalds 已提交
192 193 194 195 196
}

static struct block_device_operations aoe_bdops = {
	.open = aoeblk_open,
	.release = aoeblk_release,
197
	.getgeo = aoeblk_getgeo,
L
Linus Torvalds 已提交
198 199 200 201 202 203 204 205 206 207 208 209 210
	.owner = THIS_MODULE,
};

/* alloc_disk and add_disk can sleep */
void
aoeblk_gdalloc(void *vp)
{
	struct aoedev *d = vp;
	struct gendisk *gd;
	ulong flags;

	gd = alloc_disk(AOE_PARTITIONS);
	if (gd == NULL) {
E
Ed L. Cashin 已提交
211
		printk(KERN_ERR "aoe: cannot allocate disk structure for %ld.%ld\n",
E
Ed L. Cashin 已提交
212
			d->aoemajor, d->aoeminor);
L
Linus Torvalds 已提交
213
		spin_lock_irqsave(&d->lock, flags);
214
		d->flags &= ~DEVFL_GDALLOC;
L
Linus Torvalds 已提交
215 216 217 218
		spin_unlock_irqrestore(&d->lock, flags);
		return;
	}

219
	d->bufpool = mempool_create_slab_pool(MIN_BUFS, buf_pool_cache);
L
Linus Torvalds 已提交
220
	if (d->bufpool == NULL) {
E
Ed L. Cashin 已提交
221
		printk(KERN_ERR "aoe: cannot allocate bufpool for %ld.%ld\n",
E
Ed L. Cashin 已提交
222
			d->aoemajor, d->aoeminor);
L
Linus Torvalds 已提交
223 224
		put_disk(gd);
		spin_lock_irqsave(&d->lock, flags);
225
		d->flags &= ~DEVFL_GDALLOC;
L
Linus Torvalds 已提交
226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241
		spin_unlock_irqrestore(&d->lock, flags);
		return;
	}

	spin_lock_irqsave(&d->lock, flags);
	blk_queue_make_request(&d->blkq, aoeblk_make_request);
	gd->major = AOE_MAJOR;
	gd->first_minor = d->sysminor * AOE_PARTITIONS;
	gd->fops = &aoe_bdops;
	gd->private_data = d;
	gd->capacity = d->ssize;
	snprintf(gd->disk_name, sizeof gd->disk_name, "etherd/e%ld.%ld",
		d->aoemajor, d->aoeminor);

	gd->queue = &d->blkq;
	d->gd = gd;
242
	d->flags &= ~DEVFL_GDALLOC;
L
Linus Torvalds 已提交
243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268
	d->flags |= DEVFL_UP;

	spin_unlock_irqrestore(&d->lock, flags);

	add_disk(gd);
	aoedisk_add_sysfs(d);
}

void
aoeblk_exit(void)
{
	kmem_cache_destroy(buf_pool_cache);
}

int __init
aoeblk_init(void)
{
	buf_pool_cache = kmem_cache_create("aoe_bufs", 
					   sizeof(struct buf),
					   0, 0, NULL, NULL);
	if (buf_pool_cache == NULL)
		return -ENOMEM;

	return 0;
}