blkdev.h 44.4 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
#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_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 */
549
#define QUEUE_FLAG_STABLE_WRITES 15	/* don't modify blks until WB is done */
J
Jens Axboe 已提交
550 551 552 553 554 555 556 557
#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 */
558
#define QUEUE_FLAG_ZONE_RESETALL 26	/* supports Zone Reset All */
559
#define QUEUE_FLAG_RQ_ALLOC_TIME 27	/* record rq->alloc_time_ns */
M
Mike Snitzer 已提交
560 561
#define QUEUE_FLAG_HCTX_ACTIVE	28	/* at least one blk-mq hctx is active */
#define QUEUE_FLAG_NOWAIT       29	/* device supports NOWAIT */
562

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

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

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

606 607
extern void blk_set_pm_only(struct request_queue *q);
extern void blk_clear_pm_only(struct request_queue *q);
608

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

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

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

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

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

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

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

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;
}
690 691 692 693 694 695 696 697 698 699 700

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

726 727 728 729 730 731 732 733
static inline unsigned int blk_queue_depth(struct request_queue *q)
{
	if (q->queue_depth)
		return q->queue_depth;

	return q->nr_requests;
}

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

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

C
Christoph Hellwig 已提交
744 745 746 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
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);
856

L
Linus Torvalds 已提交
857 858
extern int blk_register_queue(struct gendisk *disk);
extern void blk_unregister_queue(struct gendisk *disk);
859
void submit_bio_noacct(struct bio *bio);
860

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

867 868 869
/* Helper to convert REQ_OP_XXX to its string format XXX */
extern const char *blk_op_str(unsigned int op);

870 871 872
int blk_status_to_errno(blk_status_t status);
blk_status_t errno_to_blk_status(int errno);

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

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

886
#ifdef CONFIG_BLK_DEV_ZONED
887 888 889 890

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

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

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

911 912 913
	if (unlikely(op == REQ_OP_WRITE_ZEROES))
		return q->limits.max_write_zeroes_sectors;

914 915 916
	return q->limits.max_sectors;
}

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

932 933 934 935 936 937
	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);
938 939
}

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

983 984 985 986 987
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);

988 989 990 991 992 993 994 995
/*
 * 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)

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

T
Tejun Heo 已提交
1001
bool __must_check blk_get_queue(struct request_queue *);
1002
extern void blk_put_queue(struct request_queue *);
1003 1004

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

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

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

1025
	unsigned short rq_count;
1026

1027
	bool multiple_queues;
1028
	bool has_elevator;
1029
	bool nowait;
1030 1031

	struct list_head cb_list; /* md requires an unplug callback */
1032
};
1033

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

1047 1048
void __blk_flush_plug(struct blk_plug *plug, bool from_schedule);
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1049
{
1050 1051
	if (plug)
		__blk_flush_plug(plug, async);
1052 1053
}

1054
int blkdev_issue_flush(struct block_device *bdev);
1055 1056 1057 1058 1059
long nr_blockdev_pages(void);
#else /* CONFIG_BLOCK */
struct blk_plug {
};

1060 1061 1062 1063 1064
static inline void blk_start_plug_nr_ios(struct blk_plug *plug,
					 unsigned short nr_ios)
{
}

1065 1066 1067 1068 1069 1070 1071 1072
static inline void blk_start_plug(struct blk_plug *plug)
{
}

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

1073
static inline void blk_flush_plug(struct blk_plug *plug, bool async)
1074 1075 1076
{
}

1077
static inline int blkdev_issue_flush(struct block_device *bdev)
1078 1079 1080 1081 1082 1083 1084 1085 1086 1087
{
	return 0;
}

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

1088 1089
extern void blk_io_schedule(void);

1090
#define BLKDEV_DISCARD_SECURE	(1 << 0)	/* issue a secure erase */
1091

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

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

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

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

1128 1129 1130 1131 1132
static inline bool bdev_is_partition(struct block_device *bdev)
{
	return bdev->bd_partno;
}

1133 1134 1135
enum blk_default_limits {
	BLK_MAX_SEGMENTS	= 128,
	BLK_SAFE_MAX_SECTORS	= 255,
1136
	BLK_DEF_MAX_SECTORS	= 2560,
1137 1138 1139
	BLK_MAX_SEGMENT_SIZE	= 65536,
	BLK_SEG_BOUNDARY_MASK	= 0xFFFFFFFFUL,
};
1140

1141
static inline unsigned long queue_segment_boundary(const struct request_queue *q)
1142
{
1143
	return q->limits.seg_boundary_mask;
1144 1145
}

1146
static inline unsigned long queue_virt_boundary(const struct request_queue *q)
1147 1148 1149 1150
{
	return q->limits.virt_boundary_mask;
}

