Navigation Menu

Skip to content

Commit

Permalink
Isolate EngineNode from NodeMetadata
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 21, 2015
1 parent 096abec commit 3dabc74
Showing 1 changed file with 4 additions and 9 deletions.
13 changes: 4 additions & 9 deletions lib/droonga/engine_node.rb
Expand Up @@ -18,7 +18,7 @@
require "droonga/loggable"
require "droonga/forward_buffer"
require "droonga/fluent_message_sender"
require "droonga/node_metadata"
require "droonga/node_role"

module Droonga
class EngineNode
Expand All @@ -31,7 +31,6 @@ def initialize(name, state, loop, params)
logger.trace("initialize: start")

@state = state
@sender_node_metadata = params[:metadata]

@buffer = ForwardBuffer.new(name)
boundary_timestamp = accept_messages_newer_than_timestamp
Expand Down Expand Up @@ -86,7 +85,7 @@ def forward(message, destination)

def forwardable?
return false unless live?
role == sender_role
role == NodeRole.my_role
end

def readable?
Expand All @@ -95,7 +94,7 @@ def readable?
end

def writable?
case sender_role
case NodeRole.my_role
when NodeMetadata::Role::SERVICE_PROVIDER
true
when NodeMetadata::Role::ABSORB_SOURCE
Expand Down Expand Up @@ -201,7 +200,7 @@ def complete_service_provider?

def really_writable?
return false unless writable?
case sender_role
case NodeRole.my_role
when NodeMetadata::Role::SERVICE_PROVIDER
service_provider?
when NodeMetadata::Role::ABSORB_SOURCE
Expand All @@ -211,10 +210,6 @@ def really_writable?
end
end

def sender_role
@sender_node_metadata.role
end

def read_message?(message)
steps = message["body"]["steps"]
return false unless steps
Expand Down

0 comments on commit 3dabc74

Please sign in to comment.