blkdev.h 45.6 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 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198

	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);
}

/*
 * 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);
}

199
static inline int blk_validate_block_size(unsigned long bsize)
200 201 202 203 204 205 206
{
	if (bsize < 512 || bsize > PAGE_SIZE || !is_power_of_2(bsize))
		return -EINVAL;

	return 0;
}

207
static inline bool blk_op_is_passthrough(unsigned int op)
208
{
209
	op &= REQ_OP_MASK;
210 211 212
	return op == REQ_OP_DRV_IN || op == REQ_OP_DRV_OUT;
}

D
Damien Le Moal 已提交
213 214
/*
 * Zoned block device models (zoned limit).
215 216 217
 *
 * 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 已提交
218 219
 */
enum blk_zoned_model {
220 221 222
	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 已提交
223 224
};

225 226 227 228 229 230 231 232 233
/*
 * BLK_BOUNCE_NONE:	never bounce (default)
 * BLK_BOUNCE_HIGH:	bounce all highmem pages
 */
enum blk_bounce {
	BLK_BOUNCE_NONE,
	BLK_BOUNCE_HIGH,
};

234
struct queue_limits {
235
	enum blk_bounce		bounce;
236
	unsigned long		seg_boundary_mask;
237
	unsigned long		virt_boundary_mask;
238 239

	unsigned int		max_hw_sectors;
240
	unsigned int		max_dev_sectors;
241
	unsigned int		chunk_sectors;
242 243
	unsigned int		max_sectors;
	unsigned int		max_segment_size;
244
	unsigned int		physical_block_size;
245
	unsigned int		logical_block_size;
246 247 248
	unsigned int		alignment_offset;
	unsigned int		io_min;
	unsigned int		io_opt;
249
	unsigned int		max_discard_sectors;
250
	unsigned int		max_hw_discard_sectors;
251
	unsigned int		max_write_zeroes_sectors;
252
	unsigned int		max_zone_append_sectors;
253 254
	unsigned int		discard_granularity;
	unsigned int		discard_alignment;
255
	unsigned int		zone_write_granularity;
256

257
	unsigned short		max_segments;
258
	unsigned short		max_integrity_segments;
259
	unsigned short		max_discard_segments;
260

261
	unsigned char		misaligned;
262
	unsigned char		discard_misaligned;
263
	unsigned char		raid_partial_stripes_expensive;
D
Damien Le Moal 已提交
264
	enum blk_zoned_model	zoned;
265 266
};

C
Christoph Hellwig 已提交
267 268 269
typedef int (*report_zones_cb)(struct blk_zone *zone, unsigned int idx,
			       void *data);

270 271
void blk_queue_set_zoned(struct gendisk *disk, enum blk_zoned_model model);

272 273
#ifdef CONFIG_BLK_DEV_ZONED

C
Christoph Hellwig 已提交
274 275 276
#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);
277
unsigned int blkdev_nr_zones(struct gendisk *disk);
278 279 280
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 已提交
281 282
int blk_revalidate_disk_zones(struct gendisk *disk,
			      void (*update_driver_data)(struct gendisk *disk));
283

S
Shaun Tancheff 已提交
284 285
extern int blkdev_report_zones_ioctl(struct block_device *bdev, fmode_t mode,
				     unsigned int cmd, unsigned long arg);
286 287
extern int blkdev_zone_mgmt_ioctl(struct block_device *bdev, fmode_t mode,
				  unsigned int cmd, unsigned long arg);
S
Shaun Tancheff 已提交
288 289 290

#else /* CONFIG_BLK_DEV_ZONED */

291
static inline unsigned int blkdev_nr_zones(struct gendisk *disk)
292 293 294
{
	return 0;
}
295

S
Shaun Tancheff 已提交
296 297 298 299 300 301 302
static inline int blkdev_report_zones_ioctl(struct block_device *bdev,
					    fmode_t mode, unsigned int cmd,
					    unsigned long arg)
{
	return -ENOTTY;
}

303 304 305
static inline int blkdev_zone_mgmt_ioctl(struct block_device *bdev,
					 fmode_t mode, unsigned int cmd,
					 unsigned long arg)
S
Shaun Tancheff 已提交
306 307 308 309
{
	return -ENOTTY;
}

310 311
#endif /* CONFIG_BLK_DEV_ZONED */

312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339
/*
 * 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[];
};

340
struct request_queue {
L
Linus Torvalds 已提交
341
	struct request		*last_merge;
J
Jens Axboe 已提交
342
	struct elevator_queue	*elevator;
L
Linus Torvalds 已提交
343

344 345
	struct percpu_ref	q_usage_counter;

346
	struct blk_queue_stats	*stats;
347
	struct rq_qos		*rq_qos;
J
Jens Axboe 已提交
348

J
Jens Axboe 已提交
349
	const struct blk_mq_ops	*mq_ops;
350 351

	/* sw queues */
352
	struct blk_mq_ctx __percpu	*queue_ctx;
353

354 355
	unsigned int		queue_depth;

356
	/* hw dispatch queues */
M
Ming Lei 已提交
357
	struct xarray		hctx_table;
358 359
	unsigned int		nr_hw_queues;

