blkdev.h 45.3 KB
Newer Older
1
/* SPDX-License-Identifier: GPL-2.0 */
C
Christoph Hellwig 已提交
2 3 4
/*
 * Portions Copyright (C) 1992 Drew Eckhardt
 */
L
Linus Torvalds 已提交
5 6 7
#ifndef _LINUX_BLKDEV_H
#define _LINUX_BLKDEV_H

C
Christoph Hellwig 已提交
8 9 10
#include <linux/types.h>
#include <linux/blk_types.h>
#include <linux/device.h>
L
Linus Torvalds 已提交
11
#include <linux/list.h>
12
#include <linux/llist.h>
13
#include <linux/minmax.h>
L
Linus Torvalds 已提交
14 15 16 17
#include <linux/timer.h>
#include <linux/workqueue.h>
#include <linux/wait.h>
#include <linux/bio.h>
18
#include <linux/gfp.h>
C
Christoph Hellwig 已提交
19
#include <linux/kdev_t.h>
T
Tejun Heo 已提交
20
#include <linux/rcupdate.h>
21
#include <linux/percpu-refcount.h>
22
#include <linux/blkzoned.h>
C
Christoph Hellwig 已提交
23
#include <linux/sched.h>
24
#include <linux/sbitmap.h>
25
#include <linux/srcu.h>
C
Christoph Hellwig 已提交
26 27
#include <linux/uuid.h>
#include <linux/xarray.h>
L
Linus Torvalds 已提交
28

29
struct module;
L
Linus Torvalds 已提交
30 31
struct request_queue;
struct elevator_queue;
32
struct blk_trace;
33 34
struct request;
struct sg_io_hdr;
T
Tejun Heo 已提交
35
struct blkcg_gq;
36
struct blk_flush_queue;
37
struct kiocb;
38
struct pr_ops;
39
struct rq_qos;
40 41
struct blk_queue_stats;
struct blk_stat_callback;
42
struct blk_crypto_profile;
L
Linus Torvalds 已提交
43

C
Christoph Hellwig 已提交
44 45 46 47
extern const struct device_type disk_type;
extern struct device_type part_type;
extern struct class block_class;

48
/* Must be consistent with blk_mq_poll_stats_bkt() */
49 50
#define BLK_MQ_POLL_STATS_BKTS 16

51 52 53
/* Doing classic polling */
#define BLK_MQ_POLL_CLASSIC -1

T
Tejun Heo 已提交
54 55 56 57
/*
 * Maximum number of blkcg policies allowed to be registered concurrently.
 * Defined here to simplify include dependency.
 */
58
#define BLKCG_MAX_POLS		6
T
Tejun Heo 已提交
59

C
Christoph Hellwig 已提交
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 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 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148
#define DISK_MAX_PARTS			256
#define DISK_NAME_LEN			32

#define PARTITION_META_INFO_VOLNAMELTH	64
/*
 * Enough for the string representation of any kind of UUID plus NULL.
 * EFI UUID is 36 characters. MSDOS UUID is 11 characters.
 */
#define PARTITION_META_INFO_UUIDLTH	(UUID_STRING_LEN + 1)

struct partition_meta_info {
	char uuid[PARTITION_META_INFO_UUIDLTH];
	u8 volname[PARTITION_META_INFO_VOLNAMELTH];
};

/**
 * DOC: genhd capability flags
 *
 * ``GENHD_FL_REMOVABLE``: indicates that the block device gives access to
 * removable media.  When set, the device remains present even when media is not
 * inserted.  Shall not be set for devices which are removed entirely when the
 * media is removed.
 *
 * ``GENHD_FL_HIDDEN``: the block device is hidden; it doesn't produce events,
 * doesn't appear in sysfs, and can't be opened from userspace or using
 * blkdev_get*. Used for the underlying components of multipath devices.
 *
 * ``GENHD_FL_NO_PART``: partition support is disabled.  The kernel will not
 * scan for partitions from add_disk, and users can't add partitions manually.
 *
 */
enum {
	GENHD_FL_REMOVABLE			= 1 << 0,
	GENHD_FL_HIDDEN				= 1 << 1,
	GENHD_FL_NO_PART			= 1 << 2,
};

enum {
	DISK_EVENT_MEDIA_CHANGE			= 1 << 0, /* media changed */
	DISK_EVENT_EJECT_REQUEST		= 1 << 1, /* eject requested */
};

enum {
	/* Poll even if events_poll_msecs is unset */
	DISK_EVENT_FLAG_POLL			= 1 << 0,
	/* Forward events to udev */
	DISK_EVENT_FLAG_UEVENT			= 1 << 1,
	/* Block event polling when open for exclusive write */
	DISK_EVENT_FLAG_BLOCK_ON_EXCL_WRITE	= 1 << 2,
};

struct disk_events;
struct badblocks;

struct blk_integrity {
	const struct blk_integrity_profile	*profile;
	unsigned char				flags;
	unsigned char				tuple_size;
	unsigned char				interval_exp;
	unsigned char				tag_size;
};

struct gendisk {
	/*
	 * major/first_minor/minors should not be set by any new driver, the
	 * block core will take care of allocating them automatically.
	 */
	int major;
	int first_minor;
	int minors;

	char disk_name[DISK_NAME_LEN];	/* name of major driver */

	unsigned short events;		/* supported events */
	unsigned short event_flags;	/* flags related to event processing */

	struct xarray part_tbl;
	struct block_device *part0;

	const struct block_device_operations *fops;
	struct request_queue *queue;
	void *private_data;

	int flags;
	unsigned long state;
#define GD_NEED_PART_SCAN		0
#define GD_READ_ONLY			1
#define GD_DEAD				2
#define GD_NATIVE_CAPACITY		3
149
#define GD_ADDED			4
C
Christoph Hellwig 已提交
150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178

	struct mutex open_mutex;	/* open/close mutex */
	unsigned open_partitions;	/* number of open partitions */

	struct backing_dev_info	*bdi;
	struct kobject *slave_dir;
#ifdef CONFIG_BLOCK_HOLDER_DEPRECATED
	struct list_head slave_bdevs;
#endif
	struct timer_rand_state *random;
	atomic_t sync_io;		/* RAID */
	struct disk_events *ev;
#ifdef  CONFIG_BLK_DEV_INTEGRITY
	struct kobject integrity_kobj;
#endif	/* CONFIG_BLK_DEV_INTEGRITY */
#if IS_ENABLED(CONFIG_CDROM)
	struct cdrom_device_info *cdi;
#endif
	int node_id;
	struct badblocks *bb;
	struct lockdep_map lockdep_map;
	u64 diskseq;
};

static inline bool disk_live(struct gendisk *disk)
{
	return !inode_unhashed(disk->part0->bd_inode);
}

179 180 181 182 183 184 185 186 187 188 189 190
/**
 * disk_openers - returns how many openers are there for a disk
 * @disk: disk to check
 *
 * This returns the number of openers for a disk.  Note that this value is only
 * stable if disk->open_mutex is held.
 *
 * Note: Due to a quirk in the block layer open code, each open partition is
 * only counted once even if there are multiple openers.
 */
static inline unsigned int disk_openers(struct gendisk *disk)
{
191
	return atomic_read(&disk->part0->bd_openers);
192 193
}

C
Christoph Hellwig 已提交
194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213
/*
 * The gendisk is refcounted by the part0 block_device, and the bd_device
 * therein is also used for device model presentation in sysfs.
 */
#define dev_to_disk(device) \
	(dev_to_bdev(device)->bd_disk)
#define disk_to_dev(disk) \
	(&((disk)->part0->bd_device))

#if IS_REACHABLE(CONFIG_CDROM)
#define disk_to_cdi(disk)	((disk)->cdi)
#else
#define disk_to_cdi(disk)	NULL
#endif

static inline dev_t disk_devt(struct gendisk *disk)
{
	return MKDEV(disk->major, disk->first_minor);
}

214
static inline int blk_validate_block_size(unsigned long bsize)
215 216 217 218 219 220 221
{
	if (bsize < 512 || bsize > PAGE_SIZE || !is_power_of_2(bsize))
		return -EINVAL;

	return 0;
}

