spec/cproxy_spec.rb in ruby_process-0.0.7 vs spec/cproxy_spec.rb in ruby_process-0.0.8

@@ -1,8 +1,28 @@
 require File.expand_path(File.dirname(__FILE__) + '/spec_helper')
 
 describe "RubyProcess" do
+  it "should be able to do quick in-and-outs without leaking" do
+    ts = []
+    
+    1.upto(2) do |tcount|
+      ts << Thread.new do
+        1.upto(10) do
+          Ruby_process::Cproxy.run do |data|
+            sp = data[:subproc]
+            str = sp.new(:String, "Wee")
+            res1 = str.include?("Kasper")
+          end
+        end
+      end
+    end
+    
+    ts.each do |thread|
+      thread.join
+    end
+  end
+  
   it "should be able to do basic stuff" do
     require "stringio"
     
     Ruby_process::Cproxy.run do |data|
       data[:subproc].static(:Object, :require, "rubygems")
@@ -15,7 +35,67 @@
       doc.write(strio)
       
       raise "Didnt expect REXML to be defined in host process." if Kernel.const_defined?(:REXML)
       raise "Expected strio to contain '<test/>' but it didnt: '#{strio.string}'." if strio.string != "<test/>"
     end
+  end
+  
+  it "should be able to do multiple calls at once" do
+    ts = []
+    
+    0.upto(9) do |tcount|
+      ts << Thread.new do
+        Ruby_process::Cproxy.run do |data|
+          sp = data[:subproc]
+          sp.new(:String, "Wee")
+          
+          1.upto(250) do
+            str = sp.new(:String, "Kasper Johansen")
+            
+            res1 = str.include?("Kasper")
+            str << " More"
+            
+            res2 = str.include?("Johansen")
+            str << " Even more"
+            
+            res3 = str.include?("Christina")
+            str << " Much more"
+            
+            raise "Expected res1 to be true but it wasnt: '#{res1}'." if res1 != true
+            raise "Expected res2 to be true but it wasnt: '#{res2}'." if res2 != true
+            raise "Expected res3 to be false but it wasnt: '#{res3}'." if res3 != false
+            
+            #print tcount
+          end
+        end
+      end
+    end
+    
+    count = 0
+    ts.each do |t|
+      count += 1
+      #puts "Thread #{count}"
+      t.join
+    end
+  end
+  
+  it "should not leak" do
+    str = "kasper"
+    str = nil
+    sleep 0.1
+    GC.start
+    sleep 0.1
+    
+    count_objs = 0
+    ObjectSpace.each_object(Ruby_process) do |obj|
+      count_objs += 1
+    end
+    
+    count_proxy_objs = 0
+    ObjectSpace.each_object(Ruby_process::Proxyobj) do |obj|
+      count_proxy_objs += 1
+    end
+    
+    raise "Expected 1 or less 'Ruby_process' to be left but it wasnt like that: #{count_objs} (proxy objects: #{count_proxy_objs})" if count_objs > 1
+    raise "Expected 0 constants to be left on cproxy." if !Ruby_process::Cproxy.constants.empty?
   end
 end