class PhusionPassenger::AnalyticsLogger::Connection

def connected?
	return !!@channel
end

def disconnect
	@channel.close if @channel
	@channel = nil
end

def initialize(io)
	@mutex = Mutex.new
	@refcount = 1
	@channel = MessageChannel.new(io) if io
end

def ref
	@refcount += 1
end

def synchronize
	@mutex.synchronize do
		yield
	end
end

def unref
	@refcount -= 1
	if @refcount == 0
		disconnect
	end
end