uvco::Udp::RecvAwaiter_ Struct Reference

Collaboration diagram for uvco::Udp::RecvAwaiter_:

Public Types
using	QueueItem_

Public Member Functions
	RecvAwaiter_ (uv_udp_t &udp, size_t queueSize=packetQueueSize)
	RecvAwaiter_ (const RecvAwaiter_ &)=default
	RecvAwaiter_ (RecvAwaiter_ &&)=delete
RecvAwaiter_ &	operator= (const RecvAwaiter_ &)=delete
RecvAwaiter_ &	operator= (RecvAwaiter_ &&)=delete
	~RecvAwaiter_ ()=default
bool	await_ready () const
bool	await_suspend (std::coroutine_handle<> handle)
std::optional< std::pair< std::string, AddressHandle > >	await_resume ()

Public Attributes
uv_udp_t &	udp_
BoundedQueue< QueueItem_ >	buffer_
std::optional< std::coroutine_handle<> >	handle_
bool	stop_receiving_ = true

Static Public Attributes
static constexpr unsigned	packetQueueSize = 128

Member Typedef Documentation

QueueItem_

using uvco::Udp::RecvAwaiter_::QueueItem_

Initial value:

 
      std::variant<std::pair<std::string, AddressHandle>, uv_status>

Constructor & Destructor Documentation

RecvAwaiter_() [1/3]

uvco::Udp::RecvAwaiter_::RecvAwaiter_ ( uv_udp_t & udp, size_t queueSize = packetQueueSize )

explicit

    : udp_{udp}, buffer_{queueSize} {}

RecvAwaiter_() [2/3]

uvco::Udp::RecvAwaiter_::RecvAwaiter_ ( const RecvAwaiter_ & )

default

RecvAwaiter_() [3/3]

uvco::Udp::RecvAwaiter_::RecvAwaiter_ ( RecvAwaiter_ && )

delete

~RecvAwaiter_()

uvco::Udp::RecvAwaiter_::~RecvAwaiter_ ( )

default

Member Function Documentation

await_ready()

bool uvco::Udp::RecvAwaiter_::await_ready ( ) const

nodiscard

{ return !buffer_.empty(); }

await_resume()

std::optional< std::pair< std::string, AddressHandle > > uvco::Udp::RecvAwaiter_::await_resume

(

)

                              {
  resetData(&udp_);
  // Woken up without read packet: stop receiving.
  if (buffer_.empty()) {
    return std::nullopt;
  }
  QueueItem_ item = buffer_.get();
  if (std::holds_alternative<uv_status>(item)) {
    throw UvcoException(std::get<uv_status>(item),
                        "Udp::RecvAwaiter_::await_resume: error during recv");
  }
  return std::get<std::pair<std::string, AddressHandle>>(item);
}

await_suspend()

bool uvco::Udp::RecvAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                                                {
  BOOST_ASSERT(dataIsNull(&udp_));
  setData(&udp_, this);
  BOOST_ASSERT(!handle_);
  handle_ = handle;
  return true;
}

operator=() [1/2]

RecvAwaiter_ & uvco::Udp::RecvAwaiter_::operator= ( const RecvAwaiter_ & )

delete

operator=() [2/2]

RecvAwaiter_ & uvco::Udp::RecvAwaiter_::operator= ( RecvAwaiter_ && )

delete

Member Data Documentation

buffer_

BoundedQueue<QueueItem_> uvco::Udp::RecvAwaiter_::buffer_

handle_

std::optional<std::coroutine_handle<> > uvco::Udp::RecvAwaiter_::handle_

packetQueueSize

unsigned uvco::Udp::RecvAwaiter_::packetQueueSize = 128

staticconstexpr

stop_receiving_

bool uvco::Udp::RecvAwaiter_::stop_receiving_ = true

udp_

uv_udp_t& uvco::Udp::RecvAwaiter_::udp_

---

The documentation for this struct was generated from the following file:

• uvco/udp.cc