fc::udt_epoll_service Class Reference

Public Member Functions
	udt_epoll_service ()
	~udt_epoll_service ()
void	poll_loop ()
void	notify_read (int udt_socket_id, const promise< void >::ptr &p)
void	notify_write (int udt_socket_id, const promise< void >::ptr &p)
void	remove (int udt_socket_id)

Detailed Description

Definition at line 25 of file udt_socket.cpp.

Constructor & Destructor Documentation

udt_epoll_service()

fc::udt_epoll_service::udt_epoll_service ( )

inline

Definition at line 28 of file udt_socket.cpp.

         :_epoll_thread("udt_epoll")
         {
            UDT::startup();
            check_udt_errors();
            _epoll_id = UDT::epoll_create();
            _epoll_loop = _epoll_thread.async( [=](){ poll_loop(); }, "udt_poll_loop" );
         }

Here is the call graph for this function:

~udt_epoll_service()

fc::udt_epoll_service::~udt_epoll_service ( )

inline

Definition at line 37 of file udt_socket.cpp.

         {
            _epoll_loop.cancel("udt_epoll_service is destructing");
            _epoll_loop.wait();
            UDT::cleanup();
         }

Member Function Documentation

notify_read()

void fc::udt_epoll_service::notify_read ( int udt_socket_id, const promise< void >::ptr & p )

inline

Definition at line 81 of file udt_socket.cpp.

         {
            int events = UDT_EPOLL_IN | UDT_EPOLL_ERR;
            if( 0 != UDT::epoll_add_usock( _epoll_id, 
                                           udt_socket_id, 
                                           &events ) )
            {
               check_udt_errors();
            }
            { synchronized(_read_promises_mutex)
 
               _read_promises[udt_socket_id] = p;
            }
         }

Here is the call graph for this function:

notify_write()

void fc::udt_epoll_service::notify_write ( int udt_socket_id, const promise< void >::ptr & p )

inline

Definition at line 97 of file udt_socket.cpp.

         {
            int events = UDT_EPOLL_OUT | UDT_EPOLL_ERR;
            if( 0 != UDT::epoll_add_usock( _epoll_id, 
                                  udt_socket_id, 
                                  &events ) )
            {
              check_udt_errors();
            }
 
            { synchronized(_write_promises_mutex)
               _write_promises[udt_socket_id] = p;
            }
         }

Here is the call graph for this function:

poll_loop()

void fc::udt_epoll_service::poll_loop ( )

inline

Definition at line 44 of file udt_socket.cpp.

         {
            std::set<UDTSOCKET> read_ready;
            std::set<UDTSOCKET> write_ready;
            while( !_epoll_loop.canceled() )
            {
               UDT::epoll_wait( _epoll_id, 
                                &read_ready, 
                                &write_ready, 100000000 );
 
               { synchronized(_read_promises_mutex)
                  for( auto sock : read_ready )
                  {
                     auto itr = _read_promises.find( sock );
                     if( itr != _read_promises.end() )
                     {
                        itr->second->set_value();
                        _read_promises.erase(itr);
                     }
                  }
               } // synchronized read promise mutex
 
               { synchronized(_write_promises_mutex)
                  for( auto sock : write_ready )
                  {
                     auto itr = _write_promises.find( sock );
                     if( itr != _write_promises.end() )
                     {
                        itr->second->set_value();
                        _write_promises.erase(itr);
                     }
                  }
               } // synchronized write promise mutex
            } // while not canceled
         } // poll_loop

Here is the caller graph for this function:

remove()

void fc::udt_epoll_service::remove ( int udt_socket_id )

inline

Definition at line 112 of file udt_socket.cpp.

         {
             { synchronized(_read_promises_mutex)
                auto read_itr = _read_promises.find( udt_socket_id );
                if( read_itr != _read_promises.end() )
                {
                   read_itr->second->set_exception( fc::copy_exception( fc::exception() ) );
                   _read_promises.erase(read_itr);
                }
             }
             { synchronized(_write_promises_mutex)
                auto write_itr = _write_promises.find( udt_socket_id );
                if( write_itr != _write_promises.end() )
                {
                   write_itr->second->set_exception( fc::copy_exception( fc::exception() ) );
                   _write_promises.erase(write_itr);
                }
             }
             UDT::epoll_remove_usock( _epoll_id, udt_socket_id );
         }

Here is the call graph for this function:

---

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

• libraries/fc/src/network/udt_socket.cpp