Class Rumai::IXP::Agent < Object

# File lib/rumai/ixp/transport.rb, line 26
      def initialize stream
        @stream = stream

        @recv_buf = {} # tag => message
        @recv_lock = Mutex.new

        @tag_pool = RangedPool.new(0...BYTE2_MASK)
        @fid_pool = RangedPool.new(0...BYTE4_MASK)

        # establish connection with 9P2000 server
        req = Tversion.new(
          :tag     => Fcall::NOTAG,
          :msize   => Tversion::MSIZE,
          :version => Tversion::VERSION
        )
        rsp = talk(req)

        unless req.version == rsp.version
          raise Error, "protocol mismatch: self=#{req.version.inspect} server=#{rsp.version.inspect}"
        end

        @msize = rsp.msize

        # authenticate the connection (not necessary for wmii)
        @auth_fid = Fcall::NOFID

        # attach to filesystem root
        @root_fid = @fid_pool.obtain
        attach @root_fid, @auth_fid
      end

# File lib/rumai/ixp/transport.rb, line 459
      def attach root_fid, auth_fid = Fcall::NOFID, auth_name = ENV['USER']
        talk Tattach.new(
          :fid    => root_fid,
          :afid   => auth_fid,
          :uname  => ENV['USER'],
          :aname  => auth_name
        )
      end

# File lib/rumai/ixp/transport.rb, line 471
      def clunk fid
        talk Tclunk.new(:fid => fid)
        @fid_pool.release fid
      end

# File lib/rumai/ixp/transport.rb, line 382
      def create path, mode = 'rw', perm = 0644
        prefix = File.dirname(path)
        target = File.basename(path)

        mode = MODES.parse(mode)

        with_fid do |prefix_fid|
          walk_fid prefix_fid, prefix

          # create the file
          talk Tcreate.new(
            :fid => prefix_fid,
            :name => target,
            :perm => perm,
            :mode => mode
          )
        end
      end

# File lib/rumai/ixp/transport.rb, line 360
      def entries path
        unless stat(path).directory?
          raise ArgumentError, "#{path.inspect} is not a directory"
        end

        read(path).map! {|t| t.name}
      end

# File lib/rumai/ixp/transport.rb, line 199
      def open path, mode = 'r' # :yields: FidStream
        mode = MODES.parse(mode)

        # open the file
        path_fid = walk(path)

        talk Topen.new(
          :fid  => path_fid,
          :mode => mode
        )

        stream = FidStream.new(self, path_fid, @msize)

        # return the file stream
        if block_given?
          begin
            yield stream
          ensure
            stream.close
          end
        else
          stream
        end
      end

# File lib/rumai/ixp/transport.rb, line 348
      def read path, *args
        open path do |f|
          f.read(*args)
        end
      end

# File lib/rumai/ixp/transport.rb, line 124
      def recv tag
        loop do
          reply = @recv_lock.synchronize do
            if @recv_buf.key? tag
              @recv_buf.delete tag
            else
              # reply was not in the receive buffer, so wait
              # for the next reply... hoping that it is ours
              msg = Fcall.from_9p(@stream)

              if msg.tag == tag
                msg
              else
                # we got someone else's reply, so buffer
                # it (for them to receive) and try again
                @recv_buf[msg.tag] = msg
                nil
              end
            end
          end

          if reply
            @tag_pool.release tag

            if reply.is_a? Rerror
              raise Error, reply.ename
            end

            return reply
          else
            # give other threads a chance to receive
            Thread.pass
          end
        end
      end

# File lib/rumai/ixp/transport.rb, line 404
      def remove path
        path_fid = walk(path)
        remove_fid path_fid # remove also does clunk
      end

# File lib/rumai/ixp/transport.rb, line 413
      def remove_fid path_fid
        talk Tremove.new(:fid => path_fid)
      end

# File lib/rumai/ixp/transport.rb, line 111
      def send request
        tag = @tag_pool.obtain

        request.tag = tag
        @stream << request.to_9p

        tag
      end

# File lib/rumai/ixp/transport.rb, line 420
      def stat path
        with_fid do |path_fid|
          walk_fid path_fid, path
          stat_fid path_fid
        end
      end

# File lib/rumai/ixp/transport.rb, line 430
      def stat_fid path_fid
        req = Tstat.new(:fid => path_fid)
        rsp = talk(req)
        rsp.stat
      end

# File lib/rumai/ixp/transport.rb, line 163
      def talk request
        tag = send(request)

        begin
          recv tag
        rescue Error => e
          e.message << " -- in reply to #{request.inspect}"
          raise
        end
      end

# File lib/rumai/ixp/transport.rb, line 439
      def walk path
        fid = @fid_pool.obtain
        walk_fid fid, path
        fid
      end

# File lib/rumai/ixp/transport.rb, line 448
      def walk_fid path_fid, path
        talk Twalk.new(
          :fid    => @root_fid,
          :newfid => path_fid,
          :wname  => path.to_s.split(%r{/+}).reject {|s| s.empty? }
        )
      end

# File lib/rumai/ixp/transport.rb, line 372
      def write path, content
        open path, 'w' do |f|
          f << content
        end
      end