L
Linus Torvalds 已提交
360 361 362 363 364 365 366
	/*
	 * The queue owner gets to use this for whatever they like.
	 * ll_rw_blk doesn't touch it.
	 */
	void			*queuedata;

	/*
367
	 * various queue flags, see QUEUE_* below
L
Linus Torvalds 已提交
368
	 */
369
	unsigned long		queue_flags;
370 371
	/*
	 * Number of contexts that have called blk_set_pm_only(). If this
372
	 * counter is above zero then only RQF_PM requests are processed.
373 374
	 */
	atomic_t		pm_only;
L
Linus Torvalds 已提交
375

376 377 378 379 380 381
	/*
	 * ida allocated id for this queue.  Used to index queues from
	 * ioctx.
	 */
	int			id;

382
	spinlock_t		queue_lock;
L
Linus Torvalds 已提交
383

384 385
	struct gendisk		*disk;

L
Linus Torvalds 已提交
386 387 388 389 390
	/*
	 * queue kobject
	 */
	struct kobject kobj;

391 392 393
	/*
	 * mq queue kobject
	 */
394
	struct kobject *mq_kobj;
395

396 397 398 399
#ifdef  CONFIG_BLK_DEV_INTEGRITY
	struct blk_integrity integrity;
#endif	/* CONFIG_BLK_DEV_INTEGRITY */

400
#ifdef CONFIG_PM
L
Lin Ming 已提交
401
	struct device		*dev;
402
	enum rpm_status		rpm_status;
L
Lin Ming 已提交
403 404
#endif

L
Linus Torvalds 已提交
405 406 407 408 409
	/*
	 * queue settings
	 */
	unsigned long		nr_requests;	/* Max # of requests */

410
	unsigned int		dma_pad_mask;
L
Linus Torvalds 已提交
411 412
	unsigned int		dma_alignment;

413
#ifdef CONFIG_BLK_INLINE_ENCRYPTION
414
	struct blk_crypto_profile *crypto_profile;
415
	struct kobject *crypto_kobject;
416 417
#endif

J
Jens Axboe 已提交
418
	unsigned int		rq_timeout;
419
	int			poll_nsec;
420 421

	struct blk_stat_callback	*poll_cb;
422
	struct blk_rq_stat	*poll_stat;
423

J
Jens Axboe 已提交
424
	struct timer_list	timeout;
425
	struct work_struct	timeout_work;
J
Jens Axboe 已提交
426

427
	atomic_t		nr_active_requests_shared_tags;
428

429
	struct blk_mq_tags	*sched_shared_tags;
430

431
	struct list_head	icq_list;
432
#ifdef CONFIG_BLK_CGROUP
433
	DECLARE_BITMAP		(blkcg_pols, BLKCG_MAX_POLS);
T
Tejun Heo 已提交
434
	struct blkcg_gq		*root_blkg;
435
	struct list_head	blkg_list;
436
#endif
437

438 439
	struct queue_limits	limits;

440 441
	unsigned int		required_elevator_features;

442
#ifdef CONFIG_BLK_DEV_ZONED
443 444 445
	/*
	 * Zoned block device information for request dispatch control.
	 * nr_zones is the total number of zones of the device. This is always
446 447 448
	 * 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
449 450 451 452 453
	 * 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.
454 455 456 457 458
	 *
	 * 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().
459 460
	 */
	unsigned int		nr_zones;
461
	unsigned long		*conv_zones_bitmap;
462
	unsigned long		*seq_zones_wlock;
463
	unsigned int		max_open_zones;
464
	unsigned int		max_active_zones;
465
#endif /* CONFIG_BLK_DEV_ZONED */
466

467
	int			node;
468
	struct mutex		debugfs_mutex;
469
#ifdef CONFIG_BLK_DEV_IO_TRACE
470
	struct blk_trace __rcu	*blk_trace;
471
#endif
L
Linus Torvalds 已提交
472
	/*
473
	 * for flush operations
L
Linus Torvalds 已提交
474
	 */
475
	struct blk_flush_queue	*fq;
476

477 478
	struct list_head	requeue_list;
	spinlock_t		requeue_lock;
479
	struct delayed_work	requeue_work;
480

481
	struct mutex		sysfs_lock;
482
	struct mutex		sysfs_dir_lock;
483

484 485 486 487 488 489 490
	/*
	 * for reusing dead hctx instance in case of updating
	 * nr_hw_queues
	 */
	struct list_head	unused_hctx_list;
	spinlock_t		unused_hctx_lock;

491
	int			mq_freeze_depth;
492

493 494 495 496
#ifdef CONFIG_BLK_DEV_THROTTLING
	/* Throttle data */
	struct throtl_data *td;
#endif
T
Tejun Heo 已提交
497
	struct rcu_head		rcu_head;
498
	wait_queue_head_t	mq_freeze_wq;
499 500 501 502 503
	/*
	 * Protect concurrent access to q_usage_counter by
	 * percpu_ref_kill() and percpu_ref_reinit().
	 */
	struct mutex		mq_freeze_lock;
504

505 506
	int			quiesce_depth;

507 508
	struct blk_mq_tag_set	*tag_set;
	struct list_head	tag_set_list;
509
	struct bio_set		bio_split;
510

511
	struct dentry		*debugfs_dir;
512 513

#ifdef CONFIG_BLK_DEBUG_FS
514
	struct dentry		*sched_debugfs_dir;
