TcpAcceptor.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_COMM_TCPACCEPTOR_H
#define SQUID_COMM_TCPACCEPTOR_H
 
#include "anyp/forward.h"
#include "base/AsyncJob.h"
#include "base/CbcPointer.h"
#include "base/Subscription.h"
#include "comm/Flag.h"
#include "comm/forward.h"
 
class CommCloseCbParams;
 
namespace Comm
{
 
class AcceptLimiter;
 
class TcpAcceptor : public AsyncJob
{
    CBDATA_CHILD(TcpAcceptor);
 
public:
    typedef CbcPointer<Comm::TcpAcceptor> Pointer;
 
private:
    void start() override;
    bool doneAll() const override;
    void swanSong() override;
    const char *status() const override;
 
    TcpAcceptor(const TcpAcceptor &); // not implemented.
 
public:
    TcpAcceptor(const Comm::ConnectionPointer &conn, const char *note, const Subscription::Pointer &aSub);
    TcpAcceptor(const AnyP::PortCfgPointer &listenPort, const char *note, const Subscription::Pointer &aSub);
 
protected:
    void subscribe(const Subscription::Pointer &aSub);
 
    void unsubscribe(const char *reason);
 
    void acceptNext();
 
    void notify(const Comm::Flag flag, const Comm::ConnectionPointer &details) const;
 
    int errcode;
 
    static bool okToAccept();
 
    friend class AcceptLimiter;
 
private:
    Subscription::Pointer theCallSub;    
 
    ConnectionPointer conn;
 
    AnyP::PortCfgPointer listenPort_;
 
    AsyncCall::Pointer closer_;
 
    static void doAccept(int fd, void *data);
 
    void acceptOne();
    bool acceptInto(Comm::ConnectionPointer &);
    void setListen();
    void handleClosure(const CommCloseCbParams &io);
    bool intendedForUserConnections() const { return bool(listenPort_); }
    void logAcceptError(const ConnectionPointer &tcpClient) const;
};
 
} // namespace Comm
 
#endif /* SQUID_COMM_TCPACCEPTOR_H */