send.cpp

Go to the documentation of this file.

#include "udp_bc_broker/send.h"

using namespace std;

namespace udp_bc_broker{

    UdpSender::UdpSender(int port)
    {
        setvbuf(stdout, NULL, _IONBF, 0);
        fflush(stdout);

        sock = -1;
        if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
            cout<<"socket is error!"<<endl;
            exit(-1);
        }

        const int opt = 1;
        int nb = 0;
        nb = setsockopt(sock, SOL_SOCKET, SO_BROADCAST, (char *)&opt, sizeof(opt));
        if(nb == -1) {
            cout<<"set socket error!"<<endl;
            exit(-1);
        }

        bzero(&addrto, sizeof(struct sockaddr_in));
        addrto.sin_family = AF_INET;
        addrto.sin_addr.s_addr = htonl(INADDR_BROADCAST);
        addrto.sin_port = htons(port);
        nlen = sizeof(addrto);
    };

    void UdpSender::send(const char* msg, int len)
    {
        int ret = sendto(sock, msg, len, 0, (sockaddr*)&addrto, nlen);
        if(ret < 0) {
            cout<<"send error, ret = "<<ret<<endl;
        }
        else {
            /*cout<<"send msg len: "<<len<<", data: ";

            for(int i = 0; i < ret; i++) {
                std::cout<<(int)msg[i];
            }
            std::cout<<endl;*/
        }
    }
};