diff options
author | Randolph Tan <randolph@10gen.com> | 2014-07-31 14:23:06 -0400 |
---|---|---|
committer | Randolph Tan <randolph@10gen.com> | 2014-08-06 14:50:50 -0400 |
commit | 82dfdf0e635bd096e5f12180b550f9899b272692 (patch) | |
tree | d83becd5200caabe4603c9e1a89f312669310ba4 /jstests/sharding | |
parent | d1ea3910fc9acd03a4964a66ff9b27ef1112a5c5 (diff) | |
download | mongo-82dfdf0e635bd096e5f12180b550f9899b272692.tar.gz |
SERVER-14745 Remove WritebackListener
Diffstat (limited to 'jstests/sharding')
-rw-r--r-- | jstests/sharding/features3.js | 23 | ||||
-rw-r--r-- | jstests/sharding/wbl_not_cleared.js | 51 |
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(); - |