222
static inline bool blk_op_is_passthrough(unsigned int op)
223
{
224
	op &= REQ_OP_MASK;
225 226 227
	return op == REQ_OP_DRV_IN || op == REQ_OP_DRV_OUT;
}

D
Damien Le Moal 已提交
228 229
/*
 * Zoned block device models (zoned limit).
230 231 232
 *
 * Note: This needs to be ordered from the least to the most severe
 * restrictions for the inheritance in blk_stack_limits() to work.
D
Damien Le Moal 已提交
233 234
 */
enum blk_zoned_model {
235 236 237
	BLK_ZONED_NONE = 0,	/* Regular block device */
	BLK_ZONED_HA,		/* Host-aware zoned block device */
	BLK_ZONED_HM,		/* Host-managed zoned block device */
D
Damien Le Moal 已提交
238 239
};

240 241 242 243 244 245 246 247 248
/*
 * BLK_BOUNCE_NONE:	never bounce (default)
 * BLK_BOUNCE_HIGH:	bounce all highmem pages
 */
enum blk_bounce {
	BLK_BOUNCE_NONE,
	BLK_BOUNCE_HIGH,
};

249
struct queue_limits {
250
	enum blk_bounce		bounce;
251
	unsigned long		seg_boundary_mask;
252
	unsigned long		virt_boundary_mask;
253 254

	unsigned int		max_hw_sectors;
255
	unsigned int		max_dev_sectors;
256
	unsigned int		chunk_sectors;
257 258
	unsigned int		max_sectors;
	unsigned int		max_segment_size;
259
	unsigned int		physical_block_size;
260
	unsigned int		logical_block_size;
261 262 263
	unsigned int		alignment_offset;
	unsigned int		io_min;
	unsigned int		io_opt;
264
	unsigned int		max_discard_sectors;
265
	unsigned int		max_hw_discard_sectors;
266
	unsigned int		max_secure_erase_sectors;
267
	unsigned int		max_write_zeroes_sectors;
268
	unsigned int		max_zone_append_sectors;
269 270
	unsigned int		discard_granularity;
	unsigned int		discard_alignment;
271
	unsigned int		zone_write_granularity;
272

273
	unsigned short		max_segments;
274
	unsigned short		max_integrity_segments;
275
	unsigned short		max_discard_segments;
276

277
	unsigned char		misaligned;
278
	unsigned char		discard_misaligned;
279
	unsigned char		raid_partial_stripes_expensive;
D
Damien Le Moal 已提交
280
	enum blk_zoned_model	zoned;
281 282
};

C
Christoph Hellwig 已提交
283 284 285
typedef int (*report_zones_cb)(struct blk_zone *zone, unsigned int idx,
			       void *data);

286 287
void blk_queue_set_zoned(struct gendisk *disk, enum blk_zoned_model model);

288 289
#ifdef CONFIG_BLK_DEV_ZONED

C
Christoph Hellwig 已提交
290 291 292
#define BLK_ALL_ZONES  ((unsigned int)-1)
int blkdev_report_zones(struct block_device *bdev, sector_t sector,
			unsigned int nr_zones, report_zones_cb cb, void *data);
293
unsigned int blkdev_nr_zones(struct gendisk *disk);
294 295 296
extern int blkdev_zone_mgmt(struct block_device *bdev, enum req_opf op,
			    sector_t sectors, sector_t nr_sectors,
			    gfp_t gfp_mask);
D
Damien Le Moal 已提交
297 298
int blk_revalidate_disk_zones(struct gendisk *disk,
			      void (*update_driver_data)(struct gendisk *disk));
299

S
Shaun Tancheff 已提交
300 301
extern int blkdev_report_zones_ioctl(struct block_device *bdev, fmode_t mode,
				     unsigned int cmd, unsigned long arg);
302 303
extern int blkdev_zone_mgmt_ioctl(struct block_device *bdev, fmode_t mode,
				  unsigned int cmd, unsigned long arg);
S
Shaun Tancheff 已提交
304 305 306

#else /* CONFIG_BLK_DEV_ZONED */

307
static inline unsigned int blkdev_nr_zones(struct gendisk *disk)
308 309 310
{
	return 0;
}
311

S
Shaun Tancheff 已提交
312 313 314 315 316 317 318
static inline int blkdev_report_zones_ioctl(struct block_device *bdev,
					    fmode_t mode, unsigned int cmd,
					    unsigned long arg)
{
	return -ENOTTY;
}

319 320 321
static inline int blkdev_zone_mgmt_ioctl(struct block_device *bdev,
					 fmode_t mode, unsigned int cmd,
					 unsigned long arg)
S
Shaun Tancheff 已提交
322 323 324 325
{
	return -ENOTTY;
}

326 327
#endif /* CONFIG_BLK_DEV_ZONED */

328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355
/*
 * Independent access ranges: struct blk_independent_access_range describes
 * a range of contiguous sectors that can be accessed using device command
 * execution resources that are independent from the resources used for
 * other access ranges. This is typically found with single-LUN multi-actuator
 * HDDs where each access range is served by a different set of heads.
 * The set of independent ranges supported by the device is defined using
 * struct blk_independent_access_ranges. The independent ranges must not overlap
 * and must include all sectors within the disk capacity (no sector holes
 * allowed).
 * For a device with multiple ranges, requests targeting sectors in different
 * ranges can be executed in parallel. A request can straddle an access range
 * boundary.
 */
struct blk_independent_access_range {
	struct kobject		kobj;
	struct request_queue	*queue;
	sector_t		sector;
	sector_t		nr_sectors;
};

struct blk_independent_access_ranges {
	struct kobject				kobj;
	bool					sysfs_registered;
	unsigned int				nr_ia_ranges;
	struct blk_independent_access_range	ia_range[];
};

356
struct request_queue {
L
Linus Torvalds 已提交
357
	struct request		*last_merge;
J
Jens Axboe 已提交
358
	struct elevator_queue	*elevator;
L
Linus Torvalds 已提交
359

360 361
	struct percpu_ref	q_usage_counter;

362
	struct blk_queue_stats	*stats;
363
	struct rq_qos		*rq_qos;
J
Jens Axboe 已提交
364

J
Jens Axboe 已提交
365
	const struct blk_mq_ops	*mq_ops;
366 367

	/* sw queues */
368
	struct blk_mq_ctx __percpu	*queue_ctx;
369

370 371
	unsigned int		queue_depth;

372
	/* hw dispatch queues */
M
Ming Lei 已提交
373
	struct xarray		hctx_table;
374 375
	unsigned int		nr_hw_queues;

L
Linus Torvalds 已提交
376 377 378 379 380 381 382
	/*
	 * The queue owner gets to use this for whatever they like.
	 * ll_rw_blk doesn't touch it.
	 */
	void			*queuedata;

	/*
383
	 * various queue flags, see QUEUE_* below
L
Linus Torvalds 已提交
384
	 */
385
	unsigned long		queue_flags;
386 387
	/*
	 * Number of contexts that have called blk_set_pm_only(). If this
388
	 * counter is above zero then only RQF_PM requests are processed.
389 390
	 */
	atomic_t		pm_only;
L
Linus Torvalds 已提交
391

392 393 394 395 396 397
	/*
	 * ida allocated id for this queue.  Used to index queues from
	 * ioctx.
	 */
	int			id;

398
	spinlock_t		queue_lock;
L
Linus Torvalds 已提交
399

400 401
	struct gendisk		*disk;

L
Linus Torvalds 已提交
402 403 404 405 406
	/*
	 * queue kobject
	 */
	struct kobject kobj;

407 408 409
	/*
	 * mq queue kobject
	 */
410
	struct kobject *mq_kobj;
411

412 413 414 415
#ifdef  CONFIG_BLK_DEV_INTEGRITY
	struct blk_integrity integrity;
#endif	/* CONFIG_BLK_DEV_INTEGRITY */

416
#ifdef CONFIG_PM
L
Lin Ming 已提交
417
	struct device		*dev;
418
	enum rpm_status		rpm_status;
L
Lin Ming 已提交
419 420
#endif

L
Linus Torvalds 已提交
421 422 423 424 425
	/*
	 * queue settings
	 */
	unsigned long		nr_requests;	/* Max # of requests */

426
	unsigned int		dma_pad_mask;
L
Linus Torvalds 已提交
427 428
	unsigned int		dma_alignment;

429
#ifdef CONFIG_BLK_INLINE_ENCRYPTION
430
	struct blk_crypto_profile *crypto_profile;
431
	struct kobject *crypto_kobject;
432 433
#endif

J
Jens Axboe 已提交
434
	unsigned int		rq_timeout;
435
	int			poll_nsec;
436 437

