Contents

# Author::    Nicolas Despres  <[e-mail]>.
# Copyright:: Copyright (c) 2004, 2005 TTK team. All rights reserved.
# License::   LGPL
# $Id: Server.rb 567 2005-04-13 08:00:06Z polrop $


require 'ttk/fetchers/server/sender'


module TTK

  module Fetchers

    class Server
      include DRb::DRbUndumped

      def initialize(service, repository)
        @service = service
        @repository = repository
        @resources_sent = []
        @mutex = Mutex.new
      end

      attr_reader :repository

      def resources_sent
        @mutex.synchronize { @resources_sent.dup }
      end

      def fetch(resource, recv)
        sender = Sender.new(@repository + resource, recv)
        @mutex.synchronize { @resources_sent << sender }
        sender.send
        sender.stat
      end

      def uri
        @service.uri
      end

    end # class Server

  end # module Fetchers

end # module TTK

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
ttk-0.1.576	lib/ttk/fetchers/Server.rb
ttk-0.1.580	lib/ttk/fetchers/Server.rb
ttk-0.1.579	lib/ttk/fetchers/Server.rb
ttk-0.2.1	lib/ttk/fetchers/Server.rb
ttk-0.2.0	lib/ttk/fetchers/Server.rb