NameError at /service/17/action

BACKTRACE

/usr/lib/one/oneflow/lib/models/role.rb in retry_scale
1. def retry_scale()
2. nodes_dispose = get_nodes.select { |node|
3. node['disposed'] == "1"
4. }
6. shutdown_nodes(nodes_dispose, true)
1. set_cardinality( get_nodes.size() - n_dispose.size() )
1. end
3. # Deletes VMs in DONE or FAILED, and sends a boot action to VMs in UNKNOWN
4. def recover()
6. nodes = @body['nodes']
7. new_nodes = []
/usr/lib/one/oneflow/lib/models/role.rb in recover_scale
1. def recover_warning()
2. recover()
3. deploy()
4. end
6. def recover_scale()
7. recover()
1. retry_scale()
1. end
4. ########################################################################
5. ########################################################################
/usr/lib/one/oneflow/lib/models/service.rb in recover
1. end
3. self.set_state(Service::STATE['DEPLOYING'])
5. elsif self.state == Service::STATE['FAILED_SCALING']
6. @roles.each do |name, role|
7. if role.state == Role::STATE['FAILED_SCALING']
1. role.recover_scale()
1. role.set_state(Role::STATE['SCALING'])
2. end
3. end
5. self.set_state(Service::STATE['SCALING'])
7. elsif self.state == Service::STATE['FAILED_UNDEPLOYING']
/usr/lib/one/oneflow/lib/models/service.rb in each
1. role.recover_deployment()
2. end
3. end
5. self.set_state(Service::STATE['DEPLOYING'])
7. elsif self.state == Service::STATE['FAILED_SCALING']
1. @roles.each do |name, role|
1. if role.state == Role::STATE['FAILED_SCALING']
2. role.recover_scale()
3. role.set_state(Role::STATE['SCALING'])
4. end
5. end
7. self.set_state(Service::STATE['SCALING'])
/usr/lib/one/oneflow/lib/models/service.rb in recover
1. role.recover_deployment()
2. end
3. end
5. self.set_state(Service::STATE['DEPLOYING'])
7. elsif self.state == Service::STATE['FAILED_SCALING']
1. @roles.each do |name, role|
1. if role.state == Role::STATE['FAILED_SCALING']
2. role.recover_scale()
3. role.set_state(Role::STATE['SCALING'])
4. end
5. end
7. self.set_state(Service::STATE['SCALING'])
/usr/lib/one/oneflow/oneflow-server.rb in POST /service/:id/action
2. rc = nil
3. service = service_pool.get(params[:id]) { |service|
4. rc = case action['perform']
5. when 'shutdown'
6. service.shutdown
7. when 'recover', 'deploy'
1. service.recover
1. when 'chown'
2. if opts && opts['owner_id']
3. args = Array.new
4. args << opts['owner_id'].to_i
5. args << (opts['group_id'] || -1).to_i
7. ret = service.chown(*args)
/usr/lib/one/oneflow/lib/models/service_pool.rb in call
1. @@mutex_hash.delete_if { |s_id, entry|
2. entry[1] == 0
3. }
4. end
5. }
7. obj_mutex.synchronize {
1. block.call(service)
1. }
3. @@mutex.synchronize {
4. entry[1] = entry[1] - 1
5. }
6. end
/usr/lib/one/oneflow/lib/models/service_pool.rb in get
1. @@mutex_hash.delete_if { |s_id, entry|
2. entry[1] == 0
3. }
4. end
5. }
7. obj_mutex.synchronize {
1. block.call(service)
1. }
3. @@mutex.synchronize {
4. entry[1] = entry[1] - 1
5. }
6. end
/usr/lib/one/oneflow/lib/models/service_pool.rb in synchronize
1. if @@mutex_hash.size > 10000
2. @@mutex_hash.delete_if { |s_id, entry|
3. entry[1] == 0
4. }
5. end
6. }
1. obj_mutex.synchronize {
1. block.call(service)
2. }
4. @@mutex.synchronize {
5. entry[1] = entry[1] - 1
6. }
7. end
/usr/lib/one/oneflow/lib/models/service_pool.rb in get
1. if @@mutex_hash.size > 10000
2. @@mutex_hash.delete_if { |s_id, entry|
3. entry[1] == 0
4. }
5. end
6. }
1. obj_mutex.synchronize {
1. block.call(service)
2. }
4. @@mutex.synchronize {
5. entry[1] = entry[1] - 1
6. }
7. end
/usr/lib/one/oneflow/oneflow-server.rb in POST /service/:id/action
2. post '/service/:id/action' do
3. service_pool = OpenNebula::ServicePool.new(@client)
4. action = JSON.parse(request.body.read)['action']
5. opts = action['params']
7. rc = nil
1. service = service_pool.get(params[:id]) { |service|
1. rc = case action['perform']
2. when 'shutdown'
3. service.shutdown
4. when 'recover', 'deploy'
5. service.recover
6. when 'chown'
7. if opts && opts['owner_id']
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. options.each_pair { |option, args| send(option, *args) }
2. method_name = "#{verb} #{path}"
3. unbound_method = generate_method(method_name, &block)
4. pattern, keys = compile path
5. conditions, @conditions = @conditions, []
7. wrapper = block.arity != 0 ?
1. proc { |a,p| unbound_method.bind(a).call(*p) } :
1. proc { |a,p| unbound_method.bind(a).call }
2. wrapper.instance_variable_set(:@route_name, method_name)
4. [ pattern, keys, conditions, wrapper ]
5. end
7. def compile(path)
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in compile!
1. options.each_pair { |option, args| send(option, *args) }
2. method_name = "#{verb} #{path}"
3. unbound_method = generate_method(method_name, &block)
4. pattern, keys = compile path
5. conditions, @conditions = @conditions, []
7. wrapper = block.arity != 0 ?
1. proc { |a,p| unbound_method.bind(a).call(*p) } :
1. proc { |a,p| unbound_method.bind(a).call }
2. wrapper.instance_variable_set(:@route_name, method_name)
4. [ pattern, keys, conditions, wrapper ]
5. end
7. def compile(path)
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in []
2. # Run routes defined on the class and all superclasses.
3. def route!(base = settings, pass_block = nil)
4. if routes = base.routes[@request.request_method]
5. routes.each do |pattern, keys, conditions, block|
6. pass_block = process_route(pattern, keys, conditions) do |*args|
7. env['sinatra.route'] = block.instance_variable_get(:@route_name)
1. route_eval { block[*args] }
1. end
2. end
3. end
5. # Run routes defined in superclass.
6. if base.superclass.respond_to?(:routes)
7. return route!(base.superclass, pass_block)
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in route!
2. # Run routes defined on the class and all superclasses.
3. def route!(base = settings, pass_block = nil)
4. if routes = base.routes[@request.request_method]
5. routes.each do |pattern, keys, conditions, block|
6. pass_block = process_route(pattern, keys, conditions) do |*args|
7. env['sinatra.route'] = block.instance_variable_get(:@route_name)
1. route_eval { block[*args] }
1. end
2. end
3. end
5. # Run routes defined in superclass.
6. if base.superclass.respond_to?(:routes)
7. return route!(base.superclass, pass_block)
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in route_eval
2. route_eval(&pass_block) if pass_block
3. route_missing
4. end
6. # Run a route block and throw :halt with the result.
7. def route_eval
1. throw :halt, yield
1. end
3. # If the current request matches pattern and conditions, fill params
4. # with keys and call the given block.
5. # Revert params afterwards.
6. #
7. # Returns pass block.
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in route!
2. # Run routes defined on the class and all superclasses.
3. def route!(base = settings, pass_block = nil)
4. if routes = base.routes[@request.request_method]
5. routes.each do |pattern, keys, conditions, block|
6. pass_block = process_route(pattern, keys, conditions) do |*args|
7. env['sinatra.route'] = block.instance_variable_get(:@route_name)
1. route_eval { block[*args] }
1. end
2. end
3. end
5. # Run routes defined in superclass.
6. if base.superclass.respond_to?(:routes)
7. return route!(base.superclass, pass_block)
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in process_route
1. if values.any?
2. original, @params = params, params.merge('splat' => [], 'captures' => values)
3. keys.zip(values) { |k,v| Array === @params[k] ? @params[k] << v : @params[k] = v if v }
4. end
6. catch(:pass) do
7. conditions.each { |c| throw :pass if c.bind(self).call == false }
1. block ? block[self, values] : yield(self, values)
1. end
2. ensure
3. @params = original if original
4. end
6. # No matching route was found or all routes passed. The default
7. # implementation is to forward the request downstream when running
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in catch
1. values += match.captures.to_a.map { |v| force_encoding URI.unescape(v) if v }
3. if values.any?
4. original, @params = params, params.merge('splat' => [], 'captures' => values)
5. keys.zip(values) { |k,v| Array === @params[k] ? @params[k] << v : @params[k] = v if v }
6. end
1. catch(:pass) do
1. conditions.each { |c| throw :pass if c.bind(self).call == false }
2. block ? block[self, values] : yield(self, values)
3. end
4. ensure
5. @params = original if original
6. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in process_route
1. values += match.captures.to_a.map { |v| force_encoding URI.unescape(v) if v }
3. if values.any?
4. original, @params = params, params.merge('splat' => [], 'captures' => values)
5. keys.zip(values) { |k,v| Array === @params[k] ? @params[k] << v : @params[k] = v if v }
6. end
1. catch(:pass) do
1. conditions.each { |c| throw :pass if c.bind(self).call == false }
2. block ? block[self, values] : yield(self, values)
3. end
4. ensure
5. @params = original if original
6. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in route!
1. base.filters[type].each { |args| process_route(*args) }
2. end
4. # Run routes defined on the class and all superclasses.
5. def route!(base = settings, pass_block = nil)
6. if routes = base.routes[@request.request_method]
7. routes.each do |pattern, keys, conditions, block|
1. pass_block = process_route(pattern, keys, conditions) do |*args|
1. env['sinatra.route'] = block.instance_variable_get(:@route_name)
2. route_eval { block[*args] }
3. end
4. end
5. end
7. # Run routes defined in superclass.
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in each
1. filter! type, base.superclass if base.superclass.respond_to?(:filters)
2. base.filters[type].each { |args| process_route(*args) }
3. end
5. # Run routes defined on the class and all superclasses.
6. def route!(base = settings, pass_block = nil)
7. if routes = base.routes[@request.request_method]
1. routes.each do |pattern, keys, conditions, block|
1. pass_block = process_route(pattern, keys, conditions) do |*args|
2. env['sinatra.route'] = block.instance_variable_get(:@route_name)
3. route_eval { block[*args] }
4. end
5. end
6. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in route!
1. filter! type, base.superclass if base.superclass.respond_to?(:filters)
2. base.filters[type].each { |args| process_route(*args) }
3. end
5. # Run routes defined on the class and all superclasses.
6. def route!(base = settings, pass_block = nil)
7. if routes = base.routes[@request.request_method]
1. routes.each do |pattern, keys, conditions, block|
1. pass_block = process_route(pattern, keys, conditions) do |*args|
2. env['sinatra.route'] = block.instance_variable_get(:@route_name)
3. route_eval { block[*args] }
4. end
5. end
6. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in dispatch!
1. end
3. # Dispatch a request with error handling.
4. def dispatch!
5. invoke do
6. static! if settings.static? && (request.get? || request.head?)
7. filter! :before
1. route!
1. end
2. rescue ::Exception => boom
3. invoke { handle_exception!(boom) }
4. ensure
5. begin
6. filter! :after unless env['sinatra.static_file']
7. rescue ::Exception => boom
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in invoke
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in catch
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in invoke
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in dispatch!
1. body res
2. end
3. nil # avoid double setting the same response tuple twice
4. end
6. # Dispatch a request with error handling.
7. def dispatch!
1. invoke do
1. static! if settings.static? && (request.get? || request.head?)
2. filter! :before
3. route!
4. end
5. rescue ::Exception => boom
6. invoke { handle_exception!(boom) }
7. ensure
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call!
1. @request = Request.new(env)
2. @response = Response.new
3. @params = indifferent_params(@request.params)
4. template_cache.clear if settings.reload_templates
5. force_encoding(@params)
7. @response['Content-Type'] = nil
1. invoke { dispatch! }
1. invoke { error_block!(response.status) } unless @env['sinatra.error']
3. unless @response['Content-Type']
4. if Array === body and body[0].respond_to? :content_type
5. content_type body[0].content_type
6. else
7. content_type :html
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in invoke
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in catch
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in invoke
1. # Creates a Hash with indifferent access.
2. def indifferent_hash
3. Hash.new {|hash,key| hash[key.to_s] if Symbol === key }
4. end
6. # Run the block with 'throw :halt' support and apply result to the response.
7. def invoke
1. res = catch(:halt) { yield }
1. res = [res] if Fixnum === res or String === res
2. if Array === res and Fixnum === res.first
3. res = res.dup
4. status(res.shift)
5. body(res.pop)
6. headers(*res)
7. elsif res.respond_to? :each
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call!
1. @request = Request.new(env)
2. @response = Response.new
3. @params = indifferent_params(@request.params)
4. template_cache.clear if settings.reload_templates
5. force_encoding(@params)
7. @response['Content-Type'] = nil
1. invoke { dispatch! }
1. invoke { error_block!(response.status) } unless @env['sinatra.error']
3. unless @response['Content-Type']
4. if Array === body and body[0].respond_to? :content_type
5. content_type body[0].content_type
6. else
7. content_type :html
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. @app = app
2. @template_cache = Tilt::Cache.new
3. yield self if block_given?
4. end
6. # Rack call interface.
7. def call(env)
1. dup.call!(env)
1. end
3. def call!(env) # :nodoc:
4. @env = env
5. @request = Request.new(env)
6. @response = Response.new
7. @params = indifferent_params(@request.params)
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/session/abstract/id.rb in context
2. def call(env)
3. context(env)
4. end
6. def context(env, app=@app)
7. prepare_session(env)
1. status, headers, body = app.call(env)
1. commit_session(env, status, headers, body)
2. end
4. private
6. def initialize_sid
7. @sidbits = @default_options[:sidbits]
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/session/abstract/id.rb in call
1. @default_options = self.class::DEFAULT_OPTIONS.merge(options)
2. @key = @default_options.delete(:key)
3. @cookie_only = @default_options.delete(:cookie_only)
4. initialize_sid
5. end
7. def call(env)
1. context(env)
1. end
3. def context(env, app=@app)
4. prepare_session(env)
5. status, headers, body = app.call(env)
6. commit_session(env, status, headers, body)
7. end
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/commonlogger.rb in call_without_check
1. def initialize(app, logger=nil)
2. @app = app
3. @logger = logger
4. end
6. def call(env)
7. began_at = Time.now
1. status, header, body = @app.call(env)
1. header = Utils::HeaderHash.new(header)
2. body = BodyProxy.new(body) { log(env, status, header, began_at) }
3. [status, header, body]
4. end
6. private
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. env['sinatra.commonlogger'] ? @app.call(env) : super
2. end
4. superclass.class_eval do
5. alias call_without_check call unless method_defined? :call_without_check
6. def call(env)
7. env['sinatra.commonlogger'] = true
1. call_without_check(env)
1. end
2. end
3. end
5. class NotFound < NameError #:nodoc:
6. def http_status; 404 end
7. end
/usr/lib/ruby/gems/1.8/gems/rack-protection-1.5.0/lib/rack/protection/xss_header.rb in call
1. #
2. # Options:
3. # xss_mode:: How the browser should prevent the attack (default: :block)
4. class XSSHeader < Base
5. default_options :xss_mode => :block, :nosniff => true
7. def call(env)
1. status, headers, body = @app.call(env)
1. headers['X-XSS-Protection'] ||= "1; mode=#{options[:xss_mode]}" if html? headers
2. headers['X-Content-Type-Options'] ||= 'nosniff' if options[:nosniff]
3. [status, headers, body]
4. end
5. end
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/rack-protection-1.5.0/lib/rack/protection/path_traversal.rb in call
1. #
2. # Unescapes '/' and '.', expands +path_info+.
3. # Thus <tt>GET /foo/%2e%2e%2fbar</tt> becomes <tt>GET /bar</tt>.
4. class PathTraversal < Base
5. def call(env)
6. path_was = env["PATH_INFO"]
7. env["PATH_INFO"] = cleanup path_was if path_was && !path_was.empty?
1. app.call env
1. ensure
2. env["PATH_INFO"] = path_was
3. end
5. def cleanup(path)
6. parts = []
7. unescaped = path.gsub('%2e', '.').gsub('%2f', '/')
/usr/lib/ruby/gems/1.8/gems/rack-protection-1.5.0/lib/rack/protection/json_csrf.rb in call
1. # Array prototype has been patched to track data. Checks the referrer
2. # even on GET requests if the content type is JSON.
3. class JsonCsrf < Base
4. default_reaction :deny
6. def call(env)
7. request = Request.new(env)
1. status, headers, body = app.call(env)
2. if has_vector? request, headers
3. warn env, "attack prevented by #{self.class}"
4. react(env)
5. else
6. [status, headers, body]
7. end
/usr/lib/ruby/gems/1.8/gems/rack-protection-1.5.0/lib/rack/protection/base.rb in call
1. end
3. def call(env)
4. unless accepts? env
5. warn env, "attack prevented by #{self.class}"
6. result = react env
7. end
1. result or app.call(env)
1. end
3. def react(env)
4. result = send(options[:reaction], env)
5. result if Array === result and result.size == 3
6. end
/usr/lib/ruby/gems/1.8/gems/rack-protection-1.5.0/lib/rack/protection/frame_options.rb in call
1. frame_options = options[:frame_options]
2. frame_options = options[:frame_options].to_s.upcase unless frame_options.respond_to? :to_str
3. frame_options.to_str
4. end
5. end
7. def call(env)
1. status, headers, body = @app.call(env)
1. headers['X-Frame-Options'] ||= frame_options if html? headers
2. [status, headers, body]
3. end
4. end
5. end
6. end
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/nulllogger.rb in call
1. class NullLogger
2. def initialize(app)
3. @app = app
4. end
6. def call(env)
7. env['rack.logger'] = self
1. @app.call(env)
1. end
3. def info(progname = nil, &block); end
4. def debug(progname = nil, &block); end
5. def warn(progname = nil, &block); end
6. def error(progname = nil, &block); end
7. def fatal(progname = nil, &block); end
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/head.rb in call
1. # Rack::Head returns an empty body for all HEAD requests. It leaves
2. # all other requests unchanged.
3. def initialize(app)
4. @app = app
5. end
7. def call(env)
1. status, headers, body = @app.call(env)
2. if env["REQUEST_METHOD"] == "HEAD"
3. body.close if body.respond_to? :close
4. [status, headers, []]
5. else
6. [status, headers, body]
7. end
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/methodoverride.rb in call
1. method = method_override(env)
2. if HTTP_METHODS.include?(method)
3. env["rack.methodoverride.original_method"] = env["REQUEST_METHOD"]
4. env["REQUEST_METHOD"] = method
5. end
6. end
1. @app.call(env)
1. end
3. def method_override(env)
4. req = Request.new(env)
5. method = req.POST[METHOD_OVERRIDE_PARAM_KEY] ||
6. env[HTTP_METHOD_OVERRIDE_HEADER]
7. method.to_s.upcase
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/showexceptions.rb in call
2. def initialize(app)
3. @app = app
4. @template = ERB.new(TEMPLATE)
5. end
7. def call(env)
1. @app.call(env)
1. rescue Exception => e
2. errors, env["rack.errors"] = env["rack.errors"], @@eats_errors
4. if prefers_plain_text?(env)
5. content_type = "text/plain"
6. body = [dump_exception(e)]
7. else
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. # Some Rack handlers (Thin, Rainbows!) implement an extended body object protocol, however,
2. # some middleware (namely Rack::Lint) will break it by not mirroring the methods in question.
3. # This middleware will detect an extended body object and will make sure it reaches the
4. # handler directly. We do this here, so our middleware and middleware set up by the app will
5. # still be able to run.
6. class ExtendedRack < Struct.new(:app)
7. def call(env)
1. result, callback = app.call(env), env['async.callback']
1. return result unless callback and async?(*result)
2. after_response { callback.call result }
3. setup_close(env, *result)
4. throw :async
5. end
7. private
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. end
3. def helpers
4. @instance
5. end
7. def call(env)
1. @stack.call(env)
1. end
3. def inspect
4. "#<#{@instance.class} app_file=#{settings.app_file.inspect}>"
5. end
6. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. setup_default_middleware builder
2. setup_middleware builder
3. builder.run app
4. builder
5. end
7. def call(env)
1. synchronize { prototype.call(env) }
1. end
3. # Like Kernel#caller but excluding certain magic entries and without
4. # line / method information; the resulting array contains filenames only.
5. def caller_files
6. cleaned_caller(1).flatten
7. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in synchronize
1. end
3. @@mutex = Mutex.new
4. def synchronize(&block)
5. if lock?
6. @@mutex.synchronize(&block)
7. else
1. yield
1. end
2. end
4. # used for deprecation warnings
5. def warn(message)
6. super message + "\n\tfrom #{cleaned_caller.first.join(':')}"
7. end
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in call
1. setup_default_middleware builder
2. setup_middleware builder
3. builder.run app
4. builder
5. end
7. def call(env)
1. synchronize { prototype.call(env) }
1. end
3. # Like Kernel#caller but excluding certain magic entries and without
4. # line / method information; the resulting array contains filenames only.
5. def caller_files
6. cleaned_caller(1).flatten
7. end
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/connection.rb in pre_process
2. # When we're under a non-async framework like rails, we can still spawn
3. # off async responses using the callback info, so there's little point
4. # in removing this.
5. response = AsyncResponse
6. catch(:async) do
7. # Process the request calling the Rack adapter
1. response = @app.call(@request.env)
1. end
2. response
3. rescue Exception
4. handle_error
5. # Pass through error response
6. can_persist? && @request.persistent? ? Response::PERSISTENT_ERROR : Response::ERROR
7. end
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/connection.rb in catch
1. end
2. end
4. # When we're under a non-async framework like rails, we can still spawn
5. # off async responses using the callback info, so there's little point
6. # in removing this.
7. response = AsyncResponse
1. catch(:async) do
1. # Process the request calling the Rack adapter
2. response = @app.call(@request.env)
3. end
4. response
5. rescue Exception
6. handle_error
7. # Pass through error response
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/connection.rb in pre_process
1. end
2. end
4. # When we're under a non-async framework like rails, we can still spawn
5. # off async responses using the callback info, so there's little point
6. # in removing this.
7. response = AsyncResponse
1. catch(:async) do
1. # Process the request calling the Rack adapter
2. response = @app.call(@request.env)
3. end
4. response
5. rescue Exception
6. handle_error
7. # Pass through error response
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in call
1. end
3. def self.spawn_threadpool # :nodoc:
4. until @threadpool.size == @threadpool_size.to_i
5. thread = Thread.new do
6. while true
7. op, cback = *@threadqueue.pop
1. result = op.call
1. @resultqueue << [result, cback]
2. EventMachine.signal_loopbreak
3. end
4. end
5. @threadpool << thread
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in spawn_threadpool
1. end
3. def self.spawn_threadpool # :nodoc:
4. until @threadpool.size == @threadpool_size.to_i
5. thread = Thread.new do
6. while true
7. op, cback = *@threadqueue.pop
1. result = op.call
1. @resultqueue << [result, cback]
2. EventMachine.signal_loopbreak
3. end
4. end
5. @threadpool << thread
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in initialize
1. end
3. @threadqueue << [op||blk,callback]
4. end
6. def self.spawn_threadpool # :nodoc:
7. until @threadpool.size == @threadpool_size.to_i
1. thread = Thread.new do
1. while true
2. op, cback = *@threadqueue.pop
3. result = op.call
4. @resultqueue << [result, cback]
5. EventMachine.signal_loopbreak
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in new
1. end
3. @threadqueue << [op||blk,callback]
4. end
6. def self.spawn_threadpool # :nodoc:
7. until @threadpool.size == @threadpool_size.to_i
1. thread = Thread.new do
1. while true
2. op, cback = *@threadqueue.pop
3. result = op.call
4. @resultqueue << [result, cback]
5. EventMachine.signal_loopbreak
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in spawn_threadpool
1. end
3. @threadqueue << [op||blk,callback]
4. end
6. def self.spawn_threadpool # :nodoc:
7. until @threadpool.size == @threadpool_size.to_i
1. thread = Thread.new do
1. while true
2. op, cback = *@threadqueue.pop
3. result = op.call
4. @resultqueue << [result, cback]
5. EventMachine.signal_loopbreak
6. end
7. end
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in defer
1. #
2. def self.defer op = nil, callback = nil, &blk
3. unless @threadpool
4. require 'thread'
5. @threadpool = []
6. @threadqueue = ::Queue.new
7. @resultqueue = ::Queue.new
1. spawn_threadpool
1. end
3. @threadqueue << [op||blk,callback]
4. end
6. def self.spawn_threadpool # :nodoc:
7. until @threadpool.size == @threadpool_size.to_i
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/connection.rb in process
1. end
3. # Called when all data was received and the request
4. # is ready to be processed.
5. def process
6. if threaded?
7. @request.threaded = true
1. EventMachine.defer(method(:pre_process), method(:post_process))
1. else
2. @request.threaded = false
3. post_process(pre_process)
4. end
5. end
7. def pre_process
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/connection.rb in receive_data
1. @response = Response.new
2. end
4. # Called when data is received from the client.
5. def receive_data(data)
6. @idle = false
7. trace { data }
1. process if @request.parse(data)
1. rescue InvalidRequest => e
2. log "!! Invalid request"
3. log_error e
4. post_process Response::BAD_REQUEST
5. end
7. # Called when all data was received and the request
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in run_machine
1. @reactor_running = true
2. initialize_event_machine
3. (b = blk || block) and add_timer(0, b)
4. if @next_tick_queue && !@next_tick_queue.empty?
5. add_timer(0) { signal_loopbreak }
6. end
7. @reactor_thread = Thread.current
1. run_machine
1. ensure
2. until @tails.empty?
3. @tails.pop.call
4. end
6. begin
7. release_machine
/usr/lib/ruby/gems/1.8/gems/eventmachine-0.12.10/lib/eventmachine.rb in run
1. @reactor_running = true
2. initialize_event_machine
3. (b = blk || block) and add_timer(0, b)
4. if @next_tick_queue && !@next_tick_queue.empty?
5. add_timer(0) { signal_loopbreak }
6. end
7. @reactor_thread = Thread.current
1. run_machine
1. ensure
2. until @tails.empty?
3. @tails.pop.call
4. end
6. begin
7. release_machine
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/backends/base.rb in start
1. @running = true
2. end
4. # Allow for early run up of eventmachine.
5. if EventMachine.reactor_running?
6. starter.call
7. else
1. EventMachine.run(&starter)
1. end
2. end
4. # Stop of the backend from accepting new connections.
5. def stop
6. @running = false
7. @stopping = true
/usr/lib/ruby/gems/1.8/gems/thin-1.5.1/lib/thin/server.rb in start
1. log ">> Thin web server (v#{VERSION::STRING} codename #{VERSION::CODENAME})"
2. debug ">> Debugging ON"
3. trace ">> Tracing ON"
5. log ">> Maximum connections set to #{@backend.maximum_connections}"
6. log ">> Listening on #{@backend}, CTRL+C to stop"
1. @backend.start
1. end
2. alias :start! :start
4. # == Gracefull shutdown
5. # Stops the server after processing all current connections.
6. # As soon as this method is called, the server stops accepting
7. # new requests and wait for all current connections to finish.
/usr/lib/ruby/gems/1.8/gems/rack-1.5.2/lib/rack/handler/thin.rb in run
1. host = options.delete(:Host) || '0.0.0.0'
2. port = options.delete(:Port) || 8080
3. args = [host, port, app, options]
4. # Thin versions below 0.8.0 do not support additional options
5. args.pop if ::Thin::VERSION::MAJOR < 1 && ::Thin::VERSION::MINOR < 8
6. server = ::Thin::Server.new(*args)
7. yield server if block_given?
1. server.start
1. end
3. def self.valid_options
4. {
5. "Host=HOST" => "Hostname to listen on (default: localhost)",
6. "Port=PORT" => "Port to listen on (default: 8080)",
7. }
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/base.rb in run!
1. # Thin, Puma, Mongrel, or WEBrick (in that order). If given a block, will call
2. # with the constructed handler once we have taken the stage.
3. def run!(options = {})
4. set options
5. handler = detect_rack_handler
6. handler_name = handler.name.gsub(/.*::/, '')
7. server_settings = settings.respond_to?(:server_settings) ? settings.server_settings : {}
1. handler.run self, server_settings.merge(:Port => port, :Host => bind) do |server|
1. unless handler_name =~ /cgi/i
2. $stderr.puts "== Sinatra/#{Sinatra::VERSION} has taken the stage " +
3. "on #{port} for #{environment} with backup from #{handler_name}"
4. end
5. [:INT, :TERM].each { |sig| trap(sig) { quit!(server, handler_name) } }
6. server.threaded = settings.threaded if server.respond_to? :threaded=
7. set :running, true
/usr/lib/ruby/gems/1.8/gems/sinatra-1.4.3/lib/sinatra/main.rb in nil
1. op.on('-e env', 'set the environment (default is development)') { |val| set :environment, val.to_sym }
2. op.on('-s server', 'specify rack server/handler (default is thin)') { |val| set :server, val }
3. op.on('-x', 'turn on the mutex lock (default is off)') { set :lock, true }
4. }.parse!(ARGV.dup)
5. end
6. end
1. at_exit { Application.run! if $!.nil? && Application.run? }
1. end
3. # include would include the module in Object
4. # extend only extends the `main` object
5. extend Sinatra::Delegator
7. class Rack::Builder
/usr/lib/one/oneflow/oneflow-server.rb in nil
1. s_template.info
3. status 201
4. #body Parser.render(rc)
5. body s_template.to_json
6. end
1. post '/service_template/:id/action' do
1. service_template = OpenNebula::ServiceTemplate.new_with_id(params[:id], @client)
3. action = JSON.parse(request.body.read)['action']
5. opts = action['params']
7. rc = case action['perform']

