+/*
+ * Copyright (C) 1996-2017 The Squid Software Foundation and contributors
+ *
+ * Squid software is distributed under GPLv2+ license and includes
+ * contributions from numerous individuals and organizations.
+ * Please see the COPYING and CONTRIBUTORS files for details.
+ */
+
#ifndef SQUID_QOSCONFIG_H
#define SQUID_QOSCONFIG_H
-#include "config.h"
+#include "acl/forward.h"
+#include "hier_code.h"
+#include "ip/forward.h"
+
+#if HAVE_LIBNETFILTER_CONNTRACK_LIBNETFILTER_CONNTRACK_H
+#include <libnetfilter_conntrack/libnetfilter_conntrack.h>
+#endif
+#if HAVE_LIBNETFILTER_CONNTRACK_LIBNETFILTER_CONNTRACK_TCP_H
+#include <libnetfilter_conntrack/libnetfilter_conntrack_tcp.h>
+#endif
+#include <limits>
-#if USE_ZPH_QOS
+class fde;
-namespace Ip {
+// TODO: move to new ACL framework
+class acl_tos
+{
+ CBDATA_CLASS(acl_tos);
+
+public:
+ acl_tos() : next(NULL), aclList(NULL), tos(0) {}
+ ~acl_tos();
-namespace Qos {
+ acl_tos *next;
+ ACLList *aclList;
+ tos_t tos;
+};
-class QosConfig
+// TODO: move to new ACL framework
+class acl_nfmark
{
+ CBDATA_CLASS(acl_nfmark);
+
public:
- int tos_local_hit;
- int tos_sibling_hit;
- int tos_parent_hit;
- int preserve_miss_tos;
- int preserve_miss_tos_mask;
+ acl_nfmark() : next(NULL), aclList(NULL), nfmark(0) {}
+ ~acl_nfmark();
+
+ acl_nfmark *next;
+ ACLList *aclList;
+ nfmark_t nfmark;
+};
+
+namespace Ip
+{
+
+/**
+ * QOS namespace contains all the QOS functionality: global functions within
+ * the namespace and the configuration parameters within a config class.
+ */
+namespace Qos
+{
+
+/**
+* Function to retrieve the TOS value of the inbound packet.
+* Called by FwdState::dispatch if QOS options are enabled.
+* Bug 2537: This part of ZPH only applies to patched Linux kernels
+* @param server Server side descriptor of connection to get TOS for
+* @param clientFde Pointer to client side fde instance to set tosFromServer in
+*/
+void getTosFromServer(const Comm::ConnectionPointer &server, fde *clientFde);
+
+/**
+* Function to retrieve the netfilter mark value of the connection
+* to the upstream server. Called by FwdState::dispatch if QOS
+* options are enabled.
+* @param server Server side descriptor of connection to get mark for
+* @param clientFde Pointer to client side fde instance to set nfmarkFromServer in
+*/
+void getNfmarkFromServer(const Comm::ConnectionPointer &server, const fde *clientFde);
+
+#if USE_LIBNETFILTERCONNTRACK
+/**
+* Callback function to mark connection once it's been found.
+* This function is called by the libnetfilter_conntrack
+* libraries, during nfct_query in Ip::Qos::getNfmarkFromServer.
+* nfct_callback_register is used to register this function.
+* @param nf_conntrack_msg_type Type of conntrack message
+* @param nf_conntrack Pointer to the conntrack structure
+* @param clientFde Pointer to client side fde instance to set nfmarkFromServer in
+*/
+int getNfMarkCallback(enum nf_conntrack_msg_type type, struct nf_conntrack *ct, void *clientFde);
+#endif
+
+/**
+* Function to work out and then apply to the socket the appropriate
+* TOS value to set on packets when items have not been retrieved from
+* local cache. Called by clientReplyContext::sendMoreData if QOS is
+* enabled for TOS.
+* @param conn Descriptor of socket to set the TOS for
+* @param hierCode Hier code of request
+*/
+int doTosLocalMiss(const Comm::ConnectionPointer &conn, const hier_code hierCode);
+
+/**
+* Function to work out and then apply to the socket the appropriate
+* netfilter mark value to set on packets when items have not been
+* retrieved from local cache. Called by clientReplyContext::sendMoreData
+* if QOS is enabled for TOS.
+* @param conn Descriptor of socket to set the mark for
+* @param hierCode Hier code of request
+*/
+int doNfmarkLocalMiss(const Comm::ConnectionPointer &conn, const hier_code hierCode);
+
+/**
+* Function to work out and then apply to the socket the appropriate
+* TOS value to set on packets when items *have* been retrieved from
+* local cache. Called by clientReplyContext::doGetMoreData if QOS is
+* enabled for TOS.
+* @param conn Descriptor of socket to set the TOS for
+*/
+int doTosLocalHit(const Comm::ConnectionPointer &conn);
+/**
+* Function to work out and then apply to the socket the appropriate
+* netfilter mark value to set on packets when items *have* been
+* retrieved from local cache. Called by clientReplyContext::doGetMoreData
+* if QOS is enabled for TOS.
+* @param conn Descriptor of socket to set the mark for
+*/
+int doNfmarkLocalHit(const Comm::ConnectionPointer &conn);
+
+/**
+* Function to set the TOS value of packets. Sets the value on the socket
+* which then gets copied to the packets.
+* @param conn Descriptor of socket to set the TOS for
+*/
+_SQUID_INLINE_ int setSockTos(const Comm::ConnectionPointer &conn, tos_t tos);
+
+/**
+* The low level variant of setSockTos function to set TOS value of packets.
+* Avoid if you can use the Connection-based setSockTos().
+* @param fd Descriptor of socket to set the TOS for
+* @param type The socket family, AF_INET or AF_INET6
+*/
+_SQUID_INLINE_ int setSockTos(const int fd, tos_t tos, int type);
+
+/**
+* Function to set the netfilter mark value of packets. Sets the value on the
+* socket which then gets copied to the packets. Called from Ip::Qos::doNfmarkLocalMiss
+* @param conn Descriptor of socket to set the mark for
+*/
+_SQUID_INLINE_ int setSockNfmark(const Comm::ConnectionPointer &conn, nfmark_t mark);
+
+/**
+* The low level variant of setSockNfmark function to set the netfilter mark
+* value of packets.
+* Avoid if you can use the Connection-based setSockNfmark().
+* @param fd Descriptor of socket to set the mark for
+*/
+_SQUID_INLINE_ int setSockNfmark(const int fd, nfmark_t mark);
+
+/**
+ * QOS configuration class. Contains all the parameters for QOS functions as well
+ * as functions to check whether either TOS or MARK QOS is enabled.
+ */
+class Config
+{
public:
- QosConfig();
- ~QosConfig() {};
+
+ Config();
+ ~Config() {}
void parseConfigLine();
+
+ /**
+ * Dump all the configuration values
+ *
+ * NOTE: Due to the low-level nature of the library these
+ * objects are part of the dump function must be self-contained.
+ * which means no StoreEntry references. Just a basic char* buffer.
+ */
void dumpConfigLine(char *entry, const char *name) const;
+
+ /// Whether we should modify TOS flags based on cache hits and misses.
+ _SQUID_INLINE_ bool isHitTosActive() const;
+
+ /// Whether we should modify netfilter marks based on cache hits and misses.
+ _SQUID_INLINE_ bool isHitNfmarkActive() const;
+
+ /**
+ * Iterates through any outgoing_nfmark or clientside_nfmark configuration parameters
+ * to find out if any Netfilter marking is required.
+ * This function is used on initialisation to define capabilities required (Netfilter
+ * marking requires CAP_NET_ADMIN).
+ */
+ _SQUID_INLINE_ bool isAclNfmarkActive() const;
+
+ /**
+ * Iterates through any outgoing_tos or clientside_tos configuration parameters
+ * to find out if packets should be marked with TOS flags.
+ */
+ _SQUID_INLINE_ bool isAclTosActive() const;
+
+ tos_t tosLocalHit; ///< TOS value to apply to local cache hits
+ tos_t tosSiblingHit; ///< TOS value to apply to hits from siblings
+ tos_t tosParentHit; ///< TOS value to apply to hits from parent
+ tos_t tosMiss; ///< TOS value to apply to cache misses
+ tos_t tosMissMask; ///< Mask for TOS value to apply to cache misses. Applied to the tosMiss value.
+ bool preserveMissTos; ///< Whether to preserve the TOS value of the inbound packet for misses
+ tos_t preserveMissTosMask; ///< The mask to apply when preserving the TOS of misses. Applies to preserved value from upstream.
+
+ nfmark_t markLocalHit; ///< Netfilter mark value to apply to local cache hits
+ nfmark_t markSiblingHit; ///< Netfilter mark value to apply to hits from siblings
+ nfmark_t markParentHit; ///< Netfilter mark value to apply to hits from parent
+ nfmark_t markMiss; ///< Netfilter mark value to apply to cache misses
+ nfmark_t markMissMask; ///< Mask for netfilter mark value to apply to cache misses. Applied to the markMiss value.
+ bool preserveMissMark; ///< Whether to preserve netfilter mark value of inbound connection
+ nfmark_t preserveMissMarkMask; ///< The mask to apply when preserving the netfilter mark of misses. Applied to preserved value from upstream.
+
+ acl_tos *tosToServer; ///< The TOS that packets to the web server should be marked with, based on ACL
+ acl_tos *tosToClient; ///< The TOS that packets to the client should be marked with, based on ACL
+ acl_nfmark *nfmarkToServer; ///< The MARK that packets to the web server should be marked with, based on ACL
+ acl_nfmark *nfmarkToClient; ///< The MARK that packets to the client should be marked with, based on ACL
+
};
-extern QosConfig TheConfig;
+/// Globally available instance of Qos::Config
+extern Config TheConfig;
/* legacy parser access wrappers */
-#define parse_QosConfig(X) (X)->parseConfigLine()
+#define parse_QosConfig(X) (X)->parseConfigLine()
#define free_QosConfig(X)
#define dump_QosConfig(e,n,X) do { \
- char temp[256]; /* random number. change as needed. max config line length. */ \
- (X).dumpConfigLine(temp,n); \
- storeAppendPrintf(e, "%s", temp); \
- } while(0);
+ char temp[256]; /* random number. change as needed. max config line length. */ \
+ (X).dumpConfigLine(temp,n); \
+ storeAppendPrintf(e, "%s", temp); \
+ } while(0);
+
+} // namespace Qos
-}; // namespace Qos
-}; // namespace Ip
+} // namespace Ip
+
+#if _USE_INLINE_
+#include "Qos.cci"
+#endif
-#endif /* USE_ZPH_QOS */
#endif /* SQUID_QOSCONFIG_H */
+
projects / thirdparty / squid.git / blobdiff