summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorJamey Hicks <jamey.hicks@nokia.com>2012-06-07 13:20:03 -0400
committerQt by Nokia <qt-info@nokia.com>2012-06-07 22:07:45 +0200
commita3176e99452e06c4f2a8a0e745c79de4c809f0ac (patch)
treec835d05cf12963677e3af27d4058e785eca6bab0 /src
parenteb129a8c2cc211767adaffbe0f0c9d7158119c85 (diff)
Added partition name to debugQuery and object types to performance log
Change-Id: I86d4735bb111454ead3a8558272933c076a504f8 Reviewed-by: Tapani Mikola <tapani.mikola@nokia.com>
Diffstat (limited to 'src')
-rw-r--r--src/daemon/dbserver.cpp10
-rw-r--r--src/daemon/dbserver.h2
2 files changed, 9 insertions, 3 deletions
diff --git a/src/daemon/dbserver.cpp b/src/daemon/dbserver.cpp
index 590c7ab..fc3fa29 100644
--- a/src/daemon/dbserver.cpp
+++ b/src/daemon/dbserver.cpp
@@ -596,7 +596,7 @@ void DBServer::processRead(ClientJsonStream *stream, JsonDbOwner *owner, const Q
partition->queryObjects(owner, parsedQuery, limit, offset);
if (jsondbSettings->debug())
- debugQuery(parsedQuery, limit, offset, queryResult);
+ debugQuery(partitionName, parsedQuery, limit, offset, queryResult);
if (queryResult.code != JsonDbError::NoError) {
sendError(stream, queryResult.code, queryResult.message, id);
@@ -712,13 +712,15 @@ void DBServer::processLog(ClientJsonStream *stream, const QString &message, int
stream->send(result);
}
-void DBServer::debugQuery(const JsonDbQuery &query, int limit, int offset, const JsonDbQueryResult &result)
+void DBServer::debugQuery(const QString partitionName , const JsonDbQuery &query, int limit, int offset, const JsonDbQueryResult &result)
{
const QList<JsonDbOrQueryTerm> &orQueryTerms = query.queryTerms;
if (jsondbSettings->verbose()) {
qDebug() << JSONDB_INFO << "query:" << query.query;
if (orQueryTerms.size())
qDebug() << JSONDB_INFO << "query terms:" << query.query;
+ if (!partitionName.isEmpty())
+ qDebug() << JSONDB_INFO << "partition:" << partitionName;
}
for (int i = 0; i < orQueryTerms.size(); i++) {
const JsonDbOrQueryTerm &orQueryTerm = orQueryTerms[i];
@@ -1208,6 +1210,10 @@ void DBServer::receiveMessage(const QJsonObject &message)
additionalInfo = object.toObject().value("query").toString();
} else if (object.type() == QJsonValue::Array) {
additionalInfo = QString::fromLatin1("%1 objects").arg(object.toArray().size());
+ QSet<QString> types;
+ foreach (const QJsonValue v, object.toArray())
+ types.insert(JsonDbObject(v.toObject()).type());
+ additionalInfo += QStringLiteral(" types: %1").arg(QStringList(types.toList()).join(QStringLiteral(", ")));
} else {
additionalInfo = object.toObject().value(JsonDbString::kTypeStr).toString();
}
diff --git a/src/daemon/dbserver.h b/src/daemon/dbserver.h
index acc4c85..563b666 100644
--- a/src/daemon/dbserver.h
+++ b/src/daemon/dbserver.h
@@ -106,7 +106,7 @@ private:
void processFlush(ClientJsonStream *stream, JsonDbOwner *owner, const QString &partitionName, int id);
void processLog(ClientJsonStream *stream, const QString &message, int id);
- void debugQuery(const JsonDbQuery &query, int limit, int offset, const JsonDbQueryResult &result);
+ void debugQuery(const QString partitionName, const JsonDbQuery &query, int limit, int offset, const JsonDbQueryResult &result);
JsonDbObjectList prepareWriteData(const QString &action, const QJsonValue &object);
JsonDbObjectList checkForNotifications(const JsonDbObjectList &objects);
void createNotification(const JsonDbObject &object, ClientJsonStream *stream);