Lines Matching refs:Connection
32 const std::vector<cricket::Connection::SentPing>& pings_since_last_response,
49 const std::vector<cricket::Connection::SentPing>& pings_since_last_response,
65 // use a large value just in case the connection is really slow.
205 std::vector<Connection*> list;
217 Connection* Port::GetConnection(const rtc::SocketAddress& remote_addr) {
264 void Port::AddConnection(Connection* conn) {
302 // pruned a connection for this port while it had STUN requests in flight,
579 // connection.
580 Connection* conn = GetConnection(addr);
642 void Port::OnConnectionDestroyed(Connection* conn) {
649 // Note: If a new connection is added after this message is posted, but it
671 explicit ConnectionRequest(Connection* connection)
673 connection_(connection) {
702 // in Connection will be set to false by default. Once the connection
703 // becomes "best connection", nomination flag will be turned on.
757 Connection* connection_;
761 // Connection
764 Connection::Connection(Port* port,
794 requests_.SignalSendPacket.connect(this, &Connection::OnSendStunPacket);
795 LOG_J(LS_INFO, this) << "Connection created";
798 Connection::~Connection() {
801 const Candidate& Connection::local_candidate() const {
806 uint64_t Connection::priority() const {
831 void Connection::set_write_state(WriteState value) {
841 void Connection::set_receiving(bool value) {
849 void Connection::set_state(State state) {
857 void Connection::set_connected(bool value) {
866 void Connection::set_use_candidate_attr(bool enable) {
870 void Connection::OnSendStunPacket(const void* data, size_t size,
882 void Connection::OnReadPacket(
897 LOG(LS_WARNING) << "Received a data packet on a timed-out Connection. "
908 // Log at LS_INFO if we receive a ping on an unwritable connection.
956 void Connection::HandleBindingRequest(IceMessage* msg) {
957 // This connection should now be receiving.
987 void Connection::OnReadyToSend() {
993 void Connection::Prune() {
995 LOG_J(LS_VERBOSE, this) << "Connection pruned";
1002 void Connection::Destroy() {
1003 LOG_J(LS_VERBOSE, this) << "Connection destroyed";
1007 void Connection::FailAndDestroy() {
1008 set_state(Connection::STATE_FAILED);
1012 void Connection::PrintPingsSinceLastResponse(std::string* s, size_t max) {
1029 void Connection::UpdateState(uint32_t now) {
1094 void Connection::Ping(uint32_t now) {
1104 void Connection::ReceivedPing() {
1109 void Connection::ReceivedPingResponse() {
1111 // the correct local and remote username for this connection.
1113 // connection back to life, but if we don't really want it, we can always
1122 bool Connection::dead(uint32_t now) const {
1126 // normal case of a successfully used connection that stops working. This
1128 // (pruned) connection.
1134 // actively pinging and not pruned. Otherwise, the connection might be
1136 // new connection that is pinging but hasn't received anything yet.
1147 std::string Connection::ToDebugId() const {
1153 std::string Connection::ToString() const {
1200 std::string Connection::ToSensitiveString() const {
1204 void Connection::OnConnectionRequestResponse(ConnectionRequest* request,
1207 // connection.
1232 void Connection::OnConnectionRequestErrorResponse(ConnectionRequest* request,
1254 // This is not a valid connection.
1256 << error_code << "; killing connection";
1261 void Connection::OnConnectionRequestTimeout(ConnectionRequest* request) {
1262 // Log at LS_INFO if we miss a ping on a writable connection.
1269 void Connection::OnConnectionRequestSent(ConnectionRequest* request) {
1270 // Log at LS_INFO if we send a ping on an unwritable connection.
1278 void Connection::HandleRoleConflictFromPeer() {
1282 void Connection::MaybeSetRemoteIceCredentials(const std::string& ice_ufrag,
1290 void Connection::MaybeUpdatePeerReflexiveCandidate(
1303 void Connection::OnMessage(rtc::Message *pmsg) {
1305 LOG_J(LS_INFO, this) << "Connection deleted";
1310 uint32_t Connection::last_received() const {
1315 size_t Connection::recv_bytes_second() {
1319 size_t Connection::recv_total_bytes() {
1323 size_t Connection::sent_bytes_second() {
1327 size_t Connection::sent_total_bytes() {
1331 size_t Connection::sent_discarded_packets() {
1335 size_t Connection::sent_total_packets() {
1339 void Connection::MaybeAddPrflxCandidate(ConnectionRequest* request,
1349 LOG(LS_WARNING) << "Connection::OnConnectionRequestResponse - "
1372 LOG(LS_WARNING) << "Connection::OnConnectionRequestResponse - "
1396 // Change the local candidate of this Connection to the new prflx candidate.
1400 // Connection's local candidate has changed.
1407 : Connection(port, index, remote_candidate) {}
