icp_v2.cc File Reference

#include "squid.h"
#include "AccessLogEntry.h"
#include "acl/Acl.h"
#include "acl/FilledChecklist.h"
#include "base/AsyncCallbacks.h"
#include "client_db.h"
#include "comm.h"
#include "comm/Connection.h"
#include "comm/Loops.h"
#include "fd.h"
#include "HttpRequest.h"
#include "icmp/net_db.h"
#include "ICP.h"
#include "ip/Address.h"
#include "ip/tools.h"
#include "ipc/StartListening.h"
#include "ipcache.h"
#include "md5.h"
#include "multicast.h"
#include "neighbors.h"
#include "refresh.h"
#include "rfc1738.h"
#include "SquidConfig.h"
#include "StatCounters.h"
#include "Store.h"
#include "store_key_md5.h"
#include "tools.h"
#include "wordlist.h"
#include <cerrno>

Include dependency graph for icp_v2.cc:

Go to the source code of this file.

Classes
class	DelayedUdpSend
	a delayed icpUdpSend() call More...
class	ICP2State

Macros
#define	N_QUERIED_KEYS   8192
#define	N_QUERIED_KEYS_MASK   8191

Functions
static void	icpIncomingConnectionOpened (Ipc::StartListeningAnswer &)
static void	icpLogIcp (const Ip::Address &caddr, const LogTags_ot logcode, const int len, const char *url, int delay, AccessLogEntry::Pointer &al)
	updates ALE (if any) and logs the transaction (if needed) More...
static void	icpHandleIcpV2 (int, Ip::Address &, char *, int)
static void	icpCount (void *, int, size_t, int)
static LogTags_ot	icpLogFromICPCode (icp_opcode)
static int	icpUdpSend (int fd, const Ip::Address &to, icp_common_t *msg, int delay, AccessLogEntryPointer al)
static void	icpSyncAle (AccessLogEntryPointer &al, const Ip::Address &caddr, const char *url, int len, int delay)
static void	icpUdpSendQueue (int fd, void *)
icp_opcode	icpGetCommonOpcode ()
void	icpCreateAndSend (icp_opcode opcode, int flags, char const *url, int reqnum, int pad, int fd, const Ip::Address &from, AccessLogEntry::Pointer al)
void	icpDenyAccess (Ip::Address &from, char *url, int reqnum, int fd)
bool	icpAccessAllowed (Ip::Address &from, HttpRequest *icp_request)
HttpRequest *	icpGetRequest (char *url, int reqnum, int fd, Ip::Address &from)
static void	doV2Query (int fd, Ip::Address &from, char *buf, icp_common_t header)
void	icpHandleUdp (int sock, void *)
void	icpOpenPorts (void)
void	icpConnectionShutdown (void)
void	icpClosePorts (void)
int	icpSetCacheKey (const cache_key *key)
const cache_key *	icpGetCacheKey (const char *url, int reqnum)

Variables
static DelayedUdpSend *	IcpQueueHead = nullptr
static DelayedUdpSend *	IcpQueueTail = nullptr
Comm::ConnectionPointer	icpIncomingConn = nullptr
Comm::ConnectionPointer	icpOutgoingConn = nullptr
static cache_key	queried_keys [N_QUERIED_KEYS][SQUID_MD5_DIGEST_LENGTH]

Macro Definition Documentation

N_QUERIED_KEYS

#define N_QUERIED_KEYS   8192

Definition at line 837 of file icp_v2.cc.

N_QUERIED_KEYS_MASK

#define N_QUERIED_KEYS_MASK   8191

Definition at line 838 of file icp_v2.cc.

Function Documentation

doV2Query()

static void doV2Query ( int  fd, Ip::Address &  from, char *  buf, icp_common_t  header  )

static

Definition at line 479 of file icp_v2.cc.

