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