#include <ICP.h>
Inherits Peer.
Public Member Functions | |
ParentSiblingPeer (PeerType_t, PeerConfigData *, ICPProcessor *, bool dynamic_peer=false) | |
~ParentSiblingPeer () | |
int | GetProxyPort () |
int | GetICPPort () |
virtual sockaddr * | GetIP () |
virtual Action * | SendMsg_re (Continuation *, void *, struct msghdr *, struct sockaddr const *to) |
virtual Action * | RecvFrom_re (Continuation *, void *, IOBufferBlock *, int, struct sockaddr *, socklen_t *) |
virtual int | GetRecvFD () |
virtual int | GetSendFD () |
virtual int | ExpectedReplies (BitMap *) |
virtual int | ValidSender (struct sockaddr *) |
virtual void | LogSendMsg (ICPMsg_t *, sockaddr const *) |
virtual int | ExtToIntRecvSockAddr (sockaddr const *in, sockaddr *out) |
virtual int | IsOnline () |
virtual Connection * | GetSendChan () |
virtual Connection * | GetRecvChan () |
PeerConfigData * | GetConfig () |
Connection * | GetChan () |
Definition at line 606 of file ICP.h.
ParentSiblingPeer::ParentSiblingPeer | ( | PeerType_t | t, | |
PeerConfigData * | p, | |||
ICPProcessor * | icpPr, | |||
bool | dynamic_peer = false | |||
) |
Definition at line 830 of file ICPConfig.cc.
References ats_ip_set(), PeerConfigData::GetICPPort(), PeerConfigData::GetIPAddr(), and IpEndpoint::sa.
ParentSiblingPeer::~ParentSiblingPeer | ( | ) | [inline] |
Definition at line 610 of file ICP.h.
References Peer::_state, and PEER_DYNAMIC.
int ParentSiblingPeer::ExpectedReplies | ( | BitMap * | expected_replies_list | ) | [virtual] |
Implements Peer.
Definition at line 908 of file ICPConfig.cc.
References Peer::_state, Peer::_stats, ats_ip_nptop(), Debug, GetIP(), Peer::GetPeerID(), Peer::OFFLINE_THRESHOLD, PEER_UP, BitMap::SetBit(), Peer::PeerStats::total_received, and Peer::PeerStats::total_sent.
Referenced by MultiCastPeer::ExpectedReplies().
int ParentSiblingPeer::ExtToIntRecvSockAddr | ( | sockaddr const * | in, | |
sockaddr * | out | |||
) | [virtual] |
Implements Peer.
Definition at line 970 of file ICPConfig.cc.
References Peer::_ICPpr, ats_ip_copy(), ICPProcessor::FindPeer(), Peer::GetIP(), and Peer::GetType().
Connection* ParentSiblingPeer::GetChan | ( | ) | [inline] |
Definition at line 642 of file ICP.h.
Referenced by ICPPeerReadCont::PeerReadStateMachine().
PeerConfigData* ParentSiblingPeer::GetConfig | ( | ) | [inline] |
int ParentSiblingPeer::GetICPPort | ( | ) |
Definition at line 843 of file ICPConfig.cc.
References PeerConfigData::GetICPPort().
sockaddr * ParentSiblingPeer::GetIP | ( | ) | [virtual] |
Implements Peer.
Definition at line 850 of file ICPConfig.cc.
References IpEndpoint::sa.
Referenced by ExpectedReplies(), ICPPeerReadCont::PeerReadStateMachine(), and ValidSender().
int ParentSiblingPeer::GetProxyPort | ( | ) |
Definition at line 837 of file ICPConfig.cc.
References PeerConfigData::GetProxyPort().
virtual Connection* ParentSiblingPeer::GetRecvChan | ( | ) | [inline, virtual] |
int ParentSiblingPeer::GetRecvFD | ( | ) | [virtual] |
virtual Connection* ParentSiblingPeer::GetSendChan | ( | ) | [inline, virtual] |
int ParentSiblingPeer::GetSendFD | ( | ) | [virtual] |
virtual int ParentSiblingPeer::IsOnline | ( | ) | [inline, virtual] |
void ParentSiblingPeer::LogSendMsg | ( | ICPMsg_t * | m, | |
sockaddr const * | ||||
) | [virtual] |
Implements Peer.
Definition at line 959 of file ICPConfig.cc.
References Peer::_stats, ICPMsg::h, ink_get_hrtime(), Peer::PeerStats::last_send, ICPMsgHeader::opcode, Peer::PeerStats::sent, and Peer::PeerStats::total_sent.
Action * ParentSiblingPeer::RecvFrom_re | ( | Continuation * | cont, | |
void * | token, | |||
IOBufferBlock * | bufblock, | |||
int | size, | |||
struct sockaddr * | from, | |||
socklen_t * | fromlen | |||
) | [virtual] |
Implements Peer.
Definition at line 883 of file ICPConfig.cc.
References Peer::_ICPpr, ICPProcessor::GetLocalPeer(), Peer::GetRecvFD(), UDPNetProcessor::recvfrom_re(), and udpNet.
virtual Action* ParentSiblingPeer::SendMsg_re | ( | Continuation * | , | |
void * | , | |||
struct msghdr * | , | |||
struct sockaddr const * | to | |||
) | [virtual] |
Implements Peer.
int ParentSiblingPeer::ValidSender | ( | struct sockaddr * | fr | ) | [virtual] |
Implements Peer.
Definition at line 928 of file ICPConfig.cc.
References Peer::_ICPpr, Peer::_type, ats_ip_addr_eq(), ats_ip_port_cast(), ICPProcessor::FindPeer(), GetIP(), and PEER_LOCAL.