include/boost/corosio/native/detail/reactor/reactor_op.hpp

80.5% Lines (169/210) 85.2% List of functions (218/256) 12.9% Branches (36/280)

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

reactor_op.hpp

f(x) Functions (256)

Function Calls Lines Branches Blocks

Line	Branch	Hits	Source Code
1			//
2			// Copyright (c) 2026 Steve Gerbino
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			#ifndef BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
12
13			#include <boost/corosio/native/detail/reactor/reactor_op_base.hpp>
14			#include <boost/corosio/io/io_object.hpp>
15			#include <boost/corosio/endpoint.hpp>
16			#include <boost/corosio/detail/continuation_op.hpp>
17			#include <boost/capy/ex/executor_ref.hpp>
18
19			#include <atomic>
20			#include <coroutine>
21			#include <cstddef>
22			#include <memory>
23			#include <optional>
24			#include <stop_token>
25			#include <system_error>
26
27			#include <errno.h>
28
29			#include <netinet/in.h>
30			#include <sys/socket.h>
31			#include <sys/uio.h>
32
33			namespace boost::corosio::detail {
34
35			/** Base operation for reactor-based backends.
36
37			Holds per-operation state that depends on the concrete backend
38			socket/acceptor types: coroutine handle, executor, output
39			pointers, file descriptor, stop_callback, and type-specific
40			impl pointers.
41
42			Fields shared across all backends (errn, bytes_transferred,
43			cancelled, impl_ptr, perform_io, complete) live in
44			reactor_op_base so the scheduler and descriptor_state can
45			access them without template instantiation.
46
47			@tparam Socket The backend socket impl type (forward-declared).
48			@tparam Acceptor The backend acceptor impl type (forward-declared).
49			*/
50			template<class Socket, class Acceptor>
51			struct reactor_op : reactor_op_base
52			{
53			// The op envelope — coroutine handle h, cont_op, executor ex, ec_out,
54			// bytes_out, cancelled, stop_cb (+ its canceller), impl_ptr — lives in
55			// coro_op (via reactor_op_base) and is shared with io_uring/IOCP.
56			// reactor_op adds only the reactor-specific routing state below.
57
58			/// File descriptor this operation targets.
59		129004x	int fd = -1;
60
61			/// Owning socket impl (for stop_token cancellation routing).
62		129004x	Socket* socket_impl_ = nullptr;
63
64			/// Owning acceptor impl (for stop_token cancellation routing).
65		129004x	Acceptor* acceptor_impl_ = nullptr;
66
67		258008x	reactor_op() = default;
68
69			/// Reset operation state for reuse.
70		1647031x	void reset() noexcept
71			{
72		1647031x	fd = -1;
73		1647031x	errn = 0;
74		1647031x	bytes_transferred = 0;
75		1647031x	cancelled.store(false, std::memory_order_relaxed);
76		1647031x	impl_ptr.reset();
77		1647031x	socket_impl_ = nullptr;
78		1647031x	acceptor_impl_ = nullptr;
79		1647031x	}
80
81			/// Return true if this is a read-direction operation.
82		160824x	virtual bool is_read_operation() const noexcept
83			{
84		160824x	return false;
85			}
86
87			/// Cancel this operation via the owning impl.
88			virtual void cancel() noexcept = 0;
89
90			/// coro_op cancellation hook (fired by the shared canceller when the
91			/// stop_token requests cancellation): route to the impl-specific cancel().
92		712x	void on_cancel() noexcept override
93			{
94		712x	cancel();
95		712x	}
96
97			/// Destroy without invoking.
98		12x	void destroy() override
99			{
100		12x	stop_cb.reset();
101		12x	reactor_op_base::destroy();
102		12x	}
103
104			/// Arm the stop-token callback for a socket operation.
105		381927x	void start(std::stop_token const& token, Socket* impl)
106			{
107		381927x	socket_impl_ = impl;
108		381927x	acceptor_impl_ = nullptr;
109		381927x	coro_op::start(token);
110		381927x	}
111
112			/// Arm the stop-token callback for an acceptor operation.
113		6668x	void start(std::stop_token const& token, Acceptor* impl)
114			{
115		6668x	socket_impl_ = nullptr;
116		6668x	acceptor_impl_ = impl;
117		6668x	coro_op::start(token);
118		6668x	}
119			};
120
121			/** Shared connect operation.
122
123			Checks SO_ERROR for connect completion status. The operator()()
124			and cancel() are provided by the concrete backend type.
125
126			@tparam Base The backend's base op type.
127			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
128			*/
129			template<class Base, class Endpoint = endpoint>
130			struct reactor_connect_op : Base
131			{
132			/// Endpoint to connect to.
133			Endpoint target_endpoint;
134
135			/// Reset operation state for reuse.
136		6670x	void reset() noexcept
137			{
138		6670x	Base::reset();
139		6670x	target_endpoint = Endpoint{};
140		6670x	}
141
142		6602x	void perform_io() noexcept override
143			{
144		6602x	int err = 0;
145		6602x	socklen_t len = sizeof(err);
146	4/32 ✓ Branch 0 taken 4738 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 4738 times. ✓ Branch 4 taken 1864 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1864 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	6602x	if (::getsockopt(this->fd, SOL_SOCKET, SO_ERROR, &err, &len) < 0)
147		✗	err = errno;
148		6602x	this->complete(err, 0);
149		6602x	}
150			};
151
152			/** Readiness-only wait operation.
153
154			Does not perform any I/O syscall. Completion is signalled by
155			the reactor delivering the requested edge event; reactor_descriptor_state
156			calls complete() directly and never invokes perform_io().
157
158			@tparam Base The backend's base op type.
159			*/
160			template<class Base>
161		65265x	struct reactor_wait_op : Base
162			{
163			/* Mirror of reactor_event_read from reactor_descriptor_state.hpp.
164			Including that header from here would create an include cycle
165			(descriptor_state -> reactor_op_base; reactor_op -> reactor_op_base),
166			so we carry the value locally. Both must stay in sync. */
167			static constexpr std::uint32_t read_event = 0x001;
168
169			/// Which event bit this wait targets (reactor_event_read/write/error).
170		65265x	std::uint32_t wait_event = 0;
171
172		72x	void reset() noexcept
173			{
174		72x	Base::reset();
175		72x	wait_event = 0;
176		72x	}
177
178		✗	bool is_read_operation() const noexcept override
179			{
180		✗	return wait_event == read_event;
181			}
182
183			/* perform_io() should never be called for a wait op — readiness
184			IS the completion. Overridden here to satisfy the virtual and
185			produce a safe result if called defensively. */
186		✗	void perform_io() noexcept override
187			{
188		✗	this->complete(0, 0);
189		✗	}
190			};
191
192			/** Shared scatter-read operation.
193
194			Uses readv() with an EINTR retry loop.
195
196			@tparam Base The backend's base op type.
197			*/
198			template<class Base>
199		20208x	struct reactor_read_op : Base
200			{
201			/// Maximum scatter-gather buffer count.
202			static constexpr std::size_t max_buffers = 16;
203
204			/// Scatter-gather I/O vectors.
205			iovec iovecs[max_buffers];
206
207			/// Number of active I/O vectors.
208		20208x	int iovec_count = 0;
209
210			/// True for zero-length reads (completed immediately).
211		20208x	bool empty_buffer_read = false;
212
213			/// Return true (this is a read-direction operation).
214		214294x	bool is_read_operation() const noexcept override
215			{
216		214294x	return !empty_buffer_read;
217			}
218
219		769859x	void reset() noexcept
220			{
221		769859x	Base::reset();
222		769859x	iovec_count = 0;
223		769859x	empty_buffer_read = false;
224		769859x	}
225
226		79515x	void perform_io() noexcept override
227			{
228			ssize_t n;
229		79515x	do
230			{
231	2/8 ✓ Branch 0 taken 46641 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 32874 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	79515x	n = ::readv(this->fd, iovecs, iovec_count);
232		159030x	}
233	6/16 ✓ Branch 0 taken 466 times. ✓ Branch 1 taken 46175 times. ✓ Branch 2 taken 466 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 567 times. ✓ Branch 5 taken 32307 times. ✓ Branch 6 taken 567 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	79515x	while (n < 0 && errno == EINTR);
234
235	4/8 ✓ Branch 0 taken 466 times. ✓ Branch 1 taken 46175 times. ✓ Branch 2 taken 567 times. ✓ Branch 3 taken 32307 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	79515x	if (n >= 0)
236		78482x	this->complete(0, static_cast<std::size_t>(n));
237			else
238	2/8 ✓ Branch 0 taken 466 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 567 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	1033x	this->complete(errno, 0);
239		79515x	}
240			};
241
242			/** Shared gather-write operation.
243
244			Delegates the actual syscall to WritePolicy::write(fd, iovecs, count),
245			which returns ssize_t (bytes written or -1 with errno set).
246
247			@tparam Base The backend's base op type.
248			@tparam WritePolicy Provides `static ssize_t write(int, iovec*, int)`.
249			*/
250			template<class Base, class WritePolicy>
251		20208x	struct reactor_write_op : Base
252			{
253			/// The write syscall policy type.
254			using write_policy = WritePolicy;
255
256			/// Maximum scatter-gather buffer count.
257			static constexpr std::size_t max_buffers = 16;
258
259			/// Scatter-gather I/O vectors.
260			iovec iovecs[max_buffers];
261
262			/// Number of active I/O vectors.
263		20208x	int iovec_count = 0;
264
265		863562x	void reset() noexcept
266			{
267		863562x	Base::reset();
268		863562x	iovec_count = 0;
269		863562x	}
270
271		1014x	void perform_io() noexcept override
272			{
273		1014x	ssize_t n = WritePolicy::write(this->fd, iovecs, iovec_count);
274	3/8 ✓ Branch 0 taken 505 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 507 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	1014x	if (n >= 0)
275		1012x	this->complete(0, static_cast<std::size_t>(n));
276			else
277	1/8 ✓ Branch 0 taken 2 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	this->complete(errno, 0);
278		1014x	}
279			};
280
281			/** Shared accept operation.
282
283			Delegates the actual syscall to AcceptPolicy::do_accept(fd, peer_storage),
284			which returns the accepted fd or -1 with errno set.
285
286			@tparam Base The backend's base op type.
287			@tparam AcceptPolicy Provides `static int do_accept(int, sockaddr_storage&)`.
288			*/
289			template<class Base, class AcceptPolicy>
290		1155x	struct reactor_accept_op : Base
291			{
292			/// File descriptor of the accepted connection.
293		1155x	int accepted_fd = -1;
294
295			/// Pointer to the peer socket implementation.
296		1155x	io_object::implementation* peer_impl = nullptr;
297
298			/// Output pointer for the accepted implementation.
299		1155x	io_object::implementation** impl_out = nullptr;
300
301			/// Peer address storage filled by accept.
302		1155x	sockaddr_storage peer_storage{};
303
304			/// Peer address length returned by accept.
305		1155x	socklen_t peer_addrlen = 0;
306
307		6656x	void reset() noexcept
308			{
309		6656x	Base::reset();
310		6656x	accepted_fd = -1;
311		6656x	peer_impl = nullptr;
312		6656x	impl_out = nullptr;
313		6656x	peer_storage = {};
314		6656x	peer_addrlen = 0;
315		6656x	}
316
317		6604x	void perform_io() noexcept override
318			{
319		6604x	int new_fd = AcceptPolicy::do_accept(
320		6604x	this->fd, peer_storage, peer_addrlen);
321	2/8 ✓ Branch 0 taken 4744 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1860 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	6604x	if (new_fd >= 0)
322			{
323		6604x	accepted_fd = new_fd;
324		6604x	this->complete(0, 0);
325		6604x	}
326			else
327			{
328		✗	this->complete(errno, 0);
329			}
330		6604x	}
331			};
332
333			/** Shared connected send operation for datagram sockets.
334
335			Uses sendmsg() with msg_name=nullptr (connected mode).
336
337			@tparam Base The backend's base op type.
338			*/
339			template<class Base>
340		392x	struct reactor_send_op : Base
341			{
342			/// Maximum scatter-gather buffer count.
343			static constexpr std::size_t max_buffers = 16;
344
345			/// Scatter-gather I/O vectors.
346			iovec iovecs[max_buffers];
347
348			/// Number of active I/O vectors.
349		392x	int iovec_count = 0;
350
351			/// User-supplied message flags.
352		392x	int msg_flags = 0;
353
354		44x	void reset() noexcept
355			{
356		44x	Base::reset();
357		44x	iovec_count = 0;
358		44x	msg_flags = 0;
359		44x	}
360
361		✗	void perform_io() noexcept override
362			{
363		✗	msghdr msg{};
364		✗	msg.msg_iov = iovecs;
365		✗	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
366
367			#ifdef MSG_NOSIGNAL
368		✗	int send_flags = msg_flags \| MSG_NOSIGNAL;
369			#else
370			int send_flags = msg_flags;
371			#endif
372
373			ssize_t n;
374		✗	do
375			{
376		✗	n = ::sendmsg(this->fd, &msg, send_flags);
377		✗	}
378		✗	while (n < 0 && errno == EINTR);
379
380		✗	if (n >= 0)
381		✗	this->complete(0, static_cast<std::size_t>(n));
382			else
383		✗	this->complete(errno, 0);
384		✗	}
385			};
386
387			/** Shared connected recv operation for datagram sockets.
388
389			Uses recvmsg() with msg_name=nullptr (connected mode).
390			Unlike reactor_read_op, does not map n==0 to EOF
391			(zero-length datagrams are valid).
392
393			@tparam Base The backend's base op type.
394			*/
395			template<class Base>
396		392x	struct reactor_recv_op : Base
397			{
398			/// Maximum scatter-gather buffer count.
399			static constexpr std::size_t max_buffers = 16;
400
401			/// Scatter-gather I/O vectors.
402			iovec iovecs[max_buffers];
403
404			/// Number of active I/O vectors.
405		392x	int iovec_count = 0;
406
407			/// User-supplied message flags.
408		392x	int msg_flags = 0;
409
410			/// Return true (this is a read-direction operation).
411		✗	bool is_read_operation() const noexcept override
412			{
413		✗	return true;
414			}
415
416		42x	void reset() noexcept
417			{
418		42x	Base::reset();
419		42x	iovec_count = 0;
420		42x	msg_flags = 0;
421		42x	}
422
423		7x	void perform_io() noexcept override
424			{
425		7x	msghdr msg{};
426		7x	msg.msg_iov = iovecs;
427		7x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
428
429			ssize_t n;
430		7x	do
431			{
432	2/8 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	7x	n = ::recvmsg(this->fd, &msg, msg_flags);
433		14x	}
434	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 4 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	7x	while (n < 0 && errno == EINTR);
435
436	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	7x	if (n >= 0)
437		7x	this->complete(0, static_cast<std::size_t>(n));
438			else
439		✗	this->complete(errno, 0);
440		7x	}
441			};
442
443			/** Shared send_to operation for datagram sockets.
444
445			Uses sendmsg() with the destination endpoint in msg_name.
446
447			@tparam Base The backend's base op type.
448			*/
449			template<class Base>
450		392x	struct reactor_send_to_op : Base
451			{
452			/// Maximum scatter-gather buffer count.
453			static constexpr std::size_t max_buffers = 16;
454
455			/// Scatter-gather I/O vectors.
456			iovec iovecs[max_buffers];
457
458			/// Number of active I/O vectors.
459		392x	int iovec_count = 0;
460
461			/// Destination address storage.
462		392x	sockaddr_storage dest_storage{};
463
464			/// Destination address length.
465		392x	socklen_t dest_len = 0;
466
467			/// User-supplied message flags.
468		392x	int msg_flags = 0;
469
470		58x	void reset() noexcept
471			{
472		58x	Base::reset();
473		58x	iovec_count = 0;
474		58x	dest_storage = {};
475		58x	dest_len = 0;
476		58x	msg_flags = 0;
477		58x	}
478
479		✗	void perform_io() noexcept override
480			{
481		✗	msghdr msg{};
482		✗	msg.msg_name = &dest_storage;
483		✗	msg.msg_namelen = dest_len;
484		✗	msg.msg_iov = iovecs;
485		✗	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
486
487			#ifdef MSG_NOSIGNAL
488		✗	int send_flags = msg_flags \| MSG_NOSIGNAL;
489			#else
490			int send_flags = msg_flags;
491			#endif
492
493			ssize_t n;
494		✗	do
495			{
496		✗	n = ::sendmsg(this->fd, &msg, send_flags);
497		✗	}
498		✗	while (n < 0 && errno == EINTR);
499
500		✗	if (n >= 0)
501		✗	this->complete(0, static_cast<std::size_t>(n));
502			else
503		✗	this->complete(errno, 0);
504		✗	}
505			};
506
507			/** Shared recv_from operation for datagram sockets.
508
509			Uses recvmsg() with msg_name to capture the source endpoint.
510
511			@tparam Base The backend's base op type.
512			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
513			*/
514			template<class Base, class Endpoint = endpoint>
515		392x	struct reactor_recv_from_op : Base
516			{
517			/// Maximum scatter-gather buffer count.
518			static constexpr std::size_t max_buffers = 16;
519
520			/// Scatter-gather I/O vectors.
521			iovec iovecs[max_buffers];
522
523			/// Number of active I/O vectors.
524		392x	int iovec_count = 0;
525
526			/// Source address storage filled by recvmsg.
527		392x	sockaddr_storage source_storage{};
528
529			/// Actual source address length returned by recvmsg.
530		392x	socklen_t source_addrlen = 0;
531
532			/// Output pointer for the source endpoint (set by do_recv_from).
533		392x	Endpoint* source_out = nullptr;
534
535			/// User-supplied message flags.
536		392x	int msg_flags = 0;
537
538			/// Return true (this is a read-direction operation).
539		✗	bool is_read_operation() const noexcept override
540			{
541		✗	return true;
542			}
543
544		68x	void reset() noexcept
545			{
546		68x	Base::reset();
547		68x	iovec_count = 0;
548		68x	source_storage = {};
549		68x	source_addrlen = 0;
550		68x	source_out = nullptr;
551		68x	msg_flags = 0;
552		68x	}
553
554		18x	void perform_io() noexcept override
555			{
556		18x	msghdr msg{};
557		18x	msg.msg_name = &source_storage;
558		18x	msg.msg_namelen = sizeof(source_storage);
559		18x	msg.msg_iov = iovecs;
560		18x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
561
562			ssize_t n;
563		18x	do
564			{
565	2/8 ✓ Branch 0 taken 5 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 13 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	18x	n = ::recvmsg(this->fd, &msg, msg_flags);
566		36x	}
567	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 13 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	18x	while (n < 0 && errno == EINTR);
568
569	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 13 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	18x	if (n >= 0)
570			{
571		18x	source_addrlen = msg.msg_namelen;
572		18x	this->complete(0, static_cast<std::size_t>(n));
573		18x	}
574			else
575		✗	this->complete(errno, 0);
576		18x	}
577			};
578
579			} // namespace boost::corosio::detail
580
581			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
582