src/corosio/src/stream_file.cpp

89.1% Lines (57/64) 92.3% List of functions (12/13)

[ ] prev/next file n p prev/next uncovered line

stream_file.cpp

f(x) Functions (13)

Function Calls Lines Blocks

Line	Hits	Source Code
1		//
2		// Copyright (c) 2026 Michael Vandeberg
3		//
4		// Distributed under the Boost Software License, Version 1.0. (See accompanying
5		// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6		//
7		// Official repository: https://github.com/cppalliance/corosio
8		//
9
10		#include <boost/corosio/stream_file.hpp>
11		#include <boost/corosio/detail/except.hpp>
12		#include <boost/corosio/detail/platform.hpp>
13
14		#if BOOST_COROSIO_HAS_IOCP
15		#include <boost/corosio/native/detail/iocp/win_file_service.hpp>
16		#else
17		#include <boost/corosio/detail/file_service.hpp>
18		#endif
19
20		namespace boost::corosio {
21
22	27x	stream_file::~stream_file()
23		{
24	27x	close();
25	27x	}
26
27	26x	stream_file::stream_file(capy::execution_context& ctx)
28		#if BOOST_COROSIO_HAS_IOCP
29		: io_object(create_handle<detail::win_file_service>(ctx))
30		#else
31	26x	: io_object(create_handle<detail::file_service>(ctx))
32		#endif
33		{
34	26x	}
35
36		void
37	19x	stream_file::open(
38		std::filesystem::path const& path, file_base::flags mode)
39		{
40	19x	if (is_open())
41	✗	close();
42	19x	auto& svc = static_cast<detail::file_service&>(h_.service());
43	19x	std::error_code ec = svc.open_file(get(), path, mode);
44	19x	if (ec)
45	2x	detail::throw_system_error(ec, "stream_file::open");
46	17x	}
47
48		void
49	32x	stream_file::close()
50		{
51	32x	if (!is_open())
52	15x	return;
53	17x	h_.service().close(h_);
54		}
55
56		void
57	1x	stream_file::cancel()
58		{
59	1x	if (!is_open())
60	✗	return;
61	1x	get().cancel();
62		}
63
64		native_handle_type
65	✗	stream_file::native_handle() const noexcept
66		{
67	✗	if (!is_open())
68		{
69		#if BOOST_COROSIO_HAS_IOCP
70		return static_cast<native_handle_type>(~0ull);
71		#else
72	✗	return -1;
73		#endif
74		}
75	✗	return get().native_handle();
76		}
77
78		std::uint64_t
79	4x	stream_file::size() const
80		{
81	4x	if (!is_open())
82	1x	detail::throw_system_error(
83	1x	make_error_code(std::errc::bad_file_descriptor),
84		"stream_file::size");
85	3x	return get().size();
86		}
87
88		void
89	2x	stream_file::resize(std::uint64_t new_size)
90		{
91	2x	if (!is_open())
92	1x	detail::throw_system_error(
93	1x	make_error_code(std::errc::bad_file_descriptor),
94		"stream_file::resize");
95	1x	get().resize(new_size);
96	1x	}
97
98		void
99	2x	stream_file::sync_data()
100		{
101	2x	if (!is_open())
102	1x	detail::throw_system_error(
103	1x	make_error_code(std::errc::bad_file_descriptor),
104		"stream_file::sync_data");
105	1x	get().sync_data();
106	1x	}
107
108		void
109	2x	stream_file::sync_all()
110		{
111	2x	if (!is_open())
112	1x	detail::throw_system_error(
113	1x	make_error_code(std::errc::bad_file_descriptor),
114		"stream_file::sync_all");
115	1x	get().sync_all();
116	1x	}
117
118		native_handle_type
119	2x	stream_file::release()
120		{
121	2x	if (!is_open())
122	1x	detail::throw_system_error(
123	1x	make_error_code(std::errc::bad_file_descriptor),
124		"stream_file::release");
125	1x	return get().release();
126		}
127
128		void
129	1x	stream_file::assign(native_handle_type handle)
130		{
131	1x	if (is_open())
132	✗	close();
133	1x	get().assign(handle);
134	1x	}
135
136		std::uint64_t
137	8x	stream_file::seek(std::int64_t offset, file_base::seek_basis origin)
138		{
139	8x	if (!is_open())
140	1x	detail::throw_system_error(
141	1x	make_error_code(std::errc::bad_file_descriptor),
142		"stream_file::seek");
143	7x	return get().seek(offset, origin);
144		}
145
146		} // namespace boost::corosio
147