]> git.ipfire.org Git - thirdparty/squid.git/blame - src/comm/Connection.h
Bug 3610: peername_regex ACL
[thirdparty/squid.git] / src / comm / Connection.h
CommitLineData
ee0989f2 1/*
45906573 2 * DEBUG: section 05 Socket Functions
93ad6f77 3 * AUTHOR: Amos Jeffries
ee0989f2 4 * AUTHOR: Robert Collins
5 *
6 * SQUID Web Proxy Cache http://www.squid-cache.org/
7 * ----------------------------------------------------------
8 *
9 * Squid is the result of efforts by numerous individuals from
10 * the Internet community; see the CONTRIBUTORS file for full
11 * details. Many organizations have provided support for Squid's
12 * development; see the SPONSORS file for full details. Squid is
13 * Copyrighted (C) 2001 by the Regents of the University of
14 * California; see the COPYRIGHT file for full details. Squid
15 * incorporates software developed and/or copyrighted by other
16 * sources; see the CREDITS file for full details.
17 *
18 * This program is free software; you can redistribute it and/or modify
19 * it under the terms of the GNU General Public License as published by
20 * the Free Software Foundation; either version 2 of the License, or
21 * (at your option) any later version.
26ac0430 22 *
ee0989f2 23 * This program is distributed in the hope that it will be useful,
24 * but WITHOUT ANY WARRANTY; without even the implied warranty of
25 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
26 * GNU General Public License for more details.
26ac0430 27 *
ee0989f2 28 * You should have received a copy of the GNU General Public License
29 * along with this program; if not, write to the Free Software
30 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
31 *
32 *
33 * Copyright (c) 2003, Robert Collins <robertc@squid-cache.org>
93ad6f77 34 * Copyright (c) 2010, Amos Jeffries <amosjeffries@squid-cache.org>
ee0989f2 35 */
36
37#ifndef _SQUIDCONNECTIONDETAIL_H_
38#define _SQUIDCONNECTIONDETAIL_H_
39
49ae8b95 40#include "comm/forward.h"
cfd66529 41#include "hier_code.h"
96d89ea0 42#include "ip/Address.h"
fd7b48b9 43#include "MemPool.h"
93ad6f77 44#include "RefCount.h"
25b481e6 45#include "typedefs.h"
89aec9b6
AJ
46#if USE_SQUID_EUI
47#include "eui/Eui48.h"
48#include "eui/Eui64.h"
49#endif
cc192b50 50
5c336a3b
AJ
51#if HAVE_IOSFWD
52#include <iosfwd>
53#endif
54#if HAVE_OSTREAM
55#include <ostream>
56#endif
57
739b352a 58struct peer;
cfd66529 59
dc49061a
A
60namespace Comm
61{
cfd66529 62
27d1f0a0
AJ
63/* TODO: make these a struct of boolean flags members in the connection instead of a bitmap.
64 * we can't do that until all non-comm code uses Commm::Connection objects to create FD
65 * currently there is code still using comm_open() and comm_openex() synchronously!!
66 */
cfd66529 67#define COMM_UNSET 0x00
40d34a62 68#define COMM_NONBLOCKING 0x01 // default flag.
cfd66529 69#define COMM_NOCLOEXEC 0x02
40d34a62
AJ
70#define COMM_REUSEADDR 0x04 // shared FD may be both accept()ing and read()ing
71#define COMM_DOBIND 0x08 // requires a bind()
72#define COMM_TRANSPARENT 0x10 // arrived via TPROXY
73#define COMM_INTERCEPTION 0x20 // arrived via NAT
62e76326 74
739b352a
AJ
75/**
76 * Store data about the physical and logical attributes of a connection.
77 *
78 * Some link state can be infered from the data, however this is not an
79 * object for state data. But a semantic equivalent for FD with easily
80 * accessible cached properties not requiring repeated complex lookups.
81 *
50847dca 82 * Connection properties may be changed until the connection is opened.
e83cc785
AJ
83 * Properties should be considered read-only outside of the Comm layer
84 * code once the connection is open.
739b352a 85 *
1c8f25bb
AJ
86 * These objects should not be passed around directly,
87 * but a Comm::ConnectionPointer should be passed instead.
739b352a 88 */
93ad6f77 89class Connection : public RefCountable
cfd66529 90{
62e76326 91public:
fd7b48b9
AJ
92 MEMPROXY_CLASS(Comm::Connection);
93
cfd66529 94 Connection();
739b352a 95
aed188fd 96 /** Clear the connection properties and close any open socket. */
cfd66529
AJ
97 ~Connection();
98
aed188fd
AJ
99 /** Copy an existing connections IP and properties.
100 * This excludes the FD. The new copy will be a closed connection.
739b352a 101 */
5ae21d99 102 ConnectionPointer copyDetails() const;
aed188fd 103
aed188fd 104 /** Close any open socket. */
55cbb02b
AJ
105 void close();
106
107 /** determine whether this object describes an active connection or not. */
d6327017 108 bool isOpen() const { return (fd >= 0); }
55cbb02b 109
5229395c
AJ
110 /** retrieve the peer pointer for use.
111 * The caller is responsible for all CBDATA operations regarding the
112 * used of the pointer returned.
113 */
743c8e20 114 peer * getPeer() const;
5229395c
AJ
115
116 /** alter the stored peer pointer.
117 * Perform appropriate CBDATA operations for locking the peer pointer
118 */
119 void setPeer(peer * p);
120
121private:
122 /** These objects may not be exactly duplicated. Use copyDetails() instead. */
123 Connection(const Connection &c);
124
125 /** These objects may not be exactly duplicated. Use copyDetails() instead. */
126 Connection & operator =(const Connection &c);
127
128public:
cfd66529
AJ
129 /** Address/Port for the Squid end of a TCP link. */
130 Ip::Address local;
62e76326 131
cfd66529
AJ
132 /** Address for the Remote end of a TCP link. */
133 Ip::Address remote;
2d8c0b1a 134
cfd66529 135 /** Hierarchy code for this connection link */
5229395c 136 hier_code peerType;
cfd66529 137
e83cc785 138 /** Socket used by this connection. Negative if not open. */
cfd66529
AJ
139 int fd;
140
739b352a 141 /** Quality of Service TOS values currently sent on this connection */
b5523edc
AJ
142 tos_t tos;
143
144 /** Netfilter MARK values currently sent on this connection */
145 nfmark_t nfmark;
cfd66529
AJ
146
147 /** COMM flags set on this connection */
148 int flags;
739b352a 149
73c36fd9
AJ
150 char rfc931[USER_IDENT_SZ];
151
89aec9b6
AJ
152#if USE_SQUID_EUI
153 Eui::Eui48 remoteEui48;
154 Eui::Eui64 remoteEui64;
155#endif
156
739b352a 157private:
418b3087
AJ
158 // XXX: we need to call this member peer_ but the struct peer_ global type
159 // behind peer* clashes despite our private Comm:: namespace
160 // (it being global gets inherited here too).
161
739b352a
AJ
162 /** cache_peer data object (if any) */
163 peer *_peer;
ee0989f2 164};
165
cfd66529
AJ
166}; // namespace Comm
167
51045442 168MEMPROXY_CLASS_INLINE(Comm::Connection);
5c336a3b
AJ
169
170// NP: Order and namespace here is very important.
171// * The second define inlines the first.
172// * Stream inheritance overloading is searched in the global scope first.
173
174inline std::ostream &
175operator << (std::ostream &os, const Comm::Connection &conn)
176{
3b7a48df 177 os << "local=" << conn.local << " remote=" << conn.remote;
9815f129 178 if (conn.fd >= 0)
3b7a48df 179 os << " FD " << conn.fd;
9815f129 180 if (conn.flags != COMM_UNSET)
50847dca 181 os << " flags=" << conn.flags;
73c36fd9 182#if USE_IDENT
50847dca
AJ
183 if (*conn.rfc931)
184 os << " IDENT::" << conn.rfc931;
73c36fd9 185#endif
5c336a3b
AJ
186 return os;
187}
188
189inline std::ostream &
190operator << (std::ostream &os, const Comm::ConnectionPointer &conn)
191{
192 if (conn != NULL)
193 os << *conn;
194 return os;
195}
196
ee0989f2 197#endif