src/corosio/src/stream_file.cpp

88.4% Lines (61/69) 92.3% List of functions (12/13) 76.9% Branches (20/26)

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

stream_file.cpp

f(x) Functions (13)

Function Calls Lines Branches Blocks

Line	Branch	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		54x	stream_file::~stream_file()
23		54x	{
24	1/2 ✓ Branch 0 taken 27 times. ✗ Branch 1 not taken.	27x	close();
25		54x	}
26
27		52x	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		52x	{
34		26x	}
35
36			void
37		19x	stream_file::open(
38			std::filesystem::path const& path, file_base::flags mode)
39			{
40	1/2 ✓ Branch 0 taken 19 times. ✗ Branch 1 not taken.	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	2/2 ✓ Branch 0 taken 17 times. ✓ Branch 1 taken 2 times.	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	2/2 ✓ Branch 0 taken 15 times. ✓ Branch 1 taken 17 times.	32x	if (!is_open())
52		15x	return;
53		17x	h_.service().close(h_);
54		32x	}
55
56			void
57		1x	stream_file::cancel()
58			{
59	1/2 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time.	1x	if (!is_open())
60		✗	return;
61		1x	get().cancel();
62		1x	}
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	2/2 ✓ Branch 0 taken 3 times. ✓ Branch 1 taken 1 time.	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	2/2 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time.	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	2/2 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time.	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	2/2 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time.	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	2/2 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time.	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	1/2 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken.	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	2/2 ✓ Branch 0 taken 7 times. ✓ Branch 1 taken 1 time.	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