remoteserver.h

Go to the documentation of this file.

 
/* Copyright (C) 2006-2026 Olly Betts
 * Copyright (C) 2007,2009,2010 Lemur Consulting Ltd
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, see
 * <https://www.gnu.org/licenses/>.
 */
 
#ifndef XAPIAN_INCLUDED_REMOTESERVER_H
#define XAPIAN_INCLUDED_REMOTESERVER_H
 
#include "xapian/database.h"
#include "xapian/postingsource.h"
#include "xapian/registry.h"
#include "xapian/visibility.h"
#include "xapian/weight.h"
 
#include "remoteconnection.h"
 
#include <string>
#include <string_view>
 
class XAPIAN_VISIBILITY_DEFAULT RemoteServer : private RemoteConnection {
    void operator=(const RemoteServer &);
 
    RemoteServer(const RemoteServer &);
 
    Xapian::Database* db = nullptr;
 
    Xapian::WritableDatabase* wdb = nullptr;
 
    bool writable;
 
    double active_timeout;
 
    double idle_timeout;
 
    Xapian::Registry reg;
 
    XAPIAN_VISIBILITY_INTERNAL
    message_type get_message(double timeout, std::string & result,
                             message_type required_type = MSG_MAX);
 
    XAPIAN_VISIBILITY_INTERNAL
    void send_message(reply_type type, std::string_view message);
 
    XAPIAN_VISIBILITY_INTERNAL
    void send_message(reply_type type, std::string_view message,
                      double end_time) {
        unsigned char type_as_char = static_cast<unsigned char>(type);
        RemoteConnection::send_message(type_as_char, message, end_time);
    }
 
    // all terms
    XAPIAN_VISIBILITY_INTERNAL
    void msg_allterms(std::string_view message);
 
    // get document
    XAPIAN_VISIBILITY_INTERNAL
    void msg_document(std::string_view message);
 
    // term exists?
    XAPIAN_VISIBILITY_INTERNAL
    void msg_termexists(std::string_view message);
 
    // get collection freq
    XAPIAN_VISIBILITY_INTERNAL
    void msg_collfreq(std::string_view message);
 
    // get termfreq
    XAPIAN_VISIBILITY_INTERNAL
    void msg_termfreq(std::string_view message);
 
    // get termfreq and collection freq
    XAPIAN_VISIBILITY_INTERNAL
    void msg_freqs(std::string_view message);
 
    // get value statistics
    XAPIAN_VISIBILITY_INTERNAL
    void msg_valuestats(std::string_view message);
 
    // keep alive
    XAPIAN_VISIBILITY_INTERNAL
    void msg_keepalive(std::string_view message);
 
    // get doclength
    XAPIAN_VISIBILITY_INTERNAL
    void msg_doclength(std::string_view message);
 
    // set the query; return the mset
    XAPIAN_VISIBILITY_INTERNAL
    void msg_query(std::string_view message);
 
    // get termlist
    XAPIAN_VISIBILITY_INTERNAL
    void msg_termlist(std::string_view message);
 
    // get postlist
    XAPIAN_VISIBILITY_INTERNAL
    void msg_postlist(std::string_view message);
 
    // get positionlist
    XAPIAN_VISIBILITY_INTERNAL
    void msg_positionlist(std::string_view message);
 
    // get positionlist count
    XAPIAN_VISIBILITY_INTERNAL
    void msg_positionlistcount(std::string_view message);
 
    // get write access
    XAPIAN_VISIBILITY_INTERNAL
    void msg_writeaccess(std::string_view message);
 
    // reopen
    XAPIAN_VISIBILITY_INTERNAL
    void msg_reopen(std::string_view message);
 
    // get updated doccount and avlength
    XAPIAN_VISIBILITY_INTERNAL
    void msg_update(std::string_view message);
 
    // commit
    XAPIAN_VISIBILITY_INTERNAL
    void msg_commit(std::string_view message);
 
    // cancel
    XAPIAN_VISIBILITY_INTERNAL
    void msg_cancel(std::string_view message);
 
    // add document
    XAPIAN_VISIBILITY_INTERNAL
    void msg_adddocument(std::string_view message);
 
    // delete document
    XAPIAN_VISIBILITY_INTERNAL
    void msg_deletedocument(std::string_view message);
 
    // delete document with unique term
    XAPIAN_VISIBILITY_INTERNAL
    void msg_deletedocumentterm(std::string_view message);
 
    // replace document
    XAPIAN_VISIBILITY_INTERNAL
    void msg_replacedocument(std::string_view message);
 
    // replace document with unique term
    XAPIAN_VISIBILITY_INTERNAL
    void msg_replacedocumentterm(std::string_view message);
 
    // get metadata
    XAPIAN_VISIBILITY_INTERNAL
    void msg_getmetadata(std::string_view message);
 
    // read metadata key list
    XAPIAN_VISIBILITY_INTERNAL
    void msg_metadatakeylist(std::string_view message);
 
    // set metadata
    XAPIAN_VISIBILITY_INTERNAL
    void msg_setmetadata(std::string_view message);
 
    // request a document (pre-fetch hint)
    XAPIAN_VISIBILITY_INTERNAL
    void msg_requestdocument(std::string_view message);
 
    // add a spelling
    XAPIAN_VISIBILITY_INTERNAL
    void msg_addspelling(std::string_view message);
 
    // remove a spelling
    XAPIAN_VISIBILITY_INTERNAL
    void msg_removespelling(std::string_view message);
 
    // get number of unique terms
    XAPIAN_VISIBILITY_INTERNAL
    void msg_uniqueterms(std::string_view message);
 
    // get max_wdf
    XAPIAN_VISIBILITY_INTERNAL
    void msg_wdfdocmax(std::string_view message);
 
    // reconstruct document text
    XAPIAN_VISIBILITY_INTERNAL
    void msg_reconstructtext(std::string_view message);
 
    // get synonyms for a term
    XAPIAN_VISIBILITY_INTERNAL
    void msg_synonymtermlist(std::string_view message);
 
    // get terms with an entry in synonym table, starting with a prefix
    XAPIAN_VISIBILITY_INTERNAL
    void msg_synonymkeylist(std::string_view message);
 
    // add a synonym
    XAPIAN_VISIBILITY_INTERNAL
    void msg_addsynonym(std::string_view message);
 
    // remove a synonym
    XAPIAN_VISIBILITY_INTERNAL
    void msg_removesynonym(std::string_view message);
 
    // clear synonyms for a term
    XAPIAN_VISIBILITY_INTERNAL
    void msg_clearsynonyms(std::string_view message);
 
  public:
    RemoteServer(const std::vector<std::string> &dbpaths,
                 int fdin, int fdout,
                 double active_timeout_,
                 double idle_timeout_,
                 bool writable = false);
 
    ~RemoteServer();
 
    void run();
 
    void set_registry(const Xapian::Registry & reg_) { reg = reg_; }
};
 
#endif // XAPIAN_INCLUDED_REMOTESERVER_H