Class: Aerospike::Node

Inherits:
Object
  • Object
show all
Defined in:
lib/aerospike/cluster/node.rb

Constant Summary collapse

PARTITIONS = 
4096
FULL_HEALTH = 
100

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cluster, nv) ⇒ Node

Initialize server node with connection parameters.



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/aerospike/cluster/node.rb', line 31

def initialize(cluster, nv)
  @cluster = cluster
  @name = nv.name
  @aliases = Atomic.new(nv.aliases)
  @host = nv.host
  @use_new_info = Atomic.new(nv.use_new_info)
  @features = nv.features

  # Assign host to first IP alias because the server identifies nodes
  # by IP address (not hostname).
  @host =                nv.aliases[0]
  @health =              Atomic.new(FULL_HEALTH)
  @partition_generation = Atomic.new(-1)
  @reference_count =      Atomic.new(0)
  @responded =           Atomic.new(false)
  @active =              Atomic.new(true)

  @connections =         Pool.new(@cluster.connection_queue_size)
  @connections.create_block = Proc.new do
    while conn = Connection.new(@host.name, @host.port, @cluster.connection_timeout)

      # need to authenticate
      if @cluster.user && @cluster.user != ''
        begin
          command = AdminCommand.new
          command.authenticate(conn, @cluster.user, @cluster.password)
        rescue => e
          # Socket not authenticated. Do not put back into pool.
          conn.close if conn
          raise e
        end
      end

      break if conn.connected?
    end
    conn
  end

  @connections.cleanup_block = Proc.new { |conn| conn.close if conn }
end

Instance Attribute Details

#features ⇒ Object (readonly)

Returns the value of attribute features.



25
26
27
 
# File 'lib/aerospike/cluster/node.rb', line 25

def features
  @features
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



25
26
27
 
# File 'lib/aerospike/cluster/node.rb', line 25

def name
  @name
end

#reference_count ⇒ Object (readonly)

Returns the value of attribute reference_count.



25
26
27
 
# File 'lib/aerospike/cluster/node.rb', line 25

def reference_count
  @reference_count
end

#responded ⇒ Object (readonly)

Returns the value of attribute responded.



25
26
27
 
# File 'lib/aerospike/cluster/node.rb', line 25

def responded
  @responded
end

Instance Method Details

#==(other) ⇒ Object Also known as: eql? 



180
181
182
 
# File 'lib/aerospike/cluster/node.rb', line 180

def ==(other)
  other && other.is_a?(Node) && (@name == other.name)
end

#active? ⇒ Boolean

Checks if the node is active

Returns:

  • (Boolean) 


141
142
143
 
# File 'lib/aerospike/cluster/node.rb', line 141

def active?
  @active.value
end

#add_alias(alias_to_add) ⇒ Object

Adds an alias for the node



156
157
158
159
160
161
162
163
164
 
# File 'lib/aerospike/cluster/node.rb', line 156

def add_alias(alias_to_add)
  # Aliases are only referenced in the cluster tend threads,
  # so synchronization is not necessary.
  aliases = get_aliases
  aliases ||= []

  aliases << alias_to_add
  set_aliases(aliases)
end

#close ⇒ Object

Marks node as inactice and closes all cached connections



167
168
169
170
 
# File 'lib/aerospike/cluster/node.rb', line 167

def close
  @active.value = false
  close_connections
end

#decrease_health ⇒ Object

Decrease node Health as a result of bad connection or communication



126
127
128
 
# File 'lib/aerospike/cluster/node.rb', line 126

def decrease_health
  @health.update {|v| v -= 1 }
end

#get_aliases ⇒ Object

Returns node aliases



151
152
153
 
# File 'lib/aerospike/cluster/node.rb', line 151

def get_aliases
  @aliases.value
end

#get_connection(timeout) ⇒ Object

Get a connection to the node. If no cached connection is not available, a new connection will be created



101
102
103
104
105
106
107
108
109
 
# File 'lib/aerospike/cluster/node.rb', line 101

def get_connection(timeout)
  while true
    conn = @connections.poll
    if conn.connected?
      conn.timeout = timeout.to_f
      return conn
    end
  end
end

#get_host ⇒ Object

Retrieves host for the node



136
137
138
 
# File 'lib/aerospike/cluster/node.rb', line 136

def get_host
  @host
end

#get_name ⇒ Object

Returns node name



146
147
148
 
# File 'lib/aerospike/cluster/node.rb', line 146

def get_name
  @name
end

#hash ⇒ Object 



189
190
191
 
# File 'lib/aerospike/cluster/node.rb', line 189

def hash
  @name.hash
end

#put_connection(conn) ⇒ Object

Put back a connection to the cache. If cache is full, the connection will be closed and discarded



113
114
115
116
 
# File 'lib/aerospike/cluster/node.rb', line 113

def put_connection(conn)
  conn.close if !@active.value
  @connections.offer(conn)
end

#refresh ⇒ Object

Request current status from server node, and update node with the result



73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/aerospike/cluster/node.rb', line 73

def refresh
  friends = []

  begin
    conn = get_connection(1)
    info_map = Info.request(conn, "node", "partition-generation", "services")
  rescue => e
    Aerospike.logger.error("Error during refresh for node #{self}: #{e}")

    conn.close if conn
    decrease_health

    return friends
  end

  verify_node_name(info_map)
  restore_health

  @responded.update{|v| true}

  friends = add_friends(info_map)
  update_partitions(conn, info_map)
  put_connection(conn)
  friends
end

#restore_health ⇒ Object

Mark the node as healthy



119
120
121
122
123
 
# File 'lib/aerospike/cluster/node.rb', line 119

def restore_health
  # There can be cases where health is full, but active is false.
  # Once a node has been marked inactive, it stays inactive.
  @health.value = FULL_HEALTH
end

#supports_feature?(feature) ⇒ Boolean

Returns:

  • (Boolean) 


172
173
174
 
# File 'lib/aerospike/cluster/node.rb', line 172

def supports_feature?(feature)
  @features.include?(feature.to_s)
end

#to_s ⇒ Object 



176
177
178
 
# File 'lib/aerospike/cluster/node.rb', line 176

def to_s
  "#{@name}:#{@host}"
end

#unhealthy? ⇒ Boolean

Check if the node is unhealthy

Returns:

  • (Boolean) 


131
132
133
 
# File 'lib/aerospike/cluster/node.rb', line 131

def unhealthy?
  @health.value <= 0
end

#use_new_info? ⇒ Boolean

Returns:

  • (Boolean) 


185
186
187
 
# File 'lib/aerospike/cluster/node.rb', line 185

def use_new_info?
  @use_new_info.value
end