Contents

# -*- coding: binary -*-
require 'thread'

module Rex

###
#
# This module provides a uniform reference counted interface for classes to
# use.
#
###
module Ref
  #
  # Raises a TypeError to prevent cloning.
  #
  def clone
    raise TypeError, "can't clone instance of Ref #{self.class}"
  end

  #
  # Raises a TypeError to prevent duping.
  #
  def dup
    raise TypeError, "can't dup instance of Ref #{self.class}"
  end

  #
  # Ensures that the Ref is correctly initialized when extended on an object:
  # ```
  # arbitrary_resource = Resource.new
  # arbitrary_resource.extend(::Rex::Ref)
  # ```
  #
  # @param instance [object] the instance that has just extended the Ref module
  def self.extended(instance)
    instance.refinit
  end

  #
  # Initializes the reference count to one.
  #
  def refinit
    return if defined?(@_references)

    @_references       = 1
    @_references_mutex = Mutex.new

    self
  end

  #
  # Increments the total number of references.
  #
  def ref
    @_references_mutex.synchronize {
      @_references += 1
    }

    self
  end

  #
  # Decrements the total number of references.  If the reference count
  # reaches zero, true is returned.  Otherwise, false is returned.
  #
  def deref
    @_references_mutex.synchronize {
      if ((@_references -= 1) == 0)
        cleanup

        true
      else
        false
      end
    }
  end

  #
  # Called to clean up resources once the ref count drops to zero.
  #
  def cleanup
  end

end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
rex-core-0.1.31	lib/rex/sync/ref.rb
rex-core-0.1.30	lib/rex/sync/ref.rb
rex-core-0.1.29	lib/rex/sync/ref.rb
rex-core-0.1.28	lib/rex/sync/ref.rb
rex-core-0.1.27	lib/rex/sync/ref.rb
rex-core-0.1.26	lib/rex/sync/ref.rb