TrackerRequestSessionFactoryImpl.cpp

Go to the documentation of this file.

/*

Copyright (C) 2006-2007 by Peter Dimov.

This file is part of Calitko (http://www.calitko.org).

Calitko is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

Calitko is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with Calitko; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

*/

#include "Qt.h"
#include "MultiTrackerRequestSession.h"
#include "SingleTrackerRequestSession.h"
#include "TrackerRequestSessionFactoryImpl.h"
#include "Imports.cpp"


TrackerRequestSessionFactoryImpl::TrackerRequestSessionFactoryImpl (
                TrackerRequestSessionFactoryStatus *trackerRequestFactorySessionStatus)
    : status_ (trackerRequestFactorySessionStatus),
      sessionsStorage_()
{
}


TrackerRequestSessionFactoryImpl::~TrackerRequestSessionFactoryImpl()
{
    foreach (TrackerRequestSession *session, sessionsStorage_.keys())
        destroySession (session);
}


TrackerRequestSession *TrackerRequestSessionFactoryImpl::createSession (
                                                        const Torrent &torrent)
{
    // Create data needed in the session ctor
    // \todo Implement real HttpRequestSession and TrackerRequestSessionStatus
    // instance creation.
    auto_ptr <HttpRequestSession> httpRequestSession;
    auto_ptr <TrackerRequestSessionStatus> trackerRequestSessionStatus;
    TrackerRequestSessionData sessionData (
        httpRequestSession.get(), trackerRequestSessionStatus.get());

    // Choose the correct session type and create an instance of it
    auto_ptr <TrackerRequestSession> session;
    if (!torrent.announceList().isEmpty()) {
        session.reset (new MultiTrackerRequestSession (httpRequestSession.get(),
            torrent.announceList(), trackerRequestSessionStatus.get()));
    } else if (torrent.announce() != Uri()) {
        session.reset (new SingleTrackerRequestSession (httpRequestSession.get(),
            torrent.announce(), trackerRequestSessionStatus.get()));
    } else {
        Q_ASSERT (false); // Invalid (empty) torrent passed!
    }

    // Store the session with its data for later usage
    sessionsStorage_.insert (session.get(), sessionData);

    // Release the session data (they're now owned by the sessionsStorage_)
    httpRequestSession.release();
    trackerRequestSessionStatus.release();

    // Session is now owned by the sessionsStorage_ too, so we can release it
    return session.release();
}


void TrackerRequestSessionFactoryImpl::destroySession (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (isHoldedSession (session));

    TrackerRequestSessionData sessionData = sessionsStorage_.take (session);
    delete sessionData.first;
    delete sessionData.second;
    delete session;
}


uint TrackerRequestSessionFactoryImpl::holdedSessionsCount() const
{
    return sessionsStorage_.size();
}


void TrackerRequestSessionFactoryImpl::trackerRequestSessionEstablished (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (isHoldedSession (session));

    status_->trackerRequestSessionFactorySessionEstablished (session);
}


void TrackerRequestSessionFactoryImpl::trackerRequestSessionError (
                    TrackerRequestSession *session, const QString &errorMessage)
{
    Q_ASSERT (isHoldedSession (session));

    status_->trackerRequestSessionFactorySessionError (session, errorMessage);
}


void TrackerRequestSessionFactoryImpl::trackerRequestSessionResponseRecieved (
        TrackerRequestSession *session, const TrackerResponse &trackerResponse)
{
    Q_ASSERT (isHoldedSession (session));

    status_->trackerRequestSessionFactoryResponseRecieved (session,
        trackerResponse);
}


void TrackerRequestSessionFactoryImpl::trackerRequestSessionClosing (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (isHoldedSession (session));

    status_->trackerRequestSessionFactorySessionClosing (session);
}


void TrackerRequestSessionFactoryImpl::trackerRequestSessionClosed (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (isHoldedSession (session));

    status_->trackerRequestSessionFactorySessionClosed (session);
}


bool TrackerRequestSessionFactoryImpl::isHoldedSession (
                                        TrackerRequestSession *session) const
{
    return sessionsStorage_.contains (session);
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.