1 /* Copyright (c) 2007 Coraid, Inc. See COPYING for GPL terms. */
4 * AoE device utility functions; maintains device list.
7 #include <linux/hdreg.h>
8 #include <linux/blkdev.h>
9 #include <linux/netdevice.h>
10 #include <linux/delay.h>
13 static void dummy_timer(ulong);
14 static void aoedev_freedev(struct aoedev *);
15 static void freetgt(struct aoedev *d, struct aoetgt *t);
16 static void skbpoolfree(struct aoedev *d);
18 static struct aoedev *devlist;
19 static DEFINE_SPINLOCK(devlist_lock);
22 aoedev_by_aoeaddr(int maj, int min)
27 spin_lock_irqsave(&devlist_lock, flags);
29 for (d=devlist; d; d=d->next)
30 if (d->aoemajor == maj && d->aoeminor == min)
33 spin_unlock_irqrestore(&devlist_lock, flags);
42 d = (struct aoedev *)vp;
43 if (d->flags & DEVFL_TKILL)
45 d->timer.expires = jiffies + HZ;
50 aoedev_downdev(struct aoedev *d)
52 struct aoetgt **t, **te;
59 for (; t < te && *t; t++) {
61 e = f + (*t)->nframes;
62 for (; f < e; f->tag = FREETAG, f->buf = NULL, f++) {
63 if (f->tag == FREETAG || f->buf == NULL)
67 if (--buf->nframesout == 0
68 && buf != d->inprocess) {
69 mempool_free(buf, d->bufpool);
73 (*t)->maxout = (*t)->nframes;
79 mempool_free(buf, d->bufpool);
85 while (!list_empty(&d->bufq)) {
86 buf = container_of(d->bufq.next, struct buf, bufs);
87 list_del(d->bufq.next);
89 mempool_free(buf, d->bufpool);
94 set_capacity(d->gd, 0);
96 d->flags &= ~DEVFL_UP;
100 aoedev_freedev(struct aoedev *d)
102 struct aoetgt **t, **e;
111 for (; t < e && *t; t++)
114 mempool_destroy(d->bufpool);
116 blk_cleanup_queue(d->blkq);
121 aoedev_flush(const char __user *str, size_t cnt)
124 struct aoedev *d, **dd;
125 struct aoedev *rmd = NULL;
130 if (cnt > sizeof buf)
132 if (copy_from_user(buf, str, cnt))
134 all = !strncmp(buf, "all", 3);
137 flush_scheduled_work();
138 spin_lock_irqsave(&devlist_lock, flags);
142 if ((!all && (d->flags & DEVFL_UP))
143 || (d->flags & (DEVFL_GDALLOC|DEVFL_NEWSIZE))
145 spin_unlock(&d->lock);
151 d->flags |= DEVFL_TKILL;
152 spin_unlock(&d->lock);
156 spin_unlock_irqrestore(&devlist_lock, flags);
159 del_timer_sync(&d->timer);
160 aoedev_freedev(d); /* must be able to sleep */
165 /* I'm not really sure that this is a realistic problem, but if the
166 network driver goes gonzo let's just leak memory after complaining. */
168 skbfree(struct sk_buff *skb)
170 enum { Sms = 100, Tms = 3*1000};
175 while (atomic_read(&skb_shinfo(skb)->dataref) != 1 && i-- > 0)
179 "aoe: %s holds ref: %s\n",
180 skb->dev ? skb->dev->name : "netif",
181 "cannot free skb -- memory leaked.");
184 skb_shinfo(skb)->nr_frags = skb->data_len = 0;
190 skbpoolfree(struct aoedev *d)
192 struct sk_buff *skb, *tmp;
194 skb_queue_walk_safe(&d->skbpool, skb, tmp)
197 __skb_queue_head_init(&d->skbpool);
200 /* find it or malloc it */
202 aoedev_by_sysminor_m(ulong sysminor)
207 spin_lock_irqsave(&devlist_lock, flags);
209 for (d=devlist; d; d=d->next)
210 if (d->sysminor == sysminor)
214 d = kcalloc(1, sizeof *d, GFP_ATOMIC);
217 INIT_WORK(&d->work, aoecmd_sleepwork);
218 spin_lock_init(&d->lock);
219 skb_queue_head_init(&d->sendq);
220 skb_queue_head_init(&d->skbpool);
221 init_timer(&d->timer);
222 d->timer.data = (ulong) d;
223 d->timer.function = dummy_timer;
224 d->timer.expires = jiffies + HZ;
225 add_timer(&d->timer);
226 d->bufpool = NULL; /* defer to aoeblk_gdalloc */
228 INIT_LIST_HEAD(&d->bufq);
229 d->sysminor = sysminor;
230 d->aoemajor = AOEMAJOR(sysminor);
231 d->aoeminor = AOEMINOR(sysminor);
232 d->mintimer = MINTIMER;
236 spin_unlock_irqrestore(&devlist_lock, flags);
241 freetgt(struct aoedev *d, struct aoetgt *t)
259 flush_scheduled_work();
261 while ((d = devlist)) {
264 spin_lock_irqsave(&d->lock, flags);
266 d->flags |= DEVFL_TKILL;
267 spin_unlock_irqrestore(&d->lock, flags);
269 del_timer_sync(&d->timer);