Contents

module NFS
  module SUNRPC
    class Procedure
      attr_reader :number

      def initialize(number, returntype, argtype, &block)
        @number = number
        @returntype, @argtype = returntype, argtype
        @block = block
      end

      def dup
        Procedure.new(@number, @returntype, @argtype, &@block)
      end

      def on_call(&block)
        @block = block
      end

      def encode(arg)
        @argtype.encode(arg)
      end

      def decode(value)
        @returntype.decode(value)
      end

      def call(arg, cred, verf)
        begin
          arg_object = @argtype.decode(arg)
        rescue
          raise GarbageArguments
        end

        # Undefined procedures are also unavailable, even if the XDR says it's
        # there. Define your procedures and this won't happen.
        if @block.nil?
          raise ProcedureUnavailable
        end

        result_object = @block.call(arg_object, cred, verf)
        result = nil

        begin
          result = @returntype.encode(result_object)
        rescue => e
          NFS.logger.error(e.message)
          NFS.logger.error(e.backtrace.join("\n"))
          raise IgnoreRequest
        end

        result
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
nfs-rb-1.0.1	lib/nfs/sunrpc/procedure.rb
nfs-rb-1.0.0	lib/nfs/sunrpc/procedure.rb