about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-10-20 09:03:23 +0000
committerEric Wong <normalperson@yhbt.net>2011-10-20 09:03:23 +0000
commit0d7f4e94223bb7413b98f39ac03ddc2970f2bbb3 (patch)
tree30f449457be65efee3eefd7a02083557368675c6
parentbd4e832d294635594c2af4da7a6b05fb884b2ce2 (diff)
downloadmogilefs-client-0d7f4e94223bb7413b98f39ac03ddc2970f2bbb3.tar.gz
One tiny step in removing core class changes.
-rw-r--r--lib/mogilefs/backend.rb6
-rw-r--r--lib/mogilefs/util.rb5
2 files changed, 5 insertions, 6 deletions
diff --git a/lib/mogilefs/backend.rb b/lib/mogilefs/backend.rb
index 80f714f..407a861 100644
--- a/lib/mogilefs/backend.rb
+++ b/lib/mogilefs/backend.rb
@@ -229,7 +229,7 @@ class MogileFS::Backend
       return true if found && found[0]
       timeleft -= (Time.now - t0)
       timeleft >= 0 and next
-      peer = io ? "#{io.mogilefs_peername} " : nil
+      peer = io ? "#{peername(io)} " : nil
 
       raise MogileFS::UnreadableSocketError, "#{peer}never became readable"
     end
@@ -297,5 +297,9 @@ class MogileFS::Backend
     str.gsub(/%([a-f0-9][a-f0-9])/i) { [$1.to_i(16)].pack 'C' }.tr('+', ' ')
   end
 
+  def peername(io) # :nodoc:
+    Socket.unpack_sockaddr_in(io.getpeername).
+           reverse!.map! { |x| x.to_s }.join(':')
+  end
 end
 
diff --git a/lib/mogilefs/util.rb b/lib/mogilefs/util.rb
index a783fd8..d621cc1 100644
--- a/lib/mogilefs/util.rb
+++ b/lib/mogilefs/util.rb
@@ -113,11 +113,6 @@ class MogileFS::Timeout < Timeout::Error; end
 class Socket
   attr_accessor :mogilefs_addr, :mogilefs_connected, :mogilefs_size
 
-  # Socket lacks peeraddr method of the IPSocket/TCPSocket classes
-  def mogilefs_peername
-    Socket.unpack_sockaddr_in(getpeername).reverse.map {|x| x.to_s }.join(':')
-  end
-
   def mogilefs_init(host = nil, port = nil)
     return true if defined?(@mogilefs_connected)