ETM-Schurig/powersync-core
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Clean up avahi debug messages

Browse Source
This commit is contained in:
Michael Zanetti 2019-04-12 11:59:28 +02:00
parent e7f7deadc3
commit b23d7c820e
8 changed files with 36 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
libnymea-core/hardware/network/avahi/qtavahiservice.cpp
View File

@ -1,6 +1,7 @@
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
* *
* Copyright (C) 2016 Simon Stürz <simon.stuerz@guh.io> *
* Copyright (C) 2019 Michael Zanetti <michael.zanetti@nymea.io> *
* *
* This file is part of nymea. *
* *
@ -61,7 +62,7 @@ namespace nymeaserver {
QtAvahiService::QtAvahiService(QObject *parent) :
QObject(parent),
d_ptr(new QtAvahiServicePrivate),
m_state(QtAvahiServiceStateUncomitted)
m_state(QtAvahiServiceStateUncommitted)
{
connect(this, &QtAvahiService::serviceStateChanged, this, &QtAvahiService::onStateChanged);
@ -71,9 +72,9 @@ QtAvahiService::QtAvahiService(QObject *parent) :
m_reregisterTimer.setInterval(60000);
m_reregisterTimer.setSingleShot(true);
connect(&m_reregisterTimer, &QTimer::timeout, this, [this](){
qCDebug(dcAvahi()) << "Re-registering services.";
resetService();
registerService(m_name, m_hostAddress, m_port, m_serviceType, m_txtRecords);
qCDebug(dcAvahiDebug()) << "Re-registering service" << this;
resetService(true);
registerService(m_name, m_hostAddress, m_port, m_serviceType, m_txtRecords, true);
});
}
@ -125,7 +126,7 @@ QtAvahiService::QtAvahiServiceState QtAvahiService::state() const
}
/*! Register a new \l{QtAvahiService} with the given \a name and \a port. The service type can be specified with the \a serviceType string. The \a txtRecords records inform about additional information. Returns true if the service could be registered. */
bool QtAvahiService::registerService(const QString &name, const QHostAddress &hostAddress, const quint16 &port, const QString &serviceType, const QHash<QString, QString> &txtRecords)
bool QtAvahiService::registerService(const QString &name, const QHostAddress &hostAddress, const quint16 &port, const QString &serviceType, const QHash<QString, QString> &txtRecords, bool silent)
{
// Check if the client is running
if (!d_ptr->client->m_client || AVAHI_CLIENT_S_RUNNING != avahi_client_get_state(d_ptr->client->m_client)) {
@ -166,7 +167,8 @@ bool QtAvahiService::registerService(const QString &name, const QHostAddress &ho
}
}
}
qCDebug(dcAvahi()) << "Registering avahi service" << name << hostAddress.toString() << port << serviceType << "on interface" << ifIndex;
qCDebug((silent ? dcAvahiDebug() : dcAvahi())) << "Registering avahi service" << name << hostAddress.toString() << port << serviceType << "on interface" << ifIndex;
d_ptr->serviceList = QtAvahiServicePrivate::createTxtList(txtRecords);
d_ptr->error = avahi_entry_group_add_service_strlst(d_ptr->group,
@ -184,7 +186,7 @@ bool QtAvahiService::registerService(const QString &name, const QHostAddress &ho
if (d_ptr->error) {
if (d_ptr->error == AVAHI_ERR_COLLISION) {
if (!handlCollision()) {
if (!handleCollision()) {
qCWarning(dcAvahi()) << this << "error:" << avahi_strerror(d_ptr->error);
return false;
}
@ -215,10 +217,14 @@ bool QtAvahiService::registerService(const QString &name, const QHostAddress &ho
}
/*! Remove this service from the local network. This \l{QtAvahiService} can be reused to register a new avahi service. */
void QtAvahiService::resetService()
void QtAvahiService::resetService(bool silent)
{
if (!d_ptr->group)
if (!d_ptr->group) {
qCWarning(dcAvahi()) << "Cannot unregister service. Service Group not existing.";
return;
}
qCDebug((silent ? dcAvahiDebug() : dcAvahi())) << "Unregistering service" << this;
if (d_ptr->serviceList) {
avahi_string_list_free(d_ptr->serviceList);
@ -286,7 +292,7 @@ QString QtAvahiService::errorString() const
return avahi_strerror(avahi_client_errno(d_ptr->client->m_client));
}
bool QtAvahiService::handlCollision()
bool QtAvahiService::handleCollision()
{
char* alt = avahi_alternative_service_name(name().toStdString().data());
QString alternativeServiceName = QLatin1String(alt);
@ -305,21 +311,21 @@ void QtAvahiService::onStateChanged(const QtAvahiServiceState &state)
m_state = state;
switch (m_state) {
case QtAvahiServiceStateUncomitted:
qCDebug(dcAvahi()) << this << "state changed: uncomitted";
case QtAvahiServiceStateUncommitted:
qCDebug(dcAvahiDebug()) << "Service state changed to Uncommitted:" << this;
break;
case QtAvahiServiceStateRegistering:
qCDebug(dcAvahi()) << this << "state changed: registering...";
qCDebug(dcAvahiDebug()) << "Service state changed to Registering:" << this;
break;
case QtAvahiServiceStateEstablished:
qCDebug(dcAvahi()) << this << "state changed: established";
qCDebug(dcAvahiDebug()) << "Service state changed to Established:" << this;
break;
case QtAvahiServiceStateCollision:
qCDebug(dcAvahi()) << this << "state changed: collision";
handlCollision();
qCDebug(dcAvahiDebug()) << "Service state changed to Collision:" << this;
handleCollision();
break;
case QtAvahiServiceStateFailure:
qCWarning(dcAvahi()) << this << "failure: " << errorString();
qCDebug(dcAvahiDebug()) << "Service state changed to Failure:" << this;
break;
}

9
libnymea-core/hardware/network/avahi/qtavahiservice.h
View File

@ -1,6 +1,7 @@
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
* *
* Copyright (C) 2016 Simon Stürz <simon.stuerz@guh.io> *
* Copyright (C) 2019 Michael Zanetti <michael.zanetti@nymea.io> *
* *
* This file is part of nymea. *
* *
@ -39,7 +40,7 @@ class QtAvahiService : public QObject
public:
enum QtAvahiServiceState {
QtAvahiServiceStateUncomitted = 0,
QtAvahiServiceStateUncommitted = 0,
QtAvahiServiceStateRegistering = 1,
QtAvahiServiceStateEstablished = 2,
QtAvahiServiceStateCollision = 3,
@ -57,8 +58,8 @@ public:
QHash<QString, QString> txtRecords() const;
QtAvahiServiceState state() const;
bool registerService(const QString &name, const QHostAddress &hostAddress, const quint16 &port, const QString &serviceType = "_http._tcp", const QHash<QString, QString> &txtRecords = QHash<QString, QString>());
void resetService();
bool registerService(const QString &name, const QHostAddress &hostAddress, const quint16 &port, const QString &serviceType = "_http._tcp", const QHash<QString, QString> &txtRecords = QHash<QString, QString>(), bool silent = false);
void resetService(bool silent = false);
bool updateTxtRecord(const QHash<QString, QString> &txtRecords);
@ -72,7 +73,7 @@ protected:
QtAvahiServicePrivate *d_ptr;
private slots:
bool handlCollision();
bool handleCollision();
void onStateChanged(const QtAvahiServiceState &state);
private:

4
libnymea-core/hardware/network/avahi/qtavahiservice_p.cpp
View File

@ -50,7 +50,7 @@ void QtAvahiServicePrivate::callback(AvahiEntryGroup *group, AvahiEntryGroupStat
switch (state) {
case AVAHI_ENTRY_GROUP_UNCOMMITED:
emit service->serviceStateChanged(QtAvahiService::QtAvahiServiceStateUncomitted);
emit service->serviceStateChanged(QtAvahiService::QtAvahiServiceStateUncommitted);
break;
case AVAHI_ENTRY_GROUP_REGISTERING:
emit service->serviceStateChanged(QtAvahiService::QtAvahiServiceStateRegistering);
@ -69,7 +69,7 @@ void QtAvahiServicePrivate::callback(AvahiEntryGroup *group, AvahiEntryGroupStat
AvahiStringList *QtAvahiServicePrivate::createTxtList(const QHash<QString, QString> &txt)
{
AvahiStringList *list = NULL;
AvahiStringList *list = nullptr;
if (txt.isEmpty())
return list;

4
libnymea-core/hardware/network/avahi/qtavahiservicebrowserimplementation.cpp
View File

@ -46,7 +46,7 @@ QtAvahiServiceBrowserImplementation::QtAvahiServiceBrowserImplementation(QObject
connect(d_ptr->client, &QtAvahiClient::clientStateChanged, this, &QtAvahiServiceBrowserImplementation::onClientStateChanged);
qCDebug(dcAvahi()) << "-->" << name() << "created successfully.";
qCDebug(dcAvahiDebug()) << "-->" << name() << "created successfully.";
}
/*! Destructs this \l{QtAvahiServiceBrowserImplementation}. */
@ -86,7 +86,7 @@ bool QtAvahiServiceBrowserImplementation::enabled() const
void QtAvahiServiceBrowserImplementation::onClientStateChanged(const QtAvahiClient::QtAvahiClientState &state)
{
if (state == QtAvahiClient::QtAvahiClientStateRunning) {
qCDebug(dcAvahi()) << "Service browser client connected.";
qCDebug(dcAvahiDebug()) << "Service browser client connected.";
// Return if we already have a service type browser
if (d_ptr->serviceTypeBrowser)
return;

2
libnymea-core/hardware/network/avahi/qtavahiservicebrowserimplementation_p.cpp
View File

@ -60,7 +60,7 @@ void QtAvahiServiceBrowserImplementationPrivate::callbackServiceTypeBrowser(Avah
case AVAHI_BROWSER_NEW:
if (!serviceBrowser->m_serviceTypes.contains(type)) {
serviceBrowser->m_serviceTypes.append(type);
qCDebug(dcAvahi()) << "[+] Service browser" << type;
qCDebug(dcAvahiDebug()) << "[+] Service browser" << type;
serviceBrowser->createServiceBrowser(type);
}
break;

1
libnymea/loggingcategories.cpp
View File

@ -42,6 +42,7 @@ Q_LOGGING_CATEGORY(dcJsonRpcTraffic, "JsonRpcTraffic")
Q_LOGGING_CATEGORY(dcRest, "Rest")
Q_LOGGING_CATEGORY(dcOAuth2, "OAuth2")
Q_LOGGING_CATEGORY(dcAvahi, "Avahi")
Q_LOGGING_CATEGORY(dcAvahiDebug, "AvahiDebug")
Q_LOGGING_CATEGORY(dcUpnp, "UPnP")
Q_LOGGING_CATEGORY(dcBluetooth, "Bluetooth")
Q_LOGGING_CATEGORY(dcCloud, "Cloud")

1
libnymea/loggingcategories.h
View File

@ -50,6 +50,7 @@ Q_DECLARE_LOGGING_CATEGORY(dcJsonRpcTraffic)
Q_DECLARE_LOGGING_CATEGORY(dcRest)
Q_DECLARE_LOGGING_CATEGORY(dcOAuth2)
Q_DECLARE_LOGGING_CATEGORY(dcAvahi)
Q_DECLARE_LOGGING_CATEGORY(dcAvahiDebug)
Q_DECLARE_LOGGING_CATEGORY(dcUpnp)
Q_DECLARE_LOGGING_CATEGORY(dcBluetooth)
Q_DECLARE_LOGGING_CATEGORY(dcCloud)

1
server/main.cpp
View File

@ -122,6 +122,7 @@ int main(int argc, char *argv[])
"TimeManager",
"Coap",
"Avahi",
"AvahiDebug",
"UPnP",
"Cloud",
"CloudTraffic",