<div dir="ltr"><div dir="ltr"><div dir="ltr"><div dir="ltr"><br></div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Fri, Jun 28, 2019 at 2:50 AM Anna Fuchs <<a href="mailto:anna.fuchs@informatik.uni-hamburg.de">anna.fuchs@informatik.uni-hamburg.de</a>> wrote:<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);padding-left:1ex">Hello Matt,<br>
<br>
thanks for your reply.<br>
<br>
> <br>
> You can set the block size (of the first and only block) using <br>
> dmu_object_set_blocksize(). FYI, I think that this comment is <br>
> incorrect:<br>
> * If the first block is allocated already, the new size must be <br>
> greater<br>
> * than the current block size.<br>
> <br>
> You can increase or decrease the block size with this routine.<br>
<br>
This is a deeper call of Lustre's osd_grow_blocksize I mentioned <br>
before. If I understand it correctly, they are called in the context of <br>
transactions, right?<br></blockquote><div><br></div><div>It is not possible to change the block size of a ZFS object outside of a transaction.</div><div> </div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);padding-left:1ex">
If so, I can not use it - I need the blocksize to be set in the buffer <br>
preparation stage, before comitting in a transaction.<br>
Lustre's original routine looks simplified as follows:<br>
<br>
osd_bufs_get_write<br>
bs = dn->dn_datablksz<br>
while (len > 0)<br>
if (sz_in_block == bs) /* full block, try zerocopy */<br>
abuf = osd_request_arcbuf(dn, bs);<br>
else /* can't use zerocopy, allocate temp. buffers */<br>
... alloc_page ...<br>
here going later on the dmu_write path (pagewise!)<br>
<br>
Currently, in the very first iteration this blocksize (bs) is taken <br>
from the dnode and is e.g. 4K.<br>
When writing a chunk of 16K, I get 4 arcbufs 4K each. For the next <br>
chunk the block size might be grown up to x (recordsize?).<br>
Here I need the blocksize to be set to 16K (or 128K or later some <br>
generic value defined by the Lustre client) before the first arcbuf is <br>
requested,<br>
because the compressed chunk sent from client is logically this size.<br>
At this point I don't have any dmu_tx yet to grow the blocksize saved <br>
in dn->dn_datablksz before the while loop.<br>
So I am not sure how deep to go? This min size is set on dnode creation <br>
by ZFS, how can I "reset" it?<br></blockquote><div><br></div><div>I think that you are saying that you want to be loaned an ARC buffer of the size provided by the client, which may be different from the object's current blocksize. You will later (within a transaction) change the object's blocksize to the size specified by the client, and write the data (using the loaned ARC buffer). You can do exactly that using the routines I mentioned.</div><div><br></div><div>In your example code above, you are providing the dnode when requesting the arc buf, which leads to the problem you described (needing that dnode's block size to match the size provided by the client before you change the blocksize of the object). However, this is an unnecessary restriction, because arc_loan_compressed_buf() does not need to know the dnode, or its current block size.</div><div><br></div><div>--matt</div><div><br></div><div> </div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);padding-left:1ex">
<br>
> <br>
> I'd recommend that you hand the compressed data to ZFS similarly to <br>
> how "zfs receive" does (for compressed send streams). It sounds like <br>
> the is the direction you're going, which is great. FYI, here are <br>
> some of the routines you'd want to use (copied from dmu_recv.c):<br>
> <br>
> abuf = arc_loan_compressed_buf(<br>
> <br>
> dmu_objset_spa(drc->drc_os),<br>
> <br>
> drrw->drr_compressed_size, drrw->drr_logical_size,<br>
> <br>
> drrw->drr_compressiontype);<br>
> <br>
> <br>
> dmu_assign_arcbuf(bonus, drrw->drr_offset, abuf, tx);<br>
> <br>
> (or dmu_assign_arcbuf_dnode())<br>
> <br>
> <br>
> dmu_return_arcbuf(rrd->write_buf);<br>
> <br>
<br>
Yes, thanks for that. We have two paths how Lustre interacts with ZFS - <br>
requesting arc buffers or dmu_write.<br>
The common dmu_request_arcbuf goes over arc_loan_buf, so we introduced <br>
dmu_request_compressed_arcbuf to go over arc_loan_compressed_buf to <br>
reuse the receive functionality.<br>
We try to make as few changes as possible on Lustre's interface since <br>
we want mix compressed and uncompressed data chunks (and be at the same <br>
time compatible with ZFS' on disk format..)<br>
The dmu_write path will be tricky, though.<br>
<br>
Any comments are welcome.<br>
<br>
Best regards<br>
Anna<br>
<br>
--<br>
<br>
Anna Fuchs<br>
Universität Hamburg<br>
<br>
<br>
</blockquote></div></div></div></div>