123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143 |
- /*
- * Internal header file _only_ for device mapper core
- *
- * Copyright (C) 2016 Red Hat, Inc. All rights reserved.
- *
- * This file is released under the LGPL.
- */
- #ifndef DM_CORE_INTERNAL_H
- #define DM_CORE_INTERNAL_H
- #include <linux/kthread.h>
- #include <linux/ktime.h>
- #include <linux/blk-mq.h>
- #include <trace/events/block.h>
- #include "dm.h"
- #define DM_RESERVED_MAX_IOS 1024
- struct dm_kobject_holder {
- struct kobject kobj;
- struct completion completion;
- };
- /*
- * DM core internal structure that used directly by dm.c and dm-rq.c
- * DM targets must _not_ deference a mapped_device to directly access its members!
- */
- struct mapped_device {
- struct mutex suspend_lock;
- struct mutex table_devices_lock;
- struct list_head table_devices;
- /*
- * The current mapping (struct dm_table *).
- * Use dm_get_live_table{_fast} or take suspend_lock for
- * dereference.
- */
- void __rcu *map;
- unsigned long flags;
- /* Protect queue and type against concurrent access. */
- struct mutex type_lock;
- enum dm_queue_mode type;
- int numa_node_id;
- struct request_queue *queue;
- atomic_t holders;
- atomic_t open_count;
- struct dm_target *immutable_target;
- struct target_type *immutable_target_type;
- char name[16];
- struct gendisk *disk;
- struct dax_device *dax_dev;
- /*
- * A list of ios that arrived while we were suspended.
- */
- struct work_struct work;
- wait_queue_head_t wait;
- spinlock_t deferred_lock;
- struct bio_list deferred;
- void *interface_ptr;
- /*
- * Event handling.
- */
- wait_queue_head_t eventq;
- atomic_t event_nr;
- atomic_t uevent_seq;
- struct list_head uevent_list;
- spinlock_t uevent_lock; /* Protect access to uevent_list */
- /* the number of internal suspends */
- unsigned internal_suspend_count;
- /*
- * io objects are allocated from here.
- */
- struct bio_set io_bs;
- struct bio_set bs;
- /*
- * Processing queue (flush)
- */
- struct workqueue_struct *wq;
- /*
- * freeze/thaw support require holding onto a super block
- */
- struct super_block *frozen_sb;
- /* forced geometry settings */
- struct hd_geometry geometry;
- /* kobject and completion */
- struct dm_kobject_holder kobj_holder;
- struct block_device *bdev;
- int swap_bios;
- struct semaphore swap_bios_semaphore;
- struct mutex swap_bios_lock;
- struct dm_stats stats;
- /* for blk-mq request-based DM support */
- struct blk_mq_tag_set *tag_set;
- bool init_tio_pdu:1;
- struct srcu_struct io_barrier;
- };
- void disable_discard(struct mapped_device *md);
- void disable_write_same(struct mapped_device *md);
- void disable_write_zeroes(struct mapped_device *md);
- static inline struct completion *dm_get_completion_from_kobject(struct kobject *kobj)
- {
- return &container_of(kobj, struct dm_kobject_holder, kobj)->completion;
- }
- unsigned __dm_get_module_param(unsigned *module_param, unsigned def, unsigned max);
- static inline bool dm_message_test_buffer_overflow(char *result, unsigned maxlen)
- {
- return !maxlen || strlen(result) + 1 >= maxlen;
- }
- extern atomic_t dm_global_event_nr;
- extern wait_queue_head_t dm_global_eventq;
- void dm_issue_global_event(void);
- #endif
|