M
Ming Lei 已提交
515
	struct dentry		*rqos_debugfs_dir;
516 517
#endif

518
	bool			mq_sysfs_init_done;
519

520 521 522 523 524
	/*
	 * 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;
525 526 527 528 529 530

	/**
	 * @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 已提交
531 532
};

533
/* Keep blk_queue_flag_name[] in sync with the definitions below */
J
Jens Axboe 已提交
534 535
#define QUEUE_FLAG_STOPPED	0	/* queue is stopped */
#define QUEUE_FLAG_DYING	1	/* queue being torn down */
536
#define QUEUE_FLAG_HAS_SRCU	2	/* SRCU is allocated */
J
Jens Axboe 已提交
537 538 539 540 541 542 543 544 545 546 547 548 549
#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_DISCARD	8	/* supports DISCARD */
#define QUEUE_FLAG_NOXMERGES	9	/* No extended merges */
#define QUEUE_FLAG_ADD_RANDOM	10	/* Contributes to random pool */
#define QUEUE_FLAG_SECERASE	11	/* supports secure erase */
#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 */
550
#define QUEUE_FLAG_STABLE_WRITES 15	/* don't modify blks until WB is done */
J
Jens Axboe 已提交
551 552 553 554 555 556 557 558
#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 */
559
#define QUEUE_FLAG_ZONE_RESETALL 26	/* supports Zone Reset All */
560
#define QUEUE_FLAG_RQ_ALLOC_TIME 27	/* record rq->alloc_time_ns */
M
Mike Snitzer 已提交
561 562
#define QUEUE_FLAG_HCTX_ACTIVE	28	/* at least one blk-mq hctx is active */
#define QUEUE_FLAG_NOWAIT       29	/* device supports NOWAIT */
563

564
#define QUEUE_FLAG_MQ_DEFAULT	((1 << QUEUE_FLAG_IO_STAT) |		\
M
Mike Snitzer 已提交
565 566
				 (1 << QUEUE_FLAG_SAME_COMP) |		\
				 (1 << QUEUE_FLAG_NOWAIT))
567

568 569 570 571
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 已提交
572
#define blk_queue_stopped(q)	test_bit(QUEUE_FLAG_STOPPED, &(q)->queue_flags)
B
Bart Van Assche 已提交
573
#define blk_queue_dying(q)	test_bit(QUEUE_FLAG_DYING, &(q)->queue_flags)
574
#define blk_queue_has_srcu(q)	test_bit(QUEUE_FLAG_HAS_SRCU, &(q)->queue_flags)
575
#define blk_queue_dead(q)	test_bit(QUEUE_FLAG_DEAD, &(q)->queue_flags)
576
#define blk_queue_init_done(q)	test_bit(QUEUE_FLAG_INIT_DONE, &(q)->queue_flags)
577
#define blk_queue_nomerges(q)	test_bit(QUEUE_FLAG_NOMERGES, &(q)->queue_flags)
578 579
#define blk_queue_noxmerges(q)	\
	test_bit(QUEUE_FLAG_NOXMERGES, &(q)->queue_flags)
580
#define blk_queue_nonrot(q)	test_bit(QUEUE_FLAG_NONROT, &(q)->queue_flags)
581 582
#define blk_queue_stable_writes(q) \
	test_bit(QUEUE_FLAG_STABLE_WRITES, &(q)->queue_flags)
583
#define blk_queue_io_stat(q)	test_bit(QUEUE_FLAG_IO_STAT, &(q)->queue_flags)
584
#define blk_queue_add_random(q)	test_bit(QUEUE_FLAG_ADD_RANDOM, &(q)->queue_flags)
585
#define blk_queue_discard(q)	test_bit(QUEUE_FLAG_DISCARD, &(q)->queue_flags)
586 587
#define blk_queue_zone_resetall(q)	\
	test_bit(QUEUE_FLAG_ZONE_RESETALL, &(q)->queue_flags)
588 589
#define blk_queue_secure_erase(q) \
	(test_bit(QUEUE_FLAG_SECERASE, &(q)->queue_flags))
590
#define blk_queue_dax(q)	test_bit(QUEUE_FLAG_DAX, &(q)->queue_flags)
591 592
#define blk_queue_pci_p2pdma(q)	\
	test_bit(QUEUE_FLAG_PCI_P2PDMA, &(q)->queue_flags)
593 594 595 596 597 598
#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 已提交
599

600 601 602
#define blk_noretry_request(rq) \
	((rq)->cmd_flags & (REQ_FAILFAST_DEV|REQ_FAILFAST_TRANSPORT| \
			     REQ_FAILFAST_DRIVER))
603
#define blk_queue_quiesced(q)	test_bit(QUEUE_FLAG_QUIESCED, &(q)->queue_flags)
604
#define blk_queue_pm_only(q)	atomic_read(&(q)->pm_only)
605
#define blk_queue_fua(q)	test_bit(QUEUE_FLAG_FUA, &(q)->queue_flags)
606
#define blk_queue_registered(q)	test_bit(QUEUE_FLAG_REGISTERED, &(q)->queue_flags)
M
Mike Snitzer 已提交
607
#define blk_queue_nowait(q)	test_bit(QUEUE_FLAG_NOWAIT, &(q)->queue_flags)
608

