Contents

module Libuv
    module FsChecks


        def stat
            @stat_deferred = @loop.defer

            request = ::Libuv::Ext.create_request(:uv_fs)
            pre_check @stat_deferred, request, ::Libuv::Ext.fs_fstat(@loop.handle, request, @fileno, callback(:on_stat))
            @stat_deferred.promise
        end


        private


        def on_stat(req)
            if post_check(req, @stat_deferred)
                uv_stat = req[:stat]
                uv_members = uv_stat.members
                values = UvStat.members.map { |k| uv_members.include?(k) ? uv_stat[k] : nil }
                uv_stat = UvStat.new(*values)

                cleanup(req)
                @stat_deferred.resolve(uv_stat)
            end
            @stat_deferred = nil
        end

        def pre_check(deferrable, request, result)
            error = check_result result
            if error
                ::Libuv::Ext.free(request)
                deferrable.reject(error)
            end
        end

        def cleanup(req)
            ::Libuv::Ext.fs_req_cleanup(req)
            ::Libuv::Ext.free(req)
        end

        def post_check(req, deferrable)
            error = check_result(req[:result])
            if error
                cleanup(req)
                deferrable.reject(error)
                false
            else
                true
            end
        end
    end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
libuv-0.11.5	lib/libuv/mixins/fs_checks.rb
libuv-0.11.3	lib/libuv/mixins/fs_checks.rb
libuv-0.11.2	lib/libuv/mixins/fs_checks.rb
libuv-0.11.1	lib/libuv/mixins/fs_checks.rb
libuv-0.11.0	lib/libuv/mixins/fs_checks.rb
libuv-0.10.3	lib/libuv/mixins/fs_checks.rb
libuv-0.10.2	lib/libuv/mixins/fs_checks.rb