struct client_list *next;
};
+/* session counting (1) , disable client counting (0) */
+static YAZ_MUTEX g_session_mutex = 0;
+static int no_sessions = 0;
+static int no_session_total = 0;
+
+static int session_use(int delta)
+{
+ int sessions;
+ if (!g_session_mutex)
+ yaz_mutex_create(&g_session_mutex);
+ yaz_mutex_enter(g_session_mutex);
+ no_sessions += delta;
+ if (delta > 0)
+ no_session_total += delta;
+ sessions = no_sessions;
+ yaz_mutex_leave(g_session_mutex);
+ yaz_log(YLOG_DEBUG, "%s sesions=%d", delta == 0 ? "" : (delta > 0 ? "INC" : "DEC"), no_sessions);
+ return sessions;
+}
+
+int sessions_count(void) {
+ return session_use(0);
+}
+
+int session_count_total(void) {
+ int total = 0;
+ if (!g_session_mutex)
+ return 0;
+ yaz_mutex_enter(g_session_mutex);
+ total = no_session_total;
+ yaz_mutex_leave(g_session_mutex);
+ return total;
+}
+
+
static void log_xml_doc(xmlDoc *doc)
{
FILE *lf = yaz_log_file();
s->num_termlists = i + 1;
}
- session_log(s, YLOG_DEBUG, "Session: facets for %s: %s norm:%s (%d)",
- type, value, wrbuf_cstr(facet_wrbuf), count);
+#if 0
+ session_log(s, YLOG_DEBUG, "Facets for %s: %s norm:%s (%d)", type, value, wrbuf_cstr(facet_wrbuf), count);
+#endif
termlist_insert(s->termlists[i].termlist, wrbuf_cstr(facet_wrbuf),
count);
}
session_leave(s);
session_log(s, YLOG_DEBUG,
- "session_alert_watch: %d calling function: %p", what, fun);
+ "Alert Watch: %d calling function: %p", what, fun);
fun(data);
}
else
struct session *se = (struct session*) context;
struct client *cl = client_create();
struct client_list *l;
- const char *maxrecs = session_setting_oneval(db, PZ_MAXRECS);
client_set_database(cl, db);
client_set_session(cl, se);
- if (*maxrecs)
- client_set_maxrecs(cl, atoi(maxrecs));
-
l = xmalloc(sizeof(*l));
l->client = cl;
l->next = se->clients;
for (l = s->clients; l; l = l->next)
if (client_is_active_preferred(l->client))
res++;
- session_log(s, YLOG_DEBUG, "Session has %d active preferred clients.", res);
+ session_log(s, YLOG_DEBUG, "Has %d active preferred clients.", res);
return res == 0;
}
}
}
+/* Depreciated: use session_destroy */
void destroy_session(struct session *se)
{
- struct session_database *sdb;
+ session_destroy(se);
+}
- session_log(se, YLOG_DEBUG, "Pazpar2 session destroy");
+void session_destroy(struct session *se) {
+ struct session_database *sdb;
+ session_log(se, YLOG_DEBUG, "Destroying");
+ session_use(-1);
session_remove_clients(se);
for (sdb = se->databases; sdb; sdb = sdb->next)
service_destroy(se->service);
yaz_mutex_destroy(&se->session_mutex);
wrbuf_destroy(se->wrbuf);
+
}
+
+size_t session_get_memory_status(struct session *session) {
+ size_t session_nmem;
+ if (session == 0)
+ return 0;
+ session_enter(session);
+ session_nmem = nmem_total(session->nmem);
+ session_leave(session);
+ return session_nmem;
+}
+
+
struct session *new_session(NMEM nmem, struct conf_service *service,
unsigned session_id)
{
sprintf(tmp_str, "session#%u", session_id);
session->session_id = session_id;
- session_log(session, YLOG_DEBUG, "New session");
+ session_log(session, YLOG_DEBUG, "New");
session->service = service;
session->relevance = 0;
session->total_hits = 0;
session->normalize_cache = normalize_cache_create();
session->session_mutex = 0;
pazpar2_mutex_create(&session->session_mutex, tmp_str);
-
+ session_use(1);
return session;
}
\param nmem working NMEM
\retval 0 OK
\retval -1 failure
+ \retval -2 Filtered
*/
int ingest_record(struct client *cl, const char *rec,
int record_no, NMEM nmem)
if (!check_record_filter(root, sdb))
{
- session_log(se, YLOG_WARN, "Filtered out record no %d from %s",
+ session_log(se, YLOG_LOG, "Filtered out record no %d from %s",
record_no, sdb->database->url);
xmlFreeDoc(xdoc);
- return -1;
+ return -2;
}
mergekey_norm = get_mergekey(xdoc, cl, record_no, service, nmem);
&se->total_merged);
const char *use_term_factor_str = session_setting_oneval(sdb, PZ_TERMLIST_TERM_FACTOR);
- // TODO: Work-around to default to use term factor, until other MK2 components supports it
- int use_term_factor = 1;
+ int use_term_factor = 0;
int term_factor = 1;
if (use_term_factor_str && use_term_factor_str[0] != 0)
use_term_factor = atoi(use_term_factor_str);
va_start(ap, fmt);
yaz_vsnprintf(buf, sizeof(buf)-30, fmt, ap);
- yaz_log(level, "%u %s", s->session_id, buf);
+ yaz_log(level, "Session (%u): %s", s->session_id, buf);
va_end(ap);
}