class Cache

# File lib/logstash/filters/ip2proxy.rb, line 142
def cache_event(event, ip, filter)
  filter.handleEvent(event)
  cache[ip] = event
  timestamps[ip] = Time.now
end

# File lib/logstash/filters/ip2proxy.rb, line 138
def cache_full?(cache_size)
  cache.size >= cache_size
end

# File lib/logstash/filters/ip2proxy.rb, line 113
def find(event, ip, filter, cache_size)
  synchronize do
    if cache.has_key?(ip)
      refresh_event(event, ip, filter) if too_old?(ip)
    else
      if cache_full?(cache_size)
        make_room
      end
      cache_event(event, ip, filter)
    end
    times_queried.increment(ip)
    cache[ip]
  end
end

# File lib/logstash/filters/ip2proxy.rb, line 132
def make_room
  key = times_queried.delete_least_used
  cache.delete(key)
  timestamps.delete(key)
end

# File lib/logstash/filters/ip2proxy.rb, line 148
def synchronize(&block)
  @mutex.synchronize(&block)
end

# File lib/logstash/filters/ip2proxy.rb, line 128
def too_old?(ip)
  timestamps[ip] < Time.now - ONE_DAY_IN_SECONDS
end