	struct blk_stat_callback	*poll_cb;
438
	struct blk_rq_stat	*poll_stat;
439

J
Jens Axboe 已提交
440
	struct timer_list	timeout;
441
	struct work_struct	timeout_work;
J
Jens Axboe 已提交
442

443
	atomic_t		nr_active_requests_shared_tags;
444

445
	struct blk_mq_tags	*sched_shared_tags;
446

447
	struct list_head	icq_list;
448
#ifdef CONFIG_BLK_CGROUP
449
	DECLARE_BITMAP		(blkcg_pols, BLKCG_MAX_POLS);
T
Tejun Heo 已提交
450
	struct blkcg_gq		*root_blkg;
451
	struct list_head	blkg_list;
452
#endif
453

454 455
	struct queue_limits	limits;

456 457
	unsigned int		required_elevator_features;

458
#ifdef CONFIG_BLK_DEV_ZONED
459 460 461
	/*
	 * Zoned block device information for request dispatch control.
	 * nr_zones is the total number of zones of the device. This is always
462 463 464
	 * 0 for regular block devices. conv_zones_bitmap is a bitmap of nr_zones
	 * bits which indicates if a zone is conventional (bit set) or
	 * sequential (bit clear). seq_zones_wlock is a bitmap of nr_zones
465 466 467 468 469
	 * bits which indicates if a zone is write locked, that is, if a write
	 * request targeting the zone was dispatched. All three fields are
	 * initialized by the low level device driver (e.g. scsi/sd.c).
	 * Stacking drivers (device mappers) may or may not initialize
	 * these fields.
470 471 472 473 474
	 *
	 * Reads of this information must be protected with blk_queue_enter() /
	 * blk_queue_exit(). Modifying this information is only allowed while
	 * no requests are being processed. See also blk_mq_freeze_queue() and
	 * blk_mq_unfreeze_queue().
475 476
	 */
	unsigned int		nr_zones;
477
	unsigned long		*conv_zones_bitmap;
478
	unsigned long		*seq_zones_wlock;
479
	unsigned int		max_open_zones;
480
	unsigned int		max_active_zones;
481
#endif /* CONFIG_BLK_DEV_ZONED */
482

483
	int			node;
484
	struct mutex		debugfs_mutex;
485
#ifdef CONFIG_BLK_DEV_IO_TRACE
486
	struct blk_trace __rcu	*blk_trace;
487
#endif
L
Linus Torvalds 已提交
488
	/*
489
	 * for flush operations
L
Linus Torvalds 已提交
490
	 */
491
	struct blk_flush_queue	*fq;
492

493 494
	struct list_head	requeue_list;
	spinlock_t		requeue_lock;
495
	struct delayed_work	requeue_work;
496

497
	struct mutex		sysfs_lock;
498
	struct mutex		sysfs_dir_lock;
499

500 501 502 503 504 505 506
	/*
	 * for reusing dead hctx instance in case of updating
	 * nr_hw_queues
	 */
	struct list_head	unused_hctx_list;
	spinlock_t		unused_hctx_lock;

507
	int			mq_freeze_depth;
508

509 510 511 512
#ifdef CONFIG_BLK_DEV_THROTTLING
	/* Throttle data */
	struct throtl_data *td;
#endif
T
Tejun Heo 已提交
513
	struct rcu_head		rcu_head;
514
	wait_queue_head_t	mq_freeze_wq;
515 516 517 518 519
	/*
	 * Protect concurrent access to q_usage_counter by
	 * percpu_ref_kill() and percpu_ref_reinit().
	 */
	struct mutex		mq_freeze_lock;
520

521 522
	int			quiesce_depth;

523 524
	struct blk_mq_tag_set	*tag_set;
	struct list_head	tag_set_list;
525
	struct bio_set		bio_split;
526

527
	struct dentry		*debugfs_dir;
528 529

#ifdef CONFIG_BLK_DEBUG_FS
530
	struct dentry		*sched_debugfs_dir;
M
Ming Lei 已提交
531
	struct dentry		*rqos_debugfs_dir;
532 533
#endif

534
	bool			mq_sysfs_init_done;
535

536 537 538 539 540
	/*
	 * Independent sector access ranges. This is always NULL for
	 * devices that do not have multiple independent access ranges.
	 */
	struct blk_independent_access_ranges *ia_ranges;
541 542 543 544 545 546

	/**
	 * @srcu: Sleepable RCU. Use as lock when type of the request queue
	 * is blocking (BLK_MQ_F_BLOCKING). Must be the last member
	 */
	struct srcu_struct	srcu[];
L
Linus Torvalds 已提交
547 548
};

549
/* Keep blk_queue_flag_name[] in sync with the definitions below */
J
Jens Axboe 已提交
550 551
#define QUEUE_FLAG_STOPPED	0	/* queue is stopped */
#define QUEUE_FLAG_DYING	1	/* queue being torn down */
552
#define QUEUE_FLAG_HAS_SRCU	2	/* SRCU is allocated */
J
Jens Axboe 已提交
553 554 555 556 557 558 559 560 561 562 563
#define QUEUE_FLAG_NOMERGES     3	/* disable merge attempts */
#define QUEUE_FLAG_SAME_COMP	4	/* complete on same CPU-group */
#define QUEUE_FLAG_FAIL_IO	5	/* fake timeout */
#define QUEUE_FLAG_NONROT	6	/* non-rotational device (SSD) */
#define QUEUE_FLAG_VIRT		QUEUE_FLAG_NONROT /* paravirt device */
#define QUEUE_FLAG_IO_STAT	7	/* do disk/partitions IO accounting */
#define QUEUE_FLAG_NOXMERGES	9	/* No extended merges */
#define QUEUE_FLAG_ADD_RANDOM	10	/* Contributes to random pool */
#define QUEUE_FLAG_SAME_FORCE	12	/* force complete on same CPU */
#define QUEUE_FLAG_DEAD		13	/* queue tear-down finished */
#define QUEUE_FLAG_INIT_DONE	14	/* queue is initialized */
564
#define QUEUE_FLAG_STABLE_WRITES 15	/* don't modify blks until WB is done */
J
Jens Axboe 已提交
565 566 567 568 569 570 571 572
#define QUEUE_FLAG_POLL		16	/* IO polling enabled if set */
#define QUEUE_FLAG_WC		17	/* Write back caching */
#define QUEUE_FLAG_FUA		18	/* device supports FUA writes */
#define QUEUE_FLAG_DAX		19	/* device supports DAX */
#define QUEUE_FLAG_STATS	20	/* track IO start and completion times */
#define QUEUE_FLAG_REGISTERED	22	/* queue has been registered to a disk */
#define QUEUE_FLAG_QUIESCED	24	/* queue has been quiesced */
#define QUEUE_FLAG_PCI_P2PDMA	25	/* device supports PCI p2p requests */
573
#define QUEUE_FLAG_ZONE_RESETALL 26	/* supports Zone Reset All */
574
#define QUEUE_FLAG_RQ_ALLOC_TIME 27	/* record rq->alloc_time_ns */
M
Mike Snitzer 已提交
575 576
#define QUEUE_FLAG_HCTX_ACTIVE	28	/* at least one blk-mq hctx is active */
#define QUEUE_FLAG_NOWAIT       29	/* device supports NOWAIT */
577

578
#define QUEUE_FLAG_MQ_DEFAULT	((1 << QUEUE_FLAG_IO_STAT) |		\
M
Mike Snitzer 已提交
579 580
				 (1 << QUEUE_FLAG_SAME_COMP) |		\
				 (1 << QUEUE_FLAG_NOWAIT))
581

582 583 584 585
void blk_queue_flag_set(unsigned int flag, struct request_queue *q);
void blk_queue_flag_clear(unsigned int flag, struct request_queue *q);
bool blk_queue_flag_test_and_set(unsigned int flag, struct request_queue *q);

