Ticket #13463: UdpMulticastSender_1_66.cpp

//
// server.cpp
// ~~~~~~~~~~
//
// Copyright (c) 2003-2017 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#define _CRT_SECURE_NO_WARNINGS
#include <ctime>
#include <iostream>
#include <string>
#include <boost/array.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/thread.hpp>
using boost::asio::ip::udp;
using std::cout;
using std::cin;
using std::endl;

class sender
{
private:
        boost::asio::ip::udp::endpoint endpoint_;
        boost::asio::ip::udp::socket socket_;
        boost::asio::steady_timer timer_;
        int message_count_;
        std::string message_;
        short multicast_port = 13000;   //30001
        int max_message_count = 10;

public:
        sender(boost::asio::io_context& io_context, const boost::asio::ip::address& multicast_address)
                : endpoint_(multicast_address, multicast_port),
                socket_(io_context, endpoint_.protocol()),
                timer_(io_context),
                message_count_(0)
        {
                //message_ = "abcd";
                //do_send();
                send_periodic();
        }

private:
        void do_send()
        {
                static int i = 0;
                cout << i << endl;      // show count
                ++i;

                std::ostringstream os;
                os << "Message " << message_count_++;
                message_ = os.str();

                socket_.async_send_to(boost::asio::buffer(message_), endpoint_, [this](boost::system::error_code ec, std::size_t /*length*/)
                {
                        //if (!ec && message_count_ < max_message_count)
                        if (!ec)
                                do_timeout();
                });
        }

        void do_timeout()
        {
                timer_.expires_after(std::chrono::seconds(1));
                timer_.async_wait([this](boost::system::error_code ec)
                {
                        if (!ec)
                                do_send();
                });
        }

        void send_periodic()
        {
                static int i = 0;
                message_ = some_string();

                socket_.async_send_to(boost::asio::buffer(message_), endpoint_, [this](boost::system::error_code ec, std::size_t /*length*/)
                {
                        //cout << i << endl;    // show count
                        cout << i << " - " << message_; // show  count
                        ++i;
                });

                timer_.expires_after(std::chrono::seconds(1));
                timer_.async_wait([this](boost::system::error_code ec)
                {
                        send_periodic();
                });
        }

        std::string make_daytime_string()
        {
                using namespace std; // For time_t, time and ctime;
                time_t now = time(0);
                return ctime(&now);
        }

        std::string some_string()
        {
                std::string result;
                // ====================================================
                //result = "abcd";
                // ====================================================
                //os << "Message " << message_count_++;
                //result = os.str();
                // ====================================================
                //std::stringstream ss;
                //ss << i;
                //result = ss.str();
                // ====================================================
                result = make_daytime_string();

                return result;
        }
};

int main(int argc, char* argv[])
{
        // ============================================================================================================
        try
        {
                //if (argc != 2)
                //{
                //      std::cerr << "Usage: sender <multicast_address>\n";
                //      std::cerr << "  For IPv4, try:\n";
                //      std::cerr << "    sender 239.255.0.1\n";
                //      std::cerr << "  For IPv6, try:\n";
                //      std::cerr << "    sender ff31::8000:1234\n";
                //      return 1;
                //}             

                boost::asio::io_context io_context;
                //sender s(io_context, boost::asio::ip::make_address(argv[1]));
                //sender s(io_context, boost::asio::ip::make_address("127.0.0.1"));
                //sender s(io_context, boost::asio::ip::make_address("239.255.0.1"));
                sender s(io_context, boost::asio::ip::make_address("192.168.0.255"));
                io_context.run();
        }
        catch (std::exception& e)
        {
                std::cerr << "Exception: " << e.what() << "\n";
        }

        return 0;
}