summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorAli Akhtarzada <ali.akhtarzada@nokia.com>2012-06-12 12:57:32 +0200
committerQt by Nokia <qt-info@nokia.com>2012-06-13 01:51:43 +0200
commit470174481800efd604f8760bd06e84284892f5b8 (patch)
tree3c7c4830eff8583cac90fabf2a6664c1b9a7023f /src
parent7e1d856b777fb0559c130f75918014a928b748a4 (diff)
Remove objects in batches for reduces and maps
Change-Id: I910745a32f89c44f3a8481d8a6ed34d37211b137 Reviewed-by: Denis Dzyubenko <denis.dzyubenko@nokia.com>
Diffstat (limited to 'src')
-rw-r--r--src/partition/jsondbmapdefinition.cpp8
-rw-r--r--src/partition/jsondbreducedefinition.cpp8
2 files changed, 6 insertions, 10 deletions
diff --git a/src/partition/jsondbmapdefinition.cpp b/src/partition/jsondbmapdefinition.cpp
index 7fdbc69..9488c63 100644
--- a/src/partition/jsondbmapdefinition.cpp
+++ b/src/partition/jsondbmapdefinition.cpp
@@ -118,11 +118,9 @@ void JsonDbMapDefinition::definitionRemoved(JsonDbPartition *partition, JsonDbOb
definitionUuid,
targetType);
JsonDbObjectList objects = getObjectResponse.data;
- for (int i = 0; i < objects.size(); i++) {
- JsonDbObject o = objects[i];
- o.markDeleted();
- partition->updateObject(partition->defaultOwner(), o, JsonDbPartition::ViewObject);
- }
+ for (int i = 0; i < objects.size(); i++)
+ objects[i].markDeleted();
+ partition->updateObjects(partition->defaultOwner(), objects, JsonDbPartition::ViewObject);
}
void JsonDbMapDefinition::initScriptEngine()
diff --git a/src/partition/jsondbreducedefinition.cpp b/src/partition/jsondbreducedefinition.cpp
index 9a8b449..078ccb0 100644
--- a/src/partition/jsondbreducedefinition.cpp
+++ b/src/partition/jsondbreducedefinition.cpp
@@ -112,11 +112,9 @@ void JsonDbReduceDefinition::definitionRemoved(JsonDbPartition *partition, JsonD
// remove the output objects
GetObjectsResult getObjectResponse = table->getObjects(QLatin1String("_reduceUuid"), definitionUuid, targetType);
JsonDbObjectList objects = getObjectResponse.data;
- for (int i = 0; i < objects.size(); i++) {
- JsonDbObject o = objects[i];
- o.markDeleted();
- partition->updateObject(partition->defaultOwner(), o, JsonDbPartition::ViewObject);
- }
+ for (int i = 0; i < objects.size(); i++)
+ objects[i].markDeleted();
+ partition->updateObjects(partition->defaultOwner(), objects, JsonDbPartition::ViewObject);
}
void JsonDbReduceDefinition::initScriptEngine()