mirror of
https://github.com/moses-smt/mosesdecoder.git
synced 2024-08-16 06:50:32 +03:00
49 lines
1.1 KiB
C++
49 lines
1.1 KiB
C++
// -*- mode: c++; indent-tabs-mode: nil; tab-width:2 -*-
|
|
|
|
#include "Translator.h"
|
|
#include "TranslationRequest.h"
|
|
#include "Server.h"
|
|
|
|
namespace MosesServer
|
|
{
|
|
|
|
using namespace std;
|
|
using namespace Moses;
|
|
|
|
Translator::
|
|
Translator(Server& server)
|
|
: m_server(server),
|
|
m_threadPool(server.options().numThreads)
|
|
{
|
|
// signature and help strings are documentation -- the client
|
|
// can query this information with a system.methodSignature and
|
|
// system.methodHelp RPC.
|
|
this->_signature = "S:S";
|
|
this->_help = "Does translation";
|
|
}
|
|
|
|
void
|
|
Translator::
|
|
execute(xmlrpc_c::paramList const& paramList,
|
|
xmlrpc_c::value * const retvalP)
|
|
{
|
|
boost::condition_variable cond;
|
|
boost::mutex mut;
|
|
boost::shared_ptr<TranslationRequest> task;
|
|
task = TranslationRequest::create(this, paramList,cond,mut);
|
|
m_threadPool.Submit(task);
|
|
boost::unique_lock<boost::mutex> lock(mut);
|
|
while (!task->IsDone())
|
|
cond.wait(lock);
|
|
*retvalP = xmlrpc_c::value_struct(task->GetRetData());
|
|
}
|
|
|
|
Session const&
|
|
Translator::
|
|
get_session(uint64_t const id)
|
|
{
|
|
return m_server.get_session(id);
|
|
}
|
|
|
|
}
|