MobileBaseVelocityControl_nwc_yarp.cpp

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-License-Identifier: LGPL-2.1-or-later
 */
 
#include "MobileBaseVelocityControl_nwc_yarp.h"
#include <yarp/dev/INavigation2D.h>
#include <yarp/os/Log.h>
#include <yarp/os/LogComponent.h>
#include <yarp/os/LogStream.h>
#include <mutex>
#include <cmath>
 
using namespace yarp::dev;
using namespace yarp::dev::Nav2D;
using namespace yarp::os;
using namespace yarp::sig;
 
namespace {
YARP_LOG_COMPONENT(MOBVEL_NWC_YARP, "yarp.device.MobileBaseVelocityControl_nwc_yarp")
}
 
//------------------------------------------------------------------------------------------------------------------------------
 
bool MobileBaseVelocityControl_nwc_yarp::open(yarp::os::Searchable &config)
{
    if (!parseParams(config)) { return false; }
 
    std::string local_rpc_1           = m_local  + "/navigation/rpc:o";
    std::string remote_rpc_1          = m_server + "/rpc:i";
 
    if (!m_rpc_port.open(local_rpc_1))
    {
        yCError(MOBVEL_NWC_YARP, "open() error could not open rpc port %s, check network", local_rpc_1.c_str());
        return false;
    }
 
    bool ok = true;
 
    ok = Network::connect(local_rpc_1, remote_rpc_1, m_carrier);
    if (!ok)
    {
        yCError(MOBVEL_NWC_YARP, "open() error could not connect to %s", remote_rpc_1.c_str());
        return false;
    }
 
    if (!m_RPC.yarp().attachAsClient(m_rpc_port))
    {
        yCError(MOBVEL_NWC_YARP, "Error! Cannot attach the port as a client");
        return false;
    }
 
    return true;
}
 
bool MobileBaseVelocityControl_nwc_yarp::close()
{
    m_rpc_port.close();
    return true;
}
 
ReturnValue MobileBaseVelocityControl_nwc_yarp::getLastVelocityCommand(double& x_vel, double& y_vel, double& theta_vel)
{
    std::lock_guard <std::mutex> lg(m_mutex);
    auto retrpc = m_RPC.getLastVelocityCommandRPC();
    if (!retrpc.ret)
    {
        yCError(MOBVEL_NWC_YARP, "Unable to set transformation");
        return retrpc.ret;
    }
    x_vel = retrpc.x_vel;
    y_vel = retrpc.y_vel;
    theta_vel = retrpc.theta_vel;
    return retrpc.ret;
}
 
ReturnValue MobileBaseVelocityControl_nwc_yarp::applyVelocityCommand(double x_vel, double y_vel, double theta_vel, double timeout)
{
    std::lock_guard <std::mutex> lg(m_mutex);
    return m_RPC.applyVelocityCommandRPC(x_vel,y_vel,theta_vel,timeout);
}