Relay Class Reference

Public Member Functions
bool	listen (std::string_view port)
	Relay ()
void	stop ()
	~Relay ()

Detailed Description

Definition at line 16 of file relay.cpp.

Constructor & Destructor Documentation

Relay()

Relay::Relay ( )

inline

Definition at line 18 of file relay.cpp.

            {
        std::cout << "relay: init.\n";
        mx_socket_ignore_pipe_signal();
    }

~Relay()

Relay::~Relay ( )

inline

Definition at line 22 of file relay.cpp.

             {
        std::cout << "relay: quit.\n";
    }

Member Function Documentation

listen()

bool Relay::listen ( std::string_view port )

inline

Definition at line 28 of file relay.cpp.

                                     {
        if (sockfd.listen(port, 5)) {
            active.store(true);
            std::vector<mxnetwork::Socket> sockets;
            Messages message(&sockets);
            std::thread background(std::move(message));
            while (active.load()) {
                std::optional<mxnetwork::Socket> new_s = sockfd.accept();
                if (new_s == std::nullopt) {
                    if (errno == EINTR)
                        continue;
                    active.store(false);
                    continue;
                }
                mut.lock();
                new_s->setblocking(false);
                sockets.push_back(std::move(*new_s));
                mut.unlock();
            }
            background.join();
        } else {
            perror("listen");
            return false;
        }
        return true;
    }

stop()

void Relay::stop ( )

inline

Definition at line 25 of file relay.cpp.

                {
        active.store(false);
    }

---

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

• MXNetwork/examples/relay/relay.cpp