1151
static inline unsigned int queue_max_sectors(const struct request_queue *q)
1152
{
1153
	return q->limits.max_sectors;
1154 1155
}

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

1161
static inline unsigned int queue_max_hw_sectors(const struct request_queue *q)
1162
{
1163
	return q->limits.max_hw_sectors;
1164 1165
}

1166
static inline unsigned short queue_max_segments(const struct request_queue *q)
1167
{
1168
	return q->limits.max_segments;
1169 1170
}

1171
static inline unsigned short queue_max_discard_segments(const struct request_queue *q)
1172 1173 1174 1175
{
	return q->limits.max_discard_segments;
}

1176
static inline unsigned int queue_max_segment_size(const struct request_queue *q)
1177
{
1178
	return q->limits.max_segment_size;
1179 1180
}

1181 1182
static inline unsigned int queue_max_zone_append_sectors(const struct request_queue *q)
{
1183 1184 1185 1186

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

	return min(l->max_zone_append_sectors, l->max_sectors);
1187 1188
}

1189 1190 1191 1192 1193 1194
static inline unsigned int
bdev_max_zone_append_sectors(struct block_device *bdev)
{
	return queue_max_zone_append_sectors(bdev_get_queue(bdev));
}

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

1199 1200
	if (q && q->limits.logical_block_size)
		retval = q->limits.logical_block_size;
L
Linus Torvalds 已提交
1201 1202 1203 1204

	return retval;
}

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

1210
static inline unsigned int queue_physical_block_size(const struct request_queue *q)
1211 1212 1213 1214
{
	return q->limits.physical_block_size;
}

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

1220
static inline unsigned int queue_io_min(const struct request_queue *q)
1221 1222 1223 1224
{
	return q->limits.io_min;
}

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

1230
static inline unsigned int queue_io_opt(const struct request_queue *q)
1231 1232 1233 1234
{
	return q->limits.io_opt;
}

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

1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251
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));
}

1252
int bdev_alignment_offset(struct block_device *bdev);
1253
unsigned int bdev_discard_alignment(struct block_device *bdev);
1254

1255 1256 1257 1258 1259
static inline unsigned int bdev_max_discard_sectors(struct block_device *bdev)
{
	return bdev_get_queue(bdev)->limits.max_discard_sectors;
}

1260 1261 1262 1263 1264 1265 1266 1267 1268 1269
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;
}

1270 1271 1272 1273 1274
static inline bool bdev_nonrot(struct block_device *bdev)
{
	return blk_queue_nonrot(bdev_get_queue(bdev));
}

1275 1276 1277 1278 1279 1280
static inline bool bdev_stable_writes(struct block_device *bdev)
{
	return test_bit(QUEUE_FLAG_STABLE_WRITES,
			&bdev_get_queue(bdev)->queue_flags);
}

1281 1282 1283 1284 1285
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 已提交
1286 1287 1288 1289 1290
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 已提交
1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310
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;
}

1311
static inline sector_t bdev_zone_sectors(struct block_device *bdev)
1312 1313 1314 1315
{
	struct request_queue *q = bdev_get_queue(bdev);

	if (q)
1316
		return blk_queue_zone_sectors(q);
1317 1318
	return 0;
}
1319

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

1329 1330 1331 1332 1333 1334 1335 1336 1337
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;
}

1338
static inline int queue_dma_alignment(const struct request_queue *q)
L
Linus Torvalds 已提交
1339
{
1340
	return q ? q->dma_alignment : 511;
L
Linus Torvalds 已提交
1341 1342
}

1343
static inline int blk_rq_aligned(struct request_queue *q, unsigned long addr,
1344 1345 1346
				 unsigned int len)
{
	unsigned int alignment = queue_dma_alignment(q) | q->dma_pad_mask;
1347
	return !(addr & alignment) && !(len & alignment);
1348 1349
}

L
Linus Torvalds 已提交
1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360
/* 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;
}

1361
static inline unsigned int block_size(struct block_device *bdev)
L
Linus Torvalds 已提交
1362
{
1363
	return 1 << bdev->bd_inode->i_blkbits;
L
Linus Torvalds 已提交
1364 1365
}

1366
int kblockd_schedule_work(struct work_struct *work);
1367
int kblockd_mod_delayed_work_on(int cpu, struct delayed_work *dwork, unsigned long delay);
L
Linus Torvalds 已提交
1368 1369 1370 1371 1372 1373

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

1374 1375
#ifdef CONFIG_BLK_INLINE_ENCRYPTION

1376 1377
bool blk_crypto_register(struct blk_crypto_profile *profile,
			 struct request_queue *q);
1378 1379 1380

#else /* CONFIG_BLK_INLINE_ENCRYPTION */

