Compare commits

...

11 Commits

7 changed files with 186 additions and 62 deletions

2
.gitignore vendored Normal file
View File

@ -0,0 +1,2 @@
.*.swp
pkg

12
Gemfile Normal file
View File

@ -0,0 +1,12 @@
source "http://rubygems.org"
# Add dependencies to develop your gem here.
# Include everything needed to run rake, tests, features, etc.
group :development do
gem "shoulda"
gem "yard"
gem "rdoc"
gem "bundler"
gem "jeweler"
gem "simplecov"
end

46
Gemfile.lock Normal file
View File

@ -0,0 +1,46 @@
GEM
remote: http://rubygems.org/
specs:
activesupport (3.2.13)
i18n (= 0.6.1)
multi_json (~> 1.0)
bourne (1.4.0)
mocha (~> 0.13.2)
git (1.2.5)
i18n (0.6.1)
jeweler (1.8.4)
bundler (~> 1.0)
git (>= 1.2.5)
rake
rdoc
json (1.7.7)
metaclass (0.0.1)
mocha (0.13.3)
metaclass (~> 0.0.1)
multi_json (1.7.2)
rake (10.0.4)
rdoc (4.0.1)
json (~> 1.4)
shoulda (3.4.0)
shoulda-context (~> 1.0, >= 1.0.1)
shoulda-matchers (~> 1.0, >= 1.4.1)
shoulda-context (1.1.0)
shoulda-matchers (1.5.6)
activesupport (>= 3.0.0)
bourne (~> 1.3)
simplecov (0.7.1)
multi_json (~> 1.0)
simplecov-html (~> 0.7.1)
simplecov-html (0.7.1)
yard (0.8.5.2)
PLATFORMS
ruby
DEPENDENCIES
bundler
jeweler
rdoc
shoulda
simplecov
yard

View File

@ -1,57 +1,49 @@
# encoding: utf-8
require 'rubygems'
require 'bundler'
begin
Bundler.setup(:default, :development)
rescue Bundler::BundlerError => e
$stderr.puts e.message
$stderr.puts "Run `bundle install` to install missing gems"
exit e.status_code
end
require 'rake'
begin
require 'jeweler'
Jeweler::Tasks.new do |gem|
gem.name = "robustserver"
gem.summary = %Q{Robust Server}
gem.description = %Q{Protects your Server against SIGS and rescues all exceptions.}
gem.email = "Denis.Knauf@gmail.com"
gem.homepage = "http://github.com/DenisKnauf/robustserver"
gem.authors = ["Denis Knauf"]
gem.files = %w[AUTHORS README.md VERSION lib/**/*.rb test/**/*.rb]
gem.require_paths = %w[lib]
end
Jeweler::GemcutterTasks.new
rescue LoadError
puts "Jeweler (or a dependency) not available. Install it with: sudo gem install jeweler"
require 'jeweler'
Jeweler::Tasks.new do |gem|
# gem is a Gem::Specification... see http://docs.rubygems.org/read/chapter/20 for more options
gem.name = "robustserver"
gem.summary = %Q{Robust Server}
gem.description = %Q{Protects your Server against SIGS and rescues all exceptions.}
gem.email = "Denis.Knauf@gmail.com"
gem.homepage = "http://github.com/DenisKnauf/robustserver"
gem.authors = ["Denis Knauf"]
gem.files = %w[AUTHORS README.md VERSION lib/**/*.rb test/**/*.rb]
gem.require_paths = %w[lib]
# dependencies defined in Gemfile
end
Jeweler::RubygemsDotOrgTasks.new
require 'rake/testtask'
Rake::TestTask.new(:test) do |test|
test.libs << 'lib' << 'test' << 'ext'
test.pattern = 'test/**/*_test.rb'
test.libs << 'lib' << 'test'
test.pattern = 'test/**/test_*.rb'
test.verbose = true
end
begin
require 'rcov/rcovtask'
Rcov::RcovTask.new do |test|
test.libs << 'test'
test.pattern = 'test/**/*_test.rb'
test.verbose = true
end
rescue LoadError
task :rcov do
abort "RCov is not available. In order to run rcov, you must: sudo gem install spicycode-rcov"
end
=begin
require 'rcov/rcovtask'
Rcov::RcovTask.new do |test|
test.libs << 'test'
test.pattern = 'test/**/test_*.rb'
test.verbose = true
test.rcov_opts << '--exclude "gems/*"'
end
task :test => :check_dependencies
=end
task :default => :test
require 'rake/rdoctask'
Rake::RDocTask.new do |rdoc|
if File.exist?('VERSION')
version = File.read('VERSION')
else
version = ""
end
rdoc.rdoc_dir = 'rdoc'
rdoc.title = "sbdb #{version}"
rdoc.rdoc_files.include('README*')
rdoc.rdoc_files.include('lib/**/*.rb')
end
require 'yard'
YARD::Rake::YardocTask.new

View File

@ -1 +1 @@
0.0.2
0.0.3

View File

