From aa1e56af00a20391104057a3a3302ae9d2e8c0c2 Mon Sep 17 00:00:00 2001
From: achille <@achille>
Date: Sun, 4 Aug 2013 15:19:34 -0700
Subject: [PATCH] Set default thread count to 100 when thread count is not
specified
---
.../java/com/yahoo/ycsb/db/AsyncMongoDbClient.java | 2 +-
.../src/main/java/com/yahoo/ycsb/db/MongoDbClient.java | 10 ++++------
2 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java b/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java
index d83fd43e..9c4a8da8 100644
--- a/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java
+++ b/mongodb/src/main/java/com/yahoo/ycsb/db/AsyncMongoDbClient.java
@@ -124,7 +124,7 @@ public class AsyncMongoDbClient extends DB {
final Properties props = getProperties();
final String maxConnections = props.getProperty(
- "mongodb.maxconnections", "10");
+ "mongodb.maxconnections", "100");
final int connections = Integer.parseInt(maxConnections);
synchronized (AsyncMongoDbClient.class) {
diff --git a/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java b/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java
index 61fca0c0..87005109 100644
--- a/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java
+++ b/mongodb/src/main/java/com/yahoo/ycsb/db/MongoDbClient.java
@@ -26,7 +26,6 @@ import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.WriteConcern;
-import com.mongodb.WriteResult;
import com.yahoo.ycsb.ByteArrayByteIterator;
import com.yahoo.ycsb.ByteIterator;
import com.yahoo.ycsb.DB;
@@ -94,7 +93,7 @@ public class MongoDbClient extends DB {
// Set connectionpool to size of ycsb thread pool
final String maxConnections = props.getProperty(
- "mongodb.maxconnections", "10");
+ "mongodb.maxconnections", "100");
final String threadsAllowedToBlockForConnectionMultiplier = props
.getProperty(
"mongodb.threadsAllowedToBlockForConnectionMultiplier",
@@ -193,7 +192,7 @@ public class MongoDbClient extends DB {
db.requestStart();
DBCollection collection = db.getCollection(table);
DBObject q = new BasicDBObject().append("_id", key);
- WriteResult res = collection.remove(q, writeConcern);
+ collection.remove(q, writeConcern);
return 0;
}
catch (Exception e) {
@@ -235,7 +234,7 @@ public class MongoDbClient extends DB {
for (Map.Entry<String, ByteIterator> entry : values.entrySet()) {
r.put(entry.getKey(), entry.getValue().toArray());
}
- WriteResult res = collection.insert(r, writeConcern);
+ collection.insert(r, writeConcern);
return 0;
}
catch (Exception e) {
@@ -339,8 +338,7 @@ public class MongoDbClient extends DB {
}
u.put("$set", fieldsToSet);
- WriteResult res = collection.update(q, u, false, false,
- writeConcern);
+ collection.update(q, u, false, false, writeConcern);
return 0;
}
catch (Exception e) {
--
GitLab