diff --git a/src/libtomahawk/network/Servent.cpp b/src/libtomahawk/network/Servent.cpp index 260211279..96ae4a7eb 100644 --- a/src/libtomahawk/network/Servent.cpp +++ b/src/libtomahawk/network/Servent.cpp @@ -252,6 +252,7 @@ Servent::createConnectionKey( const QString& name, const QString &nodeid, const return _key; } + bool Servent::isValidExternalIP( const QHostAddress& addr ) { @@ -309,12 +310,14 @@ Servent::isValidExternalIP( const QHostAddress& addr ) return !addr.isNull(); } + void Servent::registerOffer( const QString& key, Connection* conn ) { d_func()->offers[key] = QPointer(conn); } + void Servent::registerLazyOffer(const QString &key, const peerinfo_ptr &peerInfo, const QString &nodeid, const int timeout ) { @@ -326,6 +329,7 @@ Servent::registerLazyOffer(const QString &key, const peerinfo_ptr &peerInfo, con timer->start(); } + void Servent::deleteLazyOffer( const QString& key ) { @@ -373,6 +377,7 @@ Servent::lookupControlConnection( const SipInfo& sipInfo ) return NULL; } + ControlConnection* Servent::lookupControlConnection( const QString& nodeid ) { @@ -423,6 +428,7 @@ Servent::getLocalSipInfos( const QString& nodeid, const QString& key ) return sipInfos; } + void Servent::queueForAclResult( const QString& username, const QSet& peerInfos ) { @@ -439,6 +445,7 @@ Servent::queueForAclResult( const QString& username, const QSet& p d_func()->queuedForACLResult[username][ (*peerInfos.begin())->nodeId() ] = QSet( peerInfos ); } + SipInfo Servent::getSipInfoForOldVersions( const QList& sipInfos ) { @@ -457,6 +464,7 @@ Servent::getSipInfoForOldVersions( const QList& sipInfos ) return info; } + void Servent::registerPeer( const Tomahawk::peerinfo_ptr& peerInfo ) { @@ -534,7 +542,8 @@ Servent::onSipInfoChanged() } -void Servent::handleSipInfo( const Tomahawk::peerinfo_ptr& peerInfo ) +void +Servent::handleSipInfo( const Tomahawk::peerinfo_ptr& peerInfo ) { // We do not have received the initial SipInfo for this client yet, so wait for it. // Each client will have at least one non-visible SipInfo @@ -544,6 +553,7 @@ void Servent::handleSipInfo( const Tomahawk::peerinfo_ptr& peerInfo ) ConnectionManager::getManagerForNodeId( peerInfo->nodeId() )->handleSipInfo( peerInfo ); } + void Servent::incomingConnection( int sd ) { @@ -784,6 +794,7 @@ Servent::socketConnected() handoverSocket( conn, sock ); } + // transfers ownership of socket to the connection and inits the connection void Servent::handoverSocket( Connection* conn, QTcpSocketExtra* sock ) @@ -804,6 +815,7 @@ Servent::handoverSocket( Connection* conn, QTcpSocketExtra* sock ) conn->start( sock ); } + void Servent::cleanupSocket( QTcpSocketExtra *sock ) { @@ -820,6 +832,7 @@ Servent::cleanupSocket( QTcpSocketExtra *sock ) sock->deleteLater(); } + void Servent::initiateConnection( const SipInfo& sipInfo, Connection* conn ) { @@ -868,6 +881,7 @@ Servent::initiateConnection( const SipInfo& sipInfo, Connection* conn ) sock->moveToThread( thread() ); } + void Servent::socketError( QAbstractSocket::SocketError e ) { @@ -898,6 +912,7 @@ Servent::socketError( QAbstractSocket::SocketError e ) } } + void Servent::checkACLResult( const QString& nodeid, const QString& username, ACLRegistry::ACL peerStatus ) { @@ -925,6 +940,7 @@ Servent::checkACLResult( const QString& nodeid, const QString& username, ACLRegi d_func()->queuedForACLResult[username].remove( nodeid ); } + void Servent::reverseOfferRequest( ControlConnection* orig_conn, const QString& theirdbid, const QString& key, const QString& theirkey ) { @@ -947,12 +963,14 @@ Servent::reverseOfferRequest( ControlConnection* orig_conn, const QString& their createParallelConnection( orig_conn, new_conn, theirkey ); } + bool Servent::visibleExternally() const { return (!d_func()->externalHostname.isNull()) || (d_func()->externalAddresses.length() > 0); } + bool Servent::ipv6ConnectivityLikely() const { @@ -967,30 +985,35 @@ Servent::ipv6ConnectivityLikely() const return false; } + int Servent::port() const { return d_func()->port; } + QList Servent::addresses() const { return d_func()->externalAddresses; } + QString Servent::additionalAddress() const { return d_func()->externalHostname; } + int Servent::additionalPort() const { return d_func()->externalPort; } + // return the appropriate connection for a given offer key, or NULL if invalid Connection* Servent::claimOffer( ControlConnection* cc, const QString &nodeid, const QString &key, const QHostAddress peer ) @@ -1219,12 +1242,14 @@ Servent::connectedToSession( const QString& session ) return false; } + unsigned int Servent::numConnectedPeers() const { return d_func()->controlconnections.length(); } + QList Servent::streams() const { @@ -1310,6 +1335,7 @@ Servent::httpIODeviceFactory( const Tomahawk::result_ptr& result, callback( sp ); } + bool Servent::isReady() const {