@ -95,28 +95,31 @@ end
# Easy problem-handler for your Server.
#
# A Server should never crash.
# If an Exception raised, which is not rescued, your program will shutdown abnormaly.
# Or if a signal tries to "kill" your program, your program will shutdown abnormaly too.
# Problem: Your process should not crash, it should be available for anytime.
# If an exception will be raised, you have to handle it, or it will be shutdown abnormaly.
# Or if a signal tries to "kill" your program, your program will shutdown abnormaly, too.
#
# With RobustServer these errors will be a more unimportant problem and It'll be easier to handle.
# RobustServer handles any exception / kill, logs it and prevents the server to shutting down.
#
# Subclasses should implements *#run*, which will be your main-worker.
# For initializing, you can override **#initialize**, but doen't forget to call **super**.
# For implementation a server, create a subclass of RobustServer and implement the *#run*-method.
# Anytime this *#run*-method returns or an exception will be raised, it will be rescued and run recalled.
# For initialization, you can override **#initialize**, but don't forget to call **super**.
class RobustServer
attr_reader :signals
class UnimplementedRun <Exception
end
attr_reader :signals, :output
def self.main *argv
self.new( *argv).main
end
def initialize *p
def initialize *_
sh = method :signal_handler
@sigs = {
Signal[:INT] => sh, Signal[:HUP] => nil, Signal[:TERM] => sh,
Signal[:KILL] => sh, Signal[:USR1] => nil, Signal[:USR2] => nil
}
@signals = []
@signals, @output = [], $stderr
end
def trapping
@ -124,28 +127,40 @@ class RobustServer
end
def signal_handler s
$stderr.puts [:signal, s, Signal[s]].inspect
s = s
output.puts [:signal, s, Signal[s]].inspect
@signals.push s unless @signals.include? s
end
def main max = nil, range = nil
retries = Retries.new max, range
trapping
$stderr.puts "Arbeit wird nun aufgenommen..."
output.puts "Running...."
begin
self.run
rescue SystemExit, Interrupt, SignalException
$stderr.puts "Das Beenden des Programms wurde angefordert. #{$!}"
rescue UnimplementedRun
output.puts $!.message
exit 1
rescue SystemExit
output.puts "Server interrupted by signal: #$!"
raise
rescue Interrupt, SignalException
output.puts "Server interrupted by signal: #$!"
exit 0
rescue Object
$stderr.puts [:rescue, $!, $!.class, $!.backtrace].inspect
output.puts [:rescue, $!, $!.class, $!.backtrace].inspect
retry if retries.retry?
$stderr.print "Zuviele Fehler in zu kurzer Zeit. Ich gebe auf und "
output.print "Too many errors in too short time. Give up: "
exit 2
end
$stderr.puts "Unbeachtete Signale: #{@signals.map(&Signal.method(:[])).join( ', ')}"
ensure
output.puts "Disregarded signals: #{@signals.map(&Signal.method(:[])).join( ', ')}" unless @signals.empty?
trapping
self.at_exit
$stderr.puts "Beende mich selbst."
output.puts "Shutdown."
end
def run
raise UnimplementedRun, "Unimplemented #{self.class.name}#run."
end
def at_exit

57
robustserver.gemspec Normal file
View File

@ -0,0 +1,57 @@
# Generated by jeweler
# DO NOT EDIT THIS FILE DIRECTLY
# Instead, edit Jeweler::Tasks in Rakefile, and run 'rake gemspec'
# -*- encoding: utf-8 -*-
Gem::Specification.new do |s|
s.name = "robustserver"
s.version = "0.0.3"
s.required_rubygems_version = Gem::Requirement.new(">= 0") if s.respond_to? :required_rubygems_version=
s.authors = ["Denis Knauf"]
s.date = "2013-04-15"
s.description = "Protects your Server against SIGS and rescues all exceptions."
s.email = "Denis.Knauf@gmail.com"
s.extra_rdoc_files = [
"LICENSE",
"README.md"
]
s.files = [
"AUTHORS",
"README.md",
"VERSION",
"lib/robustserver.rb"
]
s.homepage = "http://github.com/DenisKnauf/robustserver"
s.require_paths = ["lib"]
s.rubygems_version = "1.8.23"
s.summary = "Robust Server"
if s.respond_to? :specification_version then
s.specification_version = 3
if Gem::Version.new(Gem::VERSION) >= Gem::Version.new('1.2.0') then
s.add_development_dependency(%q<shoulda>, [">= 0"])
s.add_development_dependency(%q<yard>, [">= 0"])
s.add_development_dependency(%q<rdoc>, [">= 0"])
s.add_development_dependency(%q<bundler>, [">= 0"])
s.add_development_dependency(%q<jeweler>, [">= 0"])
s.add_development_dependency(%q<simplecov>, [">= 0"])
else
s.add_dependency(%q<shoulda>, [">= 0"])
s.add_dependency(%q<yard>, [">= 0"])
s.add_dependency(%q<rdoc>, [">= 0"])
s.add_dependency(%q<bundler>, [">= 0"])
s.add_dependency(%q<jeweler>, [">= 0"])
s.add_dependency(%q<simplecov>, [">= 0"])
end
else
s.add_dependency(%q<shoulda>, [">= 0"])
s.add_dependency(%q<yard>, [">= 0"])
s.add_dependency(%q<rdoc>, [">= 0"])
s.add_dependency(%q<bundler>, [">= 0"])
s.add_dependency(%q<jeweler>, [">= 0"])
s.add_dependency(%q<simplecov>, [">= 0"])
end
end