virtual bool ioInProgress() const;
private:
- CBDATA_CLASS(AIODiskFile);
void error(bool const &);
int fd;
String path;
RefCount<IORequestor> ioRequestor;
bool closed;
bool error_;
+ CBDATA_CLASS(AIODiskFile);
};
#endif /* USE_DISKIO_AIO */
private:
static DRCB ReadDone;
static DWCB WriteDone;
- CBDATA_CLASS(BlockingFile);
int fd;
bool closed;
void error (bool const &);
void doClose();
void readDone(int fd, const char *buf, int len, int errflag);
void writeDone(int fd, int errflag, size_t len);
+
+ CBDATA_CLASS(BlockingFile);
};
#endif /* SQUID_BLOCKINGFILE_H */
bool errorOccured;
DiskdIOStrategy *IO;
RefCount<IORequestor> ioRequestor;
- CBDATA_CLASS(DiskdFile);
void openDone(diomsg *);
void createDone (diomsg *);
void readDone (diomsg *);
void ioAway();
void ioCompleted();
size_t inProgressIOs;
+
+ CBDATA_CLASS(DiskdFile);
};
#endif
static AIOCB OpenDone;
void openDone(int fd, const char *buf, int aio_return, int aio_errno);
RefCount<IORequestor> ioRequestor;
- CBDATA_CLASS(DiskThreadsDiskFile);
void doClose();
void readDone(int fd, const char *buf, int len, int errflag, RefCount<ReadRequest> request);
void writeDone(int fd, int errflag, size_t len, RefCount<WriteRequest> request);
+
+ CBDATA_CLASS(DiskThreadsDiskFile);
};
#include "DiskIO/ReadRequest.h"
virtual bool ioInProgress() const;
private:
- CBDATA_CLASS(MmappedFile);
-
char const *path_;
RefCount<IORequestor> ioRequestor;
//RefCount<ReadRequest> readRequest;
bool error_;
void doClose();
+
+ CBDATA_CLASS(MmappedFile);
};
#endif /* SQUID_MMAPPEDFILE_H */
void grow(mb_size_t min_cap);
- CBDATA_CLASS2(MemBuf);
-
public:
/**
\deprecated use space*() and content*() methods to access safely instead.
unsigned valid:1; /* to be used for debugging only! */
#endif
+
+private:
+ CBDATA_CLASS2(MemBuf);
};
#if _USE_INLINE_
StoreIOBuffer copyInto;
private:
- CBDATA_CLASS(store_client);
void fileRead();
void scheduleDiskRead();
void scheduleMemRead();
STCB *callback_handler;
void *callback_data;
} _callback;
+
+private:
+ CBDATA_CLASS(store_client);
};
SQUIDCEXTERN void storeClientCopy(store_client *, StoreEntry *, StoreIOBuffer, STCB *, void *);
ExternalACLEntry *extacl_entry;
private:
- CBDATA_CLASS(ACLFilledChecklist);
-
ConnStateData * conn_; /**< hack for ident and NTLM */
int fd_; /**< may be available when conn_ is not */
bool destinationDomainChecked_;
bool sourceDomainChecked_;
-
-private:
/// not implemented; will cause link failures if used
ACLFilledChecklist(const ACLFilledChecklist &);
/// not implemented; will cause link failures if used
ACLFilledChecklist &operator=(const ACLFilledChecklist &);
+
+ CBDATA_CLASS(ACLFilledChecklist);
};
/// convenience and safety wrapper for dynamic_cast<ACLFilledChecklist*>
void wroteControlMsg(const Comm::ConnectionPointer &conn, char *bufnotused, size_t size, comm_err_t errflag, int xerrno);
private:
- CBDATA_CLASS(ClientSocketContext);
void prepareReply(HttpReply * rep);
void packChunk(const StoreIOBuffer &bodyData, MemBuf &mb);
void packRange(StoreIOBuffer const &, MemBuf * mb);
bool mayUseConnection_; /* This request may use the connection. Don't read anymore requests for now */
bool connRegistered_;
+
+ CBDATA_CLASS(ClientSocketContext);
};
HttpParser parser_;
// XXX: CBDATA plays with public/private and leaves the following 'private' fields all public... :(
- CBDATA_CLASS2(ConnStateData);
#if USE_SSL
bool switchedToHttps_;
AsyncCall::Pointer reader; ///< set when we are reading
BodyPipe::Pointer bodyPipe; // set when we are reading request body
+
+ CBDATA_CLASS2(ConnStateData);
};
/* convenience class while splitting up body handling */
clientStreamNode *ourNode; /* This will go away if/when this file gets refactored some more */
private:
- CBDATA_CLASS(clientReplyContext);
clientStreamNode *getNextNode() const;
void makeThisHead();
bool errorInStream(StoreIOBuffer const &result, size_t const &sizeToProcess)const ;
StoreEntry *old_entry;
store_client *old_sc; /* ... for entry to be validated */
bool deleting;
+
+ CBDATA_CLASS(clientReplyContext);
};
#endif /* SQUID_CLIENTSIDEREPLY_H */
#endif
private:
- CBDATA_CLASS(ClientHttpRequest);
int64_t maxReplyBodySize_;
StoreEntry *entry_;
StoreEntry *loggingEntry_;
bool request_satisfaction_mode;
int64_t request_satisfaction_offset;
#endif
+
+private:
+ CBDATA_CLASS(ClientHttpRequest);
};
/* client http based routines */
bool cachedASTInUse;
private:
- CBDATA_CLASS(ESIContext);
void fail ();
void freeResources();
void fixupOutboundTail();
virtual void parserDefault (const char *s, int len);
virtual void parserComment (const char *s);
bool processing;
+
+ CBDATA_CLASS(ESIContext);
};
#endif /* SQUID_ESICONTEXT_H */
virtual StoreEntry *currentItem();
private:
- CBDATA_CLASS2(StoreSearchCoss);
RefCount<CossSwapDir> sd;
void (*callback)(void *cbdata);
void *cbdata;
bool _done;
dlink_node * current;
dlink_node * next_;
+
+ CBDATA_CLASS2(StoreSearchCoss);
};
#endif
char *read_buf;
private:
- CBDATA_CLASS(UFSStoreState);
void openDone();
void freePending();
void doWrite();
+
+ CBDATA_CLASS(UFSStoreState);
};
MEMPROXY_CLASS_INLINE(UFSStoreState::_queued_read);
RemovalPolicyWalker *walker;
private:
- CBDATA_CLASS2(StoreSearchUFS);
/// \bug (callback) should be hidden behind a proper human readable name
void (callback)(void *cbdata);
void *cbdata;
StoreEntry * current;
bool _done;
+
+ CBDATA_CLASS2(StoreSearchUFS);
};
struct _store_rebuild_data counts;
private:
- CBDATA_CLASS2(RebuildState);
void rebuildFromDirectory();
void rebuildFromSwapLog();
void rebuildStep();
/// \bug (callback) should be hidden behind a proper human readable name
void (callback)(void *cbdata);
void *cbdata;
+
+ CBDATA_CLASS2(RebuildState);
};
#if _USE_INLINE_