OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2012 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2012 The WebRTC Project Authors. All rights reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 482 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
493 if (state_ == CONNECTED) { | 493 if (state_ == CONNECTED) { |
494 hanging_get_->Close(); | 494 hanging_get_->Close(); |
495 hanging_get_->Connect(server_address_); | 495 hanging_get_->Connect(server_address_); |
496 } | 496 } |
497 } else { | 497 } else { |
498 callback_->OnMessageSent(err); | 498 callback_->OnMessageSent(err); |
499 } | 499 } |
500 } else { | 500 } else { |
501 if (socket == control_socket_.get()) { | 501 if (socket == control_socket_.get()) { |
502 LOG(WARNING) << "Connection refused; retrying in 2 seconds"; | 502 LOG(WARNING) << "Connection refused; retrying in 2 seconds"; |
503 rtc::Thread::Current()->PostDelayed(kReconnectDelay, this, 0); | 503 rtc::Thread::Current()->PostDelayed(RTC_FROM_HERE, kReconnectDelay, this, |
| 504 0); |
504 } else { | 505 } else { |
505 Close(); | 506 Close(); |
506 callback_->OnDisconnected(); | 507 callback_->OnDisconnected(); |
507 } | 508 } |
508 } | 509 } |
509 } | 510 } |
510 | 511 |
511 void PeerConnectionClient::OnMessage(rtc::Message* msg) { | 512 void PeerConnectionClient::OnMessage(rtc::Message* msg) { |
512 // ignore msg; there is currently only one supported message ("retry") | 513 // ignore msg; there is currently only one supported message ("retry") |
513 DoConnect(); | 514 DoConnect(); |
514 } | 515 } |
OLD | NEW |