summaryrefslogtreecommitdiff
path: root/protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h
diff options
context:
space:
mode:
Diffstat (limited to 'protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h')
-rw-r--r--protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h82
1 files changed, 82 insertions, 0 deletions
diff --git a/protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h b/protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h
new file mode 100644
index 00000000000..5f0c820fccd
--- /dev/null
+++ b/protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h
@@ -0,0 +1,82 @@
+/* -*- C++ -*- */
+
+//=============================================================================
+/**
+ * @file HTBP_Outside_Squid_Filter.h
+ *
+ * $Id$
+ *
+ * @author Phil Mesnier
+ */
+//=============================================================================
+
+#ifndef ACE_HTBP_OUTSIDE_SQUID_FILTER_H
+#define ACE_HTBP_OUTSIDE_SQUID_FILTER_H
+#include /**/ "ace/pre.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "HTBP_Export.h"
+#include "HTBP_Filter.h"
+
+namespace ACE
+{
+ namespace HTBP
+ {
+ // Forward declarations
+ class Channel;
+
+ /**
+ * @class Outside_Squid_Filter
+ *
+ * @brief Defines the methods in the <Filter> abstraction.
+ *
+ * A filter is responsible for wrapping / unwrapping messages depending on
+ * direction of flow on each stream. There will be 4 filters participating in
+ * a session, outside-send, outside-recv, outside-send, ouside-recv. It is
+ * anticipated that specialized filters will be implemented that tune the
+ * filter behavior based on proxy particulars. That, or there will be a matrix
+ * configuration parameters that may be tweeked to match the configuration.
+ * It remains to be seen which is easier to manage.
+ */
+ class HTBP_Export Outside_Squid_Filter : public Filter
+ {
+ public:
+ /// Destructor.
+ virtual ~Outside_Squid_Filter (void);
+
+ /// Outside and outside Send filters need to supply a data header that
+ /// sets the stage before sending the data body, and then (maybe) send a
+ /// data trailer that closes the message. The data header may be formatted
+ /// differently on the first message, to send optional context information.
+ virtual ssize_t send_data_header (ssize_t data_len, Channel *);
+ virtual ssize_t send_data_trailer (Channel *);
+
+ /// Upon receiving data, the Channel is obliged to send an ack. This is
+ /// either an empty document if this is the in-to-out stream, or a new
+ /// long-duration document request if this is the out-to-in stream.
+ virtual int send_ack (Channel *);
+ virtual int recv_ack (Channel *);
+
+ /// receiving data must compliment sending. In the case of an in-to-out
+ /// stream. It is possible that the stream identity is not known until the
+ /// first request is received. In this case the filter will have to look
+ /// lookup the received session ID and either create a new instance or
+ /// reassign itself to an existing sesion. In that case, the associated
+ /// stream will have to be reassigned as well.
+ ///
+ virtual ssize_t recv_data_header (Channel *);
+ virtual ssize_t recv_data_trailer(Channel *);
+ };
+
+ }
+}
+
+#if defined (__ACE_INLINE__)
+#include "HTBP_Outside_Squid_Filter.inl"
+#endif
+
+#include /**/ "ace/post.h"
+#endif /* ACE_HTBP_OUTSIDE_FILTER_H */