L
Linus Torvalds 已提交
586
#define blk_queue_stopped(q)	test_bit(QUEUE_FLAG_STOPPED, &(q)->queue_flags)
B
Bart Van Assche 已提交
587
#define blk_queue_dying(q)	test_bit(QUEUE_FLAG_DYING, &(q)->queue_flags)
588
#define blk_queue_has_srcu(q)	test_bit(QUEUE_FLAG_HAS_SRCU, &(q)->queue_flags)
589
#define blk_queue_dead(q)	test_bit(QUEUE_FLAG_DEAD, &(q)->queue_flags)
590
#define blk_queue_init_done(q)	test_bit(QUEUE_FLAG_INIT_DONE, &(q)->queue_flags)
591
#define blk_queue_nomerges(q)	test_bit(QUEUE_FLAG_NOMERGES, &(q)->queue_flags)
592 593
#define blk_queue_noxmerges(q)	\
	test_bit(QUEUE_FLAG_NOXMERGES, &(q)->queue_flags)
594
#define blk_queue_nonrot(q)	test_bit(QUEUE_FLAG_NONROT, &(q)->queue_flags)
595 596
#define blk_queue_stable_writes(q) \
	test_bit(QUEUE_FLAG_STABLE_WRITES, &(q)->queue_flags)
597
#define blk_queue_io_stat(q)	test_bit(QUEUE_FLAG_IO_STAT, &(q)->queue_flags)
598
#define blk_queue_add_random(q)	test_bit(QUEUE_FLAG_ADD_RANDOM, &(q)->queue_flags)
599 600
#define blk_queue_zone_resetall(q)	\
	test_bit(QUEUE_FLAG_ZONE_RESETALL, &(q)->queue_flags)
601
#define blk_queue_dax(q)	test_bit(QUEUE_FLAG_DAX, &(q)->queue_flags)
602 603
#define blk_queue_pci_p2pdma(q)	\
	test_bit(QUEUE_FLAG_PCI_P2PDMA, &(q)->queue_flags)
604 605 606 607 608 609
#ifdef CONFIG_BLK_RQ_ALLOC_TIME
#define blk_queue_rq_alloc_time(q)	\
	test_bit(QUEUE_FLAG_RQ_ALLOC_TIME, &(q)->queue_flags)
#else
#define blk_queue_rq_alloc_time(q)	false
#endif
L
Linus Torvalds 已提交
610

611 612 613
#define blk_noretry_request(rq) \
	((rq)->cmd_flags & (REQ_FAILFAST_DEV|REQ_FAILFAST_TRANSPORT| \
			     REQ_FAILFAST_DRIVER))
614
#define blk_queue_quiesced(q)	test_bit(QUEUE_FLAG_QUIESCED, &(q)->queue_flags)
615
#define blk_queue_pm_only(q)	atomic_read(&(q)->pm_only)
616
#define blk_queue_registered(q)	test_bit(QUEUE_FLAG_REGISTERED, &(q)->queue_flags)
M
Mike Snitzer 已提交
617
#define blk_queue_nowait(q)	test_bit(QUEUE_FLAG_NOWAIT, &(q)->queue_flags)
618

619 620
extern void blk_set_pm_only(struct request_queue *q);
extern void blk_clear_pm_only(struct request_queue *q);
621

L
Linus Torvalds 已提交
622 623
#define list_entry_rq(ptr)	list_entry((ptr), struct request, queuelist)

624 625 626 627
#define dma_map_bvec(dev, bv, dir, attrs) \
	dma_map_page_attrs(dev, (bv)->bv_page, (bv)->bv_offset, (bv)->bv_len, \
	(dir), (attrs))

J
Jens Axboe 已提交
628
static inline bool queue_is_mq(struct request_queue *q)
629
{
J
Jens Axboe 已提交
630
	return q->mq_ops;
631 632
}

633 634 635 636 637 638 639 640 641 642 643 644
#ifdef CONFIG_PM
static inline enum rpm_status queue_rpm_status(struct request_queue *q)
{
	return q->rpm_status;
}
#else
static inline enum rpm_status queue_rpm_status(struct request_queue *q)
{
	return RPM_ACTIVE;
}
#endif

D
Damien Le Moal 已提交
645 646 647
static inline enum blk_zoned_model
blk_queue_zoned_model(struct request_queue *q)
{
648 649 650
	if (IS_ENABLED(CONFIG_BLK_DEV_ZONED))
		return q->limits.zoned;
	return BLK_ZONED_NONE;
D
Damien Le Moal 已提交
651 652 653 654 655 656 657 658 659 660 661 662 663
}

static inline bool blk_queue_is_zoned(struct request_queue *q)
{
	switch (blk_queue_zoned_model(q)) {
	case BLK_ZONED_HA:
	case BLK_ZONED_HM:
		return true;
	default:
		return false;
	}
}

664
static inline sector_t blk_queue_zone_sectors(struct request_queue *q)
665 666 667 668
{
	return blk_queue_is_zoned(q) ? q->limits.chunk_sectors : 0;
}

669
#ifdef CONFIG_BLK_DEV_ZONED
670 671 672 673 674
static inline unsigned int blk_queue_nr_zones(struct request_queue *q)
{
	return blk_queue_is_zoned(q) ? q->nr_zones : 0;
}

675 676 677 678 679 680 681 682 683 684 685
static inline unsigned int blk_queue_zone_no(struct request_queue *q,
					     sector_t sector)
{
	if (!blk_queue_is_zoned(q))
		return 0;
	return sector >> ilog2(q->limits.chunk_sectors);
}

static inline bool blk_queue_zone_is_seq(struct request_queue *q,
					 sector_t sector)
{
686
	if (!blk_queue_is_zoned(q))
687
		return false;
688 689 690
	if (!q->conv_zones_bitmap)
		return true;
	return !test_bit(blk_queue_zone_no(q, sector), q->conv_zones_bitmap);
691
}
692 693 694 695 696 697 698 699 700 701 702

static inline void blk_queue_max_open_zones(struct request_queue *q,
		unsigned int max_open_zones)
{
	q->max_open_zones = max_open_zones;
}

static inline unsigned int queue_max_open_zones(const struct request_queue *q)
{
	return q->max_open_zones;
}
703 704 705 706 707 708 709 710 711 712 713

static inline void blk_queue_max_active_zones(struct request_queue *q,
		unsigned int max_active_zones)
{
	q->max_active_zones = max_active_zones;
}

static inline unsigned int queue_max_active_zones(const struct request_queue *q)
{
	return q->max_active_zones;
}
714 715 716 717 718
#else /* CONFIG_BLK_DEV_ZONED */
static inline unsigned int blk_queue_nr_zones(struct request_queue *q)
{
	return 0;
}
719 720 721 722 723 724 725 726 727 728
static inline bool blk_queue_zone_is_seq(struct request_queue *q,
					 sector_t sector)
{
	return false;
}
static inline unsigned int blk_queue_zone_no(struct request_queue *q,
					     sector_t sector)
{
	return 0;
}
729 730 731 732
static inline unsigned int queue_max_open_zones(const struct request_queue *q)
{
	return 0;
}
733 734 735 736
static inline unsigned int queue_max_active_zones(const struct request_queue *q)
{
	return 0;
}
737
#endif /* CONFIG_BLK_DEV_ZONED */
738

739 740 741 742 743 744 745 746
static inline unsigned int blk_queue_depth(struct request_queue *q)
{
	if (q->queue_depth)
		return q->queue_depth;

	return q->nr_requests;
}

747 748 749 750
/*
 * default timeout for SG_IO if none specified
 */
#define BLK_DEFAULT_SG_TIMEOUT	(60 * HZ)
L
Linus Torvalds 已提交
751
#define BLK_MIN_SG_TIMEOUT	(7 * HZ)
752

753
/* This should not be used directly - use rq_for_each_segment */
754 755
#define for_each_bio(_bio)		\
	for (; _bio; _bio = _bio->bi_next)
756

C
Christoph Hellwig 已提交
757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868
int __must_check device_add_disk(struct device *parent, struct gendisk *disk,
				 const struct attribute_group **groups);
static inline int __must_check add_disk(struct gendisk *disk)
{
	return device_add_disk(NULL, disk, NULL);
}
void del_gendisk(struct gendisk *gp);
void invalidate_disk(struct gendisk *disk);
void set_disk_ro(struct gendisk *disk, bool read_only);
void disk_uevent(struct gendisk *disk, enum kobject_action action);

