blob: 6df25ecd1625bc103779ecabf14a24bf39bf9c89 [file] [log] [blame]
#include "slp.hpp"
#include "slp_meta.hpp"
#include "slp_server.hpp"
#include "sock_channel.hpp"
#include <algorithm>
#include <iomanip>
/* Call Back for the sd event loop */
static int requestHandler(sd_event_source* /*es*/, int fd, uint32_t /*revents*/,
void* /*userdata*/)
{
int rc = slp::SUCCESS;
timeval tv{slp::TIMEOUT, 0};
udpsocket::Channel channel(fd, tv);
std::vector<uint8_t> recvBuff;
slp::Message req;
std::vector<uint8_t> resp;
// Read the packet
std::tie(rc, recvBuff) = channel.read();
if (rc < 0)
{
std::cerr << "SLP Error in Read : " << std::hex << rc << "\n";
return rc;
}
switch (recvBuff[0])
{
case slp::VERSION_2:
{
// Parse the buffer and construct the req object
std::tie(rc, req) = slp::parser::parseBuffer(recvBuff);
if (!rc)
{
// Passing the req object to handler to serve it
std::tie(rc, resp) = slp::handler::processRequest(req);
}
break;
}
default:
std::cout << "SLP Unsupported Request Version=" << (int)recvBuff[0]
<< "\n";
rc = static_cast<uint8_t>(slp::Error::VER_NOT_SUPPORTED);
break;
}
// if there was error during Parsing of request
// or processing of request then handle the error.
if (rc)
{
resp = slp::handler::processError(req, rc);
}
channel.write(resp);
return slp::SUCCESS;
}
int main()
{
slp::udp::Server svr(slp::PORT, requestHandler);
return svr.run();
}