609 610
extern void blk_set_pm_only(struct request_queue *q);
extern void blk_clear_pm_only(struct request_queue *q);
611

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

614 615 616 617
#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 已提交
618
static inline bool queue_is_mq(struct request_queue *q)
619
{
J
Jens Axboe 已提交
620
	return q->mq_ops;
621 622
}

623 624 625 626 627 628 629 630 631 632 633 634
#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 已提交
635 636 637
static inline enum blk_zoned_model
blk_queue_zoned_model(struct request_queue *q)
{
638 639 640
	if (IS_ENABLED(CONFIG_BLK_DEV_ZONED))
		return q->limits.zoned;
	return BLK_ZONED_NONE;
D
Damien Le Moal 已提交
641 642 643 644 645 646 647 648 649 650 651 652 653
}

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;
	}
}

654
static inline sector_t blk_queue_zone_sectors(struct request_queue *q)
655 656 657 658
{
	return blk_queue_is_zoned(q) ? q->limits.chunk_sectors : 0;
}

659
#ifdef CONFIG_BLK_DEV_ZONED
660 661 662 663 664
static inline unsigned int blk_queue_nr_zones(struct request_queue *q)
{
	return blk_queue_is_zoned(q) ? q->nr_zones : 0;
}

665 666 667 668 669 670 671 672 673 674 675
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)
{
676
	if (!blk_queue_is_zoned(q))
677
		return false;
678 679 680
	if (!q->conv_zones_bitmap)
		return true;
	return !test_bit(blk_queue_zone_no(q, sector), q->conv_zones_bitmap);
681
}
682 683 684 685 686 687 688 689 690 691 692

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;
}
693 694 695 696 697 698 699 700 701 702 703

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;
}
704 705 706 707 708
#else /* CONFIG_BLK_DEV_ZONED */
static inline unsigned int blk_queue_nr_zones(struct request_queue *q)
{
	return 0;
}
709 710 711 712 713 714 715 716 717 718
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;
}
719 720 721 722
static inline unsigned int queue_max_open_zones(const struct request_queue *q)
{
	return 0;
}
723 724 725 726
static inline unsigned int queue_max_active_zones(const struct request_queue *q)
{
	return 0;
}
727
#endif /* CONFIG_BLK_DEV_ZONED */
728

729 730 731 732 733 734 735 736
static inline unsigned int blk_queue_depth(struct request_queue *q)
{
	if (q->queue_depth)
		return q->queue_depth;

	return q->nr_requests;
}

737 738 739 740
/*
 * default timeout for SG_IO if none specified
 */
#define BLK_DEFAULT_SG_TIMEOUT	(60 * HZ)
L
Linus Torvalds 已提交
741
#define BLK_MIN_SG_TIMEOUT	(7 * HZ)
742

743
/* This should not be used directly - use rq_for_each_segment */
744 745
#define for_each_bio(_bio)		\
	for (; _bio; _bio = _bio->bi_next)
746

C
Christoph Hellwig 已提交
747 748 749 750 751 752 753 754 755 756 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
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);
859

L
Linus Torvalds 已提交
860 861
extern int blk_register_queue(struct gendisk *disk);
extern void blk_unregister_queue(struct gendisk *disk);
862
void submit_bio_noacct(struct bio *bio);
863

864
extern int blk_lld_busy(struct request_queue *q);
865
extern void blk_queue_split(struct bio **);
866
extern int blk_queue_enter(struct request_queue *q, blk_mq_req_flags_t flags);
867
extern void blk_queue_exit(struct request_queue *q);
L
Linus Torvalds 已提交
868
extern void blk_sync_queue(struct request_queue *q);
869

870 871 872
/* Helper to convert REQ_OP_XXX to its string format XXX */
extern const char *blk_op_str(unsigned int op);

873 874 875
int blk_status_to_errno(blk_status_t status);
blk_status_t errno_to_blk_status(int errno);

876 877
/* only poll the hardware once, don't continue until a completion was found */
#define BLK_POLL_ONESHOT		(1 << 0)
878 879
/* do not sleep to wait for the expected completion time */
#define BLK_POLL_NOSLEEP		(1 << 1)
880 881 882
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 已提交
883

884
static inline struct request_queue *bdev_get_queue(struct block_device *bdev)
L
Linus Torvalds 已提交
885
{
886
	return bdev->bd_queue;	/* this is never NULL */
L
Linus Torvalds 已提交
887 888
}

889
#ifdef CONFIG_BLK_DEV_ZONED
890 891 892 893

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

894 895 896 897 898 899 900 901 902 903 904
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);
}
905
#endif /* CONFIG_BLK_DEV_ZONED */
906

907
static inline unsigned int blk_queue_get_max_sectors(struct request_queue *q,
908
						     int op)
909
{
A
Adrian Hunter 已提交
910
	if (unlikely(op == REQ_OP_DISCARD || op == REQ_OP_SECURE_ERASE))
911 912
		return min(q->limits.max_discard_sectors,
			   UINT_MAX >> SECTOR_SHIFT);
913

914 915 916
	if (unlikely(op == REQ_OP_WRITE_ZEROES))
		return q->limits.max_write_zeroes_sectors;

917 918 919
	return q->limits.max_sectors;
}

