multicastsession.cpp

#include "multicastsession.h"
#include "udpsocket.h"


MulticastSession::MulticastSession(UDPSocket* socket, QStringList* playlist)
: multicastSocket_(socket), playlist_(playlist),
  playlistIterator_(new QStringListIterator(*playlist_)), current_(NULL), nextBuff_(NULL),
  currentTimer_(0) {
    QString multicastAddr("234.5.6.8");
    multicastSocket_->listen(0);
    multicastSocket_->setDest(multicastAddr, 7000);
}

MulticastSession::~MulticastSession(){
    delete playlistIterator_;
    delete current_;
    delete nextBuff_;
}

void MulticastSession::start() {
    playlistIterator_ = new QStringListIterator(*playlist_);
    loadBuffer();
    currentTimer_ = startTimer(35);
}

void MulticastSession::pause() {
    if (currentTimer_ > 0) killTimer(currentTimer_);
}

void MulticastSession::timerEvent(QTimerEvent* event) {
    multicastSocket_->write(*nextBuff_);
    delete nextBuff_;
    nextBuff_ = NULL;
    loadBuffer();
}

void MulticastSession::loadBuffer() {
    if (current_ == NULL) {
        if (!playlistIterator_->hasNext()) {
            endSession();
            return;
        }
        current_ = new QFile(playlistIterator_->next());
        if (!current_->open(QIODevice::ReadOnly)) {
            endSession();
            return;
        }
        header_ = current_->read(44);
    }

    nextBuff_ = generateBuffer();
}

QByteArray* MulticastSession::generateBuffer() {
    QByteArray* tempArray = new QByteArray;
    tempArray->append(header_);
    tempArray->append(current_->read(1024*8));

    if(current_->atEnd()){
        current_->close();
        current_->deleteLater();
        current_=NULL;
    }
    return tempArray;
}

void MulticastSession::endSession() {
    qDebug("Multicastsession::closeSession(); Multicast session closed.");
    pause();
    this->deleteLater();
    multicastSocket_->deleteLater();
    multicastSocket_ = NULL;
}