uvco::FsWatch::FsWatchAwaiter_ Struct Reference

Collaboration diagram for uvco::FsWatch::FsWatchAwaiter_:

Public Member Functions
	FsWatchAwaiter_ ()
bool	await_ready () const
void	await_suspend (std::coroutine_handle<> handle)
bool	await_resume ()
void	schedule ()
void	stop ()
void	addError (uv_status status)
void	addEvent (FileEvent event)

Public Attributes
std::optional< std::coroutine_handle<> >	handle_
BoundedQueue< FileEvent >	events_
bool	stopped_ {}

Static Public Attributes
static constexpr unsigned	defaultCapacity = 128

Constructor & Destructor Documentation

FsWatchAwaiter_()

uvco::FsWatch::FsWatchAwaiter_::FsWatchAwaiter_

(

)

: events_{defaultCapacity} {}

Member Function Documentation

addError()

void uvco::FsWatch::FsWatchAwaiter_::addError

(

uv_status

status

)

                                                      {
  if (!events_.hasSpace()) {
    fmt::print(stderr, "uvco dropped FS event error {}", uv_strerror(status));
  }
  events_.put(FileEvent{status});
}

addEvent()

void uvco::FsWatch::FsWatchAwaiter_::addEvent

(

FileEvent

event

)

                                                     {
  if (!events_.hasSpace()) {
    fmt::print(stderr, "uvco dropped FS event on {} due to queue overload\n",
               event.path);
    return;
  }
  events_.put(std::move(event));
}

await_ready()

bool uvco::FsWatch::FsWatchAwaiter_::await_ready ( ) const

nodiscard

                                               {
  return stopped_ || !events_.empty();
}

await_resume()

bool uvco::FsWatch::FsWatchAwaiter_::await_resume

(

)

                                          {
  handle_.reset();
  BOOST_ASSERT(stopped_ || !events_.empty());
  return !stopped_;
}

await_suspend()

void uvco::FsWatch::FsWatchAwaiter_::await_suspend

(

std::coroutine_handle<>

handle

)

                                                                       {
  BOOST_ASSERT(!handle_);
  handle_ = handle;
}

schedule()

void uvco::FsWatch::FsWatchAwaiter_::schedule

(

)

                                      {
  if (handle_) {
    std::coroutine_handle<> handle = handle_.value();
    handle_.reset();
    Loop::enqueue(handle);
  }
}

stop()

void uvco::FsWatch::FsWatchAwaiter_::stop

(

)

                                  {
  stopped_ = true;
  schedule();
}

Member Data Documentation

defaultCapacity

unsigned uvco::FsWatch::FsWatchAwaiter_::defaultCapacity = 128

staticconstexpr

events_

BoundedQueue<FileEvent> uvco::FsWatch::FsWatchAwaiter_::events_

handle_

std::optional<std::coroutine_handle<> > uvco::FsWatch::FsWatchAwaiter_::handle_

stopped_

bool uvco::FsWatch::FsWatchAwaiter_::stopped_ {}

{};

---

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

• uvco/fs.cc