mirror of
https://github.com/moses-smt/mosesdecoder.git
synced 2024-08-16 06:50:32 +03:00
83 lines
2.1 KiB
C++
83 lines
2.1 KiB
C++
// -*- mode: c++; indent-tabs-mode: nil; tab-width: 2 -*-
|
|
#include "Server.h"
|
|
#include <sstream>
|
|
|
|
namespace MosesServer
|
|
{
|
|
Server::
|
|
Server(Moses::Parameter& params)
|
|
: m_server_options(params),
|
|
m_updater(new Updater),
|
|
m_optimizer(new Optimizer),
|
|
m_translator(new Translator(*this)),
|
|
m_close_session(new CloseSession(*this))
|
|
{
|
|
m_registry.addMethod("translate", m_translator);
|
|
m_registry.addMethod("updater", m_updater);
|
|
m_registry.addMethod("optimize", m_optimizer);
|
|
m_registry.addMethod("close_session", m_close_session);
|
|
}
|
|
|
|
Server::
|
|
~Server()
|
|
{
|
|
unlink(m_pidfile.c_str());
|
|
}
|
|
|
|
int
|
|
Server::
|
|
run()
|
|
{
|
|
xmlrpc_c::serverAbyss myAbyssServer
|
|
(xmlrpc_c::serverAbyss::constrOpt()
|
|
.registryP(&m_registry)
|
|
.portNumber(m_server_options.port) // TCP port on which to listen
|
|
.logFileName(m_server_options.logfile)
|
|
.allowOrigin("*")
|
|
.maxConn(m_server_options.maxConn)
|
|
.maxConnBacklog(m_server_options.maxConnBacklog)
|
|
.keepaliveTimeout(m_server_options.keepaliveTimeout)
|
|
.keepaliveMaxConn(m_server_options.keepaliveMaxConn)
|
|
.timeout(m_server_options.timeout)
|
|
);
|
|
std::ostringstream pidfilename;
|
|
pidfilename << "/tmp/moses-server." << m_server_options.port << ".pid";
|
|
m_pidfile = pidfilename.str();
|
|
std::ofstream pidfile(m_pidfile.c_str());
|
|
pidfile << getpid() << std::endl;
|
|
pidfile.close();
|
|
XVERBOSE(1,"Listening on port " << m_server_options.port << std::endl);
|
|
if (m_server_options.is_serial)
|
|
{
|
|
VERBOSE(1,"Running server in serial mode." << std::endl);
|
|
while(true) myAbyssServer.runOnce();
|
|
}
|
|
else myAbyssServer.run();
|
|
|
|
std::cerr << "xmlrpc_c::serverAbyss.run() returned but it should not."
|
|
<< std::endl;
|
|
return 1;
|
|
}
|
|
|
|
Moses::ServerOptions const&
|
|
Server::
|
|
options() const
|
|
{
|
|
return m_server_options;
|
|
}
|
|
|
|
Session const&
|
|
Server::
|
|
get_session(uint64_t session_id)
|
|
{
|
|
return m_session_cache[session_id];
|
|
}
|
|
|
|
void
|
|
Server::
|
|
delete_session(uint64_t const session_id)
|
|
{
|
|
return m_session_cache.erase(session_id);
|
|
}
|
|
}
|