diff options
author | Jamey Hicks <jamey.hicks@nokia.com> | 2012-06-07 13:20:03 -0400 |
---|---|---|
committer | Qt by Nokia <qt-info@nokia.com> | 2012-06-07 22:07:45 +0200 |
commit | a3176e99452e06c4f2a8a0e745c79de4c809f0ac (patch) | |
tree | c835d05cf12963677e3af27d4058e785eca6bab0 /src | |
parent | eb129a8c2cc211767adaffbe0f0c9d7158119c85 (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.cpp | 10 | ||||
-rw-r--r-- | src/daemon/dbserver.h | 2 |
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); |