summaryrefslogtreecommitdiff
path: root/daemon/watchconnector.cpp
diff options
context:
space:
mode:
authorJavier <dev.git@javispedro.com>2014-12-08 00:16:06 +0100
committerJavier <dev.git@javispedro.com>2014-12-08 00:16:06 +0100
commit4280a9bda38046f702a4151d7b831a3bf46ef169 (patch)
treee6ebe76e2eb834a648dc2907c077a28264c4f8d8 /daemon/watchconnector.cpp
parenta60c1cb3c4afd6dfd305115ec4c52e993172fa7d (diff)
add d-bus API to list slot contents and fix other API issues
Diffstat (limited to 'daemon/watchconnector.cpp')
-rw-r--r--daemon/watchconnector.cpp16
1 files changed, 9 insertions, 7 deletions
diff --git a/daemon/watchconnector.cpp b/daemon/watchconnector.cpp
index 21f5ad5..e66ec0f 100644
--- a/daemon/watchconnector.cpp
+++ b/daemon/watchconnector.cpp
@@ -5,6 +5,7 @@
#include "unpacker.h"
static const int RECONNECT_TIMEOUT = 500; //ms
+static const bool PROTOCOL_DEBUG = false;
using std::function;
@@ -135,7 +136,7 @@ bool WatchConnector::dispatchMessage(uint endpoint, const QByteArray &data)
}
logger()->info() << "message to endpoint" << decodeEndpoint(endpoint) << "was not dispatched";
- emit messageReceived(endpoint, data);
+ logger()->debug() << data.toHex();
return false;
}
@@ -182,6 +183,7 @@ void WatchConnector::onReadSocket()
QByteArray data = socket->read(message_length);
logger()->debug() << "received message of length" << message_length << "to endpoint" << decodeEndpoint(endpoint);
+ if (PROTOCOL_DEBUG) logger()->debug() << data.toHex();
dispatchMessage(endpoint, data);
}
@@ -225,7 +227,7 @@ void WatchConnector::onDisconnected()
reconnectTimer.setInterval(reconnectTimer.interval() + RECONNECT_TIMEOUT);
}
reconnectTimer.start();
- logger()->debug() << "Will reconnect in" << reconnectTimer.interval() << "ms";
+ logger()->debug() << "will reconnect in" << reconnectTimer.interval() << "ms";
}
void WatchConnector::onError(QBluetoothSocket::SocketError error)
@@ -233,7 +235,7 @@ void WatchConnector::onError(QBluetoothSocket::SocketError error)
if (error == QBluetoothSocket::UnknownSocketError) {
logger()->info() << error << socket->errorString();
} else {
- logger()->error() << "Error connecting Pebble:" << error << socket->errorString();
+ logger()->error() << "error connecting Pebble:" << error << socket->errorString();
}
}
@@ -241,11 +243,11 @@ void WatchConnector::sendData(const QByteArray &data)
{
writeData.append(data);
if (socket == nullptr) {
- logger()->debug() << "No socket - reconnecting";
+ logger()->debug() << "no socket - reconnecting";
reconnect();
} else if (is_connected) {
- logger()->debug() << "Writing" << data.length() << "bytes to socket";
- logger()->debug() << data.toHex();
+ logger()->debug() << "writing" << data.length() << "bytes to socket";
+ if (PROTOCOL_DEBUG) logger()->debug() << data.toHex();
socket->write(data);
}
}
@@ -253,7 +255,7 @@ void WatchConnector::sendData(const QByteArray &data)
void WatchConnector::onBytesWritten(qint64 bytes)
{
writeData.remove(0, bytes);
- logger()->debug() << "Socket written" << bytes << "bytes," << writeData.length() << "left";
+ logger()->debug() << "socket written" << bytes << "bytes," << writeData.length() << "left";
}
void WatchConnector::sendMessage(uint endpoint, const QByteArray &data, const EndpointHandlerFunc &callback)