#include "anyp/forward.h"
#include "enums.h"
#include "ICP.h"
#include "lookup_t.h"
#include "typedefs.h"

Include dependency graph for neighbors.h:

This graph shows which files directly or indirectly include this file:

Functions
CachePeer *	getFirstPeer (void)

CachePeer *	getFirstUpParent (PeerSelector *)

CachePeer *	getNextPeer (CachePeer *)

CachePeer *	getSingleParent (PeerSelector *)

int	neighborsCount (PeerSelector *)

int	neighborsUdpPing (HttpRequest , StoreEntry , IRCB callback, PeerSelector ps, int exprep, int timeout)

void	neighborAddAcl (const char , const char )

void	neighborsUdpAck (const cache_key , icp_common_t , const Ip::Address &)

void	neighborAdd (const char , const char , int, int, int, int, int)

void	neighbors_init (void)

void	neighborsHtcpClear (StoreEntry , const char , HttpRequest *, const HttpRequestMethod &, htcp_clr_reason)

CachePeer *	peerFindByName (const char *)

CachePeer *	peerFindByNameAndPort (const char *, unsigned short)

CachePeer *	getDefaultParent (PeerSelector *)

CachePeer *	getRoundRobinParent (PeerSelector *)

CachePeer *	getWeightedRoundRobinParent (PeerSelector *)

void	peerClearRRStart (void)

void	peerClearRR (void)

lookup_t	peerDigestLookup (CachePeer p, PeerSelector )

CachePeer *	neighborsDigestSelect (PeerSelector *)

void	peerNoteDigestLookup (HttpRequest request, CachePeer p, lookup_t lookup)

void	peerNoteDigestGone (CachePeer *p)

int	neighborUp (const CachePeer *e)

const char *	neighborTypeStr (const CachePeer *e)

peer_t	neighborType (const CachePeer *, const AnyP::Uri &)

void	peerConnectFailed (CachePeer *)

void	peerConnectSucceded (CachePeer *)

void	dump_peer_options (StoreEntry , CachePeer )

int	peerHTTPOkay (const CachePeer , PeerSelector )

time_t	peerConnectTimeout (const CachePeer *peer)

time_t	positiveTimeout (const time_t timeout)

bool	peerCanOpenMore (const CachePeer *p)
	Whether we can open new connections to the peer (e.g., despite max-conn) More...

bool	peerHasConnAvailable (const CachePeer *p)
	Whether the peer has idle or standby connections that can be used now. More...

void	peerConnClosed (CachePeer *p)
	Notifies peer of an associated connection closure. More...

CachePeer *	whichPeer (const Ip::Address &from)

Function Documentation

◆ dump_peer_options()

void dump_peer_options	(	StoreEntry *	,
		CachePeer *
	)

Definition at line 1490 of file neighbors.cc.

References CachePeer::allow_miss, CachePeer::background_ping, CachePeer::carp, CachePeer::closest_only, CachePeer::connect_fail_limit, CachePeer::connect_timeout_raw, CachePeer::connection_auth, CachePeer::default_parent, CachePeer::digest_url, CachePeer::domain, Security::PeerOptions::dumpCfg(), CachePeer::htcp, CachePeer::htcp_no_clr, CachePeer::htcp_no_purge_clr, CachePeer::htcp_oldsquid, CachePeer::htcp_only_clr, CachePeer::limit, CachePeer::login, CachePeer::max_conn, CachePeer::mcast, CachePeer::mcast_responder, CachePeer::mcast_siblings, CachePeer::no_delay, CachePeer::no_digest, CachePeer::no_netdb_exchange, CachePeer::no_query, CachePeer::no_tproxy, CachePeer::options, CachePeer::originserver, PEER_TCP_MAGIC_COUNT, CachePeer::proxy_only, CachePeer::roundrobin, CachePeer::secure, CachePeer::sourcehash, CachePeer::standby, storeAppendPrintf(), CachePeer::ttl, CachePeer::userhash, CachePeer::weight, and CachePeer::weighted_roundrobin.

Referenced by dump_peer(), and dump_peers().

◆ getDefaultParent()

CachePeer* getDefaultParent ( PeerSelector * )

Definition at line 467 of file neighbors.cc.

References assert, Config, debugs, CachePeer::default_parent, CachePeer::host, neighborType(), CachePeer::next, NULL, CachePeer::options, p, PEER_PARENT, peerHTTPOkay(), SquidConfig::peers, PeerSelector::request, request(), and HttpRequest::url.

Referenced by PeerSelector::selectAllParents(), and PeerSelector::selectSomeParent().

◆ getFirstPeer()

CachePeer* getFirstPeer ( void )

Definition at line 500 of file neighbors.cc.

References Config, and SquidConfig::peers.

Referenced by statPeerSelect().

◆ getFirstUpParent()

CachePeer* getFirstUpParent ( PeerSelector * )

Definition at line 282 of file neighbors.cc.

References assert, Config, debugs, CachePeer::host, neighborType(), neighborUp(), CachePeer::next, NULL, p, PEER_PARENT, peerHTTPOkay(), SquidConfig::peers, PeerSelector::request, request(), and HttpRequest::url.

