Contents

require 'fastdfs-client/storage'

module Fastdfs
  module Client

    class Tracker
      
      attr_accessor :options, :socket

      def initialize(host, port, options = {})
        @options = options
        @proxy = ClientProxy.new(host, port, @options[:socket])
        @socket = @proxy.socket
      end

      def get_storage
        res = @proxy.dispose(CMD::STORE_WITHOUT_GROUP_ONE) do |body|
          storage_ip = body[ProtoCommon::IPADDR].strip
          storage_port = body[ProtoCommon::PORT].unpack("C*").to_pack_long
          store_path = body[ProtoCommon::TRACKER_BODY_LEN-1].unpack("C*")[0]
        
          Storage.new(storage_ip, storage_port, store_path, @options)
        end
        res[:status] ? res[:result] : res
      end
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fastdfs-client-1.4.4	lib/fastdfs-client/tracker.rb
fastdfs-client-1.4.3	lib/fastdfs-client/tracker.rb