Contents

require 'fastdfs-client/storage'

module Fastdfs
  module Client

    class Tracker

      attr_accessor :socket, :cmd, :options, :socket

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

      def get_storage
        res = @proxy.dispose(@cmd, 0) 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.3.0	lib/fastdfs-client/tracker.rb
fastdfs-client-1.2.0	lib/fastdfs-client/tracker.rb