Merge tag 'v4.1-rockchip-socfixes1' of git://git.kernel.org/pub/scm/linux/kernel...
[deliverable/linux.git] / drivers / target / target_core_rd.c
CommitLineData
c66ac9db
NB
1/*******************************************************************************
2 * Filename: target_core_rd.c
3 *
4 * This file contains the Storage Engine <-> Ramdisk transport
5 * specific functions.
6 *
4c76251e 7 * (c) Copyright 2003-2013 Datera, Inc.
c66ac9db
NB
8 *
9 * Nicholas A. Bellinger <nab@kernel.org>
10 *
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2 of the License, or
14 * (at your option) any later version.
15 *
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License
22 * along with this program; if not, write to the Free Software
23 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
24 *
25 ******************************************************************************/
26
c66ac9db
NB
27#include <linux/string.h>
28#include <linux/parser.h>
29#include <linux/timer.h>
c66ac9db
NB
30#include <linux/slab.h>
31#include <linux/spinlock.h>
c66ac9db
NB
32#include <scsi/scsi.h>
33#include <scsi/scsi_host.h>
34
35#include <target/target_core_base.h>
c4795fb2 36#include <target/target_core_backend.h>
03a62745 37#include <target/target_core_backend_configfs.h>
c66ac9db
NB
38
39#include "target_core_rd.h"
40
0fd97ccf
CH
41static inline struct rd_dev *RD_DEV(struct se_device *dev)
42{
43 return container_of(dev, struct rd_dev, dev);
44}
c66ac9db 45
c66ac9db
NB
46/* rd_attach_hba(): (Part of se_subsystem_api_t template)
47 *
48 *
49 */
50static int rd_attach_hba(struct se_hba *hba, u32 host_id)
51{
52 struct rd_host *rd_host;
53
54 rd_host = kzalloc(sizeof(struct rd_host), GFP_KERNEL);
6708bb27
AG
55 if (!rd_host) {
56 pr_err("Unable to allocate memory for struct rd_host\n");
c66ac9db
NB
57 return -ENOMEM;
58 }
59
60 rd_host->rd_host_id = host_id;
61
5951146d 62 hba->hba_ptr = rd_host;
c66ac9db 63
6708bb27 64 pr_debug("CORE_HBA[%d] - TCM Ramdisk HBA Driver %s on"
c66ac9db
NB
65 " Generic Target Core Stack %s\n", hba->hba_id,
66 RD_HBA_VERSION, TARGET_CORE_MOD_VERSION);
c66ac9db
NB
67
68 return 0;
69}
70
71static void rd_detach_hba(struct se_hba *hba)
72{
73 struct rd_host *rd_host = hba->hba_ptr;
74
6708bb27 75 pr_debug("CORE_HBA[%d] - Detached Ramdisk HBA: %u from"
c66ac9db
NB
76 " Generic Target Core\n", hba->hba_id, rd_host->rd_host_id);
77
78 kfree(rd_host);
79 hba->hba_ptr = NULL;
80}
81
4442dc8a
NB
82static u32 rd_release_sgl_table(struct rd_dev *rd_dev, struct rd_dev_sg_table *sg_table,
83 u32 sg_table_count)
c66ac9db 84{
c66ac9db
NB
85 struct page *pg;
86 struct scatterlist *sg;
4442dc8a 87 u32 i, j, page_count = 0, sg_per_table;
c66ac9db 88
4442dc8a 89 for (i = 0; i < sg_table_count; i++) {
c66ac9db
NB
90 sg = sg_table[i].sg_table;
91 sg_per_table = sg_table[i].rd_sg_count;
92
93 for (j = 0; j < sg_per_table; j++) {
94 pg = sg_page(&sg[j]);
6708bb27 95 if (pg) {
c66ac9db
NB
96 __free_page(pg);
97 page_count++;
98 }
99 }
c66ac9db
NB
100 kfree(sg);
101 }
102
4442dc8a
NB
103 kfree(sg_table);
104 return page_count;
105}
106
107static void rd_release_device_space(struct rd_dev *rd_dev)
108{
109 u32 page_count;
110
111 if (!rd_dev->sg_table_array || !rd_dev->sg_table_count)
112 return;
113
114 page_count = rd_release_sgl_table(rd_dev, rd_dev->sg_table_array,
115 rd_dev->sg_table_count);
116
6708bb27 117 pr_debug("CORE_RD[%u] - Released device space for Ramdisk"
c66ac9db
NB
118 " Device ID: %u, pages %u in %u tables total bytes %lu\n",
119 rd_dev->rd_host->rd_host_id, rd_dev->rd_dev_id, page_count,
120 rd_dev->sg_table_count, (unsigned long)page_count * PAGE_SIZE);
121
c66ac9db
NB
122 rd_dev->sg_table_array = NULL;
123 rd_dev->sg_table_count = 0;
124}
125
126
127/* rd_build_device_space():
128 *
129 *
130 */
4442dc8a
NB
131static int rd_allocate_sgl_table(struct rd_dev *rd_dev, struct rd_dev_sg_table *sg_table,
132 u32 total_sg_needed, unsigned char init_payload)
c66ac9db 133{
4442dc8a 134 u32 i = 0, j, page_offset = 0, sg_per_table;
c66ac9db
NB
135 u32 max_sg_per_table = (RD_MAX_ALLOCATION_SIZE /
136 sizeof(struct scatterlist));
c66ac9db
NB
137 struct page *pg;
138 struct scatterlist *sg;
4442dc8a 139 unsigned char *p;
c66ac9db
NB
140
141 while (total_sg_needed) {
bfd9a53e
AM
142 unsigned int chain_entry = 0;
143
c66ac9db
NB
144 sg_per_table = (total_sg_needed > max_sg_per_table) ?
145 max_sg_per_table : total_sg_needed;
146
bfd9a53e
AM
147#ifdef CONFIG_ARCH_HAS_SG_CHAIN
148
149 /*
150 * Reserve extra element for chain entry
151 */
152 if (sg_per_table < total_sg_needed)
153 chain_entry = 1;
154
155#endif /* CONFIG_ARCH_HAS_SG_CHAIN */
156
157 sg = kcalloc(sg_per_table + chain_entry, sizeof(*sg),
c66ac9db 158 GFP_KERNEL);
6708bb27
AG
159 if (!sg) {
160 pr_err("Unable to allocate scatterlist array"
c66ac9db 161 " for struct rd_dev\n");
065f9716 162 return -ENOMEM;
c66ac9db
NB
163 }
164
bfd9a53e
AM
165 sg_init_table(sg, sg_per_table + chain_entry);
166
167#ifdef CONFIG_ARCH_HAS_SG_CHAIN
168
169 if (i > 0) {
170 sg_chain(sg_table[i - 1].sg_table,
171 max_sg_per_table + 1, sg);
172 }
173
174#endif /* CONFIG_ARCH_HAS_SG_CHAIN */
c66ac9db
NB
175
176 sg_table[i].sg_table = sg;
177 sg_table[i].rd_sg_count = sg_per_table;
178 sg_table[i].page_start_offset = page_offset;
179 sg_table[i++].page_end_offset = (page_offset + sg_per_table)
180 - 1;
181
182 for (j = 0; j < sg_per_table; j++) {
183 pg = alloc_pages(GFP_KERNEL, 0);
6708bb27
AG
184 if (!pg) {
185 pr_err("Unable to allocate scatterlist"
c66ac9db 186 " pages for struct rd_dev_sg_table\n");
065f9716 187 return -ENOMEM;
c66ac9db
NB
188 }
189 sg_assign_page(&sg[j], pg);
190 sg[j].length = PAGE_SIZE;
4442dc8a
NB
191
192 p = kmap(pg);
193 memset(p, init_payload, PAGE_SIZE);
194 kunmap(pg);
c66ac9db
NB
195 }
196
197 page_offset += sg_per_table;
198 total_sg_needed -= sg_per_table;
199 }
200
4442dc8a
NB
201 return 0;
202}
203
204static int rd_build_device_space(struct rd_dev *rd_dev)
205{
206 struct rd_dev_sg_table *sg_table;
207 u32 sg_tables, total_sg_needed;
208 u32 max_sg_per_table = (RD_MAX_ALLOCATION_SIZE /
209 sizeof(struct scatterlist));
210 int rc;
211
212 if (rd_dev->rd_page_count <= 0) {
213 pr_err("Illegal page count: %u for Ramdisk device\n",
214 rd_dev->rd_page_count);
215 return -EINVAL;
216 }
217
218 /* Don't need backing pages for NULLIO */
219 if (rd_dev->rd_flags & RDF_NULLIO)
220 return 0;
221
222 total_sg_needed = rd_dev->rd_page_count;
223
224 sg_tables = (total_sg_needed / max_sg_per_table) + 1;
225
226 sg_table = kzalloc(sg_tables * sizeof(struct rd_dev_sg_table), GFP_KERNEL);
227 if (!sg_table) {
228 pr_err("Unable to allocate memory for Ramdisk"
229 " scatterlist tables\n");
230 return -ENOMEM;
231 }
232
233 rd_dev->sg_table_array = sg_table;
234 rd_dev->sg_table_count = sg_tables;
235
236 rc = rd_allocate_sgl_table(rd_dev, sg_table, total_sg_needed, 0x00);
237 if (rc)
238 return rc;
239
6708bb27 240 pr_debug("CORE_RD[%u] - Built Ramdisk Device ID: %u space of"
4442dc8a
NB
241 " %u pages in %u tables\n", rd_dev->rd_host->rd_host_id,
242 rd_dev->rd_dev_id, rd_dev->rd_page_count,
243 rd_dev->sg_table_count);
c66ac9db
NB
244
245 return 0;
246}
247
d7e8eb5d
NB
248static void rd_release_prot_space(struct rd_dev *rd_dev)
249{
250 u32 page_count;
251
252 if (!rd_dev->sg_prot_array || !rd_dev->sg_prot_count)
253 return;
254
255 page_count = rd_release_sgl_table(rd_dev, rd_dev->sg_prot_array,
256 rd_dev->sg_prot_count);
257
258 pr_debug("CORE_RD[%u] - Released protection space for Ramdisk"
259 " Device ID: %u, pages %u in %u tables total bytes %lu\n",
260 rd_dev->rd_host->rd_host_id, rd_dev->rd_dev_id, page_count,
261 rd_dev->sg_table_count, (unsigned long)page_count * PAGE_SIZE);
262
263 rd_dev->sg_prot_array = NULL;
264 rd_dev->sg_prot_count = 0;
265}
266
9d2e59f2 267static int rd_build_prot_space(struct rd_dev *rd_dev, int prot_length, int block_size)
d7e8eb5d
NB
268{
269 struct rd_dev_sg_table *sg_table;
270 u32 total_sg_needed, sg_tables;
271 u32 max_sg_per_table = (RD_MAX_ALLOCATION_SIZE /
272 sizeof(struct scatterlist));
273 int rc;
274
275 if (rd_dev->rd_flags & RDF_NULLIO)
276 return 0;
9d2e59f2
QT
277 /*
278 * prot_length=8byte dif data
279 * tot sg needed = rd_page_count * (PGSZ/block_size) *
280 * (prot_length/block_size) + pad
281 * PGSZ canceled each other.
282 */
283 total_sg_needed = (rd_dev->rd_page_count * prot_length / block_size) + 1;
d7e8eb5d
NB
284
285 sg_tables = (total_sg_needed / max_sg_per_table) + 1;
286
287 sg_table = kzalloc(sg_tables * sizeof(struct rd_dev_sg_table), GFP_KERNEL);
288 if (!sg_table) {
289 pr_err("Unable to allocate memory for Ramdisk protection"
290 " scatterlist tables\n");
291 return -ENOMEM;
292 }
293
294 rd_dev->sg_prot_array = sg_table;
295 rd_dev->sg_prot_count = sg_tables;
296
297 rc = rd_allocate_sgl_table(rd_dev, sg_table, total_sg_needed, 0xff);
298 if (rc)
299 return rc;
300
301 pr_debug("CORE_RD[%u] - Built Ramdisk Device ID: %u prot space of"
302 " %u pages in %u tables\n", rd_dev->rd_host->rd_host_id,
303 rd_dev->rd_dev_id, total_sg_needed, rd_dev->sg_prot_count);
304
305 return 0;
306}
307
0fd97ccf 308static struct se_device *rd_alloc_device(struct se_hba *hba, const char *name)
c66ac9db
NB
309{
310 struct rd_dev *rd_dev;
311 struct rd_host *rd_host = hba->hba_ptr;
312
313 rd_dev = kzalloc(sizeof(struct rd_dev), GFP_KERNEL);
6708bb27
AG
314 if (!rd_dev) {
315 pr_err("Unable to allocate memory for struct rd_dev\n");
c66ac9db
NB
316 return NULL;
317 }
318
319 rd_dev->rd_host = rd_host;
c66ac9db 320
0fd97ccf 321 return &rd_dev->dev;
c66ac9db
NB
322}
323
0fd97ccf 324static int rd_configure_device(struct se_device *dev)
c66ac9db 325{
0fd97ccf
CH
326 struct rd_dev *rd_dev = RD_DEV(dev);
327 struct rd_host *rd_host = dev->se_hba->hba_ptr;
328 int ret;
c66ac9db 329
0fd97ccf
CH
330 if (!(rd_dev->rd_flags & RDF_HAS_PAGE_COUNT)) {
331 pr_debug("Missing rd_pages= parameter\n");
332 return -EINVAL;
333 }
c66ac9db 334
065f9716
DC
335 ret = rd_build_device_space(rd_dev);
336 if (ret < 0)
c66ac9db
NB
337 goto fail;
338
0fd97ccf
CH
339 dev->dev_attrib.hw_block_size = RD_BLOCKSIZE;
340 dev->dev_attrib.hw_max_sectors = UINT_MAX;
341 dev->dev_attrib.hw_queue_depth = RD_MAX_DEVICE_QUEUE_DEPTH;
c66ac9db
NB
342
343 rd_dev->rd_dev_id = rd_host->rd_host_dev_id_count++;
c66ac9db 344
8feb58d0 345 pr_debug("CORE_RD[%u] - Added TCM MEMCPY Ramdisk Device ID: %u of"
c66ac9db 346 " %u pages in %u tables, %lu total bytes\n",
8feb58d0 347 rd_host->rd_host_id, rd_dev->rd_dev_id, rd_dev->rd_page_count,
c66ac9db
NB
348 rd_dev->sg_table_count,
349 (unsigned long)(rd_dev->rd_page_count * PAGE_SIZE));
350
0fd97ccf 351 return 0;
c66ac9db
NB
352
353fail:
354 rd_release_device_space(rd_dev);
0fd97ccf 355 return ret;
c66ac9db
NB
356}
357
0fd97ccf 358static void rd_free_device(struct se_device *dev)
c66ac9db 359{
0fd97ccf 360 struct rd_dev *rd_dev = RD_DEV(dev);
c66ac9db
NB
361
362 rd_release_device_space(rd_dev);
363 kfree(rd_dev);
364}
365
c66ac9db
NB
366static struct rd_dev_sg_table *rd_get_sg_table(struct rd_dev *rd_dev, u32 page)
367{
c66ac9db 368 struct rd_dev_sg_table *sg_table;
8f67835f
MS
369 u32 i, sg_per_table = (RD_MAX_ALLOCATION_SIZE /
370 sizeof(struct scatterlist));
c66ac9db 371
8f67835f
MS
372 i = page / sg_per_table;
373 if (i < rd_dev->sg_table_count) {
c66ac9db
NB
374 sg_table = &rd_dev->sg_table_array[i];
375 if ((sg_table->page_start_offset <= page) &&
376 (sg_table->page_end_offset >= page))
377 return sg_table;
378 }
379
6708bb27 380 pr_err("Unable to locate struct rd_dev_sg_table for page: %u\n",
c66ac9db
NB
381 page);
382
383 return NULL;
384}
385
6e611119
NB
386static struct rd_dev_sg_table *rd_get_prot_table(struct rd_dev *rd_dev, u32 page)
387{
388 struct rd_dev_sg_table *sg_table;
389 u32 i, sg_per_table = (RD_MAX_ALLOCATION_SIZE /
390 sizeof(struct scatterlist));
391
392 i = page / sg_per_table;
393 if (i < rd_dev->sg_prot_count) {
394 sg_table = &rd_dev->sg_prot_array[i];
395 if ((sg_table->page_start_offset <= page) &&
396 (sg_table->page_end_offset >= page))
397 return sg_table;
398 }
399
400 pr_err("Unable to locate struct prot rd_dev_sg_table for page: %u\n",
401 page);
402
403 return NULL;
404}
405
6766cc81
AM
406typedef sense_reason_t (*dif_verify)(struct se_cmd *, sector_t, unsigned int,
407 unsigned int, struct scatterlist *, int);
408
409static sense_reason_t rd_do_prot_rw(struct se_cmd *cmd, dif_verify dif_verify)
410{
411 struct se_device *se_dev = cmd->se_dev;
412 struct rd_dev *dev = RD_DEV(se_dev);
413 struct rd_dev_sg_table *prot_table;
bfd9a53e 414 bool need_to_release = false;
6766cc81
AM
415 struct scatterlist *prot_sg;
416 u32 sectors = cmd->data_length / se_dev->dev_attrib.block_size;
417 u32 prot_offset, prot_page;
bfd9a53e 418 u32 prot_npages __maybe_unused;
6766cc81 419 u64 tmp;
bfd9a53e 420 sense_reason_t rc = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE;
6766cc81
AM
421
422 tmp = cmd->t_task_lba * se_dev->prot_length;
423 prot_offset = do_div(tmp, PAGE_SIZE);
424 prot_page = tmp;
425
426 prot_table = rd_get_prot_table(dev, prot_page);
427 if (!prot_table)
428 return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE;
429
430 prot_sg = &prot_table->sg_table[prot_page -
431 prot_table->page_start_offset];
432
bfd9a53e
AM
433#ifndef CONFIG_ARCH_HAS_SG_CHAIN
434
435 prot_npages = DIV_ROUND_UP(prot_offset + sectors * se_dev->prot_length,
436 PAGE_SIZE);
437
438 /*
439 * Allocate temporaly contiguous scatterlist entries if prot pages
440 * straddles multiple scatterlist tables.
441 */
442 if (prot_table->page_end_offset < prot_page + prot_npages - 1) {
443 int i;
444
445 prot_sg = kcalloc(prot_npages, sizeof(*prot_sg), GFP_KERNEL);
446 if (!prot_sg)
447 return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE;
448
449 need_to_release = true;
450 sg_init_table(prot_sg, prot_npages);
451
452 for (i = 0; i < prot_npages; i++) {
453 if (prot_page + i > prot_table->page_end_offset) {
454 prot_table = rd_get_prot_table(dev,
455 prot_page + i);
456 if (!prot_table) {
457 kfree(prot_sg);
458 return rc;
459 }
460 sg_unmark_end(&prot_sg[i - 1]);
461 }
462 prot_sg[i] = prot_table->sg_table[prot_page + i -
463 prot_table->page_start_offset];
464 }
465 }
466
467#endif /* !CONFIG_ARCH_HAS_SG_CHAIN */
468
6766cc81 469 rc = dif_verify(cmd, cmd->t_task_lba, sectors, 0, prot_sg, prot_offset);
bfd9a53e
AM
470 if (need_to_release)
471 kfree(prot_sg);
6766cc81
AM
472
473 return rc;
474}
475
de103c93 476static sense_reason_t
a82a9538
NB
477rd_execute_rw(struct se_cmd *cmd, struct scatterlist *sgl, u32 sgl_nents,
478 enum dma_data_direction data_direction)
c66ac9db 479{
5787cacd 480 struct se_device *se_dev = cmd->se_dev;
0fd97ccf 481 struct rd_dev *dev = RD_DEV(se_dev);
c66ac9db 482 struct rd_dev_sg_table *table;
65b0c78d
SAS
483 struct scatterlist *rd_sg;
484 struct sg_mapping_iter m;
8feb58d0
CH
485 u32 rd_offset;
486 u32 rd_size;
487 u32 rd_page;
65b0c78d 488 u32 src_len;
8feb58d0 489 u64 tmp;
6e611119 490 sense_reason_t rc;
c66ac9db 491
52c07423
NB
492 if (dev->rd_flags & RDF_NULLIO) {
493 target_complete_cmd(cmd, SAM_STAT_GOOD);
494 return 0;
495 }
496
0fd97ccf 497 tmp = cmd->t_task_lba * se_dev->dev_attrib.block_size;
8feb58d0
CH
498 rd_offset = do_div(tmp, PAGE_SIZE);
499 rd_page = tmp;
5787cacd 500 rd_size = cmd->data_length;
8feb58d0
CH
501
502 table = rd_get_sg_table(dev, rd_page);
6708bb27 503 if (!table)
de103c93 504 return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE;
c66ac9db 505
8feb58d0 506 rd_sg = &table->sg_table[rd_page - table->page_start_offset];
6708bb27 507
65b0c78d 508 pr_debug("RD[%u]: %s LBA: %llu, Size: %u Page: %u, Offset: %u\n",
8feb58d0 509 dev->rd_dev_id,
5787cacd
CH
510 data_direction == DMA_FROM_DEVICE ? "Read" : "Write",
511 cmd->t_task_lba, rd_size, rd_page, rd_offset);
c66ac9db 512
1762742f
NB
513 if (cmd->prot_type && se_dev->dev_attrib.pi_prot_type &&
514 data_direction == DMA_TO_DEVICE) {
6766cc81 515 rc = rd_do_prot_rw(cmd, sbc_dif_verify_write);
6e611119
NB
516 if (rc)
517 return rc;
518 }
519
65b0c78d 520 src_len = PAGE_SIZE - rd_offset;
5787cacd
CH
521 sg_miter_start(&m, sgl, sgl_nents,
522 data_direction == DMA_FROM_DEVICE ?
8feb58d0
CH
523 SG_MITER_TO_SG : SG_MITER_FROM_SG);
524 while (rd_size) {
65b0c78d
SAS
525 u32 len;
526 void *rd_addr;
c66ac9db 527
65b0c78d 528 sg_miter_next(&m);
bbf344e5
HR
529 if (!(u32)m.length) {
530 pr_debug("RD[%u]: invalid sgl %p len %zu\n",
531 dev->rd_dev_id, m.addr, m.length);
532 sg_miter_stop(&m);
533 return TCM_INCORRECT_AMOUNT_OF_DATA;
534 }
65b0c78d 535 len = min((u32)m.length, src_len);
bbf344e5
HR
536 if (len > rd_size) {
537 pr_debug("RD[%u]: size underrun page %d offset %d "
538 "size %d\n", dev->rd_dev_id,
539 rd_page, rd_offset, rd_size);
540 len = rd_size;
541 }
65b0c78d 542 m.consumed = len;
c66ac9db 543
65b0c78d 544 rd_addr = sg_virt(rd_sg) + rd_offset;
6708bb27 545
5787cacd 546 if (data_direction == DMA_FROM_DEVICE)
65b0c78d
SAS
547 memcpy(m.addr, rd_addr, len);
548 else
549 memcpy(rd_addr, m.addr, len);
c66ac9db 550
8feb58d0
CH
551 rd_size -= len;
552 if (!rd_size)
c66ac9db
NB
553 continue;
554
65b0c78d
SAS
555 src_len -= len;
556 if (src_len) {
557 rd_offset += len;
c66ac9db
NB
558 continue;
559 }
6708bb27 560
65b0c78d 561 /* rd page completed, next one please */
8feb58d0 562 rd_page++;
65b0c78d
SAS
563 rd_offset = 0;
564 src_len = PAGE_SIZE;
8feb58d0 565 if (rd_page <= table->page_end_offset) {
65b0c78d 566 rd_sg++;
c66ac9db
NB
567 continue;
568 }
6708bb27 569
8feb58d0 570 table = rd_get_sg_table(dev, rd_page);
65b0c78d
SAS
571 if (!table) {
572 sg_miter_stop(&m);
de103c93 573 return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE;
65b0c78d 574 }
c66ac9db 575
65b0c78d
SAS
576 /* since we increment, the first sg entry is correct */
577 rd_sg = table->sg_table;
c66ac9db 578 }
65b0c78d 579 sg_miter_stop(&m);
c66ac9db 580
1762742f
NB
581 if (cmd->prot_type && se_dev->dev_attrib.pi_prot_type &&
582 data_direction == DMA_FROM_DEVICE) {
6766cc81 583 rc = rd_do_prot_rw(cmd, sbc_dif_verify_read);
6e611119
NB
584 if (rc)
585 return rc;
586 }
587
5787cacd 588 target_complete_cmd(cmd, SAM_STAT_GOOD);
03e98c9e 589 return 0;
c66ac9db
NB
590}
591
c66ac9db 592enum {
52c07423 593 Opt_rd_pages, Opt_rd_nullio, Opt_err
c66ac9db
NB
594};
595
596static match_table_t tokens = {
597 {Opt_rd_pages, "rd_pages=%d"},
52c07423 598 {Opt_rd_nullio, "rd_nullio=%d"},
c66ac9db
NB
599 {Opt_err, NULL}
600};
601
0fd97ccf
CH
602static ssize_t rd_set_configfs_dev_params(struct se_device *dev,
603 const char *page, ssize_t count)
c66ac9db 604{
0fd97ccf 605 struct rd_dev *rd_dev = RD_DEV(dev);
c66ac9db
NB
606 char *orig, *ptr, *opts;
607 substring_t args[MAX_OPT_ARGS];
608 int ret = 0, arg, token;
609
610 opts = kstrdup(page, GFP_KERNEL);
611 if (!opts)
612 return -ENOMEM;
613
614 orig = opts;
615
90c161b6 616 while ((ptr = strsep(&opts, ",\n")) != NULL) {
c66ac9db
NB
617 if (!*ptr)
618 continue;
619
620 token = match_token(ptr, tokens, args);
621 switch (token) {
622 case Opt_rd_pages:
623 match_int(args, &arg);
624 rd_dev->rd_page_count = arg;
6708bb27 625 pr_debug("RAMDISK: Referencing Page"
c66ac9db
NB
626 " Count: %u\n", rd_dev->rd_page_count);
627 rd_dev->rd_flags |= RDF_HAS_PAGE_COUNT;
628 break;
52c07423
NB
629 case Opt_rd_nullio:
630 match_int(args, &arg);
631 if (arg != 1)
632 break;
633
634 pr_debug("RAMDISK: Setting NULLIO flag: %d\n", arg);
635 rd_dev->rd_flags |= RDF_NULLIO;
636 break;
c66ac9db
NB
637 default:
638 break;
639 }
640 }
641
642 kfree(orig);
643 return (!ret) ? count : ret;
644}
645
0fd97ccf 646static ssize_t rd_show_configfs_dev_params(struct se_device *dev, char *b)
c66ac9db 647{
0fd97ccf 648 struct rd_dev *rd_dev = RD_DEV(dev);
c66ac9db 649
8feb58d0
CH
650 ssize_t bl = sprintf(b, "TCM RamDisk ID: %u RamDisk Makeup: rd_mcp\n",
651 rd_dev->rd_dev_id);
c66ac9db 652 bl += sprintf(b + bl, " PAGES/PAGE_SIZE: %u*%lu"
52c07423
NB
653 " SG_table_count: %u nullio: %d\n", rd_dev->rd_page_count,
654 PAGE_SIZE, rd_dev->sg_table_count,
655 !!(rd_dev->rd_flags & RDF_NULLIO));
c66ac9db
NB
656 return bl;
657}
658
c66ac9db
NB
659static sector_t rd_get_blocks(struct se_device *dev)
660{
0fd97ccf
CH
661 struct rd_dev *rd_dev = RD_DEV(dev);
662
c66ac9db 663 unsigned long long blocks_long = ((rd_dev->rd_page_count * PAGE_SIZE) /
0fd97ccf 664 dev->dev_attrib.block_size) - 1;
c66ac9db
NB
665
666 return blocks_long;
667}
668
d7e8eb5d
NB
669static int rd_init_prot(struct se_device *dev)
670{
671 struct rd_dev *rd_dev = RD_DEV(dev);
672
673 if (!dev->dev_attrib.pi_prot_type)
674 return 0;
675
9d2e59f2
QT
676 return rd_build_prot_space(rd_dev, dev->prot_length,
677 dev->dev_attrib.block_size);
d7e8eb5d
NB
678}
679
680static void rd_free_prot(struct se_device *dev)
681{
682 struct rd_dev *rd_dev = RD_DEV(dev);
683
684 rd_release_prot_space(rd_dev);
685}
686
9e999a6c 687static struct sbc_ops rd_sbc_ops = {
0c2ad7d1
CH
688 .execute_rw = rd_execute_rw,
689};
690
de103c93
CH
691static sense_reason_t
692rd_parse_cdb(struct se_cmd *cmd)
0c2ad7d1 693{
9e999a6c 694 return sbc_parse_cdb(cmd, &rd_sbc_ops);
0c2ad7d1
CH
695}
696
03a62745
NB
697DEF_TB_DEFAULT_ATTRIBS(rd_mcp);
698
699static struct configfs_attribute *rd_mcp_backend_dev_attrs[] = {
700 &rd_mcp_dev_attrib_emulate_model_alias.attr,
701 &rd_mcp_dev_attrib_emulate_dpo.attr,
702 &rd_mcp_dev_attrib_emulate_fua_write.attr,
703 &rd_mcp_dev_attrib_emulate_fua_read.attr,
704 &rd_mcp_dev_attrib_emulate_write_cache.attr,
705 &rd_mcp_dev_attrib_emulate_ua_intlck_ctrl.attr,
706 &rd_mcp_dev_attrib_emulate_tas.attr,
707 &rd_mcp_dev_attrib_emulate_tpu.attr,
708 &rd_mcp_dev_attrib_emulate_tpws.attr,
709 &rd_mcp_dev_attrib_emulate_caw.attr,
710 &rd_mcp_dev_attrib_emulate_3pc.attr,
711 &rd_mcp_dev_attrib_pi_prot_type.attr,
712 &rd_mcp_dev_attrib_hw_pi_prot_type.attr,
713 &rd_mcp_dev_attrib_pi_prot_format.attr,
714 &rd_mcp_dev_attrib_enforce_pr_isids.attr,
715 &rd_mcp_dev_attrib_is_nonrot.attr,
716 &rd_mcp_dev_attrib_emulate_rest_reord.attr,
717 &rd_mcp_dev_attrib_force_pr_aptpl.attr,
718 &rd_mcp_dev_attrib_hw_block_size.attr,
719 &rd_mcp_dev_attrib_block_size.attr,
720 &rd_mcp_dev_attrib_hw_max_sectors.attr,
03a62745
NB
721 &rd_mcp_dev_attrib_optimal_sectors.attr,
722 &rd_mcp_dev_attrib_hw_queue_depth.attr,
723 &rd_mcp_dev_attrib_queue_depth.attr,
724 &rd_mcp_dev_attrib_max_unmap_lba_count.attr,
725 &rd_mcp_dev_attrib_max_unmap_block_desc_count.attr,
726 &rd_mcp_dev_attrib_unmap_granularity.attr,
727 &rd_mcp_dev_attrib_unmap_granularity_alignment.attr,
728 &rd_mcp_dev_attrib_max_write_same_len.attr,
729 NULL,
730};
731
c66ac9db
NB
732static struct se_subsystem_api rd_mcp_template = {
733 .name = "rd_mcp",
0fd97ccf
CH
734 .inquiry_prod = "RAMDISK-MCP",
735 .inquiry_rev = RD_MCP_VERSION,
c66ac9db
NB
736 .transport_type = TRANSPORT_PLUGIN_VHBA_VDEV,
737 .attach_hba = rd_attach_hba,
738 .detach_hba = rd_detach_hba,
0fd97ccf
CH
739 .alloc_device = rd_alloc_device,
740 .configure_device = rd_configure_device,
c66ac9db 741 .free_device = rd_free_device,
0c2ad7d1 742 .parse_cdb = rd_parse_cdb,
c66ac9db
NB
743 .set_configfs_dev_params = rd_set_configfs_dev_params,
744 .show_configfs_dev_params = rd_show_configfs_dev_params,
6f23ac8a 745 .get_device_type = sbc_get_device_type,
c66ac9db 746 .get_blocks = rd_get_blocks,
d7e8eb5d
NB
747 .init_prot = rd_init_prot,
748 .free_prot = rd_free_prot,
c66ac9db
NB
749};
750
751int __init rd_module_init(void)
752{
03a62745 753 struct target_backend_cits *tbc = &rd_mcp_template.tb_cits;
c66ac9db
NB
754 int ret;
755
03a62745
NB
756 target_core_setup_sub_cits(&rd_mcp_template);
757 tbc->tb_dev_attrib_cit.ct_attrs = rd_mcp_backend_dev_attrs;
758
c66ac9db
NB
759 ret = transport_subsystem_register(&rd_mcp_template);
760 if (ret < 0) {
c66ac9db
NB
761 return ret;
762 }
763
764 return 0;
765}
766
767void rd_module_exit(void)
768{
c66ac9db
NB
769 transport_subsystem_release(&rd_mcp_template);
770}
This page took 0.295356 seconds and 5 git commands to generate.