You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
165 lines
4.3 KiB
165 lines
4.3 KiB
// Copyright (c) 2002-2004 Rob Kaper <cap@capsi.com>
|
|
//
|
|
// This program is free software; you can redistribute it and/or
|
|
// modify it under the terms of the GNU General Public License
|
|
// version 2 as published by the Free Software Foundation.
|
|
//
|
|
// This program 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 this program; see the file COPYING. If not, write to
|
|
// the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
|
|
// Boston, MA 02110-1301, USA.
|
|
|
|
#include <tqdom.h>
|
|
#include <tqptrlist.h>
|
|
#include <tqregexp.h>
|
|
|
|
#include <kextendedsocket.h>
|
|
|
|
#include "monopigator.moc"
|
|
#include "main.h"
|
|
|
|
Monopigator::Monopigator()
|
|
{
|
|
m_downloadData = 0;
|
|
m_job = 0;
|
|
m_timer = 0;
|
|
}
|
|
|
|
Monopigator::~Monopigator()
|
|
{
|
|
if (m_job)
|
|
m_job -> kill();
|
|
delete m_downloadData;
|
|
m_downloadData=0L;
|
|
}
|
|
|
|
void Monopigator::loadData(const KURL &url)
|
|
{
|
|
delete m_downloadData;
|
|
m_downloadData = new TQBuffer();
|
|
m_downloadData->open(IO_WriteOnly);
|
|
m_downloadData->reset();
|
|
|
|
m_job = KIO::get(url, true, false);
|
|
m_job->addMetaData(TQString::fromLatin1("UserAgent"), TQString::fromLatin1("Atlantik/" ATLANTIK_VERSION_STRING));
|
|
|
|
if (!m_timer)
|
|
{
|
|
m_timer = new TQTimer(this);
|
|
m_timer->start(10000, true);
|
|
}
|
|
|
|
connect(m_job, TQT_SIGNAL(data(KIO::Job *, const TQByteArray &)), TQT_SLOT(slotData(KIO::Job *, const TQByteArray &)));
|
|
connect(m_job, TQT_SIGNAL(result(KIO::Job *)), TQT_SLOT(slotResult(KIO::Job *)));
|
|
connect(m_timer, TQT_SIGNAL(timeout()), TQT_SLOT(slotTimeout()));
|
|
}
|
|
|
|
void Monopigator::slotData(KIO::Job *, const TQByteArray &data)
|
|
{
|
|
m_timer->stop();
|
|
m_downloadData->writeBlock(data.data(), data.size());
|
|
}
|
|
|
|
void Monopigator::slotResult(KIO::Job *job)
|
|
{
|
|
processData(m_downloadData->buffer(), !job->error());
|
|
m_job = 0;
|
|
}
|
|
|
|
void Monopigator::slotTimeout()
|
|
{
|
|
if (m_job)
|
|
m_job -> kill();
|
|
m_job = 0;
|
|
|
|
emit timeout();
|
|
}
|
|
|
|
void Monopigator::processData(const TQByteArray &data, bool okSoFar)
|
|
{
|
|
if (okSoFar)
|
|
{
|
|
TQString xmlData(data);
|
|
TQDomDocument domDoc;
|
|
if (domDoc.setContent(xmlData))
|
|
{
|
|
TQDomElement eTop = domDoc.documentElement();
|
|
if (eTop.tagName() != "monopigator")
|
|
return;
|
|
|
|
TQDomNode n = eTop.firstChild();
|
|
while(!n.isNull())
|
|
{
|
|
TQDomElement e = n.toElement();
|
|
if(!e.isNull())
|
|
{
|
|
if (e.tagName() == "server")
|
|
emit monopigatorAdd(e.attributeNode(TQString("ip")).value(), e.attributeNode(TQString("host")).value(), e.attributeNode(TQString("port")).value(), e.attributeNode(TQString("version")).value(), e.attributeNode(TQString("users")).value().toInt());
|
|
}
|
|
n = n.nextSibling();
|
|
}
|
|
emit finished();
|
|
}
|
|
}
|
|
}
|
|
|
|
MonopigatorEntry::MonopigatorEntry(TQListView *parent, TQString host, TQString latency, TQString version, TQString users, TQString port, TQString ip) : TQObject(), TQListViewItem(parent, host, latency, version, users, port)
|
|
{
|
|
m_isDev = ( version.find( TQRegExp("(CVS|-dev)") ) != -1 ) ? true : false;
|
|
|
|
setEnabled(false);
|
|
parent->sort();
|
|
|
|
if ( !ip.isEmpty() )
|
|
host = ip;
|
|
m_latencySocket = new KExtendedSocket( host, port.toInt(), KExtendedSocket::inputBufferedSocket | KExtendedSocket::noResolve );
|
|
connect(m_latencySocket, TQT_SIGNAL(lookupFinished(int)), this, TQT_SLOT(resolved()));
|
|
connect(m_latencySocket, TQT_SIGNAL(connectionSuccess()), this, TQT_SLOT(connected()));
|
|
m_latencySocket->startAsyncConnect();
|
|
}
|
|
|
|
void MonopigatorEntry::resolved()
|
|
{
|
|
time.start();
|
|
}
|
|
|
|
void MonopigatorEntry::connected()
|
|
{
|
|
setText( 1, TQString::number(time.elapsed()) );
|
|
setEnabled(true);
|
|
listView()->sort();
|
|
delete m_latencySocket;
|
|
}
|
|
|
|
int MonopigatorEntry::compare(TQListViewItem *i, int col, bool ascending) const
|
|
{
|
|
// Colums 1 and 3 are integers (latency and users)
|
|
if (col == 1 || col == 3)
|
|
{
|
|
int myVal = text(col).toInt(), iVal = i->text(col).toInt();
|
|
if (myVal == iVal)
|
|
return 0;
|
|
else if (myVal > iVal)
|
|
return 1;
|
|
else
|
|
return -1;
|
|
}
|
|
return key( col, ascending ).compare( i->key( col, ascending) );
|
|
}
|
|
|
|
bool MonopigatorEntry::isDev() const
|
|
{
|
|
return m_isDev;
|
|
}
|
|
|
|
void MonopigatorEntry::showDevelopmentServers(bool show)
|
|
{
|
|
if ( isVisible() != show )
|
|
setVisible(show);
|
|
}
|