REDROOM

Navigation

Breadcrumbs

/ / usr / include / c++ / 13 / experimental

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 5.74 KB

//usr/include/c++/13/experimental/timer

Text Base64

// <experimental/timer> -*- C++ -*-

// Copyright (C) 2015-2023 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library.  This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 3, or (at your option)
// any later version.

// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// Under Section 7 of GPL version 3, you are granted additional
// permissions described in the GCC Runtime Library Exception, version
// 3.1, as published by the Free Software Foundation.

// You should have received a copy of the GNU General Public License and
// a copy of the GCC Runtime Library Exception along with this program;
// see the files COPYING3 and COPYING.RUNTIME respectively.  If not, see
// <http://www.gnu.org/licenses/>.

/** @file experimental/timer
 *  This is a TS C++ Library header.
 *  @ingroup networking-ts
 */

#ifndef _GLIBCXX_EXPERIMENTAL_TIMER
#define _GLIBCXX_EXPERIMENTAL_TIMER 1

#pragma GCC system_header

#include <bits/requires_hosted.h> // experimental is currently omitted

#if __cplusplus >= 201402L

#include <bits/chrono.h>
#include <system_error>
#include <thread>
#include <experimental/netfwd>
#include <experimental/io_context>
#include <experimental/bits/net.h>

namespace std _GLIBCXX_VISIBILITY(default)
{
_GLIBCXX_BEGIN_NAMESPACE_VERSION
namespace experimental
{
namespace net
{
inline namespace v1
{

/** @addtogroup networking-ts
   *  @{
   */

template<typename _Clock>
    struct wait_traits
    {
      static typename _Clock::duration
      to_wait_duration(const typename _Clock::duration& __d)
      { return __d; }

static typename _Clock::duration
      to_wait_duration(const typename _Clock::time_point& __t)
      {
	auto __now = _Clock::now();
	auto __diff = __t - __now;
	if (__diff > _Clock::duration::max())
	  return _Clock::duration::max();
	if (__diff < _Clock::duration::min())
	  return _Clock::duration::min();
	return __diff;
      }
    };

template<typename _Clock, typename _WaitTraits>
    class basic_waitable_timer
    {
    public:
      // types:

using executor_type = io_context::executor_type;
      using clock_type = _Clock;
      using duration = typename clock_type::duration;
      using time_point = typename clock_type::time_point;
      using traits_type = _WaitTraits;

// construct / copy / destroy:

explicit
      basic_waitable_timer(io_context& __ctx)
      : _M_ex(__ctx.get_executor()), _M_expiry()
      { }

basic_waitable_timer(io_context& __ctx, const time_point& __t)
      : _M_ex(__ctx.get_executor()), _M_expiry(__t)
      { }

basic_waitable_timer(io_context& __ctx, const duration& __d)
      : _M_ex(__ctx.get_executor()), _M_expiry(_Clock::now() + __d)
      { }

basic_waitable_timer(const basic_waitable_timer&) = delete;

basic_waitable_timer(basic_waitable_timer&& __rhs)
      : _M_ex(std::move(__rhs._M_ex)), _M_expiry(__rhs._M_expiry)
      {
	_M_key.swap(__rhs._M_key);
	__rhs._M_expiry = time_point{};
      }

~basic_waitable_timer() { cancel(); }

basic_waitable_timer& operator=(const basic_waitable_timer&) = delete;

basic_waitable_timer&
      operator=(basic_waitable_timer&& __rhs)
      {
	if (this == std::addressof(__rhs))
	  return *this;
	cancel();
	_M_ex = std::move(__rhs._M_ex);
	_M_expiry = __rhs._M_expiry;
	__rhs._M_expiry = time_point{};
	_M_key.swap(__rhs._M_key);
	return *this;
      }

// basic_waitable_timer operations:

executor_type get_executor() noexcept { return _M_ex; }

size_t cancel() { return _M_ex.context().cancel(*this); }
      size_t cancel_one() { return _M_ex.context().cancel_one(*this); }

time_point expiry() const { return _M_expiry; }

size_t expires_at(const time_point& __t)
      {
	size_t __cancelled = cancel();
	_M_expiry = __t;
	return __cancelled;
      }

size_t expires_after(const duration& __d)
      { return expires_at(_Clock::now() + __d); }

void wait();
      void wait(error_code& __ec);

template<typename _CompletionToken>
	__deduced_t<_CompletionToken, void(error_code)>
	async_wait(_CompletionToken&& __token)
	{
	  async_completion<_CompletionToken, void(error_code)> __init(__token);
	  _M_ex.context().async_wait(*this,
				     std::move(__init.completion_handler));
	  return __init.result.get();
	}

private:
      executor_type _M_ex;
      time_point _M_expiry;

struct _Key { };  // TODO move _M_expiry into here?
      unique_ptr<_Key> _M_key{new _Key};

friend class io_context;
    };

using system_timer = basic_waitable_timer<chrono::system_clock>;
  using steady_timer = basic_waitable_timer<chrono::steady_clock>;
  using high_resolution_timer
    = basic_waitable_timer<chrono::high_resolution_clock>;

template<typename _Clock, typename _WaitTraits>
    void
    basic_waitable_timer<_Clock, _WaitTraits>::wait()
    {
      _M_ex.dispatch([this] {
	  while (clock_type::now() < _M_expiry)
	    this_thread::sleep_for(traits_type::to_wait_duration(_M_expiry));
      }, allocator<void>{});
    }

template<typename _Clock, typename _WaitTraits>
    void
    basic_waitable_timer<_Clock, _WaitTraits>::wait(error_code&)
    {
      _M_ex.dispatch([this] {
	  while (clock_type::now() < _M_expiry)
	    this_thread::sleep_for(traits_type::to_wait_duration(_M_expiry));
      }, allocator<void>{});
    }

/// @}

} // namespace v1
} // namespace net
} // namespace experimental
_GLIBCXX_END_NAMESPACE_VERSION
} // namespace std

#endif // C++14

#endif // _GLIBCXX_EXPERIMENTAL_TIMER

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 1 × Files: 42

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
bits DIR	-	drwxr-xr-x	2026-01-23 09:03:09	Edit Download recursive recursive
algorithm	3.67 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
any	15.72 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
array	3.36 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
buffer	28.12 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
chrono	2.03 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
contract	2.52 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
deque	2.31 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
executor	55.00 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
filesystem	1.62 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
forward_list	2.38 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
functional	12.08 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
internet	69.02 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
io_context	22.08 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
iterator	3.52 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
list	2.28 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
map	2.79 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
memory	5.97 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
memory_resource	17.54 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
net	1.58 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
netfwd	3.73 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
numeric	3.40 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
optional	26.06 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
propagate_const	16.73 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
random	2.61 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
ratio	2.45 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
regex	2.14 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
scope	14.17 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
set	2.66 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
simd	2.82 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
socket	76.42 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
source_location	2.78 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
string	2.92 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
string_view	21.96 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
synchronized_value	3.27 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
system_error	2.07 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
timer	5.74 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
tuple	2.48 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
type_traits	11.79 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
unordered_map	3.07 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
unordered_set	2.94 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
utility	1.76 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive
vector	2.37 KB	lrw-r--r--	2024-09-04 14:44:14	Edit Download recursive recursive