Class: MessagePack::RPC::Address

Inherits:
Object
  • Object
show all
Defined in:
lib/msgpack/rpc/address.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(host, port) ⇒ Address

BSD



39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/msgpack/rpc/address.rb', line 39

def initialize(host, port)
  raw = Socket.pack_sockaddr_in(port, host)
  family = raw.unpack('S')[0]
  if family == Socket::AF_INET
    @serial = raw[2,6]
  elsif family == Socket::AF_INET6
    @serial = raw[2,2] + raw[8,16]
  else
    raise "Unknown address family: #{family}"
  end
end

Class Method Details

.load(raw) ⇒ Object 



116
117
118
 
# File 'lib/msgpack/rpc/address.rb', line 116

def self.load(raw)
  Address.new *parse(raw)
end

.parse(raw) ⇒ Object 



112
113
114
 
# File 'lib/msgpack/rpc/address.rb', line 112

def self.parse(raw)
  Socket.unpack_sockaddr_in(parse_sockaddr(raw)).reverse
end

.parse_sockaddr(raw) ⇒ Object 



86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/msgpack/rpc/address.rb', line 86

def self.parse_sockaddr(raw)
  raw.force_encoding('ASCII-8BIT')
  if raw.length == 6
    addr = Socket.pack_sockaddr_in(0, '0.0.0.0')
    addr[2,6] = raw[0,6]
  else
    addr = Socket.pack_sockaddr_in(0, '::')
    addr[2,2]  = raw[0,2]
    addr[8,16] = raw[2,16]
  end
  addr
end

Instance Method Details

#<=>(o) ⇒ Object 



136
137
138
 
# File 'lib/msgpack/rpc/address.rb', line 136

def <=>(o)
  dump <=> o.dump
end

#==(o) ⇒ Object 



152
153
154
 
# File 'lib/msgpack/rpc/address.rb', line 152

def ==(o)
  eql?(o)
end

#connectable? ⇒ Boolean

Returns:

  • (Boolean) 


73
74
75
 
# File 'lib/msgpack/rpc/address.rb', line 73

def connectable?
  port != 0
end

#dump ⇒ Object 



120
121
122
 
# File 'lib/msgpack/rpc/address.rb', line 120

def dump
  @serial
end

#eql?(o) ⇒ Boolean

Returns:

  • (Boolean) 


144
145
146
 
# File 'lib/msgpack/rpc/address.rb', line 144

def eql?(o)
  o.class == Address && dump.eql?(o.dump)
end

#hash ⇒ Object 



148
149
150
 
# File 'lib/msgpack/rpc/address.rb', line 148

def hash
  dump.hash
end

#host ⇒ Object 



65
66
67
 
# File 'lib/msgpack/rpc/address.rb', line 65

def host
  unpack[0]
end

#inspect ⇒ Object 



140
141
142
 
# File 'lib/msgpack/rpc/address.rb', line 140

def inspect
  "#<#{self.class} #{to_s} @serial=#{@serial.inspect}>"
end

#port ⇒ Object 



69
70
71
 
# File 'lib/msgpack/rpc/address.rb', line 69

def port
  unpack[1]
end

#sockaddr ⇒ Object 



77
78
79
 
# File 'lib/msgpack/rpc/address.rb', line 77

def sockaddr
  Address.parse_sockaddr(@serial)
end

#to_a ⇒ Object 



132
133
134
 
# File 'lib/msgpack/rpc/address.rb', line 132

def to_a
  unpack
end

#to_msgpack(out = '') ⇒ Object 



124
125
126
 
# File 'lib/msgpack/rpc/address.rb', line 124

def to_msgpack(out = '')
  @serial.to_msgpack(out)
end

#to_s ⇒ Object 



128
129
130
 
# File 'lib/msgpack/rpc/address.rb', line 128

def to_s
  unpack.join(':')
end

#unpack ⇒ Object 



81
82
83
 
# File 'lib/msgpack/rpc/address.rb', line 81

def unpack
  Address.parse(@serial)
end