1/*
2 * Swap block device support for MTDs
3 * Turns an MTD device into a swap device with block wear leveling
4 *
5 * Copyright © 2007,2011 Nokia Corporation. All rights reserved.
6 *
7 * Authors: Jarkko Lavinen <jarkko.lavinen@nokia.com>
8 *
9 * Based on Richard Purdie's earlier implementation in 2007. Background
10 * support and lock-less operation written by Adrian Hunter.
11 *
12 * This program is free software; you can redistribute it and/or
13 * modify it under the terms of the GNU General Public License
14 * version 2 as published by the Free Software Foundation.
15 *
16 * This program is distributed in the hope that it will be useful, but
17 * WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
19 * General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License
22 * along with this program; if not, write to the Free Software
23 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
24 * 02110-1301 USA
25 */
26
27#include <linux/kernel.h>
28#include <linux/module.h>
29#include <linux/mtd/mtd.h>
30#include <linux/mtd/blktrans.h>
31#include <linux/rbtree.h>
32#include <linux/sched.h>
33#include <linux/slab.h>
34#include <linux/vmalloc.h>
35#include <linux/genhd.h>
36#include <linux/swap.h>
37#include <linux/debugfs.h>
38#include <linux/seq_file.h>
39#include <linux/device.h>
40#include <linux/math64.h>
41
42#define MTDSWAP_PREFIX "mtdswap"
43
44/*
45 * The number of free eraseblocks when GC should stop
46 */
47#define CLEAN_BLOCK_THRESHOLD	20
48
49/*
50 * Number of free eraseblocks below which GC can also collect low frag
51 * blocks.
52 */
53#define LOW_FRAG_GC_TRESHOLD	5
54
55/*
56 * Wear level cost amortization. We want to do wear leveling on the background
57 * without disturbing gc too much. This is made by defining max GC frequency.
58 * Frequency value 6 means 1/6 of the GC passes will pick an erase block based
59 * on the biggest wear difference rather than the biggest dirtiness.
60 *
61 * The lower freq2 should be chosen so that it makes sure the maximum erase
62 * difference will decrease even if a malicious application is deliberately
63 * trying to make erase differences large.
64 */
65#define MAX_ERASE_DIFF		4000
66#define COLLECT_NONDIRTY_BASE	MAX_ERASE_DIFF
67#define COLLECT_NONDIRTY_FREQ1	6
68#define COLLECT_NONDIRTY_FREQ2	4
69
70#define PAGE_UNDEF		UINT_MAX
71#define BLOCK_UNDEF		UINT_MAX
72#define BLOCK_ERROR		(UINT_MAX - 1)
73#define BLOCK_MAX		(UINT_MAX - 2)
74
75#define EBLOCK_BAD		(1 << 0)
76#define EBLOCK_NOMAGIC		(1 << 1)
77#define EBLOCK_BITFLIP		(1 << 2)
78#define EBLOCK_FAILED		(1 << 3)
79#define EBLOCK_READERR		(1 << 4)
80#define EBLOCK_IDX_SHIFT	5
81
82struct swap_eb {
83	struct rb_node rb;
84	struct rb_root *root;
85
86	unsigned int flags;
87	unsigned int active_count;
88	unsigned int erase_count;
89	unsigned int pad;		/* speeds up pointer decrement */
90};
91
92#define MTDSWAP_ECNT_MIN(rbroot) (rb_entry(rb_first(rbroot), struct swap_eb, \
93				rb)->erase_count)
94#define MTDSWAP_ECNT_MAX(rbroot) (rb_entry(rb_last(rbroot), struct swap_eb, \
95				rb)->erase_count)
96
97struct mtdswap_tree {
98	struct rb_root root;
99	unsigned int count;
100};
101
102enum {
103	MTDSWAP_CLEAN,
104	MTDSWAP_USED,
105	MTDSWAP_LOWFRAG,
106	MTDSWAP_HIFRAG,
107	MTDSWAP_DIRTY,
108	MTDSWAP_BITFLIP,
109	MTDSWAP_FAILING,
110	MTDSWAP_TREE_CNT,
111};
112
113struct mtdswap_dev {
114	struct mtd_blktrans_dev *mbd_dev;
115	struct mtd_info *mtd;
116	struct device *dev;
117
118	unsigned int *page_data;
119	unsigned int *revmap;
120
121	unsigned int eblks;
122	unsigned int spare_eblks;
123	unsigned int pages_per_eblk;
124	unsigned int max_erase_count;
125	struct swap_eb *eb_data;
126
127	struct mtdswap_tree trees[MTDSWAP_TREE_CNT];
128
129	unsigned long long sect_read_count;
130	unsigned long long sect_write_count;
131	unsigned long long mtd_write_count;
132	unsigned long long mtd_read_count;
133	unsigned long long discard_count;
134	unsigned long long discard_page_count;
135
136	unsigned int curr_write_pos;
137	struct swap_eb *curr_write;
138
139	char *page_buf;
140	char *oob_buf;
141
142	struct dentry *debugfs_root;
143};
144
145struct mtdswap_oobdata {
146	__le16 magic;
147	__le32 count;
148} __packed;
149
150#define MTDSWAP_MAGIC_CLEAN	0x2095
151#define MTDSWAP_MAGIC_DIRTY	(MTDSWAP_MAGIC_CLEAN + 1)
152#define MTDSWAP_TYPE_CLEAN	0
153#define MTDSWAP_TYPE_DIRTY	1
154#define MTDSWAP_OOBSIZE		sizeof(struct mtdswap_oobdata)
155
156#define MTDSWAP_ERASE_RETRIES	3 /* Before marking erase block bad */
157#define MTDSWAP_IO_RETRIES	3
158
159enum {
160	MTDSWAP_SCANNED_CLEAN,
161	MTDSWAP_SCANNED_DIRTY,
162	MTDSWAP_SCANNED_BITFLIP,
163	MTDSWAP_SCANNED_BAD,
164};
165
166/*
167 * In the worst case mtdswap_writesect() has allocated the last clean
168 * page from the current block and is then pre-empted by the GC
169 * thread. The thread can consume a full erase block when moving a
170 * block.
171 */
172#define MIN_SPARE_EBLOCKS	2
173#define MIN_ERASE_BLOCKS	(MIN_SPARE_EBLOCKS + 1)
174
175#define TREE_ROOT(d, name) (&d->trees[MTDSWAP_ ## name].root)
176#define TREE_EMPTY(d, name) (TREE_ROOT(d, name)->rb_node == NULL)
177#define TREE_NONEMPTY(d, name) (!TREE_EMPTY(d, name))
178#define TREE_COUNT(d, name) (d->trees[MTDSWAP_ ## name].count)
179
180#define MTDSWAP_MBD_TO_MTDSWAP(dev) ((struct mtdswap_dev *)dev->priv)
181
182static char partitions[128] = "";
183module_param_string(partitions, partitions, sizeof(partitions), 0444);
184MODULE_PARM_DESC(partitions, "MTD partition numbers to use as swap "
185		"partitions=\"1,3,5\"");
186
187static unsigned int spare_eblocks = 10;
188module_param(spare_eblocks, uint, 0444);
189MODULE_PARM_DESC(spare_eblocks, "Percentage of spare erase blocks for "
190		"garbage collection (default 10%)");
191
192static bool header; /* false */
193module_param(header, bool, 0444);
194MODULE_PARM_DESC(header,
195		"Include builtin swap header (default 0, without header)");
196
197static int mtdswap_gc(struct mtdswap_dev *d, unsigned int background);
198
199static loff_t mtdswap_eb_offset(struct mtdswap_dev *d, struct swap_eb *eb)
200{
201	return (loff_t)(eb - d->eb_data) * d->mtd->erasesize;
202}
203
204static void mtdswap_eb_detach(struct mtdswap_dev *d, struct swap_eb *eb)
205{
206	unsigned int oldidx;
207	struct mtdswap_tree *tp;
208
209	if (eb->root) {
210		tp = container_of(eb->root, struct mtdswap_tree, root);
211		oldidx = tp - &d->trees[0];
212
213		d->trees[oldidx].count--;
214		rb_erase(&eb->rb, eb->root);
215	}
216}
217
218static void __mtdswap_rb_add(struct rb_root *root, struct swap_eb *eb)
219{
220	struct rb_node **p, *parent = NULL;
221	struct swap_eb *cur;
222
223	p = &root->rb_node;
224	while (*p) {
225		parent = *p;
226		cur = rb_entry(parent, struct swap_eb, rb);
227		if (eb->erase_count > cur->erase_count)
228			p = &(*p)->rb_right;
229		else
230			p = &(*p)->rb_left;
231	}
232
233	rb_link_node(&eb->rb, parent, p);
234	rb_insert_color(&eb->rb, root);
235}
236
237static void mtdswap_rb_add(struct mtdswap_dev *d, struct swap_eb *eb, int idx)
238{
239	struct rb_root *root;
240
241	if (eb->root == &d->trees[idx].root)
242		return;
243
244	mtdswap_eb_detach(d, eb);
245	root = &d->trees[idx].root;
246	__mtdswap_rb_add(root, eb);
247	eb->root = root;
248	d->trees[idx].count++;
249}
250
251static struct rb_node *mtdswap_rb_index(struct rb_root *root, unsigned int idx)
252{
253	struct rb_node *p;
254	unsigned int i;
255
256	p = rb_first(root);
257	i = 0;
258	while (i < idx && p) {
259		p = rb_next(p);
260		i++;
261	}
262
263	return p;
264}
265
266static int mtdswap_handle_badblock(struct mtdswap_dev *d, struct swap_eb *eb)
267{
268	int ret;
269	loff_t offset;
270
271	d->spare_eblks--;
272	eb->flags |= EBLOCK_BAD;
273	mtdswap_eb_detach(d, eb);
274	eb->root = NULL;
275
276	/* badblocks not supported */
277	if (!mtd_can_have_bb(d->mtd))
278		return 1;
279
280	offset = mtdswap_eb_offset(d, eb);
281	dev_warn(d->dev, "Marking bad block at %08llx\n", offset);
282	ret = mtd_block_markbad(d->mtd, offset);
283
284	if (ret) {
285		dev_warn(d->dev, "Mark block bad failed for block at %08llx "
286			"error %d\n", offset, ret);
287		return ret;
288	}
289
290	return 1;
291
292}
293
294static int mtdswap_handle_write_error(struct mtdswap_dev *d, struct swap_eb *eb)
295{
296	unsigned int marked = eb->flags & EBLOCK_FAILED;
297	struct swap_eb *curr_write = d->curr_write;
298
299	eb->flags |= EBLOCK_FAILED;
300	if (curr_write == eb) {
301		d->curr_write = NULL;
302
303		if (!marked && d->curr_write_pos != 0) {
304			mtdswap_rb_add(d, eb, MTDSWAP_FAILING);
305			return 0;
306		}
307	}
308
309	return mtdswap_handle_badblock(d, eb);
310}
311
312static int mtdswap_read_oob(struct mtdswap_dev *d, loff_t from,
313			struct mtd_oob_ops *ops)
314{
315	int ret = mtd_read_oob(d->mtd, from, ops);
316
317	if (mtd_is_bitflip(ret))
318		return ret;
319
320	if (ret) {
321		dev_warn(d->dev, "Read OOB failed %d for block at %08llx\n",
322			ret, from);
323		return ret;
324	}
325
326	if (ops->oobretlen < ops->ooblen) {
327		dev_warn(d->dev, "Read OOB return short read (%zd bytes not "
328			"%zd) for block at %08llx\n",
329			ops->oobretlen, ops->ooblen, from);
330		return -EIO;
331	}
332
333	return 0;
334}
335
336static int mtdswap_read_markers(struct mtdswap_dev *d, struct swap_eb *eb)
337{
338	struct mtdswap_oobdata *data, *data2;
339	int ret;
340	loff_t offset;
341	struct mtd_oob_ops ops;
342
343	offset = mtdswap_eb_offset(d, eb);
344
345	/* Check first if the block is bad. */
346	if (mtd_can_have_bb(d->mtd) && mtd_block_isbad(d->mtd, offset))
347		return MTDSWAP_SCANNED_BAD;
348
349	ops.ooblen = 2 * d->mtd->ecclayout->oobavail;
350	ops.oobbuf = d->oob_buf;
351	ops.ooboffs = 0;
352	ops.datbuf = NULL;
353	ops.mode = MTD_OPS_AUTO_OOB;
354
355	ret = mtdswap_read_oob(d, offset, &ops);
356
357	if (ret && !mtd_is_bitflip(ret))
358		return ret;
359
360	data = (struct mtdswap_oobdata *)d->oob_buf;
361	data2 = (struct mtdswap_oobdata *)
362		(d->oob_buf + d->mtd->ecclayout->oobavail);
363
364	if (le16_to_cpu(data->magic) == MTDSWAP_MAGIC_CLEAN) {
365		eb->erase_count = le32_to_cpu(data->count);
366		if (mtd_is_bitflip(ret))
367			ret = MTDSWAP_SCANNED_BITFLIP;
368		else {
369			if (le16_to_cpu(data2->magic) == MTDSWAP_MAGIC_DIRTY)
370				ret = MTDSWAP_SCANNED_DIRTY;
371			else
372				ret = MTDSWAP_SCANNED_CLEAN;
373		}
374	} else {
375		eb->flags |= EBLOCK_NOMAGIC;
376		ret = MTDSWAP_SCANNED_DIRTY;
377	}
378
379	return ret;
380}
381
382static int mtdswap_write_marker(struct mtdswap_dev *d, struct swap_eb *eb,
383				u16 marker)
384{
385	struct mtdswap_oobdata n;
386	int ret;
387	loff_t offset;
388	struct mtd_oob_ops ops;
389
390	ops.ooboffs = 0;
391	ops.oobbuf = (uint8_t *)&n;
392	ops.mode = MTD_OPS_AUTO_OOB;
393	ops.datbuf = NULL;
394
395	if (marker == MTDSWAP_TYPE_CLEAN) {
396		n.magic = cpu_to_le16(MTDSWAP_MAGIC_CLEAN);
397		n.count = cpu_to_le32(eb->erase_count);
398		ops.ooblen = MTDSWAP_OOBSIZE;
399		offset = mtdswap_eb_offset(d, eb);
400	} else {
401		n.magic = cpu_to_le16(MTDSWAP_MAGIC_DIRTY);
402		ops.ooblen = sizeof(n.magic);
403		offset = mtdswap_eb_offset(d, eb) + d->mtd->writesize;
404	}
405
406	ret = mtd_write_oob(d->mtd, offset, &ops);
407
408	if (ret) {
409		dev_warn(d->dev, "Write OOB failed for block at %08llx "
410			"error %d\n", offset, ret);
411		if (ret == -EIO || mtd_is_eccerr(ret))
412			mtdswap_handle_write_error(d, eb);
413		return ret;
414	}
415
416	if (ops.oobretlen != ops.ooblen) {
417		dev_warn(d->dev, "Short OOB write for block at %08llx: "
418			"%zd not %zd\n",
419			offset, ops.oobretlen, ops.ooblen);
420		return ret;
421	}
422
423	return 0;
424}
425
426/*
427 * Are there any erase blocks without MAGIC_CLEAN header, presumably
428 * because power was cut off after erase but before header write? We
429 * need to guestimate the erase count.
430 */
431static void mtdswap_check_counts(struct mtdswap_dev *d)
432{
433	struct rb_root hist_root = RB_ROOT;
434	struct rb_node *medrb;
435	struct swap_eb *eb;
436	unsigned int i, cnt, median;
437
438	cnt = 0;
439	for (i = 0; i < d->eblks; i++) {
440		eb = d->eb_data + i;
441
442		if (eb->flags & (EBLOCK_NOMAGIC | EBLOCK_BAD | EBLOCK_READERR))
443			continue;
444
445		__mtdswap_rb_add(&hist_root, eb);
446		cnt++;
447	}
448
449	if (cnt == 0)
450		return;
451
452	medrb = mtdswap_rb_index(&hist_root, cnt / 2);
453	median = rb_entry(medrb, struct swap_eb, rb)->erase_count;
454
455	d->max_erase_count = MTDSWAP_ECNT_MAX(&hist_root);
456
457	for (i = 0; i < d->eblks; i++) {
458		eb = d->eb_data + i;
459
460		if (eb->flags & (EBLOCK_NOMAGIC | EBLOCK_READERR))
461			eb->erase_count = median;
462
463		if (eb->flags & (EBLOCK_NOMAGIC | EBLOCK_BAD | EBLOCK_READERR))
464			continue;
465
466		rb_erase(&eb->rb, &hist_root);
467	}
468}
469
470static void mtdswap_scan_eblks(struct mtdswap_dev *d)
471{
472	int status;
473	unsigned int i, idx;
474	struct swap_eb *eb;
475
476	for (i = 0; i < d->eblks; i++) {
477		eb = d->eb_data + i;
478
479		status = mtdswap_read_markers(d, eb);
480		if (status < 0)
481			eb->flags |= EBLOCK_READERR;
482		else if (status == MTDSWAP_SCANNED_BAD) {
483			eb->flags |= EBLOCK_BAD;
484			continue;
485		}
486
487		switch (status) {
488		case MTDSWAP_SCANNED_CLEAN:
489			idx = MTDSWAP_CLEAN;
490			break;
491		case MTDSWAP_SCANNED_DIRTY:
492		case MTDSWAP_SCANNED_BITFLIP:
493			idx = MTDSWAP_DIRTY;
494			break;
495		default:
496			idx = MTDSWAP_FAILING;
497		}
498
499		eb->flags |= (idx << EBLOCK_IDX_SHIFT);
500	}
501
502	mtdswap_check_counts(d);
503
504	for (i = 0; i < d->eblks; i++) {
505		eb = d->eb_data + i;
506
507		if (eb->flags & EBLOCK_BAD)
508			continue;
509
510		idx = eb->flags >> EBLOCK_IDX_SHIFT;
511		mtdswap_rb_add(d, eb, idx);
512	}
513}
514
515/*
516 * Place eblk into a tree corresponding to its number of active blocks
517 * it contains.
518 */
519static void mtdswap_store_eb(struct mtdswap_dev *d, struct swap_eb *eb)
520{
521	unsigned int weight = eb->active_count;
522	unsigned int maxweight = d->pages_per_eblk;
523
524	if (eb == d->curr_write)
525		return;
526
527	if (eb->flags & EBLOCK_BITFLIP)
528		mtdswap_rb_add(d, eb, MTDSWAP_BITFLIP);
529	else if (eb->flags & (EBLOCK_READERR | EBLOCK_FAILED))
530		mtdswap_rb_add(d, eb, MTDSWAP_FAILING);
531	if (weight == maxweight)
532		mtdswap_rb_add(d, eb, MTDSWAP_USED);
533	else if (weight == 0)
534		mtdswap_rb_add(d, eb, MTDSWAP_DIRTY);
535	else if (weight > (maxweight/2))
536		mtdswap_rb_add(d, eb, MTDSWAP_LOWFRAG);
537	else
538		mtdswap_rb_add(d, eb, MTDSWAP_HIFRAG);
539}
540
541
542static void mtdswap_erase_callback(struct erase_info *done)
543{
544	wait_queue_head_t *wait_q = (wait_queue_head_t *)done->priv;
545	wake_up(wait_q);
546}
547
548static int mtdswap_erase_block(struct mtdswap_dev *d, struct swap_eb *eb)
549{
550	struct mtd_info *mtd = d->mtd;
551	struct erase_info erase;
552	wait_queue_head_t wq;
553	unsigned int retries = 0;
554	int ret;
555
556	eb->erase_count++;
557	if (eb->erase_count > d->max_erase_count)
558		d->max_erase_count = eb->erase_count;
559
560retry:
561	init_waitqueue_head(&wq);
562	memset(&erase, 0, sizeof(struct erase_info));
563
564	erase.mtd	= mtd;
565	erase.callback	= mtdswap_erase_callback;
566	erase.addr	= mtdswap_eb_offset(d, eb);
567	erase.len	= mtd->erasesize;
568	erase.priv	= (u_long)&wq;
569
570	ret = mtd_erase(mtd, &erase);
571	if (ret) {
572		if (retries++ < MTDSWAP_ERASE_RETRIES) {
573			dev_warn(d->dev,
574				"erase of erase block %#llx on %s failed",
575				erase.addr, mtd->name);
576			yield();
577			goto retry;
578		}
579
580		dev_err(d->dev, "Cannot erase erase block %#llx on %s\n",
581			erase.addr, mtd->name);
582
583		mtdswap_handle_badblock(d, eb);
584		return -EIO;
585	}
586
587	ret = wait_event_interruptible(wq, erase.state == MTD_ERASE_DONE ||
588					   erase.state == MTD_ERASE_FAILED);
589	if (ret) {
590		dev_err(d->dev, "Interrupted erase block %#llx erassure on %s",
591			erase.addr, mtd->name);
592		return -EINTR;
593	}
594
595	if (erase.state == MTD_ERASE_FAILED) {
596		if (retries++ < MTDSWAP_ERASE_RETRIES) {
597			dev_warn(d->dev,
598				"erase of erase block %#llx on %s failed",
599				erase.addr, mtd->name);
600			yield();
601			goto retry;
602		}
603
604		mtdswap_handle_badblock(d, eb);
605		return -EIO;
606	}
607
608	return 0;
609}
610
611static int mtdswap_map_free_block(struct mtdswap_dev *d, unsigned int page,
612				unsigned int *block)
613{
614	int ret;
615	struct swap_eb *old_eb = d->curr_write;
616	struct rb_root *clean_root;
617	struct swap_eb *eb;
618
619	if (old_eb == NULL || d->curr_write_pos >= d->pages_per_eblk) {
620		do {
621			if (TREE_EMPTY(d, CLEAN))
622				return -ENOSPC;
623
624			clean_root = TREE_ROOT(d, CLEAN);
625			eb = rb_entry(rb_first(clean_root), struct swap_eb, rb);
626			rb_erase(&eb->rb, clean_root);
627			eb->root = NULL;
628			TREE_COUNT(d, CLEAN)--;
629
630			ret = mtdswap_write_marker(d, eb, MTDSWAP_TYPE_DIRTY);
631		} while (ret == -EIO || mtd_is_eccerr(ret));
632
633		if (ret)
634			return ret;
635
636		d->curr_write_pos = 0;
637		d->curr_write = eb;
638		if (old_eb)
639			mtdswap_store_eb(d, old_eb);
640	}
641
642	*block = (d->curr_write - d->eb_data) * d->pages_per_eblk +
643		d->curr_write_pos;
644
645	d->curr_write->active_count++;
646	d->revmap[*block] = page;
647	d->curr_write_pos++;
648
649	return 0;
650}
651
652static unsigned int mtdswap_free_page_cnt(struct mtdswap_dev *d)
653{
654	return TREE_COUNT(d, CLEAN) * d->pages_per_eblk +
655		d->pages_per_eblk - d->curr_write_pos;
656}
657
658static unsigned int mtdswap_enough_free_pages(struct mtdswap_dev *d)
659{
660	return mtdswap_free_page_cnt(d) > d->pages_per_eblk;
661}
662
663static int mtdswap_write_block(struct mtdswap_dev *d, char *buf,
664			unsigned int page, unsigned int *bp, int gc_context)
665{
666	struct mtd_info *mtd = d->mtd;
667	struct swap_eb *eb;
668	size_t retlen;
669	loff_t writepos;
670	int ret;
671
672retry:
673	if (!gc_context)
674		while (!mtdswap_enough_free_pages(d))
675			if (mtdswap_gc(d, 0) > 0)
676				return -ENOSPC;
677
678	ret = mtdswap_map_free_block(d, page, bp);
679	eb = d->eb_data + (*bp / d->pages_per_eblk);
680
681	if (ret == -EIO || mtd_is_eccerr(ret)) {
682		d->curr_write = NULL;
683		eb->active_count--;
684		d->revmap[*bp] = PAGE_UNDEF;
685		goto retry;
686	}
687
688	if (ret < 0)
689		return ret;
690
691	writepos = (loff_t)*bp << PAGE_SHIFT;
692	ret =  mtd_write(mtd, writepos, PAGE_SIZE, &retlen, buf);
693	if (ret == -EIO || mtd_is_eccerr(ret)) {
694		d->curr_write_pos--;
695		eb->active_count--;
696		d->revmap[*bp] = PAGE_UNDEF;
697		mtdswap_handle_write_error(d, eb);
698		goto retry;
699	}
700
701	if (ret < 0) {
702		dev_err(d->dev, "Write to MTD device failed: %d (%zd written)",
703			ret, retlen);
704		goto err;
705	}
706
707	if (retlen != PAGE_SIZE) {
708		dev_err(d->dev, "Short write to MTD device: %zd written",
709			retlen);
710		ret = -EIO;
711		goto err;
712	}
713
714	return ret;
715
716err:
717	d->curr_write_pos--;
718	eb->active_count--;
719	d->revmap[*bp] = PAGE_UNDEF;
720
721	return ret;
722}
723
724static int mtdswap_move_block(struct mtdswap_dev *d, unsigned int oldblock,
725		unsigned int *newblock)
726{
727	struct mtd_info *mtd = d->mtd;
728	struct swap_eb *eb, *oldeb;
729	int ret;
730	size_t retlen;
731	unsigned int page, retries;
732	loff_t readpos;
733
734	page = d->revmap[oldblock];
735	readpos = (loff_t) oldblock << PAGE_SHIFT;
736	retries = 0;
737
738retry:
739	ret = mtd_read(mtd, readpos, PAGE_SIZE, &retlen, d->page_buf);
740
741	if (ret < 0 && !mtd_is_bitflip(ret)) {
742		oldeb = d->eb_data + oldblock / d->pages_per_eblk;
743		oldeb->flags |= EBLOCK_READERR;
744
745		dev_err(d->dev, "Read Error: %d (block %u)\n", ret,
746			oldblock);
747		retries++;
748		if (retries < MTDSWAP_IO_RETRIES)
749			goto retry;
750
751		goto read_error;
752	}
753
754	if (retlen != PAGE_SIZE) {
755		dev_err(d->dev, "Short read: %zd (block %u)\n", retlen,
756		       oldblock);
757		ret = -EIO;
758		goto read_error;
759	}
760
761	ret = mtdswap_write_block(d, d->page_buf, page, newblock, 1);
762	if (ret < 0) {
763		d->page_data[page] = BLOCK_ERROR;
764		dev_err(d->dev, "Write error: %d\n", ret);
765		return ret;
766	}
767
768	eb = d->eb_data + *newblock / d->pages_per_eblk;
769	d->page_data[page] = *newblock;
770	d->revmap[oldblock] = PAGE_UNDEF;
771	eb = d->eb_data + oldblock / d->pages_per_eblk;
772	eb->active_count--;
773
774	return 0;
775
776read_error:
777	d->page_data[page] = BLOCK_ERROR;
778	d->revmap[oldblock] = PAGE_UNDEF;
779	return ret;
780}
781
782static int mtdswap_gc_eblock(struct mtdswap_dev *d, struct swap_eb *eb)
783{
784	unsigned int i, block, eblk_base, newblock;
785	int ret, errcode;
786
787	errcode = 0;
788	eblk_base = (eb - d->eb_data) * d->pages_per_eblk;
789
790	for (i = 0; i < d->pages_per_eblk; i++) {
791		if (d->spare_eblks < MIN_SPARE_EBLOCKS)
792			return -ENOSPC;
793
794		block = eblk_base + i;
795		if (d->revmap[block] == PAGE_UNDEF)
796			continue;
797
798		ret = mtdswap_move_block(d, block, &newblock);
799		if (ret < 0 && !errcode)
800			errcode = ret;
801	}
802
803	return errcode;
804}
805
806static int __mtdswap_choose_gc_tree(struct mtdswap_dev *d)
807{
808	int idx, stopat;
809
810	if (TREE_COUNT(d, CLEAN) < LOW_FRAG_GC_TRESHOLD)
811		stopat = MTDSWAP_LOWFRAG;
812	else
813		stopat = MTDSWAP_HIFRAG;
814
815	for (idx = MTDSWAP_BITFLIP; idx >= stopat; idx--)
816		if (d->trees[idx].root.rb_node != NULL)
817			return idx;
818
819	return -1;
820}
821
822static int mtdswap_wlfreq(unsigned int maxdiff)
823{
824	unsigned int h, x, y, dist, base;
825
826	/*
827	 * Calculate linear ramp down from f1 to f2 when maxdiff goes from
828	 * MAX_ERASE_DIFF to MAX_ERASE_DIFF + COLLECT_NONDIRTY_BASE.  Similar
829	 * to triangle with height f1 - f1 and width COLLECT_NONDIRTY_BASE.
830	 */
831
832	dist = maxdiff - MAX_ERASE_DIFF;
833	if (dist > COLLECT_NONDIRTY_BASE)
834		dist = COLLECT_NONDIRTY_BASE;
835
836	/*
837	 * Modelling the slop as right angular triangle with base
838	 * COLLECT_NONDIRTY_BASE and height freq1 - freq2. The ratio y/x is
839	 * equal to the ratio h/base.
840	 */
841	h = COLLECT_NONDIRTY_FREQ1 - COLLECT_NONDIRTY_FREQ2;
842	base = COLLECT_NONDIRTY_BASE;
843
844	x = dist - base;
845	y = (x * h + base / 2) / base;
846
847	return COLLECT_NONDIRTY_FREQ2 + y;
848}
849
850static int mtdswap_choose_wl_tree(struct mtdswap_dev *d)
851{
852	static unsigned int pick_cnt;
853	unsigned int i, idx = -1, wear, max;
854	struct rb_root *root;
855
856	max = 0;
857	for (i = 0; i <= MTDSWAP_DIRTY; i++) {
858		root = &d->trees[i].root;
859		if (root->rb_node == NULL)
860			continue;
861
862		wear = d->max_erase_count - MTDSWAP_ECNT_MIN(root);
863		if (wear > max) {
864			max = wear;
865			idx = i;
866		}
867	}
868
869	if (max > MAX_ERASE_DIFF && pick_cnt >= mtdswap_wlfreq(max) - 1) {
870		pick_cnt = 0;
871		return idx;
872	}
873
874	pick_cnt++;
875	return -1;
876}
877
878static int mtdswap_choose_gc_tree(struct mtdswap_dev *d,
879				unsigned int background)
880{
881	int idx;
882
883	if (TREE_NONEMPTY(d, FAILING) &&
884		(background || (TREE_EMPTY(d, CLEAN) && TREE_EMPTY(d, DIRTY))))
885		return MTDSWAP_FAILING;
886
887	idx = mtdswap_choose_wl_tree(d);
888	if (idx >= MTDSWAP_CLEAN)
889		return idx;
890
891	return __mtdswap_choose_gc_tree(d);
892}
893
894static struct swap_eb *mtdswap_pick_gc_eblk(struct mtdswap_dev *d,
895					unsigned int background)
896{
897	struct rb_root *rp = NULL;
898	struct swap_eb *eb = NULL;
899	int idx;
900
901	if (background && TREE_COUNT(d, CLEAN) > CLEAN_BLOCK_THRESHOLD &&
902		TREE_EMPTY(d, DIRTY) && TREE_EMPTY(d, FAILING))
903		return NULL;
904
905	idx = mtdswap_choose_gc_tree(d, background);
906	if (idx < 0)
907		return NULL;
908
909	rp = &d->trees[idx].root;
910	eb = rb_entry(rb_first(rp), struct swap_eb, rb);
911
912	rb_erase(&eb->rb, rp);
913	eb->root = NULL;
914	d->trees[idx].count--;
915	return eb;
916}
917
918static unsigned int mtdswap_test_patt(unsigned int i)
919{
920	return i % 2 ? 0x55555555 : 0xAAAAAAAA;
921}
922
923static unsigned int mtdswap_eblk_passes(struct mtdswap_dev *d,
924					struct swap_eb *eb)
925{
926	struct mtd_info *mtd = d->mtd;
927	unsigned int test, i, j, patt, mtd_pages;
928	loff_t base, pos;
929	unsigned int *p1 = (unsigned int *)d->page_buf;
930	unsigned char *p2 = (unsigned char *)d->oob_buf;
931	struct mtd_oob_ops ops;
932	int ret;
933
934	ops.mode = MTD_OPS_AUTO_OOB;
935	ops.len = mtd->writesize;
936	ops.ooblen = mtd->ecclayout->oobavail;
937	ops.ooboffs = 0;
938	ops.datbuf = d->page_buf;
939	ops.oobbuf = d->oob_buf;
940	base = mtdswap_eb_offset(d, eb);
941	mtd_pages = d->pages_per_eblk * PAGE_SIZE / mtd->writesize;
942
943	for (test = 0; test < 2; test++) {
944		pos = base;
945		for (i = 0; i < mtd_pages; i++) {
946			patt = mtdswap_test_patt(test + i);
947			memset(d->page_buf, patt, mtd->writesize);
948			memset(d->oob_buf, patt, mtd->ecclayout->oobavail);
949			ret = mtd_write_oob(mtd, pos, &ops);
950			if (ret)
951				goto error;
952
953			pos += mtd->writesize;
954		}
955
956		pos = base;
957		for (i = 0; i < mtd_pages; i++) {
958			ret = mtd_read_oob(mtd, pos, &ops);
959			if (ret)
960				goto error;
961
962			patt = mtdswap_test_patt(test + i);
963			for (j = 0; j < mtd->writesize/sizeof(int); j++)
964				if (p1[j] != patt)
965					goto error;
966
967			for (j = 0; j < mtd->ecclayout->oobavail; j++)
968				if (p2[j] != (unsigned char)patt)
969					goto error;
970
971			pos += mtd->writesize;
972		}
973
974		ret = mtdswap_erase_block(d, eb);
975		if (ret)
976			goto error;
977	}
978
979	eb->flags &= ~EBLOCK_READERR;
980	return 1;
981
982error:
983	mtdswap_handle_badblock(d, eb);
984	return 0;
985}
986
987static int mtdswap_gc(struct mtdswap_dev *d, unsigned int background)
988{
989	struct swap_eb *eb;
990	int ret;
991
992	if (d->spare_eblks < MIN_SPARE_EBLOCKS)
993		return 1;
994
995	eb = mtdswap_pick_gc_eblk(d, background);
996	if (!eb)
997		return 1;
998
999	ret = mtdswap_gc_eblock(d, eb);
1000	if (ret == -ENOSPC)
1001		return 1;
1002
1003	if (eb->flags & EBLOCK_FAILED) {
1004		mtdswap_handle_badblock(d, eb);
1005		return 0;
1006	}
1007
1008	eb->flags &= ~EBLOCK_BITFLIP;
1009	ret = mtdswap_erase_block(d, eb);
1010	if ((eb->flags & EBLOCK_READERR) &&
1011		(ret || !mtdswap_eblk_passes(d, eb)))
1012		return 0;
1013
1014	if (ret == 0)
1015		ret = mtdswap_write_marker(d, eb, MTDSWAP_TYPE_CLEAN);
1016
1017	if (ret == 0)
1018		mtdswap_rb_add(d, eb, MTDSWAP_CLEAN);
1019	else if (ret != -EIO && !mtd_is_eccerr(ret))
1020		mtdswap_rb_add(d, eb, MTDSWAP_DIRTY);
1021
1022	return 0;
1023}
1024
1025static void mtdswap_background(struct mtd_blktrans_dev *dev)
1026{
1027	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1028	int ret;
1029
1030	while (1) {
1031		ret = mtdswap_gc(d, 1);
1032		if (ret || mtd_blktrans_cease_background(dev))
1033			return;
1034	}
1035}
1036
1037static void mtdswap_cleanup(struct mtdswap_dev *d)
1038{
1039	vfree(d->eb_data);
1040	vfree(d->revmap);
1041	vfree(d->page_data);
1042	kfree(d->oob_buf);
1043	kfree(d->page_buf);
1044}
1045
1046static int mtdswap_flush(struct mtd_blktrans_dev *dev)
1047{
1048	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1049
1050	mtd_sync(d->mtd);
1051	return 0;
1052}
1053
1054static unsigned int mtdswap_badblocks(struct mtd_info *mtd, uint64_t size)
1055{
1056	loff_t offset;
1057	unsigned int badcnt;
1058
1059	badcnt = 0;
1060
1061	if (mtd_can_have_bb(mtd))
1062		for (offset = 0; offset < size; offset += mtd->erasesize)
1063			if (mtd_block_isbad(mtd, offset))
1064				badcnt++;
1065
1066	return badcnt;
1067}
1068
1069static int mtdswap_writesect(struct mtd_blktrans_dev *dev,
1070			unsigned long page, char *buf)
1071{
1072	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1073	unsigned int newblock, mapped;
1074	struct swap_eb *eb;
1075	int ret;
1076
1077	d->sect_write_count++;
1078
1079	if (d->spare_eblks < MIN_SPARE_EBLOCKS)
1080		return -ENOSPC;
1081
1082	if (header) {
1083		/* Ignore writes to the header page */
1084		if (unlikely(page == 0))
1085			return 0;
1086
1087		page--;
1088	}
1089
1090	mapped = d->page_data[page];
1091	if (mapped <= BLOCK_MAX) {
1092		eb = d->eb_data + (mapped / d->pages_per_eblk);
1093		eb->active_count--;
1094		mtdswap_store_eb(d, eb);
1095		d->page_data[page] = BLOCK_UNDEF;
1096		d->revmap[mapped] = PAGE_UNDEF;
1097	}
1098
1099	ret = mtdswap_write_block(d, buf, page, &newblock, 0);
1100	d->mtd_write_count++;
1101
1102	if (ret < 0)
1103		return ret;
1104
1105	eb = d->eb_data + (newblock / d->pages_per_eblk);
1106	d->page_data[page] = newblock;
1107
1108	return 0;
1109}
1110
1111/* Provide a dummy swap header for the kernel */
1112static int mtdswap_auto_header(struct mtdswap_dev *d, char *buf)
1113{
1114	union swap_header *hd = (union swap_header *)(buf);
1115
1116	memset(buf, 0, PAGE_SIZE - 10);
1117
1118	hd->info.version = 1;
1119	hd->info.last_page = d->mbd_dev->size - 1;
1120	hd->info.nr_badpages = 0;
1121
1122	memcpy(buf + PAGE_SIZE - 10, "SWAPSPACE2", 10);
1123
1124	return 0;
1125}
1126
1127static int mtdswap_readsect(struct mtd_blktrans_dev *dev,
1128			unsigned long page, char *buf)
1129{
1130	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1131	struct mtd_info *mtd = d->mtd;
1132	unsigned int realblock, retries;
1133	loff_t readpos;
1134	struct swap_eb *eb;
1135	size_t retlen;
1136	int ret;
1137
1138	d->sect_read_count++;
1139
1140	if (header) {
1141		if (unlikely(page == 0))
1142			return mtdswap_auto_header(d, buf);
1143
1144		page--;
1145	}
1146
1147	realblock = d->page_data[page];
1148	if (realblock > BLOCK_MAX) {
1149		memset(buf, 0x0, PAGE_SIZE);
1150		if (realblock == BLOCK_UNDEF)
1151			return 0;
1152		else
1153			return -EIO;
1154	}
1155
1156	eb = d->eb_data + (realblock / d->pages_per_eblk);
1157	BUG_ON(d->revmap[realblock] == PAGE_UNDEF);
1158
1159	readpos = (loff_t)realblock << PAGE_SHIFT;
1160	retries = 0;
1161
1162retry:
1163	ret = mtd_read(mtd, readpos, PAGE_SIZE, &retlen, buf);
1164
1165	d->mtd_read_count++;
1166	if (mtd_is_bitflip(ret)) {
1167		eb->flags |= EBLOCK_BITFLIP;
1168		mtdswap_rb_add(d, eb, MTDSWAP_BITFLIP);
1169		ret = 0;
1170	}
1171
1172	if (ret < 0) {
1173		dev_err(d->dev, "Read error %d\n", ret);
1174		eb->flags |= EBLOCK_READERR;
1175		mtdswap_rb_add(d, eb, MTDSWAP_FAILING);
1176		retries++;
1177		if (retries < MTDSWAP_IO_RETRIES)
1178			goto retry;
1179
1180		return ret;
1181	}
1182
1183	if (retlen != PAGE_SIZE) {
1184		dev_err(d->dev, "Short read %zd\n", retlen);
1185		return -EIO;
1186	}
1187
1188	return 0;
1189}
1190
1191static int mtdswap_discard(struct mtd_blktrans_dev *dev, unsigned long first,
1192			unsigned nr_pages)
1193{
1194	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1195	unsigned long page;
1196	struct swap_eb *eb;
1197	unsigned int mapped;
1198
1199	d->discard_count++;
1200
1201	for (page = first; page < first + nr_pages; page++) {
1202		mapped = d->page_data[page];
1203		if (mapped <= BLOCK_MAX) {
1204			eb = d->eb_data + (mapped / d->pages_per_eblk);
1205			eb->active_count--;
1206			mtdswap_store_eb(d, eb);
1207			d->page_data[page] = BLOCK_UNDEF;
1208			d->revmap[mapped] = PAGE_UNDEF;
1209			d->discard_page_count++;
1210		} else if (mapped == BLOCK_ERROR) {
1211			d->page_data[page] = BLOCK_UNDEF;
1212			d->discard_page_count++;
1213		}
1214	}
1215
1216	return 0;
1217}
1218
1219static int mtdswap_show(struct seq_file *s, void *data)
1220{
1221	struct mtdswap_dev *d = (struct mtdswap_dev *) s->private;
1222	unsigned long sum;
1223	unsigned int count[MTDSWAP_TREE_CNT];
1224	unsigned int min[MTDSWAP_TREE_CNT];
1225	unsigned int max[MTDSWAP_TREE_CNT];
1226	unsigned int i, cw = 0, cwp = 0, cwecount = 0, bb_cnt, mapped, pages;
1227	uint64_t use_size;
1228	char *name[] = {"clean", "used", "low", "high", "dirty", "bitflip",
1229			"failing"};
1230
1231	mutex_lock(&d->mbd_dev->lock);
1232
1233	for (i = 0; i < MTDSWAP_TREE_CNT; i++) {
1234		struct rb_root *root = &d->trees[i].root;
1235
1236		if (root->rb_node) {
1237			count[i] = d->trees[i].count;
1238			min[i] = rb_entry(rb_first(root), struct swap_eb,
1239					rb)->erase_count;
1240			max[i] = rb_entry(rb_last(root), struct swap_eb,
1241					rb)->erase_count;
1242		} else
1243			count[i] = 0;
1244	}
1245
1246	if (d->curr_write) {
1247		cw = 1;
1248		cwp = d->curr_write_pos;
1249		cwecount = d->curr_write->erase_count;
1250	}
1251
1252	sum = 0;
1253	for (i = 0; i < d->eblks; i++)
1254		sum += d->eb_data[i].erase_count;
1255
1256	use_size = (uint64_t)d->eblks * d->mtd->erasesize;
1257	bb_cnt = mtdswap_badblocks(d->mtd, use_size);
1258
1259	mapped = 0;
1260	pages = d->mbd_dev->size;
1261	for (i = 0; i < pages; i++)
1262		if (d->page_data[i] != BLOCK_UNDEF)
1263			mapped++;
1264
1265	mutex_unlock(&d->mbd_dev->lock);
1266
1267	for (i = 0; i < MTDSWAP_TREE_CNT; i++) {
1268		if (!count[i])
1269			continue;
1270
1271		if (min[i] != max[i])
1272			seq_printf(s, "%s:\t%5d erase blocks, erased min %d, "
1273				"max %d times\n",
1274				name[i], count[i], min[i], max[i]);
1275		else
1276			seq_printf(s, "%s:\t%5d erase blocks, all erased %d "
1277				"times\n", name[i], count[i], min[i]);
1278	}
1279
1280	if (bb_cnt)
1281		seq_printf(s, "bad:\t%5u erase blocks\n", bb_cnt);
1282
1283	if (cw)
1284		seq_printf(s, "current erase block: %u pages used, %u free, "
1285			"erased %u times\n",
1286			cwp, d->pages_per_eblk - cwp, cwecount);
1287
1288	seq_printf(s, "total erasures: %lu\n", sum);
1289
1290	seq_puts(s, "\n");
1291
1292	seq_printf(s, "mtdswap_readsect count: %llu\n", d->sect_read_count);
1293	seq_printf(s, "mtdswap_writesect count: %llu\n", d->sect_write_count);
1294	seq_printf(s, "mtdswap_discard count: %llu\n", d->discard_count);
1295	seq_printf(s, "mtd read count: %llu\n", d->mtd_read_count);
1296	seq_printf(s, "mtd write count: %llu\n", d->mtd_write_count);
1297	seq_printf(s, "discarded pages count: %llu\n", d->discard_page_count);
1298
1299	seq_puts(s, "\n");
1300	seq_printf(s, "total pages: %u\n", pages);
1301	seq_printf(s, "pages mapped: %u\n", mapped);
1302
1303	return 0;
1304}
1305
1306static int mtdswap_open(struct inode *inode, struct file *file)
1307{
1308	return single_open(file, mtdswap_show, inode->i_private);
1309}
1310
1311static const struct file_operations mtdswap_fops = {
1312	.open		= mtdswap_open,
1313	.read		= seq_read,
1314	.llseek		= seq_lseek,
1315	.release	= single_release,
1316};
1317
1318static int mtdswap_add_debugfs(struct mtdswap_dev *d)
1319{
1320	struct gendisk *gd = d->mbd_dev->disk;
1321	struct device *dev = disk_to_dev(gd);
1322
1323	struct dentry *root;
1324	struct dentry *dent;
1325
1326	root = debugfs_create_dir(gd->disk_name, NULL);
1327	if (IS_ERR(root))
1328		return 0;
1329
1330	if (!root) {
1331		dev_err(dev, "failed to initialize debugfs\n");
1332		return -1;
1333	}
1334
1335	d->debugfs_root = root;
1336
1337	dent = debugfs_create_file("stats", S_IRUSR, root, d,
1338				&mtdswap_fops);
1339	if (!dent) {
1340		dev_err(d->dev, "debugfs_create_file failed\n");
1341		debugfs_remove_recursive(root);
1342		d->debugfs_root = NULL;
1343		return -1;
1344	}
1345
1346	return 0;
1347}
1348
1349static int mtdswap_init(struct mtdswap_dev *d, unsigned int eblocks,
1350			unsigned int spare_cnt)
1351{
1352	struct mtd_info *mtd = d->mbd_dev->mtd;
1353	unsigned int i, eblk_bytes, pages, blocks;
1354	int ret = -ENOMEM;
1355
1356	d->mtd = mtd;
1357	d->eblks = eblocks;
1358	d->spare_eblks = spare_cnt;
1359	d->pages_per_eblk = mtd->erasesize >> PAGE_SHIFT;
1360
1361	pages = d->mbd_dev->size;
1362	blocks = eblocks * d->pages_per_eblk;
1363
1364	for (i = 0; i < MTDSWAP_TREE_CNT; i++)
1365		d->trees[i].root = RB_ROOT;
1366
1367	d->page_data = vmalloc(sizeof(int)*pages);
1368	if (!d->page_data)
1369		goto page_data_fail;
1370
1371	d->revmap = vmalloc(sizeof(int)*blocks);
1372	if (!d->revmap)
1373		goto revmap_fail;
1374
1375	eblk_bytes = sizeof(struct swap_eb)*d->eblks;
1376	d->eb_data = vzalloc(eblk_bytes);
1377	if (!d->eb_data)
1378		goto eb_data_fail;
1379
1380	for (i = 0; i < pages; i++)
1381		d->page_data[i] = BLOCK_UNDEF;
1382
1383	for (i = 0; i < blocks; i++)
1384		d->revmap[i] = PAGE_UNDEF;
1385
1386	d->page_buf = kmalloc(PAGE_SIZE, GFP_KERNEL);
1387	if (!d->page_buf)
1388		goto page_buf_fail;
1389
1390	d->oob_buf = kmalloc(2 * mtd->ecclayout->oobavail, GFP_KERNEL);
1391	if (!d->oob_buf)
1392		goto oob_buf_fail;
1393
1394	mtdswap_scan_eblks(d);
1395
1396	return 0;
1397
1398oob_buf_fail:
1399	kfree(d->page_buf);
1400page_buf_fail:
1401	vfree(d->eb_data);
1402eb_data_fail:
1403	vfree(d->revmap);
1404revmap_fail:
1405	vfree(d->page_data);
1406page_data_fail:
1407	printk(KERN_ERR "%s: init failed (%d)\n", MTDSWAP_PREFIX, ret);
1408	return ret;
1409}
1410
1411static void mtdswap_add_mtd(struct mtd_blktrans_ops *tr, struct mtd_info *mtd)
1412{
1413	struct mtdswap_dev *d;
1414	struct mtd_blktrans_dev *mbd_dev;
1415	char *parts;
1416	char *this_opt;
1417	unsigned long part;
1418	unsigned int eblocks, eavailable, bad_blocks, spare_cnt;
1419	uint64_t swap_size, use_size, size_limit;
1420	struct nand_ecclayout *oinfo;
1421	int ret;
1422
1423	parts = &partitions[0];
1424	if (!*parts)
1425		return;
1426
1427	while ((this_opt = strsep(&parts, ",")) != NULL) {
1428		if (kstrtoul(this_opt, 0, &part) < 0)
1429			return;
1430
1431		if (mtd->index == part)
1432			break;
1433	}
1434
1435	if (mtd->index != part)
1436		return;
1437
1438	if (mtd->erasesize < PAGE_SIZE || mtd->erasesize % PAGE_SIZE) {
1439		printk(KERN_ERR "%s: Erase size %u not multiple of PAGE_SIZE "
1440			"%lu\n", MTDSWAP_PREFIX, mtd->erasesize, PAGE_SIZE);
1441		return;
1442	}
1443
1444	if (PAGE_SIZE % mtd->writesize || mtd->writesize > PAGE_SIZE) {
1445		printk(KERN_ERR "%s: PAGE_SIZE %lu not multiple of write size"
1446			" %u\n", MTDSWAP_PREFIX, PAGE_SIZE, mtd->writesize);
1447		return;
1448	}
1449
1450	oinfo = mtd->ecclayout;
1451	if (!oinfo) {
1452		printk(KERN_ERR "%s: mtd%d does not have OOB\n",
1453			MTDSWAP_PREFIX, mtd->index);
1454		return;
1455	}
1456
1457	if (!mtd->oobsize || oinfo->oobavail < MTDSWAP_OOBSIZE) {
1458		printk(KERN_ERR "%s: Not enough free bytes in OOB, "
1459			"%d available, %zu needed.\n",
1460			MTDSWAP_PREFIX, oinfo->oobavail, MTDSWAP_OOBSIZE);
1461		return;
1462	}
1463
1464	if (spare_eblocks > 100)
1465		spare_eblocks = 100;
1466
1467	use_size = mtd->size;
1468	size_limit = (uint64_t) BLOCK_MAX * PAGE_SIZE;
1469
1470	if (mtd->size > size_limit) {
1471		printk(KERN_WARNING "%s: Device too large. Limiting size to "
1472			"%llu bytes\n", MTDSWAP_PREFIX, size_limit);
1473		use_size = size_limit;
1474	}
1475
1476	eblocks = mtd_div_by_eb(use_size, mtd);
1477	use_size = (uint64_t)eblocks * mtd->erasesize;
1478	bad_blocks = mtdswap_badblocks(mtd, use_size);
1479	eavailable = eblocks - bad_blocks;
1480
1481	if (eavailable < MIN_ERASE_BLOCKS) {
1482		printk(KERN_ERR "%s: Not enough erase blocks. %u available, "
1483			"%d needed\n", MTDSWAP_PREFIX, eavailable,
1484			MIN_ERASE_BLOCKS);
1485		return;
1486	}
1487
1488	spare_cnt = div_u64((uint64_t)eavailable * spare_eblocks, 100);
1489
1490	if (spare_cnt < MIN_SPARE_EBLOCKS)
1491		spare_cnt = MIN_SPARE_EBLOCKS;
1492
1493	if (spare_cnt > eavailable - 1)
1494		spare_cnt = eavailable - 1;
1495
1496	swap_size = (uint64_t)(eavailable - spare_cnt) * mtd->erasesize +
1497		(header ? PAGE_SIZE : 0);
1498
1499	printk(KERN_INFO "%s: Enabling MTD swap on device %lu, size %llu KB, "
1500		"%u spare, %u bad blocks\n",
1501		MTDSWAP_PREFIX, part, swap_size / 1024, spare_cnt, bad_blocks);
1502
1503	d = kzalloc(sizeof(struct mtdswap_dev), GFP_KERNEL);
1504	if (!d)
1505		return;
1506
1507	mbd_dev = kzalloc(sizeof(struct mtd_blktrans_dev), GFP_KERNEL);
1508	if (!mbd_dev) {
1509		kfree(d);
1510		return;
1511	}
1512
1513	d->mbd_dev = mbd_dev;
1514	mbd_dev->priv = d;
1515
1516	mbd_dev->mtd = mtd;
1517	mbd_dev->devnum = mtd->index;
1518	mbd_dev->size = swap_size >> PAGE_SHIFT;
1519	mbd_dev->tr = tr;
1520
1521	if (!(mtd->flags & MTD_WRITEABLE))
1522		mbd_dev->readonly = 1;
1523
1524	if (mtdswap_init(d, eblocks, spare_cnt) < 0)
1525		goto init_failed;
1526
1527	if (add_mtd_blktrans_dev(mbd_dev) < 0)
1528		goto cleanup;
1529
1530	d->dev = disk_to_dev(mbd_dev->disk);
1531
1532	ret = mtdswap_add_debugfs(d);
1533	if (ret < 0)
1534		goto debugfs_failed;
1535
1536	return;
1537
1538debugfs_failed:
1539	del_mtd_blktrans_dev(mbd_dev);
1540
1541cleanup:
1542	mtdswap_cleanup(d);
1543
1544init_failed:
1545	kfree(mbd_dev);
1546	kfree(d);
1547}
1548
1549static void mtdswap_remove_dev(struct mtd_blktrans_dev *dev)
1550{
1551	struct mtdswap_dev *d = MTDSWAP_MBD_TO_MTDSWAP(dev);
1552
1553	debugfs_remove_recursive(d->debugfs_root);
1554	del_mtd_blktrans_dev(dev);
1555	mtdswap_cleanup(d);
1556	kfree(d);
1557}
1558
1559static struct mtd_blktrans_ops mtdswap_ops = {
1560	.name		= "mtdswap",
1561	.major		= 0,
1562	.part_bits	= 0,
1563	.blksize	= PAGE_SIZE,
1564	.flush		= mtdswap_flush,
1565	.readsect	= mtdswap_readsect,
1566	.writesect	= mtdswap_writesect,
1567	.discard	= mtdswap_discard,
1568	.background	= mtdswap_background,
1569	.add_mtd	= mtdswap_add_mtd,
1570	.remove_dev	= mtdswap_remove_dev,
1571	.owner		= THIS_MODULE,
1572};
1573
1574static int __init mtdswap_modinit(void)
1575{
1576	return register_mtd_blktrans(&mtdswap_ops);
1577}
1578
1579static void __exit mtdswap_modexit(void)
1580{
1581	deregister_mtd_blktrans(&mtdswap_ops);
1582}
1583
1584module_init(mtdswap_modinit);
1585module_exit(mtdswap_modexit);
1586
1587
1588MODULE_LICENSE("GPL");
1589MODULE_AUTHOR("Jarkko Lavinen <jarkko.lavinen@nokia.com>");
1590MODULE_DESCRIPTION("Block device access to an MTD suitable for using as "
1591		"swap space");
1592