GET

No GET data.

POST

Variable	Value
{ "action": { "perform": "recover" } }	nil

No cookie data.

Rack ENV

Variable	Value
CONTENT_LENGTH	46
CONTENT_TYPE	application/x-www-form-urlencoded
GATEWAY_INTERFACE	CGI/1.2
HTTP_ACCEPT	/
HTTP_AUTHORIZATION	Basic b25lYWRtaW46dlA0RXVDLWQ=
HTTP_HOST	localhost:2474
HTTP_USER_AGENT	OpenNebula 4.4.1 (CLI)
HTTP_VERSION	HTTP/1.1
PATH_INFO	/service/17/action
QUERY_STRING
REMOTE_ADDR	127.0.0.1
REQUEST_METHOD	POST
REQUEST_PATH	/service/17/action
REQUEST_URI	/service/17/action
SCRIPT_NAME
SERVER_NAME	localhost
SERVER_PORT	2474
SERVER_PROTOCOL	HTTP/1.1
SERVER_SOFTWARE	thin 1.5.1 codename Straight Razor
async.callback	#<Method: Thin::Connection#post_process>
async.close	#<EventMachine::DefaultDeferrable:0x7f4fad1531b0>
rack.errors	#<Object:0x7f4faf767ec8>
rack.input	#<StringIO:0x7f4fad153e30>
rack.logger	#<Rack::NullLogger:0x7f4fad1c3a78 @app=#<Rack::Protection::FrameOptions:0x7f4fad1c3d20 @frame_options="SAMEORIGIN", @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :frame_options=>:sameorigin, :message=>"Forbidden", :encryptor=>Digest::SHA1, :session_key=>"rack.session", :logging=>true, :reaction=>:drop_session, :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::Protection::HttpOrigin:0x7f4fad1c3eb0 @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :message=>"Forbidden", :encryptor=>Digest::SHA1, :reaction=>:drop_session, :logging=>true, :session_key=>"rack.session", :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::Protection::IPSpoofing:0x7f4fad1c4040 @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :message=>"Forbidden", :encryptor=>Digest::SHA1, :reaction=>:drop_session, :logging=>true, :session_key=>"rack.session", :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::Protection::JsonCsrf:0x7f4fad1c4248 @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :message=>"Forbidden", :encryptor=>Digest::SHA1, :reaction=>:drop_session, :logging=>true, :session_key=>"rack.session", :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::Protection::PathTraversal:0x7f4fad1c43d8 @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :message=>"Forbidden", :encryptor=>Digest::SHA1, :reaction=>:drop_session, :logging=>true, :session_key=>"rack.session", :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::Protection::XSSHeader:0x7f4fad1c4630 @options={:except=>[:session_hijacking, :remote_token], :status=>403, :html_types=>["text/html", "application/xhtml"], :message=>"Forbidden", :encryptor=>Digest::SHA1, :xss_mode=>:block, :session_key=>"rack.session", :logging=>true, :reaction=>:drop_session, :nosniff=>true, :allow_empty_referrer=>true, :report_key=>"protection.failed"}, @app=#<Rack::CommonLogger:0x7f4fad1e9408 @app=#<Rack::Session::Pool:0x7f4fad1e9890 @sid_secure=SecureRandom, @mutex=#<Mutex:0x7f4fad1e9660>, @app=#<Sinatra::Application:0x7f4fad1fd5e8 @template_cache=#<Tilt::Cache:0x7f4fad1fd598 @cache={}>, @app=nil, @default_layout=:layout>, @sidbits=128, @cookie_only=true, @key="oneflow", @pool={}, @default_options={:secure_random=>SecureRandom, :secure=>false, :httponly=>true, :defer=>false, :expire_after=>nil, :renew=>false, :sidbits=>128, :path=>"/", :domain=>nil, :drop=>false}, @sid_length=32>, @logger=#<CloudLogger::CloudLogger:0x7f4fad2363c0 @default_formatter=#<Logger::Formatter:0x7f4fad236348 @datetime_format=nil>, @formatter=#<Proc:0x00007f4faeb85a10@/usr/lib/one/ruby/cloud/CloudServer.rb:137>, @logdev=#<Logger::LogDevice:0x7f4fad2362f8 @shift_age=0, @filename="/var/log/one/oneflow.log", @mutex=#<Logger::LogDevice::LogDeviceMutex:0x7f4fad2362a8 @mon_waiting_queue=[], @mon_entering_queue=[], @mon_count=0, @mon_owner=nil>, @dev=#<File:/var/log/one/oneflow.log>, @shift_size=1048576>, @level=1, @progname=nil>>>>>>>>>
rack.multiprocess	false
rack.multithread	true
rack.request.cookie_hash	{}
rack.request.form_hash	{"{\n \"action\": {\n \"perform\": \"recover\"\n }\n}"=>nil}
rack.request.form_input	#<StringIO:0x7f4fad153e30>
rack.request.form_vars	{ "action": { "perform": "recover" } }
rack.request.query_hash	{}
rack.request.query_string
rack.run_once	false
rack.session	#<Rack::Session::Abstract::SessionHash:0x3fa7d68a87a8 not yet loaded>
rack.session.options	{:secure=>false, :secure_random=>SecureRandom, :httponly=>true, :expire_after=>nil, :defer=>false, :renew=>false, :sidbits=>128, :path=>"/", :drop=>false, :domain=>nil}
rack.url_scheme	http
rack.version	[1, 0]
sinatra.accept	[#<Sinatra::Request::AcceptEntry:0x7f4fad0d3780 @q=1.0, @params={}, @type="/", @entry="/">]
sinatra.commonlogger	true
sinatra.error	#<NameError: undefined local variable or method `n_dispose' for #<OpenNebula::Role:0x7f4fad11d588>>
sinatra.route	POST /service/:id/action

You're seeing this error because you have enabled the show_exceptions setting.

NameError at /service/17/action

undefined local variable or method `n_dispose' for #<OpenNebula::Role:0x7f4fad11d588>

BACKTRACE

GET

POST

COOKIES

Rack ENV