1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "rpinterface.h"
#include "juniperparams.h"
#include "foreach_utils.h"
#include "queryvisitor.h"
#include "queryhandle.h"
#include "propreader.h"
#include "result.h"
#include "config.h"
#include <vector>
#include <cassert>
#include <vespa/log/log.h>
LOG_SETUP(".juniper.rpinterface");
/* Implementation of the interface between Juniper and the content/query provider */
namespace juniper {
bool AnalyseCompatible(Config* conf1, Config* conf2)
{
return conf1 == conf2 ||
(conf1 && conf2 && conf1->_matcherparams == conf2->_matcherparams
&& conf1->_docsumparams.Length() == conf2->_docsumparams.Length());
}
void SetDebug(unsigned int mask)
{
#ifdef FASTOS_DEBUG
if (mask & ~1 && mask != debug_level)
LOG(info, "Juniper debug mode enabled (0x%x)", mask);
else if (! (debug_level & ~1))
LOG(info, "Juniper debug mode disabled (0x%x)", mask);
debug_level = mask;
#else
// Make sure we do not get 200 of these warnings per query..
static bool warning_printed = false;
if (mask && !warning_printed)
{
LOG(warning,
"Juniper debug mode requested in binary compiled without debug support!");
warning_printed = true;
}
#endif
}
Juniper::Juniper(IJuniperProperties* props, Fast_WordFolder* wordfolder, int api_version) :
_props(props),
_wordfolder(wordfolder),
_modifier(new QueryModifier())
{
if (api_version != JUNIPER_RP_ABI_VERSION)
{
// This can happen if fsearch and juniper is not compiled with the same version of the
// Juniper API header files.
LOG(error, "FATAL: "
"juniper::Init: incompatible ABI versions between Juniper(%d) and caller (%d)!",
JUNIPER_RP_ABI_VERSION, api_version);
}
assert(props);
assert(wordfolder);
LOG(debug, "Juniper result processor (interface v.%d)", JUNIPER_RP_ABI_VERSION);
unsigned int debug_mask = strtol(_props->GetProperty("juniper.debug_mask", "0"), NULL, 0);
if (debug_mask) SetDebug(debug_mask);
}
Juniper::~Juniper()
{
}
std::unique_ptr<Config> Juniper::CreateConfig(const char* config_name)
{
return std::unique_ptr<Config>(new Config(config_name, *this));
}
QueryHandle* Juniper::CreateQueryHandle(const IQuery& fquery, const char* juniperoptions)
{
return new QueryHandle(fquery, juniperoptions, *_modifier);
}
void Juniper::AddRewriter(const char* index_name, IRewriter* rewriter, bool for_query, bool for_document)
{
_modifier->AddRewriter(index_name, rewriter, for_query, for_document);
}
void Juniper::FlushRewriters()
{
_modifier->FlushRewriters();
}
void ReleaseQueryHandle(QueryHandle*& handle)
{
delete handle;
handle = NULL;
}
Result* Analyse(const Config* config, QueryHandle* qhandle,
const char* docsum, size_t docsum_len,
uint32_t docid, uint32_t /* inputfield_id */,
uint32_t langid)
{
LOG(debug, "juniper::Analyse(): docId(%u), docsumLen(%zu), docsum(%s), langId(%u)",
docid, docsum_len, docsum, langid);
Result* res = new Result(const_cast<Config*>(config), qhandle, docsum, docsum_len, langid);
return res;
}
long GetRelevancy(Result* result_handle)
{
return result_handle->GetRelevancy();
}
Summary* GetTeaser(Result* result_handle, const Config* alt_config)
{
return result_handle->GetTeaser(alt_config);
}
Summary* GetLog(Result* result_handle)
{
return result_handle->GetLog();
}
void ReleaseResult(Result*& result_handle)
{
LOG(debug, "juniper::ReleaseResult");
delete result_handle;
result_handle = NULL;
}
} // end namespace juniper
|
