Core.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/udp/Core.h"
 
#include <inttypes.h>
#include <unistd.h>
 
#include "rogue/GeneralError.h"
#include "rogue/Helpers.h"
#include "rogue/Logging.h"
 
namespace rpu = rogue::protocols::udp;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
rpu::Core::Core(bool jumbo) {
    jumbo_ = jumbo;
    rogue::defaultTimeout(timeout_);
}
 
rpu::Core::~Core() {}
 
uint32_t rpu::Core::maxPayload() {
    return (jumbo_) ? (MaxJumboPayload) : (MaxStdPayload);
}
 
bool rpu::Core::setRxBufferCount(uint32_t count) {
    uint32_t rwin;
    socklen_t rwin_size = 4;
 
    uint32_t per  = (jumbo_) ? (JumboMTU) : (StdMTU);
    uint32_t size = count * per;
 
    setsockopt(fd_, SOL_SOCKET, SO_RCVBUF, reinterpret_cast<char*>(&size), sizeof(size));
    getsockopt(fd_, SOL_SOCKET, SO_RCVBUF, &rwin, &rwin_size);
 
    if (size > rwin) {
        udpLog_->critical("----------------------------------------------------------");
        udpLog_->critical("Error setting rx buffer size.");
        udpLog_->critical("Wanted %" PRIu32 " (%" PRIu32 " * %" PRIu32 ") Got %" PRIu32, size, count, per, rwin);
        udpLog_->critical("sysctl -w net.core.rmem_max=size to increase in kernel");
        udpLog_->critical("----------------------------------------------------------");
        return (false);
    }
    return (true);
}
 
void rpu::Core::setTimeout(uint32_t timeout) {
    div_t divResult  = div(timeout, 1000000);
    timeout_.tv_sec  = divResult.quot;
    timeout_.tv_usec = divResult.rem;
}
 
void rpu::Core::setup_python() {
#ifndef NO_PYTHON
    bp::class_<rpu::Core, rpu::CorePtr, boost::noncopyable>("Core", bp::no_init)
        .def("maxPayload", &rpu::Core::maxPayload)
        .def("setRxBufferCount", &rpu::Core::setRxBufferCount)
        .def("setTimeout", &rpu::Core::setTimeout);
#endif
}