Принять по UDP multicast медиа-поток MPEG2-TS

#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
 
using namespace std;
 
int main()
{
    int sock;
 
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
    {
        perror("socket");
        return -1;
    }
    cout << "Socket was created." << endl;
 
    const int optival = 1;
    setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &optival, sizeof(optival));
 
    struct sockaddr_in addr;
    bzero(&addr, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = inet_addr("10.10.20.14");
 
    bind(sock, (sockaddr *)&addr, sizeof(addr));
 
    struct ip_mreq mreq;
    mreq.imr_interface.s_addr = inet_addr("127.0.0.1");
    mreq.imr_multiaddr.s_addr = inet_addr("237.7.7.7");
 
   if ((setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq))) != 0)
   {
       perror("multicast");
       return -2;
   }
   cout << "Join to multicast group." << endl;
 
   close(sock);
 
    return 0;
}

struct sockaddr_in addr;
    bzero(&addr, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = inet_addr("10.10.20.14");

struct ip_mreq mreq;

addr.sin_family = AF_INET;
addr.sin_port = htons(10700);
addr.sin_addr.s_addr = htonl(INADDR_ANY);

mreq.imr_interface.s_addr = inet_addr("10.10.20.14") //адрес машины, с которой идет вещание, да?;
mreq.imr_multiaddr.s_addr = inet_addr("237.7.7.7"); //udp адрес, по которому идет вещание

addr.sin_family = AF_INET;
addr.sin_port = htons(554);
addr.sin_addr.s_addr = inet_addr("10.10.20.14");

bind(sock, (struct sockaddr *)&addr, sizeof(addr)

setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq))

#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
 
#include <errno.h>
#include <poll.h>
#include <fcntl.h>
 
using namespace std;
 
#define BUFF_SIZE 1024
#define ASYNC_READ_TO_MSEC 5000
 
char buffer[BUFF_SIZE];
 
/// Sync reading
void sync_reading(int sock) 
{
 
    size_t bytes2read(BUFF_SIZE);
   
    cout << "Socket reading started" << endl;
    for(;;) {
        int s = read(sock, buffer, bytes2read);
        if( 0 > s
            && EAGAIN != errno
            ) 
        {
            perror("reading socket");
            break;
        }
        // ........ Received piece of broadcasting data is in buffer now. 
        cout << "read " << s << " bytes" << endl;
    }
    cout << "Socket reading complete" << endl;    
}
 
/// Async reading.
void async_reading(int sock, int timeout)
{
    if( -1 == fcntl(sock, F_SETFL, O_NONBLOCK) ) {
        perror("seting non-block state");
        return;
    }
 
    for(;;) {
        size_t bytes2read(BUFF_SIZE);
        struct pollfd pollfd[1];
        pollfd[0].fd = sock;
        pollfd[0].events = POLLIN | POLLRDNORM;
    
        int nevents = poll(pollfd, 1, timeout);
        if( 1 == nevents 
            && pollfd[0].revents & (POLLIN | POLLRDNORM)
            ) 
        {
            int s = read(sock, buffer, bytes2read);
            if(0 <= s) {
                // ........ Received piece of broadcasting data is in buffer now. 
                cout << "read " << s << " bytes" << endl;
            } else if(errno == EAGAIN || errno == EWOULDBLOCK) // This error is OK for async read
                continue;   
            else {
                perror("async-reading socket");
                break;
            }
                
        } else {
            cout << "Timeout (" << timeout << "msec) elapsed while broadcast start/continue awaiting" << endl;
            break;
        }
    }
}
 
int main()
{
    int sock;
 
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
    {
        perror("socket");
        return -1;
    }
    cout << "Socket was created." << endl;
 
    const int optival = 1;
    setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &optival, sizeof(optival));
 
    struct sockaddr_in addr;
    bzero(&addr, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = inet_addr("237.7.7.7"); // Multicast-group address here.
 
    bind(sock, (sockaddr *)&addr, sizeof(addr));
 
    struct ip_mreq mreq; // Use ip_mreqn, instead. Avail since v.2.2 kernel. See "man 7 ip" 
    mreq.imr_interface.s_addr = INADDR_ANY; //inet_addr("192.168.1.4"); ///< YOUR PC local address(or INADDR_ANY to let the kernel to make choice). I.e. your client host address (not the TV broadcasting server) 
    mreq.imr_multiaddr.s_addr = inet_addr("237.7.7.7");   ///< Multicast-group address where TV server is broadcasting to and which we should to join with
    if ((setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq))) != 0)
    {
        perror("multicast");
        return -2;
    }
    cout << "Joined to multicast group." << endl;
 
    // Next, use one of sync_reading or async_reading (see 2 funcs above)
    // sync_readig(sock);
    async_reading(sock, ASYNC_READ_TO_MSEC);
 
    close(sock);
 
    return 0;
}