module Tengine::Core::KernelRuntime

Public Instance Methods

ack() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 28
def ack
  unless @ack_called
    @ack_called = true
    @processing_headers.ack
  end
end
ack?() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 35
def ack?
  @ack_called
end
ack_policies() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 15
def ack_policies
  @ack_policies ||= { }
end
ack_policy_for(event) click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 23
def ack_policy_for(event)
  Tengine.logger.debug("ack_policies: #{ack_policies.inspect}")
  ack_policy = ack_policies[event.event_type_name.to_s] || :at_first
end
add_ack_policy(event_type_name, policy) click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 19
def add_ack_policy(event_type_name, policy)
  ack_policies[event_type_name.to_s] = policy.to_sym
end
all_submitted?() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 46
def all_submitted?
  return false if @submitted_handlers.nil? || @handlers.nil?
  (@handlers - @submitted_handlers).empty?
end
em_setup_blocks() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 55
def em_setup_blocks
  @em_setup_blocks ||= []
end
processing_event?() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 52
def processing_event?; @processing_event; end
safety_processing_headers(headers, event, ack_policy) { || ... } click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 5
def safety_processing_headers(headers, event, ack_policy)
  @ack_called = false
  @processing_headers, @event, @ack_policy = headers, event, ack_policy
  begin
    yield if block_given?
  ensure
    @processing_headers, @event, @ack_policy = nil, nil, nil
  end
end
submit() click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 40
def submit
  if @submitted_handlers
    @submitted_handlers << @handler
  end
end

Private Instance Methods

safety_handler(handler) { || ... } click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 80
def safety_handler(handler)
  @handler = handler
  @submitted_handler = nil
  begin
    yield if block_given?
  ensure
    @handler = nil
  end
end
safety_processing_event(headers) { || ... } click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 61
def safety_processing_event(headers)
  @processing_event = true
  begin
    yield if block_given?
  ensure
    @processing_event = false
  end
end
safty_handlers(handlers) { || ... } click to toggle source
# File lib/tengine/core/kernel_runtime.rb, line 70
def safty_handlers(handlers)
  @handlers = handlers
  @submitted_handlers = (@ack_policy == :after_all_handler_submit ? [] : nil)
  begin
    yield if block_given?
  ensure
    @handlers = nil
  end
end