recv.cpp File Reference

#include "mxnetwork/socket.hpp"
#include <atomic>
#include <cstdlib>
#include <iostream>
#include <signal.h>
#include <string>
#include <vector>
#include <sys/socket.h>

Go to the source code of this file.

Functions
void	exit_signal (int)
int	main (int argc, char **argv)

Variables
std::atomic< bool >	active_loop {false}

Function Documentation

exit_signal()

void exit_signal

(

int

)

Definition at line 27 of file recv.cpp.

                      {
    active_loop.store(false);
}

main()

int main	(	int	argc,
		char **	argv )

Definition at line 32 of file recv.cpp.

                                {
 
    if (argc != 2) {
        std::cerr << "Usage: " << argv[0] << " <path>\n";
        return EXIT_FAILURE;
    }
#ifdef _WIN32
    if (!SetConsoleCtrlHandler(console_handler, TRUE)) {
        std::cerr << "Error setting console handler\n";
        return EXIT_FAILURE;
    }
#else
    struct sigaction sa = {};
    sa.sa_handler = exit_signal;
    sa.sa_flags = 0;
    if (sigaction(SIGINT, &sa, nullptr) == -1) {
        perror("sigaction");
        return EXIT_FAILURE;
    }
#endif
    try {
        mxnetwork::Socket sock(mxnetwork::SocketType::TYPE_UNIX_DGRAM);
        if (sock.bind_unix(argv[1])) {
            std::cout << "Listening for UDP datagram on port " << argv[1] << "...\n";
            std::vector<uint8_t> buffer(65536);
            active_loop.store(true);
            while (active_loop.load()) {
                ssize_t bytes = sock.recvfrom(buffer.data(), buffer.size());
                if (bytes > 0) {
                    std::cout << "Received " << bytes << " bytes.\n";
                    std::string data(buffer.begin(), buffer.end());
                    std::cout << "Data: " << data;
                } else if (bytes < 0) {
                    if (errno == EINTR)
                        continue;
                    std::cerr << "read error.\n";
                    break;
                }
            }
        }
    } catch (const mxnetwork::Exception &e) {
        std::cerr << "Exception: " << e.text() << "\n";
        return EXIT_FAILURE;
    }
    return EXIT_SUCCESS;
}

Variable Documentation

active_loop

std::atomic<bool> active_loop {false}

Definition at line 17 of file recv.cpp.

{false};