static inline int get_disk_ro(struct gendisk *disk)
{
	return disk->part0->bd_read_only ||
		test_bit(GD_READ_ONLY, &disk->state);
}

static inline int bdev_read_only(struct block_device *bdev)
{
	return bdev->bd_read_only || get_disk_ro(bdev->bd_disk);
}

bool set_capacity_and_notify(struct gendisk *disk, sector_t size);
bool disk_force_media_change(struct gendisk *disk, unsigned int events);

void add_disk_randomness(struct gendisk *disk) __latent_entropy;
void rand_initialize_disk(struct gendisk *disk);

static inline sector_t get_start_sect(struct block_device *bdev)
{
	return bdev->bd_start_sect;
}

static inline sector_t bdev_nr_sectors(struct block_device *bdev)
{
	return bdev->bd_nr_sectors;
}

static inline loff_t bdev_nr_bytes(struct block_device *bdev)
{
	return (loff_t)bdev_nr_sectors(bdev) << SECTOR_SHIFT;
}

static inline sector_t get_capacity(struct gendisk *disk)
{
	return bdev_nr_sectors(disk->part0);
}

static inline u64 sb_bdev_nr_blocks(struct super_block *sb)
{
	return bdev_nr_sectors(sb->s_bdev) >>
		(sb->s_blocksize_bits - SECTOR_SHIFT);
}

int bdev_disk_changed(struct gendisk *disk, bool invalidate);

struct gendisk *__alloc_disk_node(struct request_queue *q, int node_id,
		struct lock_class_key *lkclass);
void put_disk(struct gendisk *disk);
struct gendisk *__blk_alloc_disk(int node, struct lock_class_key *lkclass);

/**
 * blk_alloc_disk - allocate a gendisk structure
 * @node_id: numa node to allocate on
 *
 * Allocate and pre-initialize a gendisk structure for use with BIO based
 * drivers.
 *
 * Context: can sleep
 */
#define blk_alloc_disk(node_id)						\
({									\
	static struct lock_class_key __key;				\
									\
	__blk_alloc_disk(node_id, &__key);				\
})
void blk_cleanup_disk(struct gendisk *disk);

int __register_blkdev(unsigned int major, const char *name,
		void (*probe)(dev_t devt));
#define register_blkdev(major, name) \
	__register_blkdev(major, name, NULL)
void unregister_blkdev(unsigned int major, const char *name);

bool bdev_check_media_change(struct block_device *bdev);
int __invalidate_device(struct block_device *bdev, bool kill_dirty);
void set_capacity(struct gendisk *disk, sector_t size);

#ifdef CONFIG_BLOCK_HOLDER_DEPRECATED
int bd_link_disk_holder(struct block_device *bdev, struct gendisk *disk);
void bd_unlink_disk_holder(struct block_device *bdev, struct gendisk *disk);
int bd_register_pending_holders(struct gendisk *disk);
#else
static inline int bd_link_disk_holder(struct block_device *bdev,
				      struct gendisk *disk)
{
	return 0;
}
static inline void bd_unlink_disk_holder(struct block_device *bdev,
					 struct gendisk *disk)
{
}
static inline int bd_register_pending_holders(struct gendisk *disk)
{
	return 0;
}
#endif /* CONFIG_BLOCK_HOLDER_DEPRECATED */

dev_t part_devt(struct gendisk *disk, u8 partno);
void inc_diskseq(struct gendisk *disk);
dev_t blk_lookup_devt(const char *name, int partno);
void blk_request_module(dev_t devt);
869

L
Linus Torvalds 已提交
870 871
extern int blk_register_queue(struct gendisk *disk);
extern void blk_unregister_queue(struct gendisk *disk);
872
void submit_bio_noacct(struct bio *bio);
873

874
extern int blk_lld_busy(struct request_queue *q);
875
extern void blk_queue_split(struct bio **);
876
extern int blk_queue_enter(struct request_queue *q, blk_mq_req_flags_t flags);
877
extern void blk_queue_exit(struct request_queue *q);
L
Linus Torvalds 已提交
878
extern void blk_sync_queue(struct request_queue *q);
879

880 881 882
/* Helper to convert REQ_OP_XXX to its string format XXX */
extern const char *blk_op_str(unsigned int op);

883 884 885
int blk_status_to_errno(blk_status_t status);
blk_status_t errno_to_blk_status(int errno);

886 887
/* only poll the hardware once, don't continue until a completion was found */
#define BLK_POLL_ONESHOT		(1 << 0)
888 889
/* do not sleep to wait for the expected completion time */
#define BLK_POLL_NOSLEEP		(1 << 1)
890 891 892
int bio_poll(struct bio *bio, struct io_comp_batch *iob, unsigned int flags);
int iocb_bio_iopoll(struct kiocb *kiocb, struct io_comp_batch *iob,
			unsigned int flags);
J
Jens Axboe 已提交
893

894
static inline struct request_queue *bdev_get_queue(struct block_device *bdev)
L
Linus Torvalds 已提交
895
{
896
	return bdev->bd_queue;	/* this is never NULL */
L
Linus Torvalds 已提交
897 898
}

899
#ifdef CONFIG_BLK_DEV_ZONED
900 901 902 903

/* Helper to convert BLK_ZONE_ZONE_XXX to its string format XXX */
const char *blk_zone_cond_str(enum blk_zone_cond zone_cond);

904 905 906 907 908 909 910 911 912 913 914
static inline unsigned int bio_zone_no(struct bio *bio)
{
	return blk_queue_zone_no(bdev_get_queue(bio->bi_bdev),
				 bio->bi_iter.bi_sector);
}

static inline unsigned int bio_zone_is_seq(struct bio *bio)
{
	return blk_queue_zone_is_seq(bdev_get_queue(bio->bi_bdev),
				     bio->bi_iter.bi_sector);
}
915
#endif /* CONFIG_BLK_DEV_ZONED */
916

917
static inline unsigned int blk_queue_get_max_sectors(struct request_queue *q,
918
						     int op)
919
{
A
Adrian Hunter 已提交
920
	if (unlikely(op == REQ_OP_DISCARD || op == REQ_OP_SECURE_ERASE))
921 922
		return min(q->limits.max_discard_sectors,
			   UINT_MAX >> SECTOR_SHIFT);
923

924 925 926
	if (unlikely(op == REQ_OP_WRITE_ZEROES))
		return q->limits.max_write_zeroes_sectors;

927 928 929
	return q->limits.max_sectors;
}

930 931 932 933 934
/*
 * Return maximum size of a request at given offset. Only valid for
 * file system requests.
 */
static inline unsigned int blk_max_size_offset(struct request_queue *q,
M
Mike Snitzer 已提交
935 936
					       sector_t offset,
					       unsigned int chunk_sectors)
937
{
938 939 940 941 942 943
	if (!chunk_sectors) {
		if (q->limits.chunk_sectors)
			chunk_sectors = q->limits.chunk_sectors;
		else
			return q->limits.max_sectors;
	}
944

945 946 947 948 949 950
	if (likely(is_power_of_2(chunk_sectors)))
		chunk_sectors -= offset & (chunk_sectors - 1);
	else
		chunk_sectors -= sector_div(offset, chunk_sectors);

	return min(q->limits.max_sectors, chunk_sectors);
951 952
}

L
Linus Torvalds 已提交
953 954 955
/*
 * Access functions for manipulating queue properties
 */
956
extern void blk_cleanup_queue(struct request_queue *);
957
void blk_queue_bounce_limit(struct request_queue *q, enum blk_bounce limit);
958
extern void blk_queue_max_hw_sectors(struct request_queue *, unsigned int);
959
extern void blk_queue_chunk_sectors(struct request_queue *, unsigned int);
960
extern void blk_queue_max_segments(struct request_queue *, unsigned short);
961 962
extern void blk_queue_max_discard_segments(struct request_queue *,
		unsigned short);
963 964
void blk_queue_max_secure_erase_sectors(struct request_queue *q,
		unsigned int max_sectors);
965
extern void blk_queue_max_segment_size(struct request_queue *, unsigned int);
966 967
extern void blk_queue_max_discard_sectors(struct request_queue *q,
		unsigned int max_discard_sectors);
968 969
extern void blk_queue_max_write_zeroes_sectors(struct request_queue *q,
		unsigned int max_write_same_sectors);
970
extern void blk_queue_logical_block_size(struct request_queue *, unsigned int);
971 972
extern void blk_queue_max_zone_append_sectors(struct request_queue *q,
		unsigned int max_zone_append_sectors);
973
extern void blk_queue_physical_block_size(struct request_queue *, unsigned int);
974 975
void blk_queue_zone_write_granularity(struct request_queue *q,
				      unsigned int size);
976 977
extern void blk_queue_alignment_offset(struct request_queue *q,
				       unsigned int alignment);
978
void disk_update_readahead(struct gendisk *disk);
979
extern void blk_limits_io_min(struct queue_limits *limits, unsigned int min);
980
extern void blk_queue_io_min(struct request_queue *q, unsigned int min);
981
extern void blk_limits_io_opt(struct queue_limits *limits, unsigned int opt);
982
extern void blk_queue_io_opt(struct request_queue *q, unsigned int opt);
983
extern void blk_set_queue_depth(struct request_queue *q, unsigned int depth);
984
extern void blk_set_default_limits(struct queue_limits *lim);
985
extern void blk_set_stacking_limits(struct queue_limits *lim);
986 987 988 989
extern int blk_stack_limits(struct queue_limits *t, struct queue_limits *b,
			    sector_t offset);
extern void disk_stack_limits(struct gendisk *disk, struct block_device *bdev,
			      sector_t offset);
990
extern void blk_queue_update_dma_pad(struct request_queue *, unsigned int);
991
extern void blk_queue_segment_boundary(struct request_queue *, unsigned long);
992
extern void blk_queue_virt_boundary(struct request_queue *, unsigned long);
993
extern void blk_queue_dma_alignment(struct request_queue *, int);
994
extern void blk_queue_update_dma_alignment(struct request_queue *, int);
J
Jens Axboe 已提交
995
extern void blk_queue_rq_timeout(struct request_queue *, unsigned int);
996
extern void blk_queue_write_cache(struct request_queue *q, bool enabled, bool fua);
997

998 999 1000 1001 1002
struct blk_independent_access_ranges *
disk_alloc_independent_access_ranges(struct gendisk *disk, int nr_ia_ranges);
void disk_set_independent_access_ranges(struct gendisk *disk,
				struct blk_independent_access_ranges *iars);

1003 1004 1005 1006 1007 1008 1009 1010
/*
 * Elevator features for blk_queue_required_elevator_features:
 */
/* Supports zoned block devices sequential write constraint */
#define ELEVATOR_F_ZBD_SEQ_WRITE	(1U << 0)
/* Supports scheduling on multiple hardware queues */
#define ELEVATOR_F_MQ_AWARE		(1U << 1)

1011 1012
extern void blk_queue_required_elevator_features(struct request_queue *q,
						 unsigned int features);
1013 1014
extern bool blk_queue_can_use_dma_map_merging(struct request_queue *q,
					      struct device *dev);
L
Linus Torvalds 已提交
1015

T
Tejun Heo 已提交
1016
bool __must_check blk_get_queue(struct request_queue *);
1017
extern void blk_put_queue(struct request_queue *);
1018 1019

void blk_mark_disk_dead(struct gendisk *disk);
L
Linus Torvalds 已提交
1020

1021
#ifdef CONFIG_BLOCK
1022
/*
S
Suresh Jayaraman 已提交
1023 1024 1025 1026 1027 1028 1029
 * blk_plug permits building a queue of related requests by holding the I/O
 * fragments for a short period. This allows merging of sequential requests
 * into single larger request. As the requests are moved from a per-task list to
 * the device's request_queue in a batch, this results in improved scalability
 * as the lock contention for request_queue lock is reduced.
 *
 * It is ok not to disable preemption when adding the request to the plug list
1030 1031
 * or when attempting a merge. For details, please see schedule() where
 * blk_flush_plug() is called.
1032
 */
1033
struct blk_plug {
1034
	struct request *mq_list; /* blk-mq requests */
1035 1036 1037 1038 1039

	/* if ios_left is > 1, we can batch tag/rq allocations */
	struct request *cached_rq;
	unsigned short nr_ios;

1040
	unsigned short rq_count;
1041

1042
	bool multiple_queues;
1043
	bool has_elevator;
1044
	bool nowait;
1045 1046

	struct list_head cb_list; /* md requires an unplug callback */
1047
};
1048

1049
struct blk_plug_cb;
1050
typedef void (*blk_plug_cb_fn)(struct blk_plug_cb *, bool);
1051 1052
struct blk_plug_cb {
	struct list_head list;
1053 1054
	blk_plug_cb_fn callback;
	void *data;
1055
};
1056 1057
extern struct blk_plug_cb *blk_check_plugged(blk_plug_cb_fn unplug,
					     void *data, int size);
1058
extern void blk_start_plug(struct blk_plug *);
1059
extern void blk_start_plug_nr_ios(struct blk_plug *, unsigned short);
1060 1061
extern void blk_finish_plug(struct blk_plug *);

1062 1063
void __blk_flush_plug(struct blk_plug *plug, bool from_schedule);
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1064
{
1065 1066
	if (plug)
		__blk_flush_plug(plug, async);
1067 1068
}

1069
int blkdev_issue_flush(struct block_device *bdev);
1070 1071 1072 1073 1074
long nr_blockdev_pages(void);
#else /* CONFIG_BLOCK */
struct blk_plug {
};

1075 1076 1077 1078 1079
static inline void blk_start_plug_nr_ios(struct blk_plug *plug,
					 unsigned short nr_ios)
{
}

1080 1081 1082 1083 1084 1085 1086 1087
static inline void blk_start_plug(struct blk_plug *plug)
{
}

static inline void blk_finish_plug(struct blk_plug *plug)
{
}

1088
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1089 1090 1091
{
}

1092
static inline int blkdev_issue_flush(struct block_device *bdev)
1093 1094 1095 1096 1097 1098 1099 1100 1101 1102
{
	return 0;
}

static inline long nr_blockdev_pages(void)
{
	return 0;
}
#endif /* CONFIG_BLOCK */

1103 1104
extern void blk_io_schedule(void);

1105 1106 1107 1108 1109 1110
int blkdev_issue_discard(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask);
int __blkdev_issue_discard(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, struct bio **biop);
int blkdev_issue_secure_erase(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp);
1111 1112

#define BLKDEV_ZERO_NOUNMAP	(1 << 0)  /* do not free blocks */
1113
#define BLKDEV_ZERO_NOFALLBACK	(1 << 1)  /* don't write explicit zeroes */
1114

1115 1116
extern int __blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, struct bio **biop,
1117
		unsigned flags);
1118
extern int blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
1119 1120
		sector_t nr_sects, gfp_t gfp_mask, unsigned flags);

1121 1122
static inline int sb_issue_discard(struct super_block *sb, sector_t block,
		sector_t nr_blocks, gfp_t gfp_mask, unsigned long flags)
D
David Woodhouse 已提交
1123
{
1124 1125 1126 1127 1128
	return blkdev_issue_discard(sb->s_bdev,
				    block << (sb->s_blocksize_bits -
					      SECTOR_SHIFT),
				    nr_blocks << (sb->s_blocksize_bits -
						  SECTOR_SHIFT),
1129
				    gfp_mask);
D
David Woodhouse 已提交
1130
}
1131
static inline int sb_issue_zeroout(struct super_block *sb, sector_t block,
1132
		sector_t nr_blocks, gfp_t gfp_mask)
1133 1134
{
	return blkdev_issue_zeroout(sb->s_bdev,
1135 1136 1137 1138
				    block << (sb->s_blocksize_bits -
					      SECTOR_SHIFT),
				    nr_blocks << (sb->s_blocksize_bits -
						  SECTOR_SHIFT),
1139
				    gfp_mask, 0);
1140
}
L
Linus Torvalds 已提交
1141

1142 1143 1144 1145 1146
static inline bool bdev_is_partition(struct block_device *bdev)
{
	return bdev->bd_partno;
}

