Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.

BUG:215923


git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdelibs@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 140 insertions, 0 deletions

diff --git a/dnssd/query.cpp b/dnssd/query.cpp
new file mode 100644
index 000000000..bcb9c69f5
--- /dev/null
+++ b/dnssd/query.cpp
@@ -0,0 +1,140 @@
+/* This file is part of the KDE project
+ *
+ * Copyright (C) 2004 Jakub Stachowski <qbast@go2.pl>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library 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
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public License
+ * along with this library; see the file COPYING.LIB.  If not, write to
+ * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ * Boston, MA 02110-1301, USA.
+ */
+
+#include "query.h" 
+#include "responder.h"
+#include "remoteservice.h"
+#include "sdevent.h"
+#include <kdebug.h>
+#include <qapplication.h>
+#include <qtimer.h>
+
+#define TIMEOUT_WAN 2000
+#define TIMEOUT_LAN 200
+
+namespace DNSSD
+{
+#ifdef HAVE_DNSSD  
+void query_callback (DNSServiceRef, DNSServiceFlags flags, uint32_t, DNSServiceErrorType errorCode,
+		     const char *serviceName, const char *regtype, const char *replyDomain, void *context);
+#endif
+class QueryPrivate : public Responder
+{
+public:
+	QueryPrivate(const QString& type, const QString& domain) : Responder(), m_finished(false),
+	m_domain(domain), m_type(type)
+	{};
+	bool m_finished;
+	QString m_domain;
+	QTimer timeout;
+	QString m_type;
+};
+
+Query::Query(const QString& type, const QString& domain)
+{
+	d = new QueryPrivate(type,domain);
+	connect(&d->timeout,SIGNAL(timeout()),this,SLOT(timeout()));
+}
+
+
+Query::~Query()
+{
+	delete d;
+}
+
+bool Query::isRunning() const
+{
+	return d->isRunning();
+}
+
+bool Query::isFinished() const
+{
+	return d->m_finished;
+}
+
+const QString& Query::domain() const
+{
+	return d->m_domain;
+}
+
+void Query::startQuery()
+{
+	if (d->isRunning()) return;
+	d->m_finished = false;
+#ifdef HAVE_DNSSD
+	DNSServiceRef ref;
+	if (DNSServiceBrowse(&ref,0,0, d->m_type.ascii(), 
+	    domainToDNS(d->m_domain),query_callback,reinterpret_cast<void*>(this))
+		   == kDNSServiceErr_NoError) d->setRef(ref);
+#endif
+	if (!d->isRunning()) emit finished();
+		else d->timeout.start(domainIsLocal(d->m_domain) ? TIMEOUT_LAN : TIMEOUT_WAN,true);
+}
+void Query::virtual_hook(int, void*)
+{
+}
+
+void Query::customEvent(QCustomEvent* event)
+{
+	if (event->type()==QEvent::User+SD_ERROR) {
+		d->stop();
+		d->m_finished=false;
+		emit finished();
+	}
+	if (event->type()==QEvent::User+SD_ADDREMOVE) {
+		RemoteService* svr;
+		AddRemoveEvent *aev = static_cast<AddRemoveEvent*>(event);
+		// m_type has useless trailing dot
+		QString type=aev->m_type.left(aev->m_type.length()-1);
+		// label is badly splitted here - _http   _tcp.local. . - rely on decode()
+		if (d->m_type=="_services._dns-sd._udp") svr = new RemoteService(aev->m_name+"."+
+			type+"."+aev->m_domain);
+		else svr = new RemoteService(aev->m_name, type, aev->m_domain);
+		if (aev->m_op==AddRemoveEvent::Add) emit serviceAdded(svr);
+			else emit serviceRemoved(svr);
+		d->m_finished = aev->m_last;
+		if (d->m_finished) emit finished();
+	}
+}
+
+void Query::timeout()
+{
+	d->m_finished=true;
+	emit finished();
+}
+#ifdef HAVE_DNSSD
+void query_callback (DNSServiceRef, DNSServiceFlags flags, uint32_t, DNSServiceErrorType errorCode,
+		     const char *serviceName, const char *regtype, const char *replyDomain,
+		     void *context)
+{
+	QObject *obj = reinterpret_cast<QObject*>(context);
+	if (errorCode != kDNSServiceErr_NoError) {
+		ErrorEvent err;
+		QApplication::sendEvent(obj, &err);
+	} else {
+		AddRemoveEvent arev((flags & kDNSServiceFlagsAdd) ? AddRemoveEvent::Add :
+			AddRemoveEvent::Remove, QString::fromUtf8(serviceName), regtype, 
+			DNSToDomain(replyDomain), !(flags & kDNSServiceFlagsMoreComing));
+		QApplication::sendEvent(obj, &arev);
+	}
+}
+#endif
+}
+#include "query.moc"