Collaboration diagram for sysio::chain::eosvmoc::compile_monitor:

Public Member Functions
	compile_monitor (boost::asio::io_context &ctx, local::datagram_protocol::socket &&n, wrapped_fd &&t)

void	wait_for_new_incomming_session (boost::asio::io_context &ctx)

Public Attributes
local::datagram_protocol::socket	_nodeop_socket

wrapped_fd	_trampoline_socket

std::list< compile_monitor_session >	_compile_sessions

Detailed Description

Definition at line 185 of file compile_monitor.cpp.

Constructor & Destructor Documentation

◆ compile_monitor()

sysio::chain::eosvmoc::compile_monitor::compile_monitor	(	boost::asio::io_context &	ctx,
		local::datagram_protocol::socket &&	n,
		wrapped_fd &&	t )

inline

Definition at line 186 of file compile_monitor.cpp.

                                                                                               : _nodeop_socket(std::move(n)), _trampoline_socket(std::move(t)) {
      //the only duty of compile_monitor is to create a compile_monitor_session when a code_cache instance
      // in nodeop wants one
      wait_for_new_incomming_session(ctx);
   }

Here is the call graph for this function:

Member Function Documentation

◆ wait_for_new_incomming_session()

void sysio::chain::eosvmoc::compile_monitor::wait_for_new_incomming_session ( boost::asio::io_context & ctx )

inline

Definition at line 192 of file compile_monitor.cpp.

                                                                 {
      _nodeop_socket.async_wait(boost::asio::local::datagram_protocol::socket::wait_read, [this, &ctx](auto ec) {
         if(ec) {
            ctx.stop();
            return;
         }
         auto [success, message, fds] = read_message_with_fds(_nodeop_socket);
         if(!success) {   //failure reading indicates that nodeop has shut down
            ctx.stop();
            return;
         }
         if(!std::holds_alternative<initialize_message>(message) || fds.size() != 2) {
            ctx.stop();
            return;
         }
         try {
            local::datagram_protocol::socket _socket_for_comm(ctx);
            _socket_for_comm.assign(local::datagram_protocol(), fds[0].release());
            _compile_sessions.emplace_front(ctx, std::move(_socket_for_comm), std::move(fds[1]), _trampoline_socket);
            _compile_sessions.front().connection_dead_signal.connect([&, it = _compile_sessions.begin()]() {
               ctx.post([&]() {
                  _compile_sessions.erase(it);
               });
            });
            write_message_with_fds(_nodeop_socket, initalize_response_message());
         }
         catch(const std::exception& e) {
            write_message_with_fds(_nodeop_socket, initalize_response_message{e.what()});
         }
         catch(...) {
            write_message_with_fds(_nodeop_socket, initalize_response_message{"Failed to create compile process"});
         }
 
         wait_for_new_incomming_session(ctx);
      });
   }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ _compile_sessions

std::list<compile_monitor_session> sysio::chain::eosvmoc::compile_monitor::_compile_sessions

Definition at line 232 of file compile_monitor.cpp.

◆ _nodeop_socket

local::datagram_protocol::socket sysio::chain::eosvmoc::compile_monitor::_nodeop_socket

Definition at line 229 of file compile_monitor.cpp.

◆ _trampoline_socket

wrapped_fd sysio::chain::eosvmoc::compile_monitor::_trampoline_socket

Definition at line 230 of file compile_monitor.cpp.

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

libraries/chain/webassembly/runtimes/sys-vm-oc/compile_monitor.cpp

Public Member Functions

Public Attributes