: public Distributor<Answer, Question, Backend>
{
public:
+ SingleThreadDistributor(const SingleThreadDistributor&) = delete;
+ void operator=(const SingleThreadDistributor&) = delete;
SingleThreadDistributor();
typedef std::function<void(Answer*)> callback_t;
int question(Question *, callback_t callback) override; //!< Submit a question to the Distributor
: public Distributor<Answer, Question, Backend>
{
public:
+ MultiThreadDistributor(const MultiThreadDistributor&) = delete;
+ void operator=(const MultiThreadDistributor&) = delete;
MultiThreadDistributor(int n);
typedef std::function<void(Answer*)> callback_t;
int question(Question *, callback_t callback) override; //!< Submit a question to the Distributor
typedef vector<DNSZoneRecord> rrset_t;
typedef rrset_t chunk_t; // for now
+ ChunkedSigningPipe(const ChunkedSigningPipe&) = delete;
+ void operator=(const ChunkedSigningPipe&) = delete;
ChunkedSigningPipe(const DNSName& signerName, bool mustSign, unsigned int numWorkers=3);
~ChunkedSigningPipe();
bool submit(const DNSZoneRecord& rr);
protected:
public:
+ Semaphore(const Semaphore&) = delete;
+ void operator=(const Semaphore&) = delete;
//! Default constructor.
Semaphore( unsigned int value = 0 );