Referenced by PeerSelector::selectSomeParent().

◆ getNextPeer()

CachePeer* getNextPeer ( CachePeer * )

Definition at line 494 of file neighbors.cc.

References CachePeer::next.

Referenced by statPeerSelect().

◆ getRoundRobinParent()

CachePeer* getRoundRobinParent ( PeerSelector * )

Definition at line 307 of file neighbors.cc.

References assert, Config, debugs, HERE(), CachePeer::host, neighborType(), CachePeer::next, NULL, CachePeer::options, p, PEER_PARENT, peerHTTPOkay(), SquidConfig::peers, PeerSelector::request, request(), CachePeer::roundrobin, CachePeer::rr_count, HttpRequest::url, and CachePeer::weight.

Referenced by PeerSelector::selectSomeParent().

◆ getSingleParent()

CachePeer* getSingleParent ( PeerSelector * )

◆ getWeightedRoundRobinParent()

CachePeer* getWeightedRoundRobinParent ( PeerSelector * )

Definition at line 349 of file neighbors.cc.

References assert, CachePeer::basetime, Config, debugs, CachePeer::host, neighborType(), CachePeer::next, NULL, CachePeer::options, p, PEER_PARENT, peerHTTPOkay(), SquidConfig::peers, PeerSelector::request, request(), CachePeer::rr_count, CachePeer::rtt, CachePeer::stats, HttpRequest::url, CachePeer::weight, and CachePeer::weighted_roundrobin.

Referenced by PeerSelector::selectSomeParent().

◆ neighborAdd()

void neighborAdd	(	const char *	,
		const char *	,
		int	,
		int	,
		int	,
		int	,
		int
	)

◆ neighborAddAcl()

void neighborAddAcl	(	const char *	,
		const char *
	)

◆ neighbors_init()

void neighbors_init ( void )

Definition at line 547 of file neighbors.cc.

References Config, DBG_IMPORTANT, debugs, echo_port, getMyHostname(), getservbyname(), CachePeer::host, CachePeer::http_port, HttpPortList, CachePeer::icp, icpIncomingConn, Comm::IsConnOpen(), neighborRemove(), neighborsRegisterWithCacheManager(), neighborTypeStr(), CachePeer::next, NULL, peerRefreshDNS(), SquidConfig::peers, CachePeer::icp_::port, and servent::s_port.

Referenced by mainInitialize(), and mainReconfigureFinish().

◆ neighborsCount()

int neighborsCount ( PeerSelector * )

Definition at line 267 of file neighbors.cc.

References Config, debugs, CachePeer::next, NULL, p, SquidConfig::peers, and peerWouldBePinged().

Referenced by peerSelectIcpPing().

◆ neighborsDigestSelect()

CachePeer* neighborsDigestSelect ( PeerSelector * )

Definition at line 797 of file neighbors.cc.

References assert, Config, debugs, HttpRequest::flags, HttpRequest::hier, RequestFlags::hierarchical, CachePeer::host, i, LOOKUP_HIT, LOOKUP_MISS, LOOKUP_NONE, HierarchyLogEntry::n_choices, HierarchyLogEntry::n_ichoices, netdbHostRtt(), CachePeer::next, SquidConfig::npeers, NULL, p, peerDigestLookup(), peerNoteDigestLookup(), SquidConfig::peers, PeerSelector::request, request(), and storeKeyPublicByRequest().

Referenced by PeerSelector::selectSomeNeighbor().

◆ neighborsHtcpClear()

void neighborsHtcpClear	(	StoreEntry *	,
		const char *	,
		HttpRequest *	,
		const HttpRequestMethod &	,
		htcp_clr_reason
	)

Definition at line 1785 of file neighbors.cc.

References buf, Config, debugs, CachePeer::htcp, HTCP_CLR_PURGE, CachePeer::htcp_no_clr, CachePeer::htcp_no_purge_clr, htcpClear(), CachePeer::in_addr, CachePeer::next, CachePeer::options, p, SquidConfig::peers, and Ip::Address::toUrl().

Referenced by httpMaybeRemovePublic(), clientReplyContext::purgeDoPurgeGet(), clientReplyContext::purgeDoPurgeHead(), and purgeEntriesByUrl().

◆ neighborsUdpAck()

void neighborsUdpAck	(	const cache_key *	key,
		icp_common_t *	header,
		const Ip::Address &	from
	)

I should attach these records to the entry. We take the first hit we get our wait until everyone misses. The timeout handler call needs to nip this shopping list or call one of the misses.

If a hit process is already started, then sobeit

Definition at line 997 of file neighbors.cc.

