diff options
Diffstat (limited to 'protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h')
-rw-r--r-- | protocols/ace/HTBP/HTBP_Outside_Squid_Filter.h | 82 |
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 */ |