Lines Matching refs:port_

74   TurnPort* port_;
88 TurnPort* port_;
106 TurnPort* port_;
125 TurnPort* port_;
139 TurnPort* port() { return port_; }
171 TurnPort* port_;
1027 port_(port) {
1037 if (!port_->hash().empty()) {
1038 port_->AddRequestAuthInfo(request);
1043 LOG_J(LS_INFO, port_) << "TURN allocate request sent"
1049 LOG_J(LS_INFO, port_) << "TURN allocate requested successfully"
1058 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_XOR_MAPPED_ADDRESS "
1063 port_->OnStunAddress(mapped_attr->GetAddress());
1068 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_XOR_RELAYED_ADDRESS "
1076 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_TURN_LIFETIME attribute in "
1081 port_->OnAllocateSuccess(relayed_attr->GetAddress(),
1083 port_->ScheduleRefresh(lifetime_attr->value());
1090 LOG_J(LS_INFO, port_) << "Received TURN allocate error response"
1105 port_->thread()->Post(port_, TurnPort::MSG_ALLOCATE_MISMATCH);
1108 LOG_J(LS_WARNING, port_) << "Received TURN allocate error response"
1112 port_->OnAllocateError();
1117 LOG_J(LS_WARNING, port_) << "TURN allocate request "
1119 port_->OnAllocateRequestTimeout();
1124 if (code == STUN_ERROR_UNAUTHORIZED && !port_->hash().empty()) {
1125 LOG_J(LS_WARNING, port_) << "Failed to authenticate with the server "
1127 port_->OnAllocateError();
1135 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_REALM attribute in "
1139 port_->set_realm(realm_attr->GetString());
1144 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_NONCE attribute in "
1148 port_->set_nonce(nonce_attr->GetString());
1151 port_->SendRequest(new TurnAllocateRequest(port_), 0);
1164 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_ALTERNATE_SERVER "
1166 port_->OnAllocateError();
1169 if (!port_->SetAlternateServer(alternate_server_attr->GetAddress())) {
1170 port_->OnAllocateError();
1178 LOG_J(LS_INFO, port_) << "Applying STUN_ATTR_REALM attribute in "
1180 port_->set_realm(realm_attr->GetString());
1186 LOG_J(LS_INFO, port_) << "Applying STUN_ATTR_NONCE attribute in "
1188 port_->set_nonce(nonce_attr->GetString());
1194 port_->thread()->Post(port_, TurnPort::MSG_TRY_ALTERNATE_SERVER);
1199 port_(port),
1212 port_->AddRequestAuthInfo(request);
1216 LOG_J(LS_INFO, port_) << "TURN refresh request sent"
1222 LOG_J(LS_INFO, port_) << "TURN refresh requested successfully"
1231 LOG_J(LS_WARNING, port_) << "Missing STUN_ATTR_TURN_LIFETIME attribute in "
1237 port_->ScheduleRefresh(lifetime_attr->value());
1238 port_->SignalTurnRefreshResult(port_, TURN_SUCCESS_RESULT_CODE);
1245 if (port_->UpdateNonce(response)) {
1247 port_->SendRequest(new TurnRefreshRequest(port_), 0);
1250 LOG_J(LS_WARNING, port_) << "Received TURN refresh error response"
1254 port_->OnTurnRefreshError();
1255 port_->SignalTurnRefreshResult(port_, error_code->code());
1260 LOG_J(LS_WARNING, port_) << "TURN refresh timeout " << rtc::hex_encode(id());
1261 port_->OnTurnRefreshError();
1268 port_(port),
1280 port_->AddRequestAuthInfo(request);
1284 LOG_J(LS_INFO, port_) << "TURN create permission request sent"
1290 LOG_J(LS_INFO, port_) << "TURN permission requested successfully"
1302 LOG_J(LS_WARNING, port_) << "Received TURN create permission error response"
1312 LOG_J(LS_WARNING, port_) << "TURN create permission timeout "
1328 port_(port),
1343 port_->AddRequestAuthInfo(request);
1347 LOG_J(LS_INFO, port_) << "TURN channel bind request sent"
1353 LOG_J(LS_INFO, port_) << "TURN channel bind requested successfully"
1366 LOG_J(LS_INFO, port_) << "Scheduled channel bind in " << delay << "ms.";
1372 LOG_J(LS_WARNING, port_) << "Received TURN channel bind error response"
1382 LOG_J(LS_WARNING, port_) << "TURN channel bind timeout "
1396 : port_(port),
1405 port_->SendRequest(new TurnCreatePermissionRequest(port_, this, ext_addr_),
1410 port_->SendRequest(new TurnChannelBindRequest(
1411 port_, this, channel_id_, ext_addr_), delay);
1440 return port_->Send(buf.Data(), buf.Length(), options);
1444 LOG_J(LS_INFO, port_) << "Create permission for "
1447 port_->SignalCreatePermissionResult(port_, ext_addr_,
1457 LOG_J(LS_INFO, port_) << "Scheduled create-permission-request in "
1464 if (port_->UpdateNonce(response)) {
1468 port_->DestroyConnection(ext_addr_);
1470 port_->SignalCreatePermissionResult(port_, ext_addr_, code);
1471 Connection* c = port_->GetConnection(ext_addr_);
1481 port_->DestroyConnection(ext_addr_);
1485 LOG_J(LS_INFO, port_) << "Channel bind for " << ext_addr_.ToSensitiveString()
1496 if (port_->UpdateNonce(response)) {
1502 port_->DestroyConnection(ext_addr_);
1507 port_->DestroyConnection(ext_addr_);