summaryrefslogtreecommitdiffstats
path: root/spec/unit/agent_spec.rb
diff options
context:
space:
mode:
authorMarkus Roberts <Markus@reality.com>2010-07-09 18:12:17 -0700
committerMarkus Roberts <Markus@reality.com>2010-07-09 18:12:17 -0700
commit3180b9d9b2c844dade1d361326600f7001ec66dd (patch)
tree98fe7c5ac7eb942aac9c39f019a17b0b3f5a57f4 /spec/unit/agent_spec.rb
parent543225970225de5697734bfaf0a6eee996802c04 (diff)
downloadpuppet-3180b9d9b2c844dade1d361326600f7001ec66dd.tar.gz
puppet-3180b9d9b2c844dade1d361326600f7001ec66dd.tar.xz
puppet-3180b9d9b2c844dade1d361326600f7001ec66dd.zip
Code smell: Two space indentation
Replaced 106806 occurances of ^( +)(.*$) with The ruby community almost universally (i.e. everyone but Luke, Markus, and the other eleven people who learned ruby in the 1900s) uses two-space indentation. 3 Examples: The code: end # Tell getopt which arguments are valid def test_get_getopt_args element = Setting.new :name => "foo", :desc => "anything", :settings => Puppet::Util::Settings.new assert_equal([["--foo", GetoptLong::REQUIRED_ARGUMENT]], element.getopt_args, "Did not produce appropriate getopt args") becomes: end # Tell getopt which arguments are valid def test_get_getopt_args element = Setting.new :name => "foo", :desc => "anything", :settings => Puppet::Util::Settings.new assert_equal([["--foo", GetoptLong::REQUIRED_ARGUMENT]], element.getopt_args, "Did not produce appropriate getopt args") The code: assert_equal(str, val) assert_instance_of(Float, result) end # Now test it with a passed object becomes: assert_equal(str, val) assert_instance_of(Float, result) end # Now test it with a passed object The code: end assert_nothing_raised do klass[:Yay] = "boo" klass["Cool"] = :yayness end becomes: end assert_nothing_raised do klass[:Yay] = "boo" klass["Cool"] = :yayness end
Diffstat (limited to 'spec/unit/agent_spec.rb')
-rwxr-xr-xspec/unit/agent_spec.rb430
1 files changed, 215 insertions, 215 deletions
diff --git a/spec/unit/agent_spec.rb b/spec/unit/agent_spec.rb
index 446ec3df4..2b3ee8ca0 100755
--- a/spec/unit/agent_spec.rb
+++ b/spec/unit/agent_spec.rb
@@ -7,275 +7,275 @@ require File.dirname(__FILE__) + '/../spec_helper'
require 'puppet/agent'
class AgentTestClient
- def run
- # no-op
- end
- def stop
- # no-op
- end
+ def run
+ # no-op
+ end
+ def stop
+ # no-op
+ end
end
def without_warnings
- flag = $VERBOSE
- $VERBOSE = nil
- yield
- $VERBOSE = flag
+ flag = $VERBOSE
+ $VERBOSE = nil
+ yield
+ $VERBOSE = flag
end
describe Puppet::Agent do
- before do
- @agent = Puppet::Agent.new(AgentTestClient)
-
- # So we don't actually try to hit the filesystem.
- @agent.stubs(:lock).yields
-
- # make Puppet::Application safe for stubbing; restore in an :after block; silence warnings for this.
- without_warnings { Puppet::Application = Class.new(Puppet::Application) }
- Puppet::Application.stubs(:clear?).returns(true)
- Puppet::Application.class_eval do
- class << self
- def controlled_run(&block)
- block.call
- end
- end
+ before do
+ @agent = Puppet::Agent.new(AgentTestClient)
+
+ # So we don't actually try to hit the filesystem.
+ @agent.stubs(:lock).yields
+
+ # make Puppet::Application safe for stubbing; restore in an :after block; silence warnings for this.
+ without_warnings { Puppet::Application = Class.new(Puppet::Application) }
+ Puppet::Application.stubs(:clear?).returns(true)
+ Puppet::Application.class_eval do
+ class << self
+ def controlled_run(&block)
+ block.call
end
+ end
end
+ end
- after do
- # restore Puppet::Application from stub-safe subclass, and silence warnings
- without_warnings { Puppet::Application = Puppet::Application.superclass }
- end
+ after do
+ # restore Puppet::Application from stub-safe subclass, and silence warnings
+ without_warnings { Puppet::Application = Puppet::Application.superclass }
+ end
- it "should set its client class at initialization" do
- Puppet::Agent.new("foo").client_class.should == "foo"
- end
+ it "should set its client class at initialization" do
+ Puppet::Agent.new("foo").client_class.should == "foo"
+ end
- it "should include the Locker module" do
- Puppet::Agent.ancestors.should be_include(Puppet::Agent::Locker)
- end
+ it "should include the Locker module" do
+ Puppet::Agent.ancestors.should be_include(Puppet::Agent::Locker)
+ end
- it "should create an instance of its client class and run it when asked to run" do
- client = mock 'client'
- AgentTestClient.expects(:new).returns client
+ it "should create an instance of its client class and run it when asked to run" do
+ client = mock 'client'
+ AgentTestClient.expects(:new).returns client
- client.expects(:run)
+ client.expects(:run)
- @agent.stubs(:running?).returns false
- @agent.run
- end
+ @agent.stubs(:running?).returns false
+ @agent.run
+ end
- it "should determine its lock file path by asking the client class" do
- AgentTestClient.expects(:lockfile_path).returns "/my/lock"
- @agent.lockfile_path.should == "/my/lock"
- end
+ it "should determine its lock file path by asking the client class" do
+ AgentTestClient.expects(:lockfile_path).returns "/my/lock"
+ @agent.lockfile_path.should == "/my/lock"
+ end
- it "should be considered running if the lock file is locked" do
- lockfile = mock 'lockfile'
+ it "should be considered running if the lock file is locked" do
+ lockfile = mock 'lockfile'
- @agent.expects(:lockfile).returns lockfile
- lockfile.expects(:locked?).returns true
+ @agent.expects(:lockfile).returns lockfile
+ lockfile.expects(:locked?).returns true
- @agent.should be_running
- end
+ @agent.should be_running
+ end
- describe "when being run" do
- before do
- @agent.stubs(:running?).returns false
- end
+ describe "when being run" do
+ before do
+ @agent.stubs(:running?).returns false
+ end
- it "should splay" do
- @agent.expects(:splay)
- @agent.stubs(:running?).returns false
+ it "should splay" do
+ @agent.expects(:splay)
+ @agent.stubs(:running?).returns false
- @agent.run
- end
+ @agent.run
+ end
- it "should do nothing if already running" do
- @agent.expects(:running?).returns true
- AgentTestClient.expects(:new).never
- @agent.run
- end
+ it "should do nothing if already running" do
+ @agent.expects(:running?).returns true
+ AgentTestClient.expects(:new).never
+ @agent.run
+ end
- it "should use Puppet::Application.controlled_run to manage process state behavior" do
- calls = sequence('calls')
- Puppet::Application.expects(:controlled_run).yields.in_sequence(calls)
- AgentTestClient.expects(:new).once.in_sequence(calls)
- @agent.run
- end
+ it "should use Puppet::Application.controlled_run to manage process state behavior" do
+ calls = sequence('calls')
+ Puppet::Application.expects(:controlled_run).yields.in_sequence(calls)
+ AgentTestClient.expects(:new).once.in_sequence(calls)
+ @agent.run
+ end
- it "should not fail if a client class instance cannot be created" do
- AgentTestClient.expects(:new).raises "eh"
- Puppet.expects(:err)
- @agent.run
- end
+ it "should not fail if a client class instance cannot be created" do
+ AgentTestClient.expects(:new).raises "eh"
+ Puppet.expects(:err)
+ @agent.run
+ end
- it "should not fail if there is an exception while running its client" do
- client = AgentTestClient.new
- AgentTestClient.expects(:new).returns client
- client.expects(:run).raises "eh"
- Puppet.expects(:err)
- @agent.run
- end
+ it "should not fail if there is an exception while running its client" do
+ client = AgentTestClient.new
+ AgentTestClient.expects(:new).returns client
+ client.expects(:run).raises "eh"
+ Puppet.expects(:err)
+ @agent.run
+ end
- it "should use a mutex to restrict multi-threading" do
- client = AgentTestClient.new
- AgentTestClient.expects(:new).returns client
+ it "should use a mutex to restrict multi-threading" do
+ client = AgentTestClient.new
+ AgentTestClient.expects(:new).returns client
- mutex = mock 'mutex'
- @agent.expects(:sync).returns mutex
+ mutex = mock 'mutex'
+ @agent.expects(:sync).returns mutex
- mutex.expects(:synchronize)
- client.expects(:run).never # if it doesn't run, then we know our yield is what triggers it
- @agent.run
- end
+ mutex.expects(:synchronize)
+ client.expects(:run).never # if it doesn't run, then we know our yield is what triggers it
+ @agent.run
+ end
- it "should use a filesystem lock to restrict multiple processes running the agent" do
- client = AgentTestClient.new
- AgentTestClient.expects(:new).returns client
+ it "should use a filesystem lock to restrict multiple processes running the agent" do
+ client = AgentTestClient.new
+ AgentTestClient.expects(:new).returns client
- @agent.expects(:lock)
+ @agent.expects(:lock)
- client.expects(:run).never # if it doesn't run, then we know our yield is what triggers it
- @agent.run
- end
+ client.expects(:run).never # if it doesn't run, then we know our yield is what triggers it
+ @agent.run
+ end
- it "should make its client instance available while running" do
- client = AgentTestClient.new
- AgentTestClient.expects(:new).returns client
+ it "should make its client instance available while running" do
+ client = AgentTestClient.new
+ AgentTestClient.expects(:new).returns client
- client.expects(:run).with { @agent.client.should equal(client); true }
- @agent.run
- end
+ client.expects(:run).with { @agent.client.should equal(client); true }
+ @agent.run
+ end
- it "should run the client instance with any arguments passed to it" do
- client = AgentTestClient.new
- AgentTestClient.expects(:new).returns client
+ it "should run the client instance with any arguments passed to it" do
+ client = AgentTestClient.new
+ AgentTestClient.expects(:new).returns client
- client.expects(:run).with("testargs")
- @agent.run("testargs")
- end
+ client.expects(:run).with("testargs")
+ @agent.run("testargs")
end
+ end
- describe "when splaying" do
- before do
- Puppet.settings.stubs(:value).with(:splay).returns true
- Puppet.settings.stubs(:value).with(:splaylimit).returns "10"
- end
+ describe "when splaying" do
+ before do
+ Puppet.settings.stubs(:value).with(:splay).returns true
+ Puppet.settings.stubs(:value).with(:splaylimit).returns "10"
+ end
- it "should do nothing if splay is disabled" do
- Puppet.settings.expects(:value).returns false
- @agent.expects(:sleep).never
- @agent.splay
- end
+ it "should do nothing if splay is disabled" do
+ Puppet.settings.expects(:value).returns false
+ @agent.expects(:sleep).never
+ @agent.splay
+ end
- it "should do nothing if it has already splayed" do
- @agent.expects(:splayed?).returns true
- @agent.expects(:sleep).never
- @agent.splay
- end
+ it "should do nothing if it has already splayed" do
+ @agent.expects(:splayed?).returns true
+ @agent.expects(:sleep).never
+ @agent.splay
+ end
- it "should log that it is splaying" do
- @agent.stubs :sleep
- Puppet.expects :info
- @agent.splay
- end
+ it "should log that it is splaying" do
+ @agent.stubs :sleep
+ Puppet.expects :info
+ @agent.splay
+ end
- it "should sleep for a random portion of the splaylimit plus 1" do
- Puppet.settings.expects(:value).with(:splaylimit).returns "50"
- @agent.expects(:rand).with(51).returns 10
- @agent.expects(:sleep).with(10)
- @agent.splay
- end
+ it "should sleep for a random portion of the splaylimit plus 1" do
+ Puppet.settings.expects(:value).with(:splaylimit).returns "50"
+ @agent.expects(:rand).with(51).returns 10
+ @agent.expects(:sleep).with(10)
+ @agent.splay
+ end
- it "should mark that it has splayed" do
- @agent.stubs(:sleep)
- @agent.splay
- @agent.should be_splayed
- end
+ it "should mark that it has splayed" do
+ @agent.stubs(:sleep)
+ @agent.splay
+ @agent.should be_splayed
end
+ end
+
+ describe "when checking execution state" do
+ describe 'with regular run status' do
+ before :each do
+ Puppet::Application.stubs(:restart_requested?).returns(false)
+ Puppet::Application.stubs(:stop_requested?).returns(false)
+ Puppet::Application.stubs(:interrupted?).returns(false)
+ Puppet::Application.stubs(:clear?).returns(true)
+ end
- describe "when checking execution state" do
- describe 'with regular run status' do
- before :each do
- Puppet::Application.stubs(:restart_requested?).returns(false)
- Puppet::Application.stubs(:stop_requested?).returns(false)
- Puppet::Application.stubs(:interrupted?).returns(false)
- Puppet::Application.stubs(:clear?).returns(true)
- end
-
- it 'should be false for :stopping?' do
- @agent.stopping?.should be_false
- end
-
- it 'should be false for :needing_restart?' do
- @agent.needing_restart?.should be_false
- end
- end
+ it 'should be false for :stopping?' do
+ @agent.stopping?.should be_false
+ end
- describe 'with a stop requested' do
- before :each do
- Puppet::Application.stubs(:clear?).returns(false)
- Puppet::Application.stubs(:restart_requested?).returns(false)
- Puppet::Application.stubs(:stop_requested?).returns(true)
- Puppet::Application.stubs(:interrupted?).returns(true)
- end
-
- it 'should be true for :stopping?' do
- @agent.stopping?.should be_true
- end
-
- it 'should be false for :needing_restart?' do
- @agent.needing_restart?.should be_false
- end
- end
+ it 'should be false for :needing_restart?' do
+ @agent.needing_restart?.should be_false
+ end
+ end
- describe 'with a restart requested' do
- before :each do
- Puppet::Application.stubs(:clear?).returns(false)
- Puppet::Application.stubs(:restart_requested?).returns(true)
- Puppet::Application.stubs(:stop_requested?).returns(false)
- Puppet::Application.stubs(:interrupted?).returns(true)
- end
-
- it 'should be false for :stopping?' do
- @agent.stopping?.should be_false
- end
-
- it 'should be true for :needing_restart?' do
- @agent.needing_restart?.should be_true
- end
- end
+ describe 'with a stop requested' do
+ before :each do
+ Puppet::Application.stubs(:clear?).returns(false)
+ Puppet::Application.stubs(:restart_requested?).returns(false)
+ Puppet::Application.stubs(:stop_requested?).returns(true)
+ Puppet::Application.stubs(:interrupted?).returns(true)
+ end
+
+ it 'should be true for :stopping?' do
+ @agent.stopping?.should be_true
+ end
+
+ it 'should be false for :needing_restart?' do
+ @agent.needing_restart?.should be_false
+ end
end
- describe "when starting" do
- before do
- @agent.stubs(:observe_signal)
- end
+ describe 'with a restart requested' do
+ before :each do
+ Puppet::Application.stubs(:clear?).returns(false)
+ Puppet::Application.stubs(:restart_requested?).returns(true)
+ Puppet::Application.stubs(:stop_requested?).returns(false)
+ Puppet::Application.stubs(:interrupted?).returns(true)
+ end
+
+ it 'should be false for :stopping?' do
+ @agent.stopping?.should be_false
+ end
+
+ it 'should be true for :needing_restart?' do
+ @agent.needing_restart?.should be_true
+ end
+ end
+ end
+
+ describe "when starting" do
+ before do
+ @agent.stubs(:observe_signal)
+ end
- it "should create a timer with the runinterval, a tolerance of 1, and :start? set to true" do
- Puppet.settings.expects(:value).with(:runinterval).returns 5
- timer = stub 'timer', :sound_alarm => nil
- EventLoop::Timer.expects(:new).with(:interval => 5, :start? => true, :tolerance => 1).returns timer
+ it "should create a timer with the runinterval, a tolerance of 1, and :start? set to true" do
+ Puppet.settings.expects(:value).with(:runinterval).returns 5
+ timer = stub 'timer', :sound_alarm => nil
+ EventLoop::Timer.expects(:new).with(:interval => 5, :start? => true, :tolerance => 1).returns timer
- @agent.stubs(:run)
- @agent.start
- end
+ @agent.stubs(:run)
+ @agent.start
+ end
- it "should run once immediately" do
- timer = mock 'timer'
- EventLoop::Timer.expects(:new).returns timer
+ it "should run once immediately" do
+ timer = mock 'timer'
+ EventLoop::Timer.expects(:new).returns timer
- timer.expects(:sound_alarm)
+ timer.expects(:sound_alarm)
- @agent.start
- end
+ @agent.start
+ end
- it "should run within the block passed to the timer" do
- timer = stub 'timer', :sound_alarm => nil
- EventLoop::Timer.expects(:new).returns(timer).yields
- @agent.expects(:run)
+ it "should run within the block passed to the timer" do
+ timer = stub 'timer', :sound_alarm => nil
+ EventLoop::Timer.expects(:new).returns(timer).yields
+ @agent.expects(:run)
- @agent.start
- end
+ @agent.start
end
+ end
end