stream.h

#pragma once

#include "rtp_service.h"
#include "rtcp.h"
#include <boost\asio.hpp>
#include <boost\thread.hpp>

namespace media
{
    using namespace boost::asio;

    class rtp_packet;
    class rtcp_packet;

    class stream
    {
        rtp_service connections;
        uint32_t ssrc;
        
        rtcp rtcp;
        
        bool init;
        uint32_t remote_start_time;

        void start_rtp_receive();
        void start_rtcp_receive();
        void start_rtcp_timer();

        // This method performs the media loop-back by taking a received 
        // packet, modifying header fields and sending it to the RTP peer.
        void loop_rtp_packet(rtp_packet&);

        // This is called whenever an RTP packet is received.
        void rtp_received(rtp_packet&);

        // This is called whenever an RTCP packet is received.
        void rtcp_received(rtcp_packet&);

    public:
        stream(boost::asio::io_service&, const char* cname);
        ~stream();

        // Opens RTP and RTCP sockets for a single stream
        void open(const ip::address& iface, int& rtp_port, int& rtcp_port);

        // Starts send/receive operations on all streams.  Any calls to 
        // open() must be made prior to calling this method.
        void start(const ip::udp::endpoint rtp_peer, const ip::udp::endpoint rtcp_peer);

        // Same as above, but doesn't send anything until something is 
        // received from a remote peer (in order to determine the remote 
        // address/port).  This is particularly useful for loopback.
        void start();

        // Schedules an RTCP BYE message to be sent.  The message won't 
        // necessarily be sent upon return of this method, as it occurrs in 
        // the context of another thread.
        void bye();

        // Stops the stream by completing/canceling any outstanding 
        // operations, closing sockets, etc.
        void stop();
    };
}