920 921 922 923 924
/*
 * 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 已提交
925 926
					       sector_t offset,
					       unsigned int chunk_sectors)
927
{
928 929 930 931 932 933
	if (!chunk_sectors) {
		if (q->limits.chunk_sectors)
			chunk_sectors = q->limits.chunk_sectors;
		else
			return q->limits.max_sectors;
	}
934

935 936 937 938 939 940
	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);
941 942
}

L
Linus Torvalds 已提交
943 944 945
/*
 * Access functions for manipulating queue properties
 */
946
extern void blk_cleanup_queue(struct request_queue *);
947
void blk_queue_bounce_limit(struct request_queue *q, enum blk_bounce limit);
948
extern void blk_queue_max_hw_sectors(struct request_queue *, unsigned int);
949
extern void blk_queue_chunk_sectors(struct request_queue *, unsigned int);
950
extern void blk_queue_max_segments(struct request_queue *, unsigned short);
951 952
extern void blk_queue_max_discard_segments(struct request_queue *,
		unsigned short);
953
extern void blk_queue_max_segment_size(struct request_queue *, unsigned int);
954 955
extern void blk_queue_max_discard_sectors(struct request_queue *q,
		unsigned int max_discard_sectors);
956 957
extern void blk_queue_max_write_zeroes_sectors(struct request_queue *q,
		unsigned int max_write_same_sectors);
958
extern void blk_queue_logical_block_size(struct request_queue *, unsigned int);
959 960
extern void blk_queue_max_zone_append_sectors(struct request_queue *q,
		unsigned int max_zone_append_sectors);
961
extern void blk_queue_physical_block_size(struct request_queue *, unsigned int);
962 963
void blk_queue_zone_write_granularity(struct request_queue *q,
				      unsigned int size);
964 965
extern void blk_queue_alignment_offset(struct request_queue *q,
				       unsigned int alignment);
966
void disk_update_readahead(struct gendisk *disk);
967
extern void blk_limits_io_min(struct queue_limits *limits, unsigned int min);
968
extern void blk_queue_io_min(struct request_queue *q, unsigned int min);
969
extern void blk_limits_io_opt(struct queue_limits *limits, unsigned int opt);
970
extern void blk_queue_io_opt(struct request_queue *q, unsigned int opt);
971
extern void blk_set_queue_depth(struct request_queue *q, unsigned int depth);
972
extern void blk_set_default_limits(struct queue_limits *lim);
973
extern void blk_set_stacking_limits(struct queue_limits *lim);
974 975 976 977
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);
978
extern void blk_queue_update_dma_pad(struct request_queue *, unsigned int);
979
extern void blk_queue_segment_boundary(struct request_queue *, unsigned long);
980
extern void blk_queue_virt_boundary(struct request_queue *, unsigned long);
981
extern void blk_queue_dma_alignment(struct request_queue *, int);
982
extern void blk_queue_update_dma_alignment(struct request_queue *, int);
J
Jens Axboe 已提交
983
extern void blk_queue_rq_timeout(struct request_queue *, unsigned int);
984
extern void blk_queue_write_cache(struct request_queue *q, bool enabled, bool fua);
985

986 987 988 989 990
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);

991 992 993 994 995 996 997 998
/*
 * 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)

999 1000
extern void blk_queue_required_elevator_features(struct request_queue *q,
						 unsigned int features);
1001 1002
extern bool blk_queue_can_use_dma_map_merging(struct request_queue *q,
					      struct device *dev);
L
Linus Torvalds 已提交
1003

T
Tejun Heo 已提交
1004
bool __must_check blk_get_queue(struct request_queue *);
1005
extern void blk_put_queue(struct request_queue *);
1006 1007

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

1009
#ifdef CONFIG_BLOCK
1010
/*
S
Suresh Jayaraman 已提交
1011 1012 1013 1014 1015 1016 1017
 * 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
1018 1019
 * or when attempting a merge. For details, please see schedule() where
 * blk_flush_plug() is called.
1020
 */
1021
struct blk_plug {
1022
	struct request *mq_list; /* blk-mq requests */
1023 1024 1025 1026 1027

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

1028
	unsigned short rq_count;
1029

1030
	bool multiple_queues;
1031
	bool has_elevator;
1032
	bool nowait;
1033 1034

	struct list_head cb_list; /* md requires an unplug callback */
1035
};
1036

1037
struct blk_plug_cb;
1038
typedef void (*blk_plug_cb_fn)(struct blk_plug_cb *, bool);
1039 1040
struct blk_plug_cb {
	struct list_head list;
1041 1042
	blk_plug_cb_fn callback;
	void *data;
1043
};
1044 1045
extern struct blk_plug_cb *blk_check_plugged(blk_plug_cb_fn unplug,
					     void *data, int size);
1046
extern void blk_start_plug(struct blk_plug *);
1047
extern void blk_start_plug_nr_ios(struct blk_plug *, unsigned short);
1048 1049
extern void blk_finish_plug(struct blk_plug *);

1050 1051
void __blk_flush_plug(struct blk_plug *plug, bool from_schedule);
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1052
{
1053 1054
	if (plug)
		__blk_flush_plug(plug, async);
1055 1056
}

1057
int blkdev_issue_flush(struct block_device *bdev);
1058 1059 1060 1061 1062
long nr_blockdev_pages(void);
#else /* CONFIG_BLOCK */
struct blk_plug {
};

1063 1064 1065 1066 1067
static inline void blk_start_plug_nr_ios(struct blk_plug *plug,
					 unsigned short nr_ios)
{
}

1068 1069 1070 1071 1072 1073 1074 1075
static inline void blk_start_plug(struct blk_plug *plug)
{
}

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

1076
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1077 1078 1079
{
}

1080
static inline int blkdev_issue_flush(struct block_device *bdev)
1081 1082 1083 1084 1085 1086 1087 1088 1089 1090
{
	return 0;
}

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

1091 1092
extern void blk_io_schedule(void);

1093
#define BLKDEV_DISCARD_SECURE	(1 << 0)	/* issue a secure erase */
1094

1095 1096
extern int blkdev_issue_discard(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, unsigned long flags);
1097
extern int __blkdev_issue_discard(struct block_device *bdev, sector_t sector,
1098
		sector_t nr_sects, gfp_t gfp_mask, int flags,
1099
		struct bio **biop);
1100 1101

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

1104 1105
extern int __blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
		sector_t nr_sects, gfp_t gfp_mask, struct bio **biop,
1106
		unsigned flags);
1107
extern int blkdev_issue_zeroout(struct block_device *bdev, sector_t sector,
1108 1109
		sector_t nr_sects, gfp_t gfp_mask, unsigned flags);

1110 1111
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 已提交
1112
{
1113 1114 1115 1116 1117
	return blkdev_issue_discard(sb->s_bdev,
				    block << (sb->s_blocksize_bits -
					      SECTOR_SHIFT),
				    nr_blocks << (sb->s_blocksize_bits -
						  SECTOR_SHIFT),
1118
				    gfp_mask, flags);
D
David Woodhouse 已提交
1119
}
1120
static inline int sb_issue_zeroout(struct super_block *sb, sector_t block,
1121
		sector_t nr_blocks, gfp_t gfp_mask)
1122 1123
{
	return blkdev_issue_zeroout(sb->s_bdev,
1124 1125 1126 1127
				    block << (sb->s_blocksize_bits -
					      SECTOR_SHIFT),
				    nr_blocks << (sb->s_blocksize_bits -
						  SECTOR_SHIFT),
1128
				    gfp_mask, 0);
1129
}
L
Linus Torvalds 已提交
1130

1131 1132 1133 1134 1135
static inline bool bdev_is_partition(struct block_device *bdev)
{
	return bdev->bd_partno;
}

1136 1137 1138
enum blk_default_limits {
	BLK_MAX_SEGMENTS	= 128,
	BLK_SAFE_MAX_SECTORS	= 255,
1139
	BLK_DEF_MAX_SECTORS	= 2560,
1140 1141 1142
	BLK_MAX_SEGMENT_SIZE	= 65536,
	BLK_SEG_BOUNDARY_MASK	= 0xFFFFFFFFUL,
};
1143

1144
static inline unsigned long queue_segment_boundary(const struct request_queue *q)
1145
{
1146
	return q->limits.seg_boundary_mask;
1147 1148
}

1149
static inline unsigned long queue_virt_boundary(const struct request_queue *q)
1150 1151 1152 1153
{
	return q->limits.virt_boundary_mask;
}

1154
static inline unsigned int queue_max_sectors(const struct request_queue *q)
1155
{
1156
	return q->limits.max_sectors;
1157 1158
}

1159 1160 1161 1162 1163
static inline unsigned int queue_max_bytes(struct request_queue *q)
{
	return min_t(unsigned int, queue_max_sectors(q), INT_MAX >> 9) << 9;
}

1164
static inline unsigned int queue_max_hw_sectors(const struct request_queue *q)
1165
{
1166
	return q->limits.max_hw_sectors;
1167 1168
}

1169
static inline unsigned short queue_max_segments(const struct request_queue *q)
1170
{
1171
	return q->limits.max_segments;
1172 1173
}

1174
static inline unsigned short queue_max_discard_segments(const struct request_queue *q)
1175 1176 1177 1178
{
	return q->limits.max_discard_segments;
}

1179
static inline unsigned int queue_max_segment_size(const struct request_queue *q)
1180
{
1181
	return q->limits.max_segment_size;
1182 1183
}

1184 1185
static inline unsigned int queue_max_zone_append_sectors(const struct request_queue *q)
{
1186 1187 1188 1189

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

	return min(l->max_zone_append_sectors, l->max_sectors);
1190 1191
}

1192
static inline unsigned queue_logical_block_size(const struct request_queue *q)
L
Linus Torvalds 已提交
1193 1194 1195
{
	int retval = 512;

1196 1197
	if (q && q->limits.logical_block_size)
		retval = q->limits.logical_block_size;
L
Linus Torvalds 已提交
1198 1199 1200 1201

	return retval;
}

1202
static inline unsigned int bdev_logical_block_size(struct block_device *bdev)
L
Linus Torvalds 已提交
1203
{
1204
	return queue_logical_block_size(bdev_get_queue(bdev));
L
Linus Torvalds 已提交
1205 1206
}

1207
static inline unsigned int queue_physical_block_size(const struct request_queue *q)
1208 1209 1210 1211
{
	return q->limits.physical_block_size;
}

