3
* $Id: CommRead.h,v 1.7 2006/08/07 02:28:22 robertc Exp $
5
* DEBUG: section 5 Comms
6
* AUTHOR: Robert Collins <robertc@squid-cache.org>
8
* SQUID Web Proxy Cache http://www.squid-cache.org/
9
* ----------------------------------------------------------
11
* Squid is the result of efforts by numerous individuals from
12
* the Internet community; see the CONTRIBUTORS file for full
13
* details. Many organizations have provided support for Squid's
14
* development; see the SPONSORS file for full details. Squid is
15
* Copyrighted (C) 2001 by the Regents of the University of
16
* California; see the COPYRIGHT file for full details. Squid
17
* incorporates software developed and/or copyrighted by other
18
* sources; see the CREDITS file for full details.
20
* This program is free software; you can redistribute it and/or modify
21
* it under the terms of the GNU General Public License as published by
22
* the Free Software Foundation; either version 2 of the License, or
23
* (at your option) any later version.
25
* This program is distributed in the hope that it will be useful,
26
* but WITHOUT ANY WARRANTY; without even the implied warranty of
27
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
28
* GNU General Public License for more details.
30
* You should have received a copy of the GNU General Public License
31
* along with this program; if not, write to the Free Software
32
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
35
* Copyright (c) 2003, Robert Collins <robertc@squid-cache.org>
53
CallBack() : handler(NULL), data(NULL){}
55
CallBack(C *aHandler, void *someData) : handler(aHandler), data (NULL)
58
data = cbdataReference(someData);
61
CallBack(CallBack const &old) : handler(old.handler)
64
data = cbdataReference (old.data);
74
CallBack &operator = (CallBack const & rhs)
76
handler = rhs.handler;
78
replaceData (rhs.data);
85
return cbdataReferenceValid(data);
88
bool operator == (CallBack const &rhs) { return handler==rhs.handler && data==rhs.data;}
91
// twould be nice - RBC 20030307
99
void replaceData(void *someData)
104
temp = cbdataReference(someData);
107
cbdataReferenceDone(data);
114
// twould be nice - RBC 20030307
116
CallBack<IOCB>::callback(int fd, char *buf, size_t size , comm_err_t errcode, int xerrno, void *tempData)
118
assert (tempData == data);
119
handler (fd, buf, size , errcode, xerrno, data);
130
CommRead (int fd, char *buf, int len, IOCB *handler, void *data);
131
void queueCallback(size_t retval, comm_err_t errcode, int xerrno);
132
bool hasCallback() const;
133
void hasCallbackInvariant() const;
134
void hasNoCallbackInvariant() const;
137
void initiateActualRead();
139
void doCallback(comm_err_t errcode, int xerrno);
143
CallBack<IOCB> callback;
144
static void ReadTry(int fd, void *data);
151
typedef void DeferrableRead(void *context, CommRead const &);
153
DeferredRead (DeferrableRead *, void *, CommRead const &);
154
void markCancelled();
155
DeferrableRead *theReader;
163
class DeferredReadManager
167
~DeferredReadManager();
168
void delayRead(DeferredRead const &);
169
void kickReads(int const count);
172
static PF CloseHandler;
173
static DeferredRead popHead(ListContainer<DeferredRead> &deferredReads);
174
void kickARead(DeferredRead const &);
176
ListContainer<DeferredRead> deferredReads;
180
#endif /* COMMREAD_H */