RpcServer.cpp

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-FileCopyrightText: 2006-2010 RobotCub Consortium
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#include <yarp/os/RpcServer.h>
 
#include <yarp/os/impl/LogComponent.h>
 
using namespace yarp::os;
using namespace yarp::os::impl;
 
namespace {
YARP_OS_LOG_COMPONENT(RPCSERVER, "yarp.os.RpcServer")
} // namespace
 
RpcServer::RpcServer()
{
    port.setInputMode(true);
    port.setOutputMode(false);
    port.setRpcMode(true);
}
 
RpcServer::~RpcServer()
{
    port.close();
}
 
bool RpcServer::write(const PortWriter& writer, const PortWriter* callback) const
{
    YARP_UNUSED(writer);
    YARP_UNUSED(callback);
    yCError(RPCSERVER, "%s cannot write, please use a regular Port or RpcClient for that", port.getName().c_str());
    return false;
}
 
bool RpcServer::write(const PortWriter& writer,
                      PortReader& reader,
                      const PortWriter* callback) const
{
    YARP_UNUSED(writer);
    YARP_UNUSED(reader);
    YARP_UNUSED(callback);
    yCError(RPCSERVER, "%s cannot write, please use a regular Port or RpcClient for that", port.getName().c_str());
    return false;
}
 
bool RpcServer::read(PortReader& reader, bool willReply)
{
    if (!willReply) {
        yCError(RPCSERVER, "%s must reply, please use a regular Port if you do not want to", port.getName().c_str());
        // this is an error for RpcServer
        return false;
    }
    return port.read(reader, true);
}
 
void RpcServer::setInputMode(bool expectInput)
{
    yCAssert(RPCSERVER, expectInput);
}
 
 
void RpcServer::setOutputMode(bool expectOutput)
{
    yCAssert(RPCSERVER, !expectOutput);
}
 
 
void RpcServer::setRpcMode(bool expectRpc)
{
    yCAssert(RPCSERVER, expectRpc);
}