1381 1382
static inline bool blk_crypto_register(struct blk_crypto_profile *profile,
				       struct request_queue *q)
1383 1384 1385 1386 1387 1388
{
	return true;
}

#endif /* CONFIG_BLK_INLINE_ENCRYPTION */

1389 1390 1391 1392 1393 1394 1395 1396
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
1397

1398
struct block_device_operations {
1399
	void (*submit_bio)(struct bio *bio);
1400 1401
	int (*poll_bio)(struct bio *bio, struct io_comp_batch *iob,
			unsigned int flags);
A
Al Viro 已提交
1402
	int (*open) (struct block_device *, fmode_t);
1403
	void (*release) (struct gendisk *, fmode_t);
1404
	int (*rw_page)(struct block_device *, sector_t, struct page *, unsigned int);
A
Al Viro 已提交
1405 1406
	int (*ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
	int (*compat_ioctl) (struct block_device *, fmode_t, unsigned, unsigned long);
1407 1408
	unsigned int (*check_events) (struct gendisk *disk,
				      unsigned int clearing);
1409
	void (*unlock_native_capacity) (struct gendisk *);
1410
	int (*getgeo)(struct block_device *, struct hd_geometry *);
1411
	int (*set_read_only)(struct block_device *bdev, bool ro);
1412
	void (*free_disk)(struct gendisk *disk);
1413 1414
	/* this callback is with swap_lock and sometimes page table lock held */
	void (*swap_slot_free_notify) (struct block_device *, unsigned long);
1415
	int (*report_zones)(struct gendisk *, sector_t sector,
C
Christoph Hellwig 已提交
1416
			unsigned int nr_zones, report_zones_cb cb, void *data);
1417
	char *(*devnode)(struct gendisk *disk, umode_t *mode);
1418 1419 1420
	/* 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);
1421
	struct module *owner;
1422
	const struct pr_ops *pr_ops;
1423 1424 1425 1426 1427 1428 1429

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

1432 1433 1434 1435 1436 1437 1438
#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

1439 1440 1441
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 *);
1442

J
Jens Axboe 已提交
1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455
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);
}

1456 1457 1458 1459 1460
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);

1461
void bio_start_io_acct_time(struct bio *bio, unsigned long start_time);
1462 1463 1464
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);
1465 1466 1467 1468

/**
 * bio_end_io_acct - end I/O accounting for bio based drivers
 * @bio:	bio to end account for
1469
 * @start_time:	start time returned by bio_start_io_acct()
1470 1471 1472
 */
static inline void bio_end_io_acct(struct bio *bio, unsigned long start_time)
{
1473
	return bio_end_io_acct_remapped(bio, start_time, bio->bi_bdev);
1474 1475
}

1476 1477 1478 1479
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 已提交
1480
int lookup_bdev(const char *pathname, dev_t *dev);
1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494

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);
1495 1496
int bd_prepare_to_claim(struct block_device *bdev, void *holder);
void bd_abort_claiming(struct block_device *bdev, void *holder);
1497 1498
void blkdev_put(struct block_device *bdev, fmode_t mode);

1499 1500 1501 1502 1503 1504
/* 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);
1505
struct block_device *I_BDEV(struct inode *inode);
1506 1507
int truncate_bdev_range(struct block_device *bdev, fmode_t mode, loff_t lstart,
		loff_t lend);
1508 1509 1510 1511

#ifdef CONFIG_BLOCK
void invalidate_bdev(struct block_device *bdev);
int sync_blockdev(struct block_device *bdev);
C
Christoph Hellwig 已提交
1512
int sync_blockdev_nowait(struct block_device *bdev);
1513
void sync_bdevs(bool wait);
C
Christoph Hellwig 已提交
1514
void printk_all_partitions(void);
1515 1516 1517 1518 1519 1520 1521 1522
#else
static inline void invalidate_bdev(struct block_device *bdev)
{
}
static inline int sync_blockdev(struct block_device *bdev)
{
	return 0;
}
C
Christoph Hellwig 已提交
1523 1524 1525 1526
static inline int sync_blockdev_nowait(struct block_device *bdev)
{
	return 0;
}
1527 1528 1529
static inline void sync_bdevs(bool wait)
{
}
C
Christoph Hellwig 已提交
1530 1531 1532 1533 1534
static inline void printk_all_partitions(void)
{
}
#endif /* CONFIG_BLOCK */

1535 1536
int fsync_bdev(struct block_device *bdev);

1537 1538
int freeze_bdev(struct block_device *bdev);
int thaw_bdev(struct block_device *bdev);
1539

1540 1541 1542 1543 1544 1545 1546 1547
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 = { }

1548
#endif /* _LINUX_BLKDEV_H */