aoe.h

  1/* Copyright (c) 2013 Coraid, Inc.  See COPYING for GPL terms. */
  2#include <linux/blk-mq.h>
  3
  4#define VERSION "85"
  5#define AOE_MAJOR 152
  6#define DEVICE_NAME "aoe"
  7
  8/* set AOE_PARTITIONS to 1 to use whole-disks only
  9 * default is 16, which is 15 partitions plus the whole disk
 10 */
 11#ifndef AOE_PARTITIONS
 12#define AOE_PARTITIONS (16)
 13#endif
 14
 15#define WHITESPACE " \t\v\f\n,"
 16
 17enum {
 18	AOECMD_ATA,
 19	AOECMD_CFG,
 20	AOECMD_VEND_MIN = 0xf0,
 21
 22	AOEFL_RSP = (1<<3),
 23	AOEFL_ERR = (1<<2),
 24
 25	AOEAFL_EXT = (1<<6),
 26	AOEAFL_DEV = (1<<4),
 27	AOEAFL_ASYNC = (1<<1),
 28	AOEAFL_WRITE = (1<<0),
 29
 30	AOECCMD_READ = 0,
 31	AOECCMD_TEST,
 32	AOECCMD_PTEST,
 33	AOECCMD_SET,
 34	AOECCMD_FSET,
 35
 36	AOE_HVER = 0x10,
 37};
 38
 39struct aoe_hdr {
 40	unsigned char dst[6];
 41	unsigned char src[6];
 42	__be16 type;
 43	unsigned char verfl;
 44	unsigned char err;
 45	__be16 major;
 46	unsigned char minor;
 47	unsigned char cmd;
 48	__be32 tag;
 49};
 50
 51struct aoe_atahdr {
 52	unsigned char aflags;
 53	unsigned char errfeat;
 54	unsigned char scnt;
 55	unsigned char cmdstat;
 56	unsigned char lba0;
 57	unsigned char lba1;
 58	unsigned char lba2;
 59	unsigned char lba3;
 60	unsigned char lba4;
 61	unsigned char lba5;
 62	unsigned char res[2];
 63};
 64
 65struct aoe_cfghdr {
 66	__be16 bufcnt;
 67	__be16 fwver;
 68	unsigned char scnt;
 69	unsigned char aoeccmd;
 70	unsigned char cslen[2];
 71};
 72
 73enum {
 74	DEVFL_UP = 1,	/* device is installed in system and ready for AoE->ATA commands */
 75	DEVFL_TKILL = (1<<1),	/* flag for timer to know when to kill self */
 76	DEVFL_EXT = (1<<2),	/* device accepts lba48 commands */
 77	DEVFL_GDALLOC = (1<<3),	/* need to alloc gendisk */
 78	DEVFL_GD_NOW = (1<<4),	/* allocating gendisk */
 79	DEVFL_KICKME = (1<<5),	/* slow polling network card catch */
 80	DEVFL_NEWSIZE = (1<<6),	/* need to update dev size in block layer */
 81	DEVFL_FREEING = (1<<7),	/* set when device is being cleaned up */
 82	DEVFL_FREED = (1<<8),	/* device has been cleaned up */
 83	DEVFL_DEAD = (1<<9),	/* device has timed out of aoe_deadsecs */
 84};
 85
 86enum {
 87	DEFAULTBCNT = 2 * 512,	/* 2 sectors */
 88	MIN_BUFS = 16,
 89	NTARGETS = 4,
 90	NAOEIFS = 8,
 91	NSKBPOOLMAX = 256,
 92	NFACTIVE = 61,
 93
 94	TIMERTICK = HZ / 10,
 95	RTTSCALE = 8,
 96	RTTDSCALE = 3,
 97	RTTAVG_INIT = USEC_PER_SEC / 4 << RTTSCALE,
 98	RTTDEV_INIT = RTTAVG_INIT / 4,
 99
100	HARD_SCORN_SECS = 10,	/* try another remote port after this */
101	MAX_TAINT = 1000,	/* cap on aoetgt taint */
102};
103
104struct aoe_req {
105	unsigned long nr_bios;
106};
107
108struct buf {
109	ulong nframesout;
110	struct bio *bio;
111	struct bvec_iter iter;
112	struct request *rq;
113};
114
115enum frame_flags {
116	FFL_PROBE = 1,
117};
118
119struct frame {
120	struct list_head head;
121	u32 tag;
122	ktime_t sent;			/* high-res time packet was sent */
123	ulong waited;
124	ulong waited_total;
125	struct aoetgt *t;		/* parent target I belong to */
126	struct sk_buff *skb;		/* command skb freed on module exit */
127	struct sk_buff *r_skb;		/* response skb for async processing */
128	struct buf *buf;
129	struct bvec_iter iter;
130	char flags;
131};
132
133struct aoeif {
134	struct net_device *nd;
135	ulong lost;
136	int bcnt;
137};
138
139struct aoetgt {
140	unsigned char addr[6];
141	ushort nframes;		/* cap on frames to use */
142	struct aoedev *d;			/* parent device I belong to */
143	struct list_head ffree;			/* list of free frames */
144	struct aoeif ifs[NAOEIFS];
145	struct aoeif *ifp;	/* current aoeif in use */
146	ushort nout;		/* number of AoE commands outstanding */
147	ushort maxout;		/* current value for max outstanding */
148	ushort next_cwnd;	/* incr maxout after decrementing to zero */
149	ushort ssthresh;	/* slow start threshold */
150	ulong falloc;		/* number of allocated frames */
151	int taint;		/* how much we want to avoid this aoetgt */
152	int minbcnt;
153	int wpkts, rpkts;
154	char nout_probes;
155};
156
157struct aoedev {
158	struct aoedev *next;
159	ulong sysminor;
160	ulong aoemajor;
161	u32 rttavg;		/* scaled AoE round trip time average */
162	u32 rttdev;		/* scaled round trip time mean deviation */
163	u16 aoeminor;
164	u16 flags;
165	u16 nopen;		/* (bd_openers isn't available without sleeping) */
166	u16 fw_ver;		/* version of blade's firmware */
167	u16 lasttag;		/* last tag sent */
168	u16 useme;
169	ulong ref;
170	struct work_struct work;/* disk create work struct */
171	struct gendisk *gd;
172	struct dentry *debugfs;
173	struct request_queue *blkq;
174	struct list_head rq_list;
175	struct blk_mq_tag_set tag_set;
176	struct hd_geometry geo;
177	sector_t ssize;
178	struct timer_list timer;
179	spinlock_t lock;
180	struct sk_buff_head skbpool;
181	mempool_t *bufpool;	/* for deadlock-free Buf allocation */
182	struct {		/* pointers to work in progress */
183		struct buf *buf;
184		struct bio *nxbio;
185		struct request *rq;
186	} ip;
187	ulong maxbcnt;
188	struct list_head factive[NFACTIVE];	/* hash of active frames */
189	struct list_head rexmitq; /* deferred retransmissions */
190	struct aoetgt **targets;
191	ulong ntargets;		/* number of allocated aoetgt pointers */
192	struct aoetgt **tgt;	/* target in use when working */
193	ulong kicked;
194	char ident[512];
195};
196
197/* kthread tracking */
198struct ktstate {
199	struct completion rendez;
200	struct task_struct *task;
201	wait_queue_head_t *waitq;
202	int (*fn) (int);
203	char name[12];
204	spinlock_t *lock;
205	int id;
206	int active;
207};
208
209int aoeblk_init(void);
210void aoeblk_exit(void);
211void aoeblk_gdalloc(void *);
212void aoedisk_rm_debugfs(struct aoedev *d);
213
214int aoechr_init(void);
215void aoechr_exit(void);
216void aoechr_error(char *);
217
218void aoecmd_work(struct aoedev *d);
219void aoecmd_cfg(ushort aoemajor, unsigned char aoeminor);
220struct sk_buff *aoecmd_ata_rsp(struct sk_buff *);
221void aoecmd_cfg_rsp(struct sk_buff *);
222void aoecmd_sleepwork(struct work_struct *);
223void aoecmd_wreset(struct aoetgt *t);
224void aoecmd_cleanslate(struct aoedev *);
225void aoecmd_exit(void);
226int aoecmd_init(void);
227struct sk_buff *aoecmd_ata_id(struct aoedev *);
228void aoe_freetframe(struct frame *);
229void aoe_flush_iocq(void);
230void aoe_flush_iocq_by_index(int);
231void aoe_end_request(struct aoedev *, struct request *, int);
232int aoe_ktstart(struct ktstate *k);
233void aoe_ktstop(struct ktstate *k);
234
235int aoedev_init(void);
236void aoedev_exit(void);
237struct aoedev *aoedev_by_aoeaddr(ulong maj, int min, int do_alloc);
238void aoedev_downdev(struct aoedev *d);
239int aoedev_flush(const char __user *str, size_t size);
240void aoe_failbuf(struct aoedev *, struct buf *);
241void aoedev_put(struct aoedev *);
242
243int aoenet_init(void);
244void aoenet_exit(void);
245void aoenet_xmit(struct sk_buff_head *);
246int is_aoe_netif(struct net_device *ifp);
247int set_aoe_iflist(const char __user *str, size_t size);
248
249extern struct workqueue_struct *aoe_wq;