References ICPState::al, Config, ICPState::fd, icp_common_t::flags, ICP2State::flags, ICPState::from, AnyP::Uri::host(), HTTPMSGLOCK(), HTTPMSGUNLOCK(), ICP_ERR, ICP_FLAG_SRC_RTT, ICP_HIT, ICP_MISS, ICP_MISS_NOFETCH, icpAccessAllowed(), icpCreateAndSend(), icpDenyAccess(), icpGetCommonOpcode(), icpGetRequest(), ICPState::isHit(), netdbHostHops(), netdbHostRtt(), netdbPingSite(), SquidConfig::onoff, icp_common_t::reqnum, ICPState::request, ICP2State::rtt, ICP2State::src_rtt, SquidConfig::test_reachability, ICPState::url, HttpRequest::url, and xstrdup.

Referenced by icpHandleIcpV2().

icpHandleUdp()

void icpHandleUdp	(	int	sock,
		void *
	)

Definition at line 612 of file icp_v2.cc.

References COMM_SELECT_READ, comm_udp_recvfrom(), DBG_IMPORTANT, debugs, ICP_VERSION_2, ICP_VERSION_3, icpCount(), icpHandleIcpV2(), icpHandleIcpV3(), icpOutgoingConn, ignoreErrno(), incoming_sockets_accepted, INCOMING_UDP_MAX, int, LOCAL_ARRAY, max(), RECV, Comm::SetSelect(), SQUID_UDP_SO_RCVBUF, and xstrerr().

Referenced by icpIncomingConnectionOpened(), and icpOpenPorts().

icpIncomingConnectionOpened()

static void icpIncomingConnectionOpened ( Ipc::StartListeningAnswer &  answer )

static

Definition at line 733 of file icp_v2.cc.

References SquidConfig::Addrs, COMM_SELECT_READ, Config, Ipc::StartListeningAnswer::conn, DBG_IMPORTANT, debugs, fatal(), fd_note(), icpHandleUdp(), icpOutgoingConn, ipcache_nbgethostbyname(), Comm::IsConnOpen(), Ip::Address::isNoAddr(), SquidConfig::mcast_group_list, mcastJoinGroups, wordlist::next, Comm::SetSelect(), and SquidConfig::udp_outgoing.

Referenced by icpOpenPorts().

icpLogFromICPCode()

static LogTags_ot icpLogFromICPCode ( icp_opcode  opcode )

static

Definition at line 389 of file icp_v2.cc.

References fatal(), ICP_DECHO, ICP_DENIED, ICP_ERR, ICP_HIT, ICP_MISS, ICP_MISS_NOFETCH, ICP_QUERY, LOG_ICP_QUERY, LOG_UDP_DENIED, LOG_UDP_HIT, LOG_UDP_INVALID, LOG_UDP_MISS, and LOG_UDP_MISS_NOFETCH.

Referenced by icpCreateAndSend(), and icpUdpSend().

icpSyncAle()

static void icpSyncAle ( AccessLogEntryPointer &  al, const Ip::Address &  caddr, const char *  url, int  len, int  delay  )

static

Definition at line 73 of file icp_v2.cc.

References current_time, and ICP_QUERY.

Referenced by ICPState::fillChecklist(), and icpLogIcp().

icpUdpSend()

static int icpUdpSend ( int  fd, const Ip::Address &  to, icp_common_t *  msg, int  delay, AccessLogEntryPointer  al  )

static

writes the given UDP msg to the socket; queues a retry on the first failure

Returns

a negative number on failures

Definition at line 319 of file icp_v2.cc.

References COMM_SELECT_WRITE, comm_udp_sendto(), current_time, debugs, StatCounters::icp, icp_opcode_str, icpCount(), icpLogFromICPCode(), icpLogIcp(), IcpQueueHead, IcpQueueTail, icpUdpSendQueue(), int, icp_common_t::length, DelayedUdpSend::next, icp_common_t::opcode, StatCounters::replies_dropped, StatCounters::replies_queued, safe_free, SENT, Comm::SetSelect(), and statCounter.

Referenced by icpCreateAndSend(), and icpUdpSendQueue().

Variable Documentation

queried_keys

cache_key queried_keys[N_QUERIED_KEYS][SQUID_MD5_DIGEST_LENGTH]

static

Definition at line 839 of file icp_v2.cc.

Referenced by icpGetCacheKey(), and icpSetCacheKey().