diff options
author | eregon <eregon@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-05-07 12:04:49 +0000 |
---|---|---|
committer | eregon <eregon@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-05-07 12:04:49 +0000 |
commit | 95e8c48dd3348503a8c7db5d0498894a1b676395 (patch) | |
tree | 9eef7f720314ebaff56845a74e203770e62284e4 /spec/rubyspec/library/fiber | |
parent | ed7d803500de38186c74bce94d233e85ef51e503 (diff) | |
download | ruby-95e8c48dd3348503a8c7db5d0498894a1b676395.tar.gz |
Add in-tree mspec and ruby/spec
* For easier modifications of ruby/spec by MRI developers.
* .gitignore: track changes under spec.
* spec/mspec, spec/rubyspec: add in-tree mspec and ruby/spec.
These files can therefore be updated like any other file in MRI.
Instructions are provided in spec/README.
[Feature #13156] [ruby-core:79246]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@58595 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'spec/rubyspec/library/fiber')
-rw-r--r-- | spec/rubyspec/library/fiber/alive_spec.rb | 48 | ||||
-rw-r--r-- | spec/rubyspec/library/fiber/current_spec.rb | 61 | ||||
-rw-r--r-- | spec/rubyspec/library/fiber/resume_spec.rb | 14 | ||||
-rw-r--r-- | spec/rubyspec/library/fiber/transfer_spec.rb | 51 |
4 files changed, 174 insertions, 0 deletions
diff --git a/spec/rubyspec/library/fiber/alive_spec.rb b/spec/rubyspec/library/fiber/alive_spec.rb new file mode 100644 index 0000000000..fbd5c4bc1a --- /dev/null +++ b/spec/rubyspec/library/fiber/alive_spec.rb @@ -0,0 +1,48 @@ +require File.expand_path('../../../spec_helper', __FILE__) + +with_feature :fiber_library do + require 'fiber' + + describe "Fiber#alive?" do + it "returns true for a Fiber that hasn't had #resume called" do + fiber = Fiber.new { true } + fiber.alive?.should be_true + end + + # FIXME: Better description? + it "returns true for a Fiber that's yielded to the caller" do + fiber = Fiber.new { Fiber.yield } + fiber.resume + fiber.alive?.should be_true + end + + it "returns true when called from its Fiber" do + fiber = Fiber.new { fiber.alive?.should be_true } + fiber.resume + end + + it "doesn't invoke the block associated with the Fiber" do + offthehook = mock('do not call') + offthehook.should_not_receive(:ring) + fiber = Fiber.new { offthehook.ring } + fiber.alive? + end + + it "returns false for a Fiber that's dead" do + fiber = Fiber.new { true } + fiber.resume + lambda { fiber.resume }.should raise_error(FiberError) + fiber.alive?.should be_false + end + + it "always returns false for a dead Fiber" do + fiber = Fiber.new { true } + fiber.resume + lambda { fiber.resume }.should raise_error(FiberError) + fiber.alive?.should be_false + lambda { fiber.resume }.should raise_error(FiberError) + fiber.alive?.should be_false + fiber.alive?.should be_false + end + end +end diff --git a/spec/rubyspec/library/fiber/current_spec.rb b/spec/rubyspec/library/fiber/current_spec.rb new file mode 100644 index 0000000000..48345fb7cf --- /dev/null +++ b/spec/rubyspec/library/fiber/current_spec.rb @@ -0,0 +1,61 @@ +require File.expand_path('../../../spec_helper', __FILE__) + +with_feature :fiber_library do + require 'fiber' + + describe "Fiber.current" do + it "returns the root Fiber when called outside of a Fiber" do + root = Fiber.current + root.should be_an_instance_of(Fiber) + # We can always transfer to the root Fiber; it will never die + 5.times do + root.transfer.should be_nil + root.alive?.should_not be_false #Workaround for bug #1547 + end + end + + it "returns the current Fiber when called from a Fiber" do + fiber = Fiber.new do + this = Fiber.current + this.should be_an_instance_of(Fiber) + this.should == fiber + this.alive?.should_not be_false # Workaround for bug #1547 + end + fiber.resume + end + + it "returns the current Fiber when called from a Fiber that transferred to another" do + + states = [] + fiber = Fiber.new do + states << :fiber + this = Fiber.current + this.should be_an_instance_of(Fiber) + this.should === fiber + this.alive?.should_not be_false # Workaround for bug #1547 + end + + fiber2 = Fiber.new do + states << :fiber2 + fiber.transfer + this = Fiber.current + this.should be_an_instance_of(Fiber) + this.should === fiber2 + this.alive?.should_not be_false # Workaround for bug #1547 + end + + fiber3 = Fiber.new do + states << :fiber3 + fiber2.transfer + this = Fiber.current + this.should be_an_instance_of(Fiber) + this.should === fiber3 + this.alive?.should_not be_false # Workaround for bug #1547 + fiber2.transfer + end + + fiber3.resume + states.should == [:fiber3, :fiber2, :fiber] + end + end +end diff --git a/spec/rubyspec/library/fiber/resume_spec.rb b/spec/rubyspec/library/fiber/resume_spec.rb new file mode 100644 index 0000000000..8709d01142 --- /dev/null +++ b/spec/rubyspec/library/fiber/resume_spec.rb @@ -0,0 +1,14 @@ +require File.expand_path('../../../spec_helper', __FILE__) + +with_feature :fiber_library do + require 'fiber' + + describe "Fiber#resume" do + it "raises a FiberError if the Fiber has transfered control to another Fiber" do + fiber1 = Fiber.new { true } + fiber2 = Fiber.new { fiber1.transfer; Fiber.yield } + fiber2.resume + lambda { fiber2.resume }.should raise_error(FiberError) + end + end +end diff --git a/spec/rubyspec/library/fiber/transfer_spec.rb b/spec/rubyspec/library/fiber/transfer_spec.rb new file mode 100644 index 0000000000..79319a7d39 --- /dev/null +++ b/spec/rubyspec/library/fiber/transfer_spec.rb @@ -0,0 +1,51 @@ +require File.expand_path('../../../spec_helper', __FILE__) +require File.expand_path('../../../shared/fiber/resume', __FILE__) + +with_feature :fiber_library do + require 'fiber' + + describe "Fiber#transfer" do + it_behaves_like :fiber_resume, :transfer + end + + describe "Fiber#transfer" do + it "transfers control from one Fiber to another when called from a Fiber" do + fiber1 = Fiber.new { :fiber1 } + fiber2 = Fiber.new { fiber1.transfer; :fiber2 } + fiber2.resume.should == :fiber1 + end + + it "returns to the root Fiber when finished" do + f1 = Fiber.new { :fiber_1 } + f2 = Fiber.new { f1.transfer; :fiber_2 } + + f2.transfer.should == :fiber_1 + f2.transfer.should == :fiber_2 + end + + it "can be invoked from the same Fiber it transfers control to" do + states = [] + fiber = Fiber.new { states << :start; fiber.transfer; states << :end } + fiber.transfer + states.should == [:start, :end] + + states = [] + fiber = Fiber.new { states << :start; fiber.transfer; states << :end } + fiber.resume + states.should == [:start, :end] + end + + it "can transfer control to a Fiber that has transfered to another Fiber" do + states = [] + fiber1 = Fiber.new { states << :fiber1 } + fiber2 = Fiber.new { states << :fiber2_start; fiber1.transfer; states << :fiber2_end} + fiber2.resume.should == [:fiber2_start, :fiber1] + fiber2.transfer.should == [:fiber2_start, :fiber1, :fiber2_end] + end + + it "raises a FiberError when transferring to a Fiber which resumes itself" do + fiber = Fiber.new { fiber.resume } + lambda { fiber.transfer }.should raise_error(FiberError) + end + end +end |