Compare commits
11 Commits
Author | SHA1 | Date |
---|---|---|
Denis Knauf | 92060db994 | |
Denis Knauf | 0e90737ae1 | |
Denis Knauf | f09d6150dd | |
Denis Knauf | c34cc60ae6 | |
Denis Knauf | 5b7d63fb2d | |
Denis Knauf | 37ac8bb3db | |
Denis Knauf | 960f3ef7a9 | |
Denis Knauf | d7edbb750e | |
Denis Knauf | f11b7df104 | |
Denis Knauf | 9551fbe35d | |
Denis Knauf | fc48ded7ba |
|
@ -0,0 +1,2 @@
|
|||
.*.swp
|
||||
pkg
|
|
@ -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
|
|
@ -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
|
78
Rakefile
78
Rakefile
|
@ -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
|
||||
|
|
|
@ -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
|
||||
|
|
|
@ -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
|
||||
|
Loading…
Reference in New Issue