JobWait.h

Go to the documentation of this file.

/*
 * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
 *
 * Squid software is distributed under GPLv2+ license and includes
 * contributions from numerous individuals and organizations.
 * Please see the COPYING and CONTRIBUTORS files for details.
 */
 
#ifndef SQUID_SRC_BASE_JOBWAIT_H
#define SQUID_SRC_BASE_JOBWAIT_H
 
#include "base/AsyncJob.h"
#include "base/CbcPointer.h"
 
#include <iosfwd>
 
class JobWaitBase
{
public:
    JobWaitBase();
    ~JobWaitBase();
 
    JobWaitBase(JobWaitBase &&) = delete;
 
    explicit operator bool() const { return waiting(); }
 
    bool waiting() const { return bool(callback_); }
 
    void finish();
 
    void cancel(const char *reason);
 
    void print(std::ostream &) const;
 
protected:
    void start_(AsyncJob::Pointer, AsyncCall::Pointer);
 
private:
    void clear() { job_.clear(); callback_ = nullptr; }
 
    AsyncJob::Pointer job_;
 
    AsyncCall::Pointer callback_;
};
 
template <class Job>
class JobWait: public JobWaitBase
{
public:
    typedef CbcPointer<Job> JobPointer;
 
    void start(const JobPointer &aJob, const AsyncCall::Pointer &aCallback) {
        start_(aJob, aCallback);
        typedJob_ = aJob;
    }
 
    JobPointer job() const { return waiting() ? typedJob_ : nullptr; }
 
private:
    JobPointer typedJob_;
};
 
inline
std::ostream &operator <<(std::ostream &os, const JobWaitBase &wait)
{
    wait.print(os);
    return os;
}
 
#endif /* SQUID_SRC_BASE_JOBWAIT_H */