References CachePeer::icp_::counts, DBG_CRITICAL, DBG_IMPORTANT, debug_trap(), debugs, EBIT_TEST, ENTRY_DISPATCHED, StoreEntry::flags, CachePeer::host, CachePeer::icp, ICP_DECHO, ICP_DENIED, ICP_END, ICP_HIT, ICP_MISS, ICP_MISS_NOFETCH, icp_opcode_str, ICP_SECHO, ignoreMulticastReply(), MemObject::ircb_data, StoreEntry::locked(), StoreEntry::mem_obj, neighborAlive(), neighborCountIgnored(), neighborIgnoreNonPeer(), neighborRemove(), neighborType(), neighborUpdateRtt(), NULL, icp_common_t::opcode, p, PEER_NONE, PEER_SIBLING, MemObject::ping_reply_callback, StoreEntry::ping_status, PING_WAITING, CachePeer::pings_acked, AnyP::PROTO_ICP, MemObject::request, Store::Root(), CachePeer::stats, storeKeyText(), HttpRequest::url, and whichPeer().

Referenced by icp_common_t::handleReply().

◆ neighborsUdpPing()

int neighborsUdpPing	(	HttpRequest *	,
		StoreEntry *	,
		IRCB *	callback,
		PeerSelector *	ps,
		int *	exprep,
		int *	timeout
	)

Definition at line 589 of file neighbors.cc.

References assert, callback, Config, current_time, DBG_CRITICAL, DBG_IMPORTANT, debugs, echo_port, Comm::Connection::fd, StoreEntry::getMD5Text(), StoreEntry::hasDisk(), CachePeer::host, CachePeer::htcp, SquidConfig::htcp, CachePeer::htcp_only_clr, htcpQuery(), i, CachePeer::icp, SquidConfig::icp, ICP_DECHO, ICP_FLAG_SRC_RTT, ICP_QUERY, SquidConfig::icp_query, SquidConfig::icp_query_max, SquidConfig::icp_query_min, ICP_VERSION_2, icpCreateAndSend(), icpOutgoingConn, icpSetCacheKey(), CachePeer::in_addr, MemObject::ircb_data, Comm::IsConnOpen(), hash_link::key, CachePeer::last_query, CachePeer::logged_state, CachePeer::mcast, mcastSetTtl(), StoreEntry::mem_obj, CachePeer::n_replies_expected, CachePeer::name, neighborType(), neighborTypeStr(), neighborUp(), CachePeer::next, SquidConfig::npeers, NULL, SquidConfig::onoff, CachePeer::options, p, PEER_ALIVE, PEER_DEAD, PEER_MULTICAST, PEER_PARENT, SquidConfig::peers, peerWouldBePinged(), MemObject::ping_reply_callback, CachePeer::pings_sent, CachePeer::icp_::port, SquidConfig::Port, CachePeer::probe_start, SquidConfig::query_icmp, CachePeer::rtt, squid_curtime, MemObject::start_ping, CachePeer::stats, SquidConfig::Timeout, CachePeer::ttl, CachePeer::type, HttpRequest::url, StoreEntry::url(), and CachePeer::icp_::version.

Referenced by PeerSelector::selectSomeNeighbor().

◆ neighborType()

peer_t neighborType	(	const CachePeer *	,
		const AnyP::Uri &
	)

◆ neighborTypeStr()

const char* neighborTypeStr ( const CachePeer * e )

Definition at line 79 of file neighbors.cc.

References PEER_MULTICAST, PEER_NONE, PEER_SIBLING, and CachePeer::type.

Referenced by dump_peer(), dump_peers(), neighbors_init(), neighborsUdpPing(), peerAlive(), peerConnectFailedSilent(), and peerDNSConfigure().

◆ neighborUp()

int neighborUp ( const CachePeer * e )

Definition at line 1149 of file neighbors.cc.

References Config, SquidConfig::deadPeer, debugs, CachePeer::host, CachePeer::in_addr, CachePeer::n_addresses, CachePeer::no_query, CachePeer::options, peerProbeConnect(), CachePeer::probe_start, squid_curtime, CachePeer::stats, CachePeer::tcp_up, and SquidConfig::Timeout.

Referenced by dump_peers(), getFirstUpParent(), neighborsUdpPing(), PeerPoolMgr::openNewConnection(), peerHTTPOkay(), peerWouldBePinged(), and snmp_meshPtblFn().

◆ peerCanOpenMore()

bool peerCanOpenMore ( const CachePeer * p )

Definition at line 217 of file neighbors.cc.

References CachePeer::conn_open, debugs, CachePeer::max_conn, Squid_MaxFD, and CachePeer::stats.

Referenced by PeerPoolMgr::openNewConnection(), peerConnClosed(), and peerHTTPOkay().

◆ peerClearRR()

void peerClearRR ( void )

Called whenever the round-robin counters need to be reset to a sane state. So far those times are:

On startup and reconfigure - to set the counters to sane initial settings.
When a CachePeer has revived from dead, to prevent the revived CachePeer being flooded with requests which it has 'missed' during the down period.

Definition at line 440 of file neighbors.cc.

References Config, CachePeer::next, NULL, p, SquidConfig::peers, and CachePeer::rr_count.

Referenced by peerAlive(), and peerClearRRLoop().

◆ peerClearRRStart()

void peerClearRRStart ( void )

This gets called on startup and restart to kick off the CachePeer round-robin maintenance event. It ensures that no matter how many times its called no more than one event is scheduled.

Definition at line 423 of file neighbors.cc.

References NULL, and peerClearRRLoop().

Referenced by parse_peer().