MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-06-10 14:08:56 +02:00
Code Issues Releases Wiki Activity

ircd::fs: fs::write() stack based on pwritev() using iov.

Browse source
This commit is contained in:
Jason Volk 2018-11-28 17:10:48 -08:00
parent c9b10bd841
commit db36ea6255
2 changed files with 42 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
include/ircd/fs/write.h
View file

@ -15,6 +15,10 @@ namespace ircd::fs
{
struct write_opts extern const write_opts_default;
// Yields ircd::ctx for write from buffers; returns bytes written
size_t write(const fd &, const const_buffers &, const write_opts & = write_opts_default);
size_t write(const string_view &path, const const_buffers &, const write_opts & = write_opts_default);
// Yields ircd::ctx for write from buffer; returns view of written portion
const_buffer write(const fd &, const const_buffer &, const write_opts & = write_opts_default);
const_buffer write(const string_view &path, const const_buffer &, const write_opts & = write_opts_default);

50
ircd/fs.cc
View file

@ -716,6 +716,38 @@ ircd::const_buffer
ircd::fs::write(const string_view &path,
const const_buffer &buf,
const write_opts &opts)
{
const const_buffers bufs
{
&buf, 1
};
return const_buffer
{
data(buf), write(path, bufs, opts)
};
}
ircd::const_buffer
ircd::fs::write(const fd &fd,
const const_buffer &buf,
const write_opts &opts)
{
const const_buffers bufs
{
&buf, 1
};
return const_buffer
{
data(buf), write(fd, bufs, opts)
};
}
size_t
ircd::fs::write(const string_view &path,
const const_buffers &bufs,
const write_opts &opts)
try
{
const fd fd
@ -723,7 +755,7 @@ try
path, std::ios::out
};
return write(fd, buf, opts);
return write(fd, bufs, opts);
}
catch(const error &e)
{
@ -741,25 +773,19 @@ catch(const std::exception &e)
};
}
ircd::const_buffer
size_t
ircd::fs::write(const fd &fd,
const const_buffer &buf,
const const_buffers &bufs,
const write_opts &opts)
try
{
#ifdef IRCD_USE_AIO
if(likely(aio::context))
return
{
data(buf), aio::write(fd, {&buf, 1}, opts)
};
return aio::write(fd, bufs, opts);
#endif
return
{
data(buf),
size_t(syscall(::pwrite, fd, data(buf), size(buf), opts.offset))
};
const auto iov(make_iov(bufs));
return size_t(syscall(::pwritev, fd, iov.data(), iov.size(), opts.offset));
}
catch(const error &e)
{