common/remoteserver.h

Go to the documentation of this file.

/* Copyright (C) 2006,2007 Olly Betts
 * Copyright (C) 2007 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, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
 */

#ifndef XAPIAN_INCLUDED_REMOTESERVER_H
#define XAPIAN_INCLUDED_REMOTESERVER_H

#include "xapian/database.h"
#include "xapian/enquire.h"
#include "xapian/visibility.h"

#include "remoteconnection.h"

#include <map>
#include <string>

// Forward declaration
namespace Xapian { class Weight; }

using namespace std;

class XAPIAN_VISIBILITY_DEFAULT RemoteServer : private RemoteConnection {
    void operator=(const RemoteServer &);

    RemoteServer(const RemoteServer &);

    Xapian::Database * db;

    Xapian::WritableDatabase * wdb;

    Xapian::timeout active_timeout;

    Xapian::timeout idle_timeout;

    map<string, Xapian::Weight *> wtschemes;

    message_type get_message(Xapian::timeout timeout, string & result,
                             message_type required_type = MSG_MAX);

    void send_message(reply_type type, const string &message);

    // all terms
    void msg_allterms(const std::string & message);

    // get document
    void msg_document(const std::string & message);

    // term exists?
    void msg_termexists(const std::string & message);

    // get collection freq
    void msg_collfreq(const std::string & message);

    // get termfreq
    void msg_termfreq(const std::string & message);

    // keep alive
    void msg_keepalive(const std::string & message);

    // get doclength
    void msg_doclength(const std::string & message);

    // set the query; return the mset
    void msg_query(const std::string & message);

    // get termlist
    void msg_termlist(const std::string & message);

    // get postlist
    void msg_postlist(const std::string & message);

    // get positionlist
    void msg_positionlist(const std::string &message);

    // reopen
    void msg_reopen(const std::string & message);

    // get updated doccount and avlength
    void msg_update(const std::string &message);

    // flush
    void msg_flush(const std::string & message);

    // cancel
    void msg_cancel(const string &message);

    // add document
    void msg_adddocument(const std::string & message);

    // delete document for compatiblity with protocol < 30.2
    void msg_deletedocument_pre_30_2(const std::string & message);

    // delete document
    void msg_deletedocument(const std::string & message);

    // delete document with unique term
    void msg_deletedocumentterm(const std::string & message);

    // replace document
    void msg_replacedocument(const std::string & message);

    // replace document with unique term
    void msg_replacedocumentterm(const std::string & message);

  public:
    RemoteServer(const std::vector<std::string> &dbpaths,
                 int fdin, int fdout,
                 Xapian::timeout active_timeout_,
                 Xapian::timeout idle_timeout_,
                 bool writable = false);

    ~RemoteServer();

    void run();

    void register_weighting_scheme(const Xapian::Weight &wt) {
        wtschemes[wt.name()] = wt.clone();
    }
};

#endif // XAPIAN_INCLUDED_REMOTESERVER_H

---