From a17455da2753d55f6bb0d6360fc1e11e9a0a4efa Mon Sep 17 00:00:00 2001 From: Kyle Banker Date: Fri, 10 Dec 2010 11:16:28 -0500 Subject: [PATCH] Not using replica pair tests anymore --- test/replica_pairs/count_test.rb | 34 --------------- test/replica_pairs/insert_test.rb | 50 ---------------------- test/replica_pairs/pooled_insert_test.rb | 54 ------------------------ test/replica_pairs/query_test.rb | 39 ----------------- 4 files changed, 177 deletions(-) delete mode 100644 test/replica_pairs/count_test.rb delete mode 100644 test/replica_pairs/insert_test.rb delete mode 100644 test/replica_pairs/pooled_insert_test.rb delete mode 100644 test/replica_pairs/query_test.rb diff --git a/test/replica_pairs/count_test.rb b/test/replica_pairs/count_test.rb deleted file mode 100644 index f0a9292..0000000 --- a/test/replica_pairs/count_test.rb +++ /dev/null @@ -1,34 +0,0 @@ -$:.unshift(File.join(File.dirname(__FILE__), '..', 'lib')) -require 'mongo' -require 'test/unit' -require './test/test_helper' - -# NOTE: this test should be run only if a replica pair is running. -class ReplicaPairCountTest < Test::Unit::TestCase - include Mongo - - def setup - @conn = Mongo::Connection.new({:left => ["localhost", 27017], :right => ["localhost", 27018]}, nil) - @db = @conn.db('mongo-ruby-test') - @db.drop_collection("test-pairs") - @coll = @db.collection("test-pairs") - end - - def test_correct_count_after_insertion_reconnect - @coll.insert({:a => 20}, :safe => true) - assert_equal 1, @coll.count - - # Sleep to allow resync - sleep(3) - - puts "Please disconnect the current master." - gets - - rescue_connection_failure do - @coll.insert({:a => 30}, :safe => true) - end - @coll.insert({:a => 40}, :safe => true) - assert_equal 3, @coll.count, "Second count failed" - end - -end diff --git a/test/replica_pairs/insert_test.rb b/test/replica_pairs/insert_test.rb deleted file mode 100644 index 2e11145..0000000 --- a/test/replica_pairs/insert_test.rb +++ /dev/null @@ -1,50 +0,0 @@ -$:.unshift(File.join(File.dirname(__FILE__), '..', 'lib')) -require 'mongo' -require 'test/unit' -require './test/test_helper' - -# NOTE: this test should be run only if a replica pair is running. -class ReplicaPairInsertTest < Test::Unit::TestCase - include Mongo - - def setup - @conn = Mongo::Connection.new({:left => ["localhost", 27017], :right => ["localhost", 27018]}, nil) - @db = @conn.db('mongo-ruby-test') - @db.drop_collection("test-pairs") - @coll = @db.collection("test-pairs") - end - - def test_insert - @coll.save({:a => 20}, :safe => true) - puts "Please disconnect the current master." - gets - - rescue_connection_failure do - @coll.save({:a => 30}, :safe => true) - end - - @coll.save({:a => 40}, :safe => true) - @coll.save({:a => 50}, :safe => true) - @coll.save({:a => 60}, :safe => true) - @coll.save({:a => 70}, :safe => true) - - puts "Please reconnect the old master to make sure that the new master " + - "has synced with the previous master. Note: this may have happened already." - gets - results = [] - - rescue_connection_failure do - @coll.find.each {|r| results << r} - [20, 30, 40, 50, 60, 70].each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a}" - end - end - - @coll.save({:a => 80}, :safe => true) - @coll.find.each {|r| results << r} - [20, 30, 40, 50, 60, 70, 80].each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a} on second find" - end - end - -end diff --git a/test/replica_pairs/pooled_insert_test.rb b/test/replica_pairs/pooled_insert_test.rb deleted file mode 100644 index 89eec5e..0000000 --- a/test/replica_pairs/pooled_insert_test.rb +++ /dev/null @@ -1,54 +0,0 @@ -$:.unshift(File.join(File.dirname(__FILE__), '..', 'lib')) -require 'mongo' -require 'test/unit' -require './test/test_helper' - -# NOTE: this test should be run only if a replica pair is running. -class ReplicaPairPooledInsertTest < Test::Unit::TestCase - include Mongo - - def setup - @conn = Mongo::Connection.new({:left => ["localhost", 27017], :right => ["localhost", 27018]}, nil, :pool_size => 10, :timeout => 5) - @db = @conn.db('mongo-ruby-test') - @db.drop_collection("test-pairs") - @coll = @db.collection("test-pairs") - end - - def test_insert - expected_results = [-1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9] - @coll.save({:a => -1}, :safe => true) - puts "Please disconnect the current master." - gets - - threads = [] - 10.times do |i| - threads[i] = Thread.new do - rescue_connection_failure do - @coll.save({:a => i}, :safe => true) - end - end - end - - puts "Please reconnect the old master to make sure that the new master " + - "has synced with the previous master. Note: this may have happened already." + - "Note also that when connection with multiple threads, you may need to wait a few seconds" + - "after restarting the old master so that all the data has had a chance to sync." + - "This is a case of eventual consistency." - gets - results = [] - - rescue_connection_failure do - @coll.find.each {|r| results << r} - expected_results.each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a}" - end - end - - @coll.save({:a => 10}, :safe => true) - @coll.find.each {|r| results << r} - (expected_results + [10]).each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a} on second find" - end - end - -end diff --git a/test/replica_pairs/query_test.rb b/test/replica_pairs/query_test.rb deleted file mode 100644 index 23250a0..0000000 --- a/test/replica_pairs/query_test.rb +++ /dev/null @@ -1,39 +0,0 @@ -$:.unshift(File.join(File.dirname(__FILE__), '..', 'lib')) -require 'mongo' -require 'test/unit' -require './test/test_helper' - -# NOTE: this test should be run only if a replica pair is running. -class ReplicaPairQueryTest < Test::Unit::TestCase - include Mongo - - def setup - @conn = Mongo::Connection.new({:left => ["localhost", 27017], :right => ["localhost", 27018]}, nil) - @db = @conn.db('mongo-ruby-test') - @db.drop_collection("test-pairs") - @coll = @db.collection("test-pairs") - end - - def test_query - @coll.save({:a => 20}) - @coll.save({:a => 30}) - @coll.save({:a => 40}) - results = [] - @coll.find.each {|r| results << r} - [20, 30, 40].each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a}" - end - - puts "Please disconnect the current master." - gets - - results = [] - rescue_connection_failure do - @coll.find.each {|r| results << r} - [20, 30, 40].each do |a| - assert results.any? {|r| r['a'] == a}, "Could not find record for a => #{a}" - end - end - end - -end