Lines Matching defs:channel
890 struct spdk_io_channel *channel;
906 channel = spdk_bs_alloc_io_channel(bs);
907 bs_channel = spdk_io_channel_get_ctx(channel);
931 spdk_blob_io_write(blob, channel, payload_write, 0, num_of_pages, blob_op_complete, NULL);
949 spdk_blob_io_read(blob, channel, payload_read, 0, num_of_pages, blob_op_complete, NULL);
954 spdk_bs_free_io_channel(channel);
1085 struct spdk_io_channel *channel;
1088 channel = spdk_bs_alloc_io_channel(bs);
1089 SPDK_CU_ASSERT_FATAL(channel != NULL);
1106 spdk_bs_blob_decouple_parent(bs, channel, blobid, blob_op_complete, NULL);
1111 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
1145 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
1153 spdk_bs_blob_decouple_parent(bs, channel, blobid, blob_op_complete, NULL);
1169 spdk_bs_free_io_channel(channel);
1424 struct spdk_io_channel *channel;
1426 channel = spdk_bs_alloc_io_channel(bs);
1427 CU_ASSERT(channel != NULL);
1429 spdk_bs_free_io_channel(channel);
1438 struct spdk_io_channel *channel;
1444 channel = spdk_bs_alloc_io_channel(bs);
1445 CU_ASSERT(channel != NULL);
1448 spdk_blob_io_write(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1459 spdk_blob_io_write(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1465 spdk_blob_io_write(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1470 spdk_blob_io_write(blob, channel, payload, 5 * io_units_per_cluster, 1, blob_op_complete,
1476 spdk_blob_io_write(blob, channel, payload, 4 * io_units_per_cluster, io_units_per_cluster + 1,
1481 spdk_bs_free_io_channel(channel);
1490 struct spdk_io_channel *channel;
1496 channel = spdk_bs_alloc_io_channel(bs);
1497 CU_ASSERT(channel != NULL);
1500 spdk_blob_io_read(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1511 spdk_blob_io_read(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1517 spdk_blob_io_read(blob, channel, payload, 0, 1, blob_op_complete, NULL);
1522 spdk_blob_io_read(blob, channel, payload, 5 * io_units_per_cluster, 1, blob_op_complete,
1528 spdk_blob_io_read(blob, channel, payload, 4 * io_units_per_cluster, io_units_per_cluster + 1,
1533 spdk_bs_free_io_channel(channel);
1542 struct spdk_io_channel *channel;
1546 channel = spdk_bs_alloc_io_channel(bs);
1547 CU_ASSERT(channel != NULL);
1554 spdk_blob_io_write(blob, channel, payload_write, 4, 10, blob_op_complete, NULL);
1559 spdk_blob_io_read(blob, channel, payload_read, 4, 10, blob_op_complete, NULL);
1564 spdk_bs_free_io_channel(channel);
1573 struct spdk_io_channel *channel;
1581 channel = spdk_bs_alloc_io_channel(bs);
1582 CU_ASSERT(channel != NULL);
1611 spdk_blob_io_writev(blob, channel, iov_write, 3, 250, 10, blob_op_complete, NULL);
1622 spdk_blob_io_readv(blob, channel, iov_read, 3, 250, 10, blob_op_complete, NULL);
1638 spdk_bs_free_io_channel(channel);
1645 struct spdk_bs_channel *channel = spdk_io_channel_get_ctx(_channel);
1649 TAILQ_FOREACH(set, &channel->reqs, link) {
1661 struct spdk_io_channel *channel;
1666 channel = spdk_bs_alloc_io_channel(bs);
1667 CU_ASSERT(channel != NULL);
1684 req_count = bs_channel_get_req_count(channel);
1685 spdk_blob_io_writev(blob, channel, iov_write, 3, 250, 10, blob_op_complete, NULL);
1688 CU_ASSERT(req_count == bs_channel_get_req_count(channel));
1691 spdk_bs_free_io_channel(channel);
1700 struct spdk_io_channel *channel;
1706 channel = spdk_bs_alloc_io_channel(bs);
1707 CU_ASSERT(channel != NULL);
1717 spdk_blob_io_writev(blob, channel, &iov_write, 1, 0, 1, blob_op_complete, NULL);
1724 spdk_blob_io_readv(blob, channel, &iov_read, 1, 0, 1, blob_op_complete, NULL);
1728 spdk_bs_free_io_channel(channel);
1733 _blob_io_read_no_split(struct spdk_blob *blob, struct spdk_io_channel *channel,
1744 spdk_blob_io_read(blob, channel, buf, i + offset, 1, blob_op_complete, NULL);
1757 _blob_io_write_no_split(struct spdk_blob *blob, struct spdk_io_channel *channel,
1768 spdk_blob_io_write(blob, channel, buf, i + offset, 1, blob_op_complete, NULL);
1785 struct spdk_io_channel *channel;
1821 channel = spdk_bs_alloc_io_channel(bs);
1822 SPDK_CU_ASSERT_FATAL(channel != NULL);
1834 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete, NULL);
1840 spdk_blob_io_write(blob, channel, payload_pattern, 0, io_units_per_payload - 1,
1846 spdk_blob_io_write(blob, channel, payload_pattern, io_units_per_payload - 1, 1,
1853 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete, NULL);
1860 spdk_blob_io_write(blob, channel, payload_pattern, 1, io_units_per_payload - 1,
1866 spdk_blob_io_write(blob, channel, payload_pattern, 0, 1,
1873 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete, NULL);
1883 _blob_io_write_no_split(blob, channel, payload_pattern, 0, io_units_per_payload,
1889 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete, NULL);
1896 spdk_blob_io_write(blob, channel, payload_pattern, 0, io_units_per_payload,
1902 _blob_io_read_no_split(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete,
1908 spdk_bs_free_io_channel(channel);
1926 struct spdk_io_channel *channel;
1970 channel = spdk_bs_alloc_io_channel(bs);
1971 SPDK_CU_ASSERT_FATAL(channel != NULL);
1987 spdk_blob_io_readv(blob, channel, iov_read, 2, 0, io_units_per_payload, blob_op_complete, NULL);
1998 spdk_blob_io_writev(blob, channel, iov_write, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2008 spdk_blob_io_readv(blob, channel, iov_read, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2020 spdk_blob_io_writev(blob, channel, iov_write, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2030 spdk_blob_io_readv(blob, channel, iov_read, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2040 _blob_io_write_no_split(blob, channel, payload_pattern, 0, io_units_per_payload,
2050 spdk_blob_io_readv(blob, channel, iov_read, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2060 spdk_blob_io_writev(blob, channel, iov_write, 2, 0, io_units_per_payload, blob_op_complete, NULL);
2065 _blob_io_read_no_split(blob, channel, payload_read, 0, io_units_per_payload, blob_op_complete,
2071 spdk_bs_free_io_channel(channel);
2089 struct spdk_io_channel *channel;
2095 channel = spdk_bs_alloc_io_channel(bs);
2096 CU_ASSERT(channel != NULL);
2121 spdk_blob_io_read(blob, channel, &payload, i * SPDK_BLOB_OPTS_CLUSTER_SZ / BLOCKLEN, 1,
2162 spdk_bs_free_io_channel(channel);
4504 struct spdk_io_channel *channel, *channel_thread1;
4517 channel = spdk_bs_alloc_io_channel(bs);
4518 CU_ASSERT(channel != NULL);
4551 spdk_blob_io_read(blob, channel, payload_read, 4, 10, blob_op_complete, NULL);
4570 spdk_blob_io_write(blob, channel, payload_write, 4, 10, blob_op_complete, NULL);
4586 spdk_blob_io_read(blob, channel, payload_read, 4, 10, blob_op_complete, NULL);
4597 spdk_bs_free_io_channel(channel);
5010 struct spdk_io_channel *channel;
5036 channel = spdk_bs_alloc_io_channel(bs);
5037 CU_ASSERT(channel != NULL);
5044 spdk_blob_io_read(blob, channel, payload_read, io_unit, 10, blob_op_complete, NULL);
5054 spdk_blob_io_write(blob, channel, payload_write, io_unit, 10, blob_op_complete, NULL);
5068 spdk_blob_io_read(blob, channel, payload_read, io_unit, 10, blob_op_complete, NULL);
5073 spdk_bs_free_io_channel(channel);
5088 channel = spdk_bs_alloc_io_channel(bs);
5089 CU_ASSERT(channel != NULL);
5092 spdk_blob_io_read(blob, channel, payload_read, io_unit, 10, blob_op_complete, NULL);
5097 spdk_bs_free_io_channel(channel);
5109 struct spdk_io_channel *channel;
5119 channel = spdk_bs_alloc_io_channel(bs);
5120 CU_ASSERT(channel != NULL);
5152 spdk_blob_io_readv(blob, channel, iov_read, 3, 250, 10, blob_op_complete, NULL);
5165 spdk_blob_io_writev(blob, channel, iov_write, 3, 250, 10, blob_op_complete, NULL);
5176 spdk_blob_io_readv(blob, channel, iov_read, 3, 250, 10, blob_op_complete, NULL);
5181 spdk_bs_free_io_channel(channel);
5289 struct spdk_io_channel *channel;
5309 channel = spdk_bs_alloc_io_channel(bs);
5310 CU_ASSERT(channel != NULL);
5323 spdk_blob_io_read(blob, channel, payload_read, 4, 10, blob_op_complete, NULL);
5329 spdk_blob_io_write(blob, channel, payload_write, 4, 10, blob_op_complete, NULL);
5356 spdk_blob_io_write(blob, channel, payload_write, 4, 10, blob_op_complete, NULL);
5380 spdk_blob_io_read(blob, channel, payload_read, 4, 10, blob_op_complete, NULL);
5387 spdk_blob_io_read(snapshot, channel, payload_read, 4, 10, blob_op_complete, NULL);
5395 spdk_bs_free_io_channel(channel);
5407 struct spdk_io_channel *channel;
5418 channel = spdk_bs_alloc_io_channel(bs);
5419 CU_ASSERT(channel != NULL);
5455 spdk_blob_io_readv(blob, channel, iov_read, 3, 250, 10, blob_op_complete, NULL);
5468 spdk_blob_io_writev(blob, channel, iov_write, 3, 250, 10, blob_op_complete, NULL);
5479 spdk_blob_io_readv(blob, channel, iov_read, 3, 250, 10, blob_op_complete, NULL);
5484 spdk_bs_free_io_channel(channel);
5530 struct spdk_io_channel *channel;
5564 channel = spdk_bs_alloc_io_channel(bs);
5565 SPDK_CU_ASSERT_FATAL(channel != NULL);
5580 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload,
5589 spdk_blob_io_write(blob, channel, payload_write, 0, io_units_per_payload -
5626 spdk_blob_io_write(blob, channel, payload_write, i * io_units_per_cluster,
5639 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload,
5667 spdk_blob_io_write(blob, channel, payload_write, io_units_per_cluster,
5677 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload,
5713 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
5737 spdk_bs_blob_decouple_parent(bs, channel, blobid, blob_op_complete, NULL);
5784 spdk_blob_io_read(blob, channel, payload_read, 0, io_units_per_payload,
5790 spdk_bs_free_io_channel(channel);
6531 struct spdk_io_channel *channel;
6547 channel = spdk_bs_alloc_io_channel(bs);
6548 SPDK_CU_ASSERT_FATAL(channel != NULL);
6579 spdk_bs_blob_decouple_parent(bs, channel, blobid, blob_op_complete, NULL);
6584 spdk_bs_blob_decouple_parent(bs, channel, snapshotid2, blob_op_complete, NULL);
6612 spdk_bs_free_io_channel(channel);
6909 test_io_write(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel)
6922 spdk_blob_io_write(blob, channel, payload_ff, 0, 1, blob_op_complete, NULL);
6937 spdk_blob_io_write(blob, channel, payload_ff, 2, 1, blob_op_complete, NULL);
6949 spdk_blob_io_write(blob, channel, payload_ff, 4, 4, blob_op_complete, NULL);
6961 spdk_blob_io_write(blob, channel, payload_ff, 8, 4, blob_op_complete, NULL);
6973 spdk_blob_io_write(blob, channel, payload_aa, 4, 8, blob_op_complete, NULL);
6985 spdk_blob_io_write(blob, channel, payload_ff, SZ - 4, 8, blob_op_complete, NULL);
7004 spdk_blob_io_write(blob, channel, payload_ff, SZ + 12, 2, blob_op_complete, NULL);
7026 test_io_read(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel)
7043 spdk_blob_io_read(blob, channel, payload_read, 0, 1, blob_op_complete, NULL);
7055 spdk_blob_io_read(blob, channel, payload_read, 2, 4, blob_op_complete, NULL);
7070 spdk_blob_io_read(blob, channel, payload_read, 4, 8, blob_op_complete, NULL);
7082 spdk_blob_io_read(blob, channel, payload_read, SZ - 4, 8, blob_op_complete, NULL);
7094 spdk_blob_io_read(blob, channel, payload_read, SZ + 10, 4, blob_op_complete, NULL);
7107 spdk_blob_io_read(blob, channel, payload_read, SZ, SZ, blob_op_complete, NULL);
7119 spdk_blob_io_read(blob, channel, payload_read, 0, SZ * 2, blob_op_complete, NULL);
7138 test_io_unmap(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel)
7154 spdk_blob_io_unmap(blob, channel, 0, SZ * 2, blob_op_complete, NULL);
7164 test_io_zeroes(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel)
7180 spdk_blob_io_write_zeroes(blob, channel, 0, SZ * 2, blob_op_complete, NULL);
7190 test_blob_io_writev(struct spdk_blob *blob, struct spdk_io_channel *channel,
7197 spdk_blob_io_writev_ext(blob, channel, iov, iovcnt, offset, length, blob_op_complete, NULL,
7200 spdk_blob_io_writev(blob, channel, iov, iovcnt, offset, length, blob_op_complete, NULL);
7211 test_iov_write(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel,
7235 test_blob_io_writev(blob, channel, iov, 1, 0, 1, blob_op_complete, NULL,
7252 test_blob_io_writev(blob, channel, iov, 1, 2, 1, blob_op_complete, NULL,
7265 spdk_blob_io_writev(blob, channel, iov, 1, 4, 4, blob_op_complete, NULL);
7279 spdk_blob_io_writev(blob, channel, iov, 1, 8, 4, blob_op_complete, NULL);
7294 test_blob_io_writev(blob, channel, iov, 1, 4, 8, blob_op_complete, NULL,
7310 test_blob_io_writev(blob, channel, iov, 1, (SZ - 4), 8, blob_op_complete, NULL,
7334 test_blob_io_writev(blob, channel, iov, 1, SZ + 12, 2, blob_op_complete, NULL,
7356 test_blob_io_readv(struct spdk_blob *blob, struct spdk_io_channel *channel,
7363 spdk_blob_io_readv_ext(blob, channel, iov, iovcnt, offset, length, blob_op_complete, NULL, io_opts);
7365 spdk_blob_io_readv(blob, channel, iov, iovcnt, offset, length, blob_op_complete, NULL);
7376 test_iov_read(struct spdk_bs_dev *dev, struct spdk_blob *blob, struct spdk_io_channel *channel,
7404 test_blob_io_readv(blob, channel, iov, 1, 0, 1, blob_op_complete, NULL, ext_api ? &ext_opts : NULL);
7418 test_blob_io_readv(blob, channel, iov, 1, 2, 4, blob_op_complete, NULL, ext_api ? &ext_opts : NULL);
7436 test_blob_io_readv(blob, channel, iov, 2, 4, 8, blob_op_complete, NULL, ext_api ? &ext_opts : NULL);
7455 test_blob_io_readv(blob, channel, iov, 4, SZ - 4, 8, blob_op_complete, NULL,
7471 test_blob_io_readv(blob, channel, iov, 2, SZ + 10, 4, blob_op_complete, NULL,
7492 test_blob_io_readv(blob, channel, iov, 4, SZ, SZ, blob_op_complete, NULL,
7513 test_blob_io_readv(blob, channel, iov, 4, 0, SZ * 2, blob_op_complete, NULL,
7538 struct spdk_io_channel *channel;
7559 channel = spdk_bs_alloc_io_channel(bs);
7569 test_io_write(dev, blob, channel);
7570 test_io_read(dev, blob, channel);
7571 test_io_zeroes(dev, blob, channel);
7573 test_iov_write(dev, blob, channel, false);
7574 test_iov_read(dev, blob, channel, false);
7575 test_io_zeroes(dev, blob, channel);
7577 test_iov_write(dev, blob, channel, true);
7578 test_iov_read(dev, blob, channel, true);
7580 test_io_unmap(dev, blob, channel);
7597 test_io_write(dev, blob, channel);
7598 test_io_read(dev, blob, channel);
7599 test_io_zeroes(dev, blob, channel);
7601 test_iov_write(dev, blob, channel, false);
7602 test_iov_read(dev, blob, channel, false);
7603 test_io_zeroes(dev, blob, channel);
7605 test_iov_write(dev, blob, channel, true);
7606 test_iov_read(dev, blob, channel, true);
7634 test_io_read(dev, blob, channel);
7635 test_io_read(dev, snapshot, channel);
7636 test_io_read(dev, clone, channel);
7638 test_iov_read(dev, blob, channel, false);
7639 test_iov_read(dev, snapshot, channel, false);
7640 test_iov_read(dev, clone, channel, false);
7642 test_iov_read(dev, blob, channel, true);
7643 test_iov_read(dev, snapshot, channel, true);
7644 test_iov_read(dev, clone, channel, true);
7648 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
7653 test_io_read(dev, clone, channel);
7655 test_io_unmap(dev, clone, channel);
7657 test_iov_write(dev, clone, channel, false);
7658 test_iov_read(dev, clone, channel, false);
7659 test_io_unmap(dev, clone, channel);
7661 test_iov_write(dev, clone, channel, true);
7662 test_iov_read(dev, clone, channel, true);
7672 spdk_bs_free_io_channel(channel);
7788 struct spdk_io_channel *channel;
7791 channel = spdk_bs_alloc_io_channel(bs);
7792 SPDK_CU_ASSERT_FATAL(channel != NULL);
7828 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
7886 spdk_bs_free_io_channel(channel);
7900 struct spdk_io_channel *channel;
7908 channel = spdk_bs_alloc_io_channel(bs);
7909 SPDK_CU_ASSERT_FATAL(channel != NULL);
7994 spdk_bs_free_io_channel(channel);
8004 struct spdk_io_channel *channel;
8009 channel = spdk_bs_alloc_io_channel(bs);
8010 SPDK_CU_ASSERT_FATAL(channel != NULL);
8051 spdk_bs_blob_decouple_parent(bs, channel, snapshot2->id, blob_op_complete, NULL);
8063 spdk_bs_free_io_channel(channel);
8083 struct spdk_io_channel *channel;
8092 channel = spdk_bs_alloc_io_channel(bs);
8093 CU_ASSERT(channel != NULL);
8114 spdk_blob_io_write(blob, channel, payload, offset, 1, blob_op_complete, NULL);
8126 spdk_blob_io_write(blob, channel, payload, offset, 1, blob_op_complete, NULL);
8138 spdk_blob_io_write(blob, channel, payload, offset, 1, blob_op_complete, NULL);
8148 spdk_bs_free_io_channel(channel);
8705 /* Create a channel on thread 0. It is lazily created on the first read. */
8719 /* Create a channel on thread 1 and verify its lazy creation too. */
8734 /* Close the channel on thread 0 and verify the bs_dev channel is also gone. */
8747 /* The esnap channel for the blob should be gone now too. */
8780 struct spdk_io_channel *channel[2];
8787 channel[i] = spdk_bs_alloc_io_channel(bs);
8788 SPDK_CU_ASSERT_FATAL(channel[i] != NULL);
8838 spdk_bs_free_io_channel(channel[i]);
9056 struct spdk_io_channel *channel;
9065 channel = spdk_bs_alloc_io_channel(bs);
9066 SPDK_CU_ASSERT_FATAL(channel != NULL);
9093 spdk_bs_inflate_blob(bs, channel, blobid, blob_op_complete, NULL);
9095 spdk_bs_blob_decouple_parent(bs, channel, blobid, blob_op_complete, NULL);
9100 CU_ASSERT(blob_esnap_verify_contents(blob, channel, 0, esnap_sz, esnap_sz, "read"));
9106 spdk_bs_free_io_channel(channel);
9293 struct spdk_io_channel *channel;
9296 channel = spdk_bs_alloc_io_channel(bs);
9297 SPDK_CU_ASSERT_FATAL(channel != NULL);
9367 spdk_blob_io_write(clone, channel, payload_write, 5 * pages_per_cluster, 1, blob_op_complete, NULL);
9373 spdk_blob_io_read(clone, channel, payload_read, 5 * pages_per_cluster, 1, blob_op_complete, NULL);
9381 spdk_blob_io_write(clone, channel, payload_write, 15 * pages_per_cluster, 1, blob_op_complete,
9388 spdk_blob_io_read(clone, channel, payload_read, 15 * pages_per_cluster, 1, blob_op_complete, NULL);
9395 spdk_bs_inflate_blob(bs, channel, cloneid, blob_op_complete, NULL);
9416 spdk_bs_free_io_channel(channel);
9532 bs_dev_io_complete_cb(struct spdk_io_channel *channel, void *cb_arg, int bserrno)