| // Copyright 2014 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "components/copresence/public/copresence_client.h" |
| |
| #include "base/bind.h" |
| #include "components/copresence/public/copresence_client_delegate.h" |
| #include "components/copresence/public/whispernet_client.h" |
| #include "components/copresence/rpc/rpc_handler.h" |
| |
| namespace copresence { |
| |
| PendingRequest::PendingRequest(const copresence::ReportRequest& report, |
| const std::string app_id, |
| const StatusCallback& callback) |
| : report(report), app_id(app_id), callback(callback) { |
| } |
| |
| PendingRequest::~PendingRequest() { |
| } |
| |
| // Public methods |
| |
| CopresenceClient::CopresenceClient(CopresenceClientDelegate* delegate) |
| : delegate_(delegate), init_failed_(false), pending_init_operations_(0) { |
| DVLOG(3) << "Initializing client."; |
| pending_init_operations_++; |
| rpc_handler_.reset(new RpcHandler(delegate)); |
| // We own the RpcHandler, so it won't outlive us. |
| rpc_handler_->Initialize(base::Bind(&CopresenceClient::InitStepComplete, |
| base::Unretained(this), |
| "Copresence device registration")); |
| |
| pending_init_operations_++; |
| delegate_->GetWhispernetClient()->Initialize( |
| base::Bind(&CopresenceClient::InitStepComplete, |
| // We cannot cancel WhispernetClient initialization. |
| // TODO(ckehoe): Get rid of this. |
| AsWeakPtr(), |
| "Whispernet proxy initialization")); |
| } |
| |
| CopresenceClient::~CopresenceClient() {} |
| |
| // Returns false if any operations were malformed. |
| void CopresenceClient::ExecuteReportRequest(copresence::ReportRequest request, |
| const std::string& app_id, |
| const StatusCallback& callback) { |
| // Don't take on any more requests, we can't execute any, init failed. |
| if (init_failed_) { |
| callback.Run(FAIL); |
| return; |
| } |
| |
| if (pending_init_operations_) { |
| pending_requests_queue_.push_back( |
| PendingRequest(request, app_id, callback)); |
| } else { |
| rpc_handler_->SendReportRequest( |
| make_scoped_ptr(new copresence::ReportRequest(request)), |
| app_id, |
| callback); |
| } |
| } |
| |
| // Private methods |
| |
| void CopresenceClient::CompleteInitialization() { |
| if (pending_init_operations_) |
| return; |
| |
| if (!init_failed_) |
| rpc_handler_->ConnectToWhispernet(); |
| |
| for (std::vector<PendingRequest>::iterator request = |
| pending_requests_queue_.begin(); |
| request != pending_requests_queue_.end(); |
| ++request) { |
| if (init_failed_) { |
| request->callback.Run(FAIL); |
| } else { |
| rpc_handler_->SendReportRequest( |
| make_scoped_ptr(new copresence::ReportRequest(request->report)), |
| request->app_id, |
| request->callback); |
| } |
| } |
| pending_requests_queue_.clear(); |
| } |
| |
| void CopresenceClient::InitStepComplete(const std::string& step, bool success) { |
| if (!success) { |
| LOG(ERROR) << step << " failed!"; |
| init_failed_ = true; |
| } |
| |
| DVLOG(3) << "Init step: " << step << " complete."; |
| pending_init_operations_--; |
| CompleteInitialization(); |
| } |
| |
| } // namespace copresence |