◆ FsWatchAwaiter_()
uvco::FsWatch::FsWatchAwaiter_::FsWatchAwaiter_ |
( |
| ) |
|
static constexpr unsigned defaultCapacity
Definition fs.h:172
BoundedQueue< FileEvent > events_
Definition fs.h:186
◆ addError()
void uvco::FsWatch::FsWatchAwaiter_::addError |
( |
uv_status |
status | ) |
|
405 {
407 fmt::print(stderr, "uvco dropped FS event error {}", uv_strerror(status));
408 }
409 events_.put(FileEvent{status});
410}
◆ addEvent()
void uvco::FsWatch::FsWatchAwaiter_::addEvent |
( |
FileEvent |
event | ) |
|
412 {
414 fmt::print(stderr, "uvco dropped FS event on {} due to queue overload\n",
415 event.path);
416 return;
417 }
419}
◆ await_ready()
bool uvco::FsWatch::FsWatchAwaiter_::await_ready |
( |
| ) |
const |
377 {
379}
bool stopped_
Definition fs.h:187
◆ await_resume()
bool uvco::FsWatch::FsWatchAwaiter_::await_resume |
( |
| ) |
|
386 {
390}
std::optional< std::coroutine_handle<> > handle_
Definition fs.h:185
◆ await_suspend()
void uvco::FsWatch::FsWatchAwaiter_::await_suspend |
( |
std::coroutine_handle<> |
handle | ) |
|
◆ schedule()
void uvco::FsWatch::FsWatchAwaiter_::schedule |
( |
| ) |
|
392 {
394 std::coroutine_handle<> handle =
handle_.value();
397 }
398}
static void enqueue(std::coroutine_handle<> handle)
Definition loop.cc:73
◆ stop()
void uvco::FsWatch::FsWatchAwaiter_::stop |
( |
| ) |
|
400 {
403}
void schedule()
Definition fs.cc:392
◆ defaultCapacity
constexpr unsigned uvco::FsWatch::FsWatchAwaiter_::defaultCapacity = 128 |
|
staticconstexpr |
◆ 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 files: