TrackerManagerImpl.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 "TrackerManagerImpl.h"
#include "Imports.cpp"


TrackerManagerImpl::TrackerManagerImpl (
                        TrackerRequestSessionFactory *peersRequestSessionFactory,
                        Timer *trackerUpdateTimer,
                        TrackerManagerStatus *trackerManagerStatus)
    : sessionFactory_ (peersRequestSessionFactory), timer_ (trackerUpdateTimer),
      status_ (trackerManagerStatus), session_ (0), state_ (Stopped),
      torrent_(), updateInterval_ (0), trackerId_()
{
}


TrackerManagerImpl::~TrackerManagerImpl()
{
}


void TrackerManagerImpl::start (const Torrent &torrent)
{
    state_ = Started;
    torrent_ = torrent;
    session_ = sessionFactory_->createSession (torrent_);
    session_->open();
}


void TrackerManagerImpl::stop()
{
    state_ = Stopping;
    timer_->stop();
    if (session_ != 0)
        session_->close();
}


void TrackerManagerImpl::updateTime()
{
    Q_ASSERT (state_ == Started);

    timer_->stop();
    session_->sendRequest (createTrackerRequest());
    timer_->start (0, updateInterval_);
}


void TrackerManagerImpl::trackerRequestSessionFactorySessionEstablished (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (session_ == session);
    Q_ASSERT (state_ == Started);

    session_->sendRequest (createTrackerRequest());
}


void TrackerManagerImpl::trackerRequestSessionFactorySessionError (
                                                TrackerRequestSession *session,
                                                const QString &errorMessage)
{
    Q_ASSERT (session_ == session);
    Q_ASSERT (state_ != Stopped);

    status_->trackerManagerError (errorMessage);
}


void TrackerManagerImpl::trackerRequestSessionFactoryResponseRecieved (
                                                TrackerRequestSession *session,
                                                const TrackerResponse &response)
{
    Q_ASSERT (session_ == session);
    Q_ASSERT (state_ == Started);

    timer_->stop();

    // Update necessary info (that must be stored) from the response
    updateInterval_ = response.interval();
    if (!response.trackerId().isEmpty())
        trackerId_ = response.trackerId();

    status_->trackerManagerFoundPeers (response.peers());
    timer_->start (0, updateInterval_);
}


void TrackerManagerImpl::trackerRequestSessionFactorySessionClosing (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (session_ == session);
    Q_ASSERT (state_ != Stopped);

    state_ = Stopping;
    timer_->stop();
}


void TrackerManagerImpl::trackerRequestSessionFactorySessionClosed (
                                                TrackerRequestSession *session)
{
    Q_ASSERT (session_ == session);
    Q_ASSERT (state_ != Stopped);

    state_ = Stopped;
    timer_->stop();
    sessionFactory_->destroySession (session_);
}


TrackerRequest TrackerManagerImpl::createTrackerRequest() const
{
    return TrackerRequest (
        Uri::fromUnencoded ("http://localhost/announce.php"),
        PeerInfo ("1.2.3.4", 6881, PeerInfo::PeerId ("-CA0610-574938205849")),
        Torrent::InfoHash ("z53bf64bd05hfn2daqml"),
        4096,
        2048,
        63488,
        false,
        TrackerRequest::Empty,
        0,
        QByteArray(),
        trackerId_);
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.