Incoming.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_COMM_INCOMING_H
#define SQUID_SRC_COMM_INCOMING_H
 
#if USE_POLL || USE_SELECT
 
#include "SquidConfig.h"
#include "StatHist.h"
 
namespace Comm
{
 
class Incoming
{
public:
#if !defined(INCOMING_FACTOR)
#define INCOMING_FACTOR 5
#endif
 
    static const int Factor = INCOMING_FACTOR;
 
    static const int MaxInterval = (256 << Factor);
 
    // TODO replace with constructor initialization
    void init(int n) { nMaximum = n; history.enumInit(n); }
 
    bool startPolling(int n) { ioEvents = 0; return (n > 0); }
 
    void finishPolling(int, SquidConfig::CommIncoming::Measure &);
 
    bool check() { return (++ioEvents > (interval >> Factor)); }
 
    /*
     * How many normal I/O events to process before checking
     * incoming sockets again.
     *
     * \note We store the interval multiplied by a factor of
     *       (2^Factor) to have some pseudo-floating
     *       point precision.
     */
    int interval = (16 << Factor);
 
    StatHist history;
 
private:
    int ioEvents = 0;
 
    int nMaximum = 0;
};
 
} // namespace Comm
 
#endif /* USE_POLL || USE_SELECT */
#endif /* SQUID_SRC_COMM_INCOMING_H */