add missing file

diff --git a/src/client_side_reply.h b/src/client_side_reply.h
new file mode 100644 (file)
index 0000000..43d4a40
--- /dev/null
+++ b/src/client_side_reply.h
@@ -0,0 +1,156 @@
+
+/*
+ * $Id: client_side_reply.h,v 1.1 2003/03/15 04:27:27 robertc Exp $
+ *
+ *
+ * SQUID Web Proxy Cache          http://www.squid-cache.org/
+ * ----------------------------------------------------------
+ *
+ *  Squid is the result of efforts by numerous individuals from
+ *  the Internet community; see the CONTRIBUTORS file for full
+ *  details.   Many organizations have provided support for Squid's
+ *  development; see the SPONSORS file for full details.  Squid is
+ *  Copyrighted (C) 2001 by the Regents of the University of
+ *  California; see the COPYRIGHT file for full details.  Squid
+ *  incorporates software developed and/or copyrighted by other
+ *  sources; see the CREDITS file for full details.
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *  
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *  
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
+ *
+ * Copyright (c) 2003, Robert Collins <robertc@squid-cache.org>
+ */
+
+#ifndef SQUID_CLIENTSIDEREPLY_H
+#define SQUID_CLIENTSIDEREPLY_H
+
+#include "RefCount.h"
+#include "HttpHeader.h"
+#include "clientStream.h"
+#include "StoreClient.h"
+#include "client_side_request.h"
+
+/* XXX make static method */
+
+class clientReplyContext : public RefCountable, public StoreClient
+{
+
+public:
+    void *operator new (size_t byteCount);
+    void operator delete (void *address);
+    void deleteSelf() const;
+    static STCB CacheHit;
+    static STCB HandleIMSReply;
+    static STCB SendMoreData;
+
+    clientReplyContext(clientHttpRequest *);
+    ~clientReplyContext();
+
+    void saveState();
+    void restoreState();
+    void purgeRequest ();
+    void purgeRequestFindObjectToPurge();
+    void purgeDoMissPurge();
+    void purgeFoundGet(StoreEntry *newEntry);
+    void purgeFoundHead(StoreEntry *newEntry);
+    void purgeFoundObject(StoreEntry *entry);
+    void sendClientUpstreamResponse();
+    void purgeDoPurgeGet(StoreEntry *entry);
+    void purgeDoPurgeHead(StoreEntry *entry);
+    void doGetMoreData();
+    void identifyStoreObject();
+    void identifyFoundObject(StoreEntry *entry);
+    int storeOKTransferDone() const;
+    int storeNotOKTransferDone() const;
+
+    void setReplyToError(err_type, http_status, method_t, char const *, struct in_addr *, request_t *, char *, auth_user_request_t *);
+    void createStoreEntry(method_t m, request_flags flags);
+    void removeStoreReference(store_client ** scp, StoreEntry ** ep);
+    void startError(ErrorState * err);
+    bool clientGetsOldEntry() const;
+    void processExpired();
+    clientStream_status_t replyStatus();
+    void processMiss();
+    void traceReply(clientStreamNode * node);
+
+    http_status purgeStatus;
+
+    /* state variable - replace with class to handle storeentries at some point */
+    int lookingforstore;
+    virtual void created (StoreEntry *newEntry);
+
+    clientHttpRequest *http;
+    int headers_sz;
+    store_client *sc;          /* The store_client we're using */
+    StoreIOBuffer tempBuffer;  /* For use in validating requests via IMS */
+    int old_reqsize;           /* ... again, for the buffer */
+    size_t reqsize;
+    off_t reqofs;
+    char tempbuf[HTTP_REQBUF_SZ];      /* a temporary buffer if we need working storage */
+#if USE_CACHE_DIGESTS
+
+    const char *lookup_type;   /* temporary hack: storeGet() result: HIT/MISS/NONE */
+#endif
+
+    struct
+    {
+
+int storelogiccomplete:
+        1;
+
+int complete:
+        1;             /* we have read all we can from upstream */
+        bool headersSent;
+    }
+
+    flags;
+    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 ;
+    void sendStreamError(StoreIOBuffer const &result);
+    void pushStreamData(StoreIOBuffer const &result, char *source);
+    void waitForMoreData ();
+    clientStreamNode * next() const;
+    void startSendProcess();
+    StoreIOBuffer holdingBuffer;
+    HttpReply *holdingReply;
+    void processReplyAccess();
+    static PF ProcessReplyAccessResult;
+    void processReplyAccessResult(bool accessAllowed);
+    void buildReply(const char *buf, size_t size);
+    void buildReplyHeader ();
+    void holdReply(HttpReply *);
+    bool alwaysAllowResponse(http_status sline) const;
+    void obeyConnectionHeader();
+    int checkTransferDone();
+    void processOnlyIfCachedMiss();
+    void cacheHit(StoreIOBuffer result);
+    void handleIMSReply(StoreIOBuffer result);
+    void sendMoreData(StoreIOBuffer result);
+    void triggerInitialStoreRead();
+    void cleanUpAfterIMSCheck();
+    void handlePartialIMSHeaders();
+    void handleIMSGiveClientUpdatedOldEntry();
+    void handleIMSGiveClientNewEntry();
+    void sendClientOldEntry();
+
+    StoreEntry *old_entry;
+    store_client *old_sc;      /* ... for entry to be validated */
+};
+
+#endif /* SQUID_CLIENTSIDEREPLY_H */