survey_server.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_SURVEY_SERVER_H
#define CPPSERVER_NANOMSG_SURVEY_SERVER_H

#include "server.h"

namespace CppServer {
namespace Nanomsg {


class SurveyServer : public Server
{
public:

    explicit SurveyServer(const std::string& address, int deadline = 1000)
        : Server(CppServer::Nanomsg::Domain::Std, CppServer::Nanomsg::Protocol::Surveyor, address, false)
    {
        socket().SetSocketOption(NN_SURVEYOR, NN_SURVEYOR_DEADLINE, &deadline, sizeof(deadline));
    }
    SurveyServer(const SurveyServer&) = delete;
    SurveyServer(SurveyServer&&) = default;
    virtual ~SurveyServer() = default;

    SurveyServer& operator=(const SurveyServer&) = delete;
    SurveyServer& operator=(SurveyServer&&) = default;


    std::tuple<size_t, bool> ReceiveSurvey(Message& message);


    std::tuple<size_t, bool> TryReceiveSurvey(Message& message);

private:
    using Server::Receive;
    using Server::TryReceive;
    using Server::onThreadInitialize;
    using Server::onThreadCleanup;
    using Server::onIdle;
    using Server::onReceived;
};

} // namespace Nanomsg
} // namespace CppServer

#endif // CPPSERVER_NANOMSG_SURVEY_SERVER_H