Test

Author: chadlwilson

src/spec/ruby/rack/application_spec.rb

@@ -555,7 +555,7 @@ def createRackServletWrapper(runtime, rackup, filename)
 describe org.jruby.rack.PoolingRackApplicationFactory do
 
   before :each do
-    @factory = double("factory").as_null_object
+    @factory = double "factory"
     @pooling_factory = org.jruby.rack.PoolingRackApplicationFactory.new @factory
     @pooling_factory.context = @rack_context
   end
@@ -638,7 +638,7 @@ def createRackServletWrapper(runtime, rackup, filename)
   it "forces the maximum size to be greater or equal to the initial size" do
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double("app").as_null_object
+      app = double "app"
       expect(app).to receive(:init)
       app
     end
@@ -652,15 +652,15 @@ def createRackServletWrapper(runtime, rackup, filename)
   end
 
   it "retrieves the error application from the delegate factory" do
-    app = double("app").as_null_object
+    app = double "app"
     expect(@factory).to receive(:getErrorApplication).and_return app
     expect(@pooling_factory.getErrorApplication).to eq app
   end
 
   it "waits till initial runtimes get initialized (with wait set to true)" do
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double("app").as_null_object
+      app = double "app"
       allow(app).to receive(:init) do
         sleep(0.05)
       end
@@ -680,7 +680,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     allow(@factory).to receive(:init)
     app_count = java.util.concurrent.atomic.AtomicInteger.new(0)
     allow(@factory).to receive(:newApplication) do
-      app = double("app").as_null_object
+      app = double "app"
       allow(app).to receive(:init) do
         if app_count.addAndGet(1) == 2
           raise org.jruby.rack.RackInitializationException.new('failed app init')
@@ -761,6 +761,17 @@ def createRackServletWrapper(runtime, rackup, filename)
     expect(@pooling_factory.getApplication).to eq app2
   end
 
+  class ThreadSafeMock
+    def initialize(obj)
+      @delegate = obj
+      @lock = Mutex.new
+    end
+
+    def method_missing(name, *args, &block)
+      @lock.synchronize { @delegate.send(name, *args, &block) }
+    end
+  end
+
   it "gets and initializes new applications until maximum allows to create more" do
     app_init_secs = 0.1
     allow(@factory).to receive(:init)
@@ -796,7 +807,7 @@ def createRackServletWrapper(runtime, rackup, filename)
   end
 
   it "initializes initial runtimes in parallel (with wait set to false)" do
-    app_init_secs = 0.15
+    app_init_secs = 0.05
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
       app = double "app"
@@ -826,7 +837,7 @@ def createRackServletWrapper(runtime, rackup, filename)
     app_init_secs = 0.05
     allow(@factory).to receive(:init)
     allow(@factory).to receive(:newApplication) do
-      app = double("app").as_null_object
+      app = double "app"
       allow(app).to receive(:init) { sleep(app_init_secs); raise "app.init raising" }
       app
     end