1147 1148 1149
enum blk_default_limits {
	BLK_MAX_SEGMENTS	= 128,
	BLK_SAFE_MAX_SECTORS	= 255,
1150
	BLK_DEF_MAX_SECTORS	= 2560,
1151 1152 1153
	BLK_MAX_SEGMENT_SIZE	= 65536,
	BLK_SEG_BOUNDARY_MASK	= 0xFFFFFFFFUL,
};
1154

1155
static inline unsigned long queue_segment_boundary(const struct request_queue *q)
1156
{
1157
	return q->limits.seg_boundary_mask;
1158 1159
}

1160
static inline unsigned long queue_virt_boundary(const struct request_queue *q)
1161 1162 1163 1164
{
	return q->limits.virt_boundary_mask;
}

1165
static inline unsigned int queue_max_sectors(const struct request_queue *q)
1166
{
1167
	return q->limits.max_sectors;
1168 1169
}

1170 1171 1172 1173 1174
static inline unsigned int queue_max_bytes(struct request_queue *q)
{
	return min_t(unsigned int, queue_max_sectors(q), INT_MAX >> 9) << 9;
}

1175
static inline unsigned int queue_max_hw_sectors(const struct request_queue *q)
1176
{
1177
	return q->limits.max_hw_sectors;
1178 1179
}

1180
static inline unsigned short queue_max_segments(const struct request_queue *q)
1181
{
1182
	return q->limits.max_segments;
1183 1184
}

1185
static inline unsigned short queue_max_discard_segments(const struct request_queue *q)
1186 1187 1188 1189
{
	return q->limits.max_discard_segments;
}

1190
static inline unsigned int queue_max_segment_size(const struct request_queue *q)
1191
{
1192
	return q->limits.max_segment_size;
1193 1194
}

1195 1196
static inline unsigned int queue_max_zone_append_sectors(const struct request_queue *q)
{
1197 1198 1199 1200

	const struct queue_limits *l = &q->limits;

	return min(l->max_zone_append_sectors, l->max_sectors);
1201 1202
}

1203 1204 1205 1206 1207 1208
static inline unsigned int
bdev_max_zone_append_sectors(struct block_device *bdev)
{
	return queue_max_zone_append_sectors(bdev_get_queue(bdev));
}

1209
static inline unsigned queue_logical_block_size(const struct request_queue *q)
L
Linus Torvalds 已提交
1210 1211 1212
{
	int retval = 512;

1213 1214
	if (q && q->limits.logical_block_size)
		retval = q->limits.logical_block_size;
L
Linus Torvalds 已提交
1215 1216 1217 1218

	return retval;
}

1219
static inline unsigned int bdev_logical_block_size(struct block_device *bdev)
L
Linus Torvalds 已提交
1220
{
1221
	return queue_logical_block_size(bdev_get_queue(bdev));
L
Linus Torvalds 已提交
1222 1223
}

1224
static inline unsigned int queue_physical_block_size(const struct request_queue *q)
1225 1226 1227 1228
{
	return q->limits.physical_block_size;
}

1229
static inline unsigned int bdev_physical_block_size(struct block_device *bdev)
M
Martin K. Petersen 已提交
1230 1231 1232 1233
{
	return queue_physical_block_size(bdev_get_queue(bdev));
}

1234
static inline unsigned int queue_io_min(const struct request_queue *q)
1235 1236 1237 1238
{
	return q->limits.io_min;
}

M
Martin K. Petersen 已提交
1239 1240 1241 1242 1243
static inline int bdev_io_min(struct block_device *bdev)
{
	return queue_io_min(bdev_get_queue(bdev));
}

1244
static inline unsigned int queue_io_opt(const struct request_queue *q)
1245 1246 1247 1248
{
	return q->limits.io_opt;
}

M
Martin K. Petersen 已提交
1249 1250 1251 1252 1253
static inline int bdev_io_opt(struct block_device *bdev)
{
	return queue_io_opt(bdev_get_queue(bdev));
}

1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265
static inline unsigned int
queue_zone_write_granularity(const struct request_queue *q)
{
	return q->limits.zone_write_granularity;
}

static inline unsigned int
bdev_zone_write_granularity(struct block_device *bdev)
{
	return queue_zone_write_granularity(bdev_get_queue(bdev));
}

1266
int bdev_alignment_offset(struct block_device *bdev);
1267
unsigned int bdev_discard_alignment(struct block_device *bdev);
1268

1269 1270 1271 1272 1273
static inline unsigned int bdev_max_discard_sectors(struct block_device *bdev)
{
	return bdev_get_queue(bdev)->limits.max_discard_sectors;
}

1274 1275 1276 1277 1278
static inline unsigned int bdev_discard_granularity(struct block_device *bdev)
{
	return bdev_get_queue(bdev)->limits.discard_granularity;
}

1279 1280 1281 1282 1283 1284
static inline unsigned int
bdev_max_secure_erase_sectors(struct block_device *bdev)
{
	return bdev_get_queue(bdev)->limits.max_secure_erase_sectors;
}

1285 1286 1287 1288 1289 1290 1291 1292 1293 1294
static inline unsigned int bdev_write_zeroes_sectors(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
		return q->limits.max_write_zeroes_sectors;

	return 0;
}

1295 1296 1297 1298 1299
static inline bool bdev_nonrot(struct block_device *bdev)
{
	return blk_queue_nonrot(bdev_get_queue(bdev));
}

1300 1301 1302 1303 1304 1305
static inline bool bdev_stable_writes(struct block_device *bdev)
{
	return test_bit(QUEUE_FLAG_STABLE_WRITES,
			&bdev_get_queue(bdev)->queue_flags);
}

1306 1307 1308 1309 1310
static inline bool bdev_write_cache(struct block_device *bdev)
{
	return test_bit(QUEUE_FLAG_WC, &bdev_get_queue(bdev)->queue_flags);
}

C
Christoph Hellwig 已提交
1311 1312 1313 1314 1315
static inline bool bdev_fua(struct block_device *bdev)
{
	return test_bit(QUEUE_FLAG_FUA, &bdev_get_queue(bdev)->queue_flags);
}

D
Damien Le Moal 已提交
1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335
static inline enum blk_zoned_model bdev_zoned_model(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
		return blk_queue_zoned_model(q);

	return BLK_ZONED_NONE;
}

static inline bool bdev_is_zoned(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
		return blk_queue_is_zoned(q);

	return false;
}

1336
static inline sector_t bdev_zone_sectors(struct block_device *bdev)
1337 1338 1339 1340
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
1341
		return blk_queue_zone_sectors(q);
1342 1343
	return 0;
}
1344

1345 1346 1347 1348 1349 1350 1351 1352 1353
static inline unsigned int bdev_max_open_zones(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
		return queue_max_open_zones(q);
	return 0;
}

1354 1355 1356 1357 1358 1359 1360 1361 1362
static inline unsigned int bdev_max_active_zones(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
		return queue_max_active_zones(q);
	return 0;
}

1363
static inline int queue_dma_alignment(const struct request_queue *q)
L
Linus Torvalds 已提交
1364
{
1365
	return q ? q->dma_alignment : 511;
L
Linus Torvalds 已提交
1366 1367
}

1368
static inline int blk_rq_aligned(struct request_queue *q, unsigned long addr,
1369 1370 1371
				 unsigned int len)
{
	unsigned int alignment = queue_dma_alignment(q) | q->dma_pad_mask;
1372
	return !(addr & alignment) && !(len & alignment);
1373 1374
}

L
Linus Torvalds 已提交
1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385
/* assumes size > 256 */
static inline unsigned int blksize_bits(unsigned int size)
{
	unsigned int bits = 8;
	do {
		bits++;
		size >>= 1;
	} while (size > 256);
	return bits;
}

1386
static inline unsigned int block_size(struct block_device *bdev)
L
Linus Torvalds 已提交
1387
{
1388
	return 1 << bdev->bd_inode->i_blkbits;
L
Linus Torvalds 已提交
1389 1390
}

1391
int kblockd_schedule_work(struct work_struct *work);
1392
int kblockd_mod_delayed_work_on(int cpu, struct delayed_work *dwork, unsigned long delay);
L
Linus Torvalds 已提交
1393 1394 1395 1396 1397 1398

#define MODULE_ALIAS_BLOCKDEV(major,minor) \
	MODULE_ALIAS("block-major-" __stringify(major) "-" __stringify(minor))
#define MODULE_ALIAS_BLOCKDEV_MAJOR(major) \
	MODULE_ALIAS("block-major-" __stringify(major) "-*")

1399 1400
#ifdef CONFIG_BLK_INLINE_ENCRYPTION

1401 1402
bool blk_crypto_register(struct blk_crypto_profile *profile,
			 struct request_queue *q);
1403 1404 1405

#else /* CONFIG_BLK_INLINE_ENCRYPTION */

1406 1407
static inline bool blk_crypto_register(struct blk_crypto_profile *profile,
				       struct request_queue *q)
1408 1409 1410 1411 1412 1413
{
	return true;
}

#endif /* CONFIG_BLK_INLINE_ENCRYPTION */

1414 1415 1416 1417 1418 1419 1420 1421
enum blk_unique_id {
	/* these match the Designator Types specified in SPC */
	BLK_UID_T10	= 1,
	BLK_UID_EUI64	= 2,
	BLK_UID_NAA	= 3,
};

#define NFL4_UFLG_MASK			0x0000003F
1422

1423
struct block_device_operations {
1424
	void (*submit_bio)(struct bio *bio);
1425 1426
	int (*poll_bio)(struct bio *bio, struct io_comp_batch *iob,
			unsigned int flags);
A
Al Viro 已提交
1427
	int (*open) (struct block_device *, fmode_t);
1428
	void (*release) (struct gendisk *, fmode_t);
1429
	int (*rw_page)(struct block_device *, sector_t, struct page *, unsigned int);
A
Al Viro 已提交
1430 1431
	int (*ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
	int (*compat_ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
1432 1433
	unsigned int (*check_events) (struct gendisk *disk,
				      unsigned int clearing);
1434
	void (*unlock_native_capacity) (struct gendisk *);
1435
	int (*getgeo)(struct block_device *, struct hd_geometry *);
1436
	int (*set_read_only)(struct block_device *bdev, bool ro);
1437
	void (*free_disk)(struct gendisk *disk);
1438 1439
	/* this callback is with swap_lock and sometimes page table lock held */
	void (*swap_slot_free_notify) (struct block_device *, unsigned long);
1440
	int (*report_zones)(struct gendisk *, sector_t sector,
C
Christoph Hellwig 已提交
1441
			unsigned int nr_zones, report_zones_cb cb, void *data);
1442
	char *(*devnode)(struct gendisk *disk, umode_t *mode);
1443 1444 1445
	/* returns the length of the identifier or a negative errno: */
	int (*get_unique_id)(struct gendisk *disk, u8 id[16],
			enum blk_unique_id id_type);
1446
	struct module *owner;
1447
	const struct pr_ops *pr_ops;
1448 1449 1450 1451 1452 1453 1454

	/*
	 * Special callback for probing GPT entry at a given sector.
	 * Needed by Android devices, used by GPT scanner and MMC blk
	 * driver.
	 */
	int (*alternative_gpt_sector)(struct gendisk *disk, sector_t *sector);
1455 1456
};

1457 1458 1459 1460 1461 1462 1463
#ifdef CONFIG_COMPAT
extern int blkdev_compat_ptr_ioctl(struct block_device *, fmode_t,
				      unsigned int, unsigned long);
#else
#define blkdev_compat_ptr_ioctl NULL
#endif

1464 1465 1466
extern int bdev_read_page(struct block_device *, sector_t, struct page *);
extern int bdev_write_page(struct block_device *, sector_t, struct page *,
						struct writeback_control *);
1467

J
Jens Axboe 已提交
1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480
static inline void blk_wake_io_task(struct task_struct *waiter)
{
	/*
	 * If we're polling, the task itself is doing the completions. For
	 * that case, we don't need to signal a wakeup, it's enough to just
	 * mark us as RUNNING.
	 */
	if (waiter == current)
		__set_current_state(TASK_RUNNING);
	else
		wake_up_process(waiter);
}

1481 1482 1483 1484
unsigned long bdev_start_io_acct(struct block_device *bdev,
				 unsigned int sectors, unsigned int op,
				 unsigned long start_time);
void bdev_end_io_acct(struct block_device *bdev, unsigned int op,
1485 1486
		unsigned long start_time);

1487
void bio_start_io_acct_time(struct bio *bio, unsigned long start_time);
1488 1489 1490
unsigned long bio_start_io_acct(struct bio *bio);
void bio_end_io_acct_remapped(struct bio *bio, unsigned long start_time,
		struct block_device *orig_bdev);
1491 1492 1493 1494

/**
 * bio_end_io_acct - end I/O accounting for bio based drivers
 * @bio:	bio to end account for
1495
 * @start_time:	start time returned by bio_start_io_acct()
1496 1497 1498
 */
static inline void bio_end_io_acct(struct bio *bio, unsigned long start_time)
{
1499
	return bio_end_io_acct_remapped(bio, start_time, bio->bi_bdev);
1500 1501
}

1502 1503 1504 1505
int bdev_read_only(struct block_device *bdev);
int set_blocksize(struct block_device *bdev, int size);

const char *bdevname(struct block_device *bdev, char *buffer);
C
Christoph Hellwig 已提交
1506
int lookup_bdev(const char *pathname, dev_t *dev);
1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520

void blkdev_show(struct seq_file *seqf, off_t offset);

#define BDEVNAME_SIZE	32	/* Largest string for a blockdev identifier */
#define BDEVT_SIZE	10	/* Largest string for MAJ:MIN for blkdev */
#ifdef CONFIG_BLOCK
#define BLKDEV_MAJOR_MAX	512
#else
#define BLKDEV_MAJOR_MAX	0
#endif

struct block_device *blkdev_get_by_path(const char *path, fmode_t mode,
		void *holder);
struct block_device *blkdev_get_by_dev(dev_t dev, fmode_t mode, void *holder);
1521 1522
int bd_prepare_to_claim(struct block_device *bdev, void *holder);
void bd_abort_claiming(struct block_device *bdev, void *holder);
1523 1524
void blkdev_put(struct block_device *bdev, fmode_t mode);

1525 1526 1527 1528 1529 1530
/* just for blk-cgroup, don't use elsewhere */
struct block_device *blkdev_get_no_open(dev_t dev);
void blkdev_put_no_open(struct block_device *bdev);

struct block_device *bdev_alloc(struct gendisk *disk, u8 partno);
void bdev_add(struct block_device *bdev, dev_t dev);
1531
struct block_device *I_BDEV(struct inode *inode);
1532 1533
int truncate_bdev_range(struct block_device *bdev, fmode_t mode, loff_t lstart,
		loff_t lend);
1534 1535 1536 1537

#ifdef CONFIG_BLOCK
void invalidate_bdev(struct block_device *bdev);
int sync_blockdev(struct block_device *bdev);
Y
Yuezhang Mo 已提交
1538
int sync_blockdev_range(struct block_device *bdev, loff_t lstart, loff_t lend);
C
Christoph Hellwig 已提交
1539
int sync_blockdev_nowait(struct block_device *bdev);
1540
void sync_bdevs(bool wait);
C
Christoph Hellwig 已提交
1541
void printk_all_partitions(void);
1542 1543 1544 1545 1546 1547 1548 1549
#else
static inline void invalidate_bdev(struct block_device *bdev)
{
}
static inline int sync_blockdev(struct block_device *bdev)
{
	return 0;
}
C
Christoph Hellwig 已提交
1550 1551 1552 1553
static inline int sync_blockdev_nowait(struct block_device *bdev)
{
	return 0;
}
1554 1555 1556
static inline void sync_bdevs(bool wait)
{
}
C
Christoph Hellwig 已提交
1557 1558 1559 1560 1561
static inline void printk_all_partitions(void)
{
}
#endif /* CONFIG_BLOCK */

1562 1563
int fsync_bdev(struct block_device *bdev);

1564 1565
int freeze_bdev(struct block_device *bdev);
int thaw_bdev(struct block_device *bdev);
1566

1567 1568 1569 1570 1571 1572 1573 1574
struct io_comp_batch {
	struct request *req_list;
	bool need_ts;
	void (*complete)(struct io_comp_batch *);
};

#define DEFINE_IO_COMP_BATCH(name)	struct io_comp_batch name = { }

1575
#endif /* _LINUX_BLKDEV_H */