1212
static inline unsigned int bdev_physical_block_size(struct block_device *bdev)
M
Martin K. Petersen 已提交
1213 1214 1215 1216
{
	return queue_physical_block_size(bdev_get_queue(bdev));
}

1217
static inline unsigned int queue_io_min(const struct request_queue *q)
1218 1219 1220 1221
{
	return q->limits.io_min;
}

M
Martin K. Petersen 已提交
1222 1223 1224 1225 1226
static inline int bdev_io_min(struct block_device *bdev)
{
	return queue_io_min(bdev_get_queue(bdev));
}

1227
static inline unsigned int queue_io_opt(const struct request_queue *q)
1228 1229 1230 1231
{
	return q->limits.io_opt;
}

M
Martin K. Petersen 已提交
1232 1233 1234 1235 1236
static inline int bdev_io_opt(struct block_device *bdev)
{
	return queue_io_opt(bdev_get_queue(bdev));
}

1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248
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));
}

1249
static inline int queue_alignment_offset(const struct request_queue *q)
1250
{
M
Martin K. Petersen 已提交
1251
	if (q->limits.misaligned)
1252 1253
		return -1;

M
Martin K. Petersen 已提交
1254
	return q->limits.alignment_offset;
1255 1256
}

1257
static inline int queue_limit_alignment_offset(struct queue_limits *lim, sector_t sector)
1258 1259
{
	unsigned int granularity = max(lim->physical_block_size, lim->io_min);
1260 1261
	unsigned int alignment = sector_div(sector, granularity >> SECTOR_SHIFT)
		<< SECTOR_SHIFT;
1262

1263
	return (granularity + lim->alignment_offset - alignment) % granularity;
1264 1265
}

M
Martin K. Petersen 已提交
1266 1267 1268 1269 1270 1271
static inline int bdev_alignment_offset(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q->limits.misaligned)
		return -1;
1272
	if (bdev_is_partition(bdev))
1273
		return queue_limit_alignment_offset(&q->limits,
1274
				bdev->bd_start_sect);
M
Martin K. Petersen 已提交
1275 1276 1277
	return q->limits.alignment_offset;
}

1278
static inline int queue_discard_alignment(const struct request_queue *q)
1279 1280 1281 1282 1283 1284 1285
{
	if (q->limits.discard_misaligned)
		return -1;

	return q->limits.discard_alignment;
}

1286
static inline int queue_limit_discard_alignment(struct queue_limits *lim, sector_t sector)
1287
{
1288
	unsigned int alignment, granularity, offset;
1289

1290 1291 1292
	if (!lim->max_discard_sectors)
		return 0;

1293
	/* Why are these in bytes, not sectors? */
1294 1295
	alignment = lim->discard_alignment >> SECTOR_SHIFT;
	granularity = lim->discard_granularity >> SECTOR_SHIFT;
1296 1297 1298 1299 1300 1301 1302 1303 1304 1305
	if (!granularity)
		return 0;

	/* Offset of the partition start in 'granularity' sectors */
	offset = sector_div(sector, granularity);

	/* And why do we do this modulus *again* in blkdev_issue_discard()? */
	offset = (granularity + alignment - offset) % granularity;

	/* Turn it back into bytes, gaah */
1306
	return offset << SECTOR_SHIFT;
1307 1308
}

1309 1310 1311 1312
static inline int bdev_discard_alignment(struct block_device *bdev)
{
	struct request_queue *q = bdev_get_queue(bdev);

1313
	if (bdev_is_partition(bdev))
1314
		return queue_limit_discard_alignment(&q->limits,
1315
				bdev->bd_start_sect);
1316 1317 1318
	return q->limits.discard_alignment;
}

1319 1320 1321 1322 1323 1324 1325 1326 1327 1328
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;
}

D
Damien Le Moal 已提交
1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348
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;
}

1349
static inline sector_t bdev_zone_sectors(struct block_device *bdev)
1350 1351 1352 1353
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
1354
		return blk_queue_zone_sectors(q);
1355 1356
	return 0;
}
1357

1358 1359 1360 1361 1362 1363 1364 1365 1366
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;
}

1367 1368 1369 1370 1371 1372 1373 1374 1375
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;
}

1376
static inline int queue_dma_alignment(const struct request_queue *q)
L
Linus Torvalds 已提交
1377
{
1378
	return q ? q->dma_alignment : 511;
L
Linus Torvalds 已提交
1379 1380
}

1381
static inline int blk_rq_aligned(struct request_queue *q, unsigned long addr,
1382 1383 1384
				 unsigned int len)
{
	unsigned int alignment = queue_dma_alignment(q) | q->dma_pad_mask;
1385
	return !(addr & alignment) && !(len & alignment);
1386 1387
}

L
Linus Torvalds 已提交
1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398
/* 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;
}

1399
static inline unsigned int block_size(struct block_device *bdev)
L
Linus Torvalds 已提交
1400
{
1401
	return 1 << bdev->bd_inode->i_blkbits;
L
Linus Torvalds 已提交
1402 1403
}

1404
int kblockd_schedule_work(struct work_struct *work);
1405
int kblockd_mod_delayed_work_on(int cpu, struct delayed_work *dwork, unsigned long delay);
L
Linus Torvalds 已提交
1406 1407 1408 1409 1410 1411

#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) "-*")

1412 1413
#ifdef CONFIG_BLK_INLINE_ENCRYPTION

1414 1415
bool blk_crypto_register(struct blk_crypto_profile *profile,
			 struct request_queue *q);
1416 1417 1418

#else /* CONFIG_BLK_INLINE_ENCRYPTION */

1419 1420
static inline bool blk_crypto_register(struct blk_crypto_profile *profile,
				       struct request_queue *q)
1421 1422 1423 1424 1425 1426
{
	return true;
}

#endif /* CONFIG_BLK_INLINE_ENCRYPTION */

1427 1428 1429 1430 1431 1432 1433 1434
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
1435

1436
struct block_device_operations {
1437
	void (*submit_bio)(struct bio *bio);
1438 1439
	int (*poll_bio)(struct bio *bio, struct io_comp_batch *iob,
			unsigned int flags);
A
Al Viro 已提交
1440
	int (*open) (struct block_device *, fmode_t);
1441
	void (*release) (struct gendisk *, fmode_t);
1442
	int (*rw_page)(struct block_device *, sector_t, struct page *, unsigned int);
A
Al Viro 已提交
1443 1444
	int (*ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
	int (*compat_ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
1445 1446
	unsigned int (*check_events) (struct gendisk *disk,
				      unsigned int clearing);
1447
	void (*unlock_native_capacity) (struct gendisk *);
1448
	int (*getgeo)(struct block_device *, struct hd_geometry *);
1449
	int (*set_read_only)(struct block_device *bdev, bool ro);
1450
	void (*free_disk)(struct gendisk *disk);
1451 1452
	/* this callback is with swap_lock and sometimes page table lock held */
	void (*swap_slot_free_notify) (struct block_device *, unsigned long);
1453
	int (*report_zones)(struct gendisk *, sector_t sector,
C
Christoph Hellwig 已提交
1454
			unsigned int nr_zones, report_zones_cb cb, void *data);
1455
	char *(*devnode)(struct gendisk *disk, umode_t *mode);
1456 1457 1458
	/* 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);
1459
	struct module *owner;
1460
	const struct pr_ops *pr_ops;
1461 1462 1463 1464 1465 1466 1467

	/*
	 * 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);
1468 1469
};

1470 1471 1472 1473 1474 1475 1476
#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

1477 1478 1479
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 *);
1480

J
Jens Axboe 已提交
1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493
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);
}

1494 1495 1496 1497 1498
unsigned long disk_start_io_acct(struct gendisk *disk, unsigned int sectors,
		unsigned int op);
void disk_end_io_acct(struct gendisk *disk, unsigned int op,
		unsigned long start_time);

1499
void bio_start_io_acct_time(struct bio *bio, unsigned long start_time);
1500 1501 1502
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);
1503 1504 1505 1506

/**
 * bio_end_io_acct - end I/O accounting for bio based drivers
 * @bio:	bio to end account for
1507
 * @start_time:	start time returned by bio_start_io_acct()
1508 1509 1510
 */
static inline void bio_end_io_acct(struct bio *bio, unsigned long start_time)
{
1511
	return bio_end_io_acct_remapped(bio, start_time, bio->bi_bdev);
1512 1513
}

1514 1515 1516 1517
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 已提交
1518
int lookup_bdev(const char *pathname, dev_t *dev);
1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532

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);
1533 1534
int bd_prepare_to_claim(struct block_device *bdev, void *holder);
void bd_abort_claiming(struct block_device *bdev, void *holder);
1535 1536
void blkdev_put(struct block_device *bdev, fmode_t mode);

1537 1538 1539 1540 1541 1542
/* 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);
1543
struct block_device *I_BDEV(struct inode *inode);
1544 1545
int truncate_bdev_range(struct block_device *bdev, fmode_t mode, loff_t lstart,
		loff_t lend);
1546 1547 1548 1549

#ifdef CONFIG_BLOCK
void invalidate_bdev(struct block_device *bdev);
int sync_blockdev(struct block_device *bdev);
C
Christoph Hellwig 已提交
1550
int sync_blockdev_nowait(struct block_device *bdev);
1551
void sync_bdevs(bool wait);
C
Christoph Hellwig 已提交
1552
void printk_all_partitions(void);
1553 1554 1555 1556 1557 1558 1559 1560
#else
static inline void invalidate_bdev(struct block_device *bdev)
{
}
static inline int sync_blockdev(struct block_device *bdev)
{
	return 0;
}
C
Christoph Hellwig 已提交
1561 1562 1563 1564
static inline int sync_blockdev_nowait(struct block_device *bdev)
{
	return 0;
}
1565 1566 1567
static inline void sync_bdevs(bool wait)
{
}
C
Christoph Hellwig 已提交
1568 1569 1570 1571 1572
static inline void printk_all_partitions(void)
{
}
#endif /* CONFIG_BLOCK */

1573 1574
int fsync_bdev(struct block_device *bdev);

1575 1576
int freeze_bdev(struct block_device *bdev);
int thaw_bdev(struct block_device *bdev);
1577

1578 1579 1580 1581 1582 1583 1584 1585
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 = { }

1586
#endif /* _LINUX_BLKDEV_H */