12#define STUB_API "comm/libcomm.la"
18void Comm::AcceptLimiter::defer(const
Comm::TcpAcceptor::Pointer &)
STUB
19void Comm::AcceptLimiter::removeDead(const
Comm::TcpAcceptor::Pointer &)
STUB
22#include "comm/Connection.h"
26void Comm::Connection::noteClosure()
STUB
33#include "comm/ConnOpener.h"
37void Comm::ConnOpener::swanSong()
STUB
40void Comm::ConnOpener::setHost(const
char *)
STUB
43#include "comm/forward.h"
46#include "comm/IoCallback.h"
49void Comm::IoCallback::cancel(const
char *)
STUB
52#include "comm/Loops.h"
68#include "comm/TcpAcceptor.h"
void IOCB(const Comm::ConnectionPointer &conn, char *, size_t size, Comm::Flag flag, int xerrno, void *data)
#define InstanceIdDefinitions(...)
convenience macro to instantiate Class-specific stuff in .cc files
void comm_read_cancel(int fd, IOCB *callback, void *data)
void comm_read_base(const Comm::ConnectionPointer &conn, char *buf, int size, AsyncCall::Pointer &callback)
#define STUB
macro to stub a void function.
#define CBDATA_NAMESPACED_CLASS_INIT(namespace, type)
static AcceptLimiter & Instance()
bool doneAll() const override
whether positive goal has been reached
void setCallback(iocb_type type, AsyncCall::Pointer &cb, char *buf, FREE *func, int sz)
void selectOrQueueWrite()
called when fd needs to write but may need to wait in line for its quota
void unsubscribe(const char *reason)
void subscribe(const Subscription::Pointer &aSub)
Abstraction layer for TCP, UDP, TLS, UDS and filedescriptor sockets.
bool MonitorsRead(int fd)
whether the FD socket is being monitored for read
RefCount< Comm::Connection > ConnectionPointer
void ReadCancel(int fd, AsyncCall::Pointer &callback)
Cancel the read pending on FD. No action if none pending.
void QuickPollRequired(void)
std::ostream & operator<<(std::ostream &, const Connection &)
iocb_type
Type of IO callbacks the Comm layer deals with.
void Read(const Comm::ConnectionPointer &conn, AsyncCall::Pointer &callback)
bool IsConnOpen(const Comm::ConnectionPointer &conn)
void Write(const Comm::ConnectionPointer &conn, const char *buf, int size, AsyncCall::Pointer &callback, FREE *free_func)
Comm::Flag DoSelect(int)
Do poll and trigger callback functions as appropriate.
void ApplyTcpKeepAlive(int fd, const TcpKeepAlive &)
apply configured TCP keep-alive settings to the given FD socket
void WriteCancel(const Comm::ConnectionPointer &conn, const char *reason)
Cancel the write pending on FD. No action if none pending.
void SelectLoopInit(void)
Initialize the module on Squid startup.
void SetSelect(int, unsigned int, PF *, void *, time_t)
Mark an FD to be watched for its IO status.
Comm::Flag ReadNow(CommIoCbParams ¶ms, SBuf &buf)
Comm::AcceptLimiter dummy