+static void termlist_response(struct http_channel *c, struct http_session *s, const char *cmd_status)
+{
+ struct http_request *rq = c->request;
+ const char *name = http_argbyname(rq, "name");
+ const char *nums = http_argbyname(rq, "num");
+ int version = get_version(rq);
+ int num = 15;
+ int status;
+
+ if (nums)
+ num = atoi(nums);
+
+ status = session_active_clients(s->psession);
+
+ response_open_no_status(c, "termlist");
+ /* new protocol add a status to response. Triggered by a status parameter */
+ if (cmd_status != 0)
+ wrbuf_printf(c->wrbuf, "<status>%s</status>\n", cmd_status);
+ wrbuf_printf(c->wrbuf, "<activeclients>%d</activeclients>\n", status);
+
+ perform_termlist(c, s->psession, name, num, version);
+
+ response_close(c, "termlist");
+}
+
+static void termlist_result_ready(void *data)
+{
+ struct http_channel *c = (struct http_channel *) data;
+ struct http_request *rq = c->request;
+ const char *report = http_argbyname(rq, "report");
+ const char *status = 0;
+ struct http_session *s = locate_session(c);
+ if (report && !strcmp("status", report))
+ status = "OK";
+ if (s)
+ {
+ session_log(s->psession, c->http_sessions->log_level,
+ "termlist watch released");
+ termlist_response(c, s, status);
+ release_session(c,s);
+ }
+}
+
+static void cmd_termlist(struct http_channel *c)
+{
+ struct http_request *rq = c->request;
+ struct http_response *rs = c->response;
+ struct http_session *s = locate_session(c);
+ const char *block = http_argbyname(rq, "block");
+ const char *report = http_argbyname(rq, "report");
+ int report_status = 0;
+ int report_error = 0;
+ const char *status_message = 0;
+ int active_clients;
+
+ if (report && !strcmp("error", report))
+ {
+ report_error = 1;
+ status_message = "OK";
+ }
+ if (report && !strcmp("status", report))
+ {
+ report_status = 1;
+ status_message = "OK";
+ }
+ if (!s)
+ return;
+
+ active_clients = session_active_clients(s->psession);
+ if (block && !strcmp("1", block) && active_clients)
+ {
+ // if there is already a watch/block. we do not block this one
+ if (session_set_watch(s->psession, SESSION_WATCH_TERMLIST,
+ termlist_result_ready, c, c) != 0)
+ {
+ session_log(s->psession, YLOG_WARN, "Attempt to block "
+ "multiple times on termlist block. Not supported!");
+ if (report_error) {
+ error(rs, PAZPAR2_ALREADY_BLOCKED, "termlist");
+ release_session(c, s);
+ return;
+ }
+ else if (report_status)
+ status_message = "WARNING (Already blocked on termlist)";
+ else
+ session_log(s->psession, YLOG_WARN,
+ "Ignoring termlist block. Return current result");
+ }
+ else
+ {
+ session_log(s->psession, c->http_sessions->log_level,
+ "Blocking on command termlist");
+ release_session(c, s);
+ return;
+ }
+ }
+
+ termlist_response(c, s, status_message);
+ release_session(c, s);
+}
+
+size_t session_get_memory_status(struct session *session);
+
+static void session_status(struct http_channel *c, struct http_session *s)
+{
+ size_t session_nmem;
+ wrbuf_printf(c->wrbuf, "<http_count>%u</http_count>\n", s->activity_counter);
+ wrbuf_printf(c->wrbuf, "<http_nmem>%zu</http_nmem>\n", nmem_total(s->nmem) );
+ session_nmem = session_get_memory_status(s->psession);
+ wrbuf_printf(c->wrbuf, "<session_nmem>%zu</session_nmem>\n", session_nmem);
+}
+
+static void cmd_session_status(struct http_channel *c)
+{
+ struct http_session *s = locate_session(c);
+ if (!s)
+ return;
+
+ response_open(c, "session-status");
+ session_status(c, s);
+ response_close(c, "session-status");
+ release_session(c, s);
+}
+
+int sessions_count(void);
+int clients_count(void);
+#ifdef HAVE_RESULTSETS_COUNT
+int resultsets_count(void);
+#else
+#define resultsets_count() 0
+#endif
+
+static void cmd_server_status(struct http_channel *c)
+{
+ int sessions = sessions_count();
+ int clients = clients_count();
+ int resultsets = resultsets_count();
+
+ response_open(c, "server-status");
+ wrbuf_printf(c->wrbuf, "\n <sessions>%u</sessions>\n", sessions);
+ wrbuf_printf(c->wrbuf, " <clients>%u</clients>\n", clients);
+ /* Only works if yaz has been compiled with enabling of this */
+ wrbuf_printf(c->wrbuf, " <resultsets>%u</resultsets>\n",resultsets);
+ print_meminfo(c->wrbuf);
+
+/* TODO add all sessions status */
+/* http_sessions_t http_sessions = c->http_sessions; */
+/* struct http_session *p; */
+/*
+ yaz_mutex_enter(http_sessions->mutex);
+ for (p = http_sessions->session_list; p; p = p->next)
+ {
+ p->activity_counter++;
+ wrbuf_puts(c->wrbuf, "<session-status>\n");
+ wrbuf_printf(c->wrbuf, "<id>%s</id>\n", p->session_id);
+ yaz_mutex_leave(http_sessions->mutex);
+ session_status(c, p);
+ wrbuf_puts(c->wrbuf, "</session-status>\n");
+ yaz_mutex_enter(http_sessions->mutex);
+ p->activity_counter--;
+ }
+ yaz_mutex_leave(http_sessions->mutex);
+*/
+ response_close(c, "server-status");
+ xmalloc_trav(0);
+}
+
+static void bytarget_response(struct http_channel *c, struct http_session *s, const char *cmd_status) {
+ int count, i;
+ struct hitsbytarget *ht;
+ struct http_request *rq = c->request;
+ const char *settings = http_argbyname(rq, "settings");
+ int version = get_version(rq);
+ ht = get_hitsbytarget(s->psession, &count, c->nmem);
+ if (!cmd_status)
+ /* Old protocol, always ok */
+ response_open(c, "bytarget");
+ else {
+ /* New protocol, OK or WARNING (...)*/
+ response_open_no_status(c, "bytarget");
+ wrbuf_printf(c->wrbuf, "<status>%s</status>", cmd_status);
+ }
+
+ if (count == 0)
+ session_log(s->psession, YLOG_WARN,
+ "Empty bytarget Response. No targets found!");
+ for (i = 0; i < count; i++)
+ {
+ wrbuf_puts(c->wrbuf, "\n<target>");