fml::MessageLoopLinux Class Reference

#include <message_loop_linux.h>

Inheritance diagram for fml::MessageLoopLinux:

Private Member Functions
	~MessageLoopLinux () override
void	Run () override
void	Terminate () override
void	WakeUp (fml::TimePoint time_point) override

Additional Inherited Members
Public Member Functions inherited from fml::MessageLoopImpl
virtual	~MessageLoopImpl ()
void	PostTask (const fml::closure &task, fml::TimePoint target_time)
void	AddTaskObserver (intptr_t key, const fml::closure &callback)
void	RemoveTaskObserver (intptr_t key)
void	DoRun ()
void	DoTerminate ()
virtual TaskQueueId	GetTaskQueueId () const
Public Member Functions inherited from fml::Wakeable
virtual	~Wakeable ()
Public Member Functions inherited from fml::RefCountedThreadSafe< MessageLoopImpl >
void	Release () const
Public Member Functions inherited from fml::internal::RefCountedThreadSafeBase
void	AddRef () const
bool	HasOneRef () const
void	AssertHasOneRef () const
Static Public Member Functions inherited from fml::MessageLoopImpl
static fml::RefPtr< MessageLoopImpl >	Create ()
Protected Member Functions inherited from fml::MessageLoopImpl
void	RunExpiredTasksNow ()
void	RunSingleExpiredTaskNow ()
	MessageLoopImpl ()
Protected Member Functions inherited from fml::RefCountedThreadSafe< MessageLoopImpl >
	RefCountedThreadSafe ()
	~RefCountedThreadSafe ()
Protected Member Functions inherited from fml::internal::RefCountedThreadSafeBase
	RefCountedThreadSafeBase ()
	~RefCountedThreadSafeBase ()
bool	Release () const
void	Adopt ()

Detailed Description

Definition at line 16 of file message_loop_linux.h.

Member Function Documentation

Run()

void fml::MessageLoopLinux::Run ( )

overrideprivatevirtual

Implements fml::MessageLoopImpl.

Definition at line 46 of file message_loop_linux.cc.

                           {
  running_ = true;
 
  while (running_) {
    struct epoll_event event = {};
 
    int epoll_result = FML_HANDLE_EINTR(
        ::epoll_wait(epoll_fd_.get(), &event, 1, -1 /* timeout */));
 
    // Errors are fatal.
    if (event.events & (EPOLLERR | EPOLLHUP)) {
      running_ = false;
      continue;
    }
 
    // Timeouts are fatal since we specified an infinite timeout already.
    // Likewise, > 1 is not possible since we waited for one result.
    if (epoll_result != 1) {
      running_ = false;
      continue;
    }
 
    if (event.data.fd == timer_fd_.get()) {
      OnEventFired();
    }
  }
}

Terminate()

void fml::MessageLoopLinux::Terminate ( )

overrideprivatevirtual

Implements fml::MessageLoopImpl.

Definition at line 75 of file message_loop_linux.cc.

                                 {
  running_ = false;
  WakeUp(fml::TimePoint::Now());
}

WakeUp()

void fml::MessageLoopLinux::WakeUp ( fml::TimePoint  time_point )

overrideprivatevirtual

Implements fml::Wakeable.

Definition at line 81 of file message_loop_linux.cc.

                                                     {
  bool result = TimerRearm(timer_fd_.get(), time_point);
  (void)result;
  FML_DCHECK(result);
}

~MessageLoopLinux()

fml::MessageLoopLinux::~MessageLoopLinux ( )

overrideprivate

Definition at line 26 of file message_loop_linux.cc.

                                    {
  bool removed_source = AddOrRemoveTimerSource(false);
  FML_CHECK(removed_source);
}

---

The documentation for this class was generated from the following files:

• fml/platform/linux/message_loop_linux.h
• fml/platform/linux/message_loop_linux.cc