github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

- make get_ferret open a new IndexReader and Searcher every time, otherwise we

Browse source 
can get stale search results.
This commit is contained in:
Jordan Sissel 2009-10-23 10:07:10 +00:00
parent 645d17da70
commit 9195abd6de
1 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
lib/net/servers/indexer.rb
View file

@ -80,15 +80,20 @@ module LogStash; module Net; module Servers
end
def get_ferret(log_type)
@readers[log_type] ||= Ferret::Index::IndexReader.new(
@config.logs[log_type].index_dir)
reader = @readers[log_type]
@searchers[log_type] ||= Ferret::Search::Searcher.new(reader)
#@readers[log_type] ||= Ferret::Index::IndexReader.new(
#@config.logs[log_type].index_dir)
#reader = @readers[log_type]
#@searchers[log_type] ||= Ferret::Search::Searcher.new(reader)
# open the index every time otherwise we get stale results.
reader = Ferret::Index::IndexReader.new(@config.logs[log_type].index_dir)
searcher = Ferret::Search::Searcher.new(reader)
@qps[log_type] ||= Ferret::QueryParser.new(
:fields => reader.fields,
:tokenized_fields => reader.tokenized_fields,
:or_default => false)
return @readers[log_type], @searchers[log_type], @qps[log_type]
#return @readers[log_type], @searchers[log_type], @qps[log_type]
return reader, searcher, @qps[log_type]
end
def SearchRequestHandler(request)