Sha256: fca2f4250bc3e07a596dc9744c21cf798e0060507d3a81aeb6cb4a40f399f00e
Contents?: true
Size: 1.42 KB
Versions: 2
Compression:
Stored size: 1.42 KB
Contents
# :include: rdoc/MDC # # == Other Info # # Version:: $Id$ # Author:: Colby Gutierrez-Kraybill <colby(at)astro.berkeley.edu> require 'monitor' module Log4r MDCNAME = "log4rMDC" MDCNAMEMAXDEPTH = "log4rMDCMAXDEPTH" $globalMDCLock = Monitor.new # See log4r-color/MDC.rb class MDC < Monitor private_class_method :new def self.check_thread_instance() # need to interlock here, so that if # another thread is entering this section # of code before the main thread does, # then the main thread copy of the MDC # is setup before then attempting to clone # it off if ( Thread.current[MDCNAME] == nil ) then $globalMDCLock.synchronize do if ( Thread.main[MDCNAME] == nil ) then Thread.main[MDCNAME] = Hash.new end if ( Thread.current != Thread.main ) then Thread.current[MDCNAME] = Hash.new Thread.main[MDCNAME].each{ |k,v| Thread.current[MDCNAME][k] = v } end end end end def self.get( a_key ) self.check_thread_instance() Thread.current[MDCNAME].fetch(a_key, ""); end def self.get_context() self.check_thread_instance() return Thread.current[MDCNAME].clone end def self.put( a_key, a_value ) self.check_thread_instance() Thread.current[MDCNAME][a_key] = a_value end def self.remove( a_key ) self.check_thread_instance() Thread.current[MDCNAME].delete( a_key ) end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
log4r-color-1.2.2 | lib/log4r-color/MDC.rb |
log4r-color-1.2 | lib/log4r-color/MDC.rb |