summaryrefslogtreecommitdiff
path: root/jstests/sharding
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2014-07-31 14:23:06 -0400
committerRandolph Tan <randolph@10gen.com>2014-08-06 14:50:50 -0400
commit82dfdf0e635bd096e5f12180b550f9899b272692 (patch)
treed83becd5200caabe4603c9e1a89f312669310ba4 /jstests/sharding
parentd1ea3910fc9acd03a4964a66ff9b27ef1112a5c5 (diff)
downloadmongo-82dfdf0e635bd096e5f12180b550f9899b272692.tar.gz
SERVER-14745 Remove WritebackListener
Diffstat (limited to 'jstests/sharding')
-rw-r--r--jstests/sharding/features3.js23
-rw-r--r--jstests/sharding/wbl_not_cleared.js51
2 files changed, 0 insertions, 74 deletions
diff --git a/jstests/sharding/features3.js b/jstests/sharding/features3.js
index 58efd44ceac..90a4cec6479 100644
--- a/jstests/sharding/features3.js
+++ b/jstests/sharding/features3.js
@@ -156,27 +156,4 @@ assert(x.ok == 1 && x.numFiles > 0, "fsync failed: " + tojson(x));
x = db._adminCommand({"fsync" :1, lock:true});
assert(!x.ok, "lock should fail: " + tojson(x));
-// write back stuff
-// SERVER-4194
-
-function countWritebacks(curop) {
- print("---------------");
- var num = 0;
- for (var i = 0; i < curop.inprog.length; i++) {
- var q = curop.inprog[i].query;
- if (q && q.writebacklisten) {
- printjson(curop.inprog[i]);
- num++;
- }
- }
- return num;
-}
-
-x = db.currentOp();
-assert.eq(0, countWritebacks(x), "without all");
-
-x = db.currentOp(true);
-y = countWritebacks(x);
-assert(y == 1 || y == 2, "with all: " + y);
-
s.stop()
diff --git a/jstests/sharding/wbl_not_cleared.js b/jstests/sharding/wbl_not_cleared.js
deleted file mode 100644
index 12dbfca842f..00000000000
--- a/jstests/sharding/wbl_not_cleared.js
+++ /dev/null
@@ -1,51 +0,0 @@
-/**
- * Tests whether the WBL gets reset without subsequent events.
- */
-
-var st = new ShardingTest({ shards : 2, mongos : 2, other : { mongosOptions : { verbose : 5 } } });
-
-st.stopBalancer();
-
-var mongos = st.s0;
-var staleMongos = st.s1;
-var admin = mongos.getDB("admin");
-var config = mongos.getDB("config");
-var shards = config.shards.find().toArray();
-var coll = mongos.getCollection("foo.bar");
-
-jsTest.log("Sharding collection...");
-
-printjson(admin.runCommand({ enableSharding : coll.getDB() + "" }));
-printjson(admin.runCommand({ movePrimary : coll.getDB() + "", to : shards[0]._id }));
-printjson(admin.runCommand({ shardCollection : coll + "", key : { _id : 1 } }));
-printjson(admin.runCommand({ split : coll + "", middle : { _id : 0 } }));
-printjson(admin.runCommand({ moveChunk : coll + "", find : { _id : 0 }, to : shards[1]._id }));
-
-jsTest.log("Collection now sharded...");
-st.printShardingStatus();
-
-jsTest.log("Making mongos stale...");
-
-assert.writeOK(coll.insert({ _id : 0 }));
-
-// Make sure the stale mongos knows about the collection at the original version
-assert.neq(null, staleMongos.getCollection(coll + "").findOne());
-
-printjson(admin.runCommand({ moveChunk : coll + "", find : { _id : 0 }, to : shards[0]._id, _waitForDelete : true }));
-printjson(admin.runCommand({ moveChunk : coll + "", find : { _id : 0 }, to : shards[1]._id, _waitForDelete : true }));
-
-jsTest.log("Running a stale insert...");
-
-// duplicate _id
-assert.writeError(staleMongos.getCollection(coll + "").insert({ _id : 0, dup : "key" }));
-
-st.printShardingStatus();
-
-jsTest.log("Performing insert op on the same shard...");
-
-assert.writeOK(staleMongos.getCollection(coll + "").insert({ _id : 1, key : "isOk" }));
-
-jsTest.log("DONE!");
-
-st.stop();
-