Connection.cpp

Go to the documentation of this file.

/*

Copyright (C) 2005-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 "Imports.h"
#include "Connection.h"

using namespace Protocols::Transports;

namespace Protocols {
namespace Transports {

class ConnectionPrivate
{
public:
    NodeAddress         remoteNodeAddress;
    Connection::State   state;

    ConnectionPrivate()
     :  remoteNodeAddress(), state (Connection::DisconnectedState)
    {}
} p;

} // namespace Transports;
} // namespace Protocols;

Connection::State Connection::state() const
{ return p->state; }

NodeAddress Connection::remoteNodeAddress() const
{ return p->remoteNodeAddress; }

void Connection::setState (Connection::State state)
{ p->state = state; }

void Connection::setRemoteNodeAddress (const NodeAddress &remoteNodeAddress)
{ p->remoteNodeAddress = remoteNodeAddress; }

Connection::Connection()
    : p (new ConnectionPrivate)
{
}

Connection::~Connection()
{
    //Q_ASSERT (state() == DisconnectedState);
}

void Connection::connectToNode (NodeAddress nodeAddress)
{
    Q_ASSERT (!nodeAddress.isNull());
    Q_ASSERT (p->state == DisconnectedState);

    p->remoteNodeAddress = nodeAddress;
    QHostAddress hostAddress = nodeAddress.hostAddress();
    if (hostAddress.isNull()) {
        setState (ResolvingHostNameState);
qDebug() << "Resolving " << nodeAddress.hostName();
        QHostInfo::lookupHost (nodeAddress.hostName(), this,
                               SLOT (lookupFinished (QHostInfo)));
    } else {
        setState (ConnectingState);
        doConnectToNode (nodeAddress);
    }
}

void Connection::lookupFinished (QHostInfo hostInfo)
{
    if (hostInfo.addresses().count() == 0) {
qDebug() << "Name resolution failed for " << hostInfo.hostName();
        emit connectionFailed();
        setState (DisconnectedState);
    } else {
        setState (ConnectingState);
        // \todo We now only try the first IP. Should we try more? How long to wait?
        QHostAddress hostAddress = hostInfo.addresses().first();
qDebug() << "Found address " << hostAddress.toString() << " for "<< hostInfo.hostName();
        // This call overwrites the hostName field of remoteNodeAddress:
        p->remoteNodeAddress.setHostAddress (hostAddress);
        // Call implementation:
        doConnectToNode (p->remoteNodeAddress);
    }
}

void Connection::disconnectFromNode()
{
    setState (DisconnectingState);
    doDisconnectFromNode();
}

bool Connection::isSequential() const
{
    return true;
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.