Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/copresence/public/copresence_client.h" | 5 #include "components/copresence/public/copresence_client.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "components/copresence/public/copresence_client_delegate.h" | 8 #include "components/copresence/public/copresence_client_delegate.h" |
| 9 #include "components/copresence/public/whispernet_client.h" | 9 #include "components/copresence/public/whispernet_client.h" |
| 10 #include "components/copresence/rpc/rpc_handler.h" | 10 #include "components/copresence/rpc/rpc_handler.h" |
| 11 | 11 |
| 12 namespace copresence { | 12 namespace copresence { |
| 13 | 13 |
| 14 PendingRequest::PendingRequest(const copresence::ReportRequest& report, | 14 PendingRequest::PendingRequest(const copresence::ReportRequest& report, |
| 15 const std::string app_id, | 15 const std::string app_id, |
| 16 const StatusCallback& callback) | 16 const StatusCallback& callback) |
| 17 : report(report), app_id(app_id), callback(callback) { | 17 : report(report), app_id(app_id), callback(callback) { |
| 18 } | 18 } |
| 19 | 19 |
| 20 PendingRequest::~PendingRequest() { | 20 PendingRequest::~PendingRequest() { |
| 21 } | 21 } |
| 22 | 22 |
| 23 // Public methods | 23 // Public methods |
| 24 | 24 |
| 25 CopresenceClient::CopresenceClient(CopresenceClientDelegate* delegate) | 25 CopresenceClient::~CopresenceClient() {} |
| 26 : delegate_(delegate), init_failed_(false), pending_init_operations_(0) { | |
| 27 DVLOG(3) << "Initializing client."; | |
| 28 pending_init_operations_++; | |
| 29 rpc_handler_.reset( | |
| 30 new RpcHandler(delegate, | |
| 31 base::Bind(&CopresenceClient::InitStepComplete, | |
| 32 AsWeakPtr(), | |
| 33 "Copresence device registration"))); | |
| 34 | |
| 35 pending_init_operations_++; | |
| 36 delegate_->GetWhispernetClient()->Initialize( | |
| 37 base::Bind(&CopresenceClient::InitStepComplete, | |
| 38 AsWeakPtr(), | |
| 39 "Whispernet proxy initialization")); | |
| 40 } | |
| 41 | |
| 42 CopresenceClient::~CopresenceClient() { | |
| 43 } | |
| 44 | 26 |
| 45 void CopresenceClient::Shutdown() { | 27 void CopresenceClient::Shutdown() { |
| 46 DVLOG(3) << "Shutting down client."; | 28 DVLOG(3) << "Shutting down client."; |
| 47 delegate_->GetWhispernetClient()->Shutdown(); | 29 if (delegate_ && delegate_->GetWhispernetClient()) |
|
not at google - send to devlin
2014/08/07 23:21:12
when would there not be a delegate? could you pass
Charlie
2014/08/07 23:52:25
I guess we only have the use case where there's no
rkc
2014/08/08 00:05:35
We should rebase this code and have it tracked of
Charlie
2014/08/08 18:25:50
Done.
| |
| 48 rpc_handler_->DisconnectFromWhispernet(); | 30 delegate_->GetWhispernetClient()->Shutdown(); |
| 31 if (rpc_handler_.get()) | |
|
not at google - send to devlin
2014/08/07 23:21:13
likewise.
Charlie
2014/08/07 23:52:25
MockCopresenceClient won't have an rpc_handler_.
not at google - send to devlin
2014/08/07 23:54:24
this inheritance structure is confusing. inheritan
rkc
2014/08/08 00:37:00
Deriving a Mock class from a concrete class is a v
not at google - send to devlin
2014/08/08 13:48:35
git gs "Mock.*: public.*" | wc -l = 1115
what doe
Charlie
2014/08/08 18:25:50
IIUC the change to the production code that we're
not at google - send to devlin
2014/08/08 19:42:04
Thanks.
I think you're right that CopresenceClien
Charlie
2014/08/13 19:13:15
Done.
| |
| 32 rpc_handler_->DisconnectFromWhispernet(); | |
| 49 } | 33 } |
| 50 | 34 |
| 51 // Returns false if any operations were malformed. | 35 // Returns false if any operations were malformed. |
| 52 void CopresenceClient::ExecuteReportRequest(copresence::ReportRequest request, | 36 void CopresenceClient::ExecuteReportRequest(copresence::ReportRequest request, |
| 53 const std::string& app_id, | 37 const std::string& app_id, |
| 54 const StatusCallback& callback) { | 38 const StatusCallback& callback) { |
| 55 // Don't take on any more requests, we can't execute any, init failed. | 39 // Don't take on any more requests. We can't execute them since init failed. |
| 56 if (init_failed_) { | 40 if (init_failed_) { |
| 57 callback.Run(FAIL); | 41 callback.Run(FAIL); |
| 58 return; | 42 return; |
| 59 } | 43 } |
| 60 | 44 |
| 45 DCHECK(rpc_handler_.get()); | |
| 61 if (pending_init_operations_) { | 46 if (pending_init_operations_) { |
| 62 pending_requests_queue_.push_back( | 47 pending_requests_queue_.push_back( |
| 63 PendingRequest(request, app_id, callback)); | 48 PendingRequest(request, app_id, callback)); |
| 64 } else { | 49 } else { |
| 65 rpc_handler_->SendReportRequest( | 50 rpc_handler_->SendReportRequest( |
| 66 make_scoped_ptr(new copresence::ReportRequest(request)), | 51 make_scoped_ptr(new copresence::ReportRequest(request)), |
| 67 app_id, | 52 app_id, |
| 68 callback); | 53 callback); |
| 69 } | 54 } |
| 70 } | 55 } |
| 71 | 56 |
| 57 // static | |
| 58 scoped_ptr<CopresenceClient> CopresenceClient::Create( | |
| 59 CopresenceClientDelegate* delegate) { | |
| 60 DVLOG(3) << "Initializing client."; | |
| 61 scoped_ptr<CopresenceClient> client(new CopresenceClient); | |
| 62 DCHECK(delegate); | |
| 63 client->delegate_ = delegate; | |
| 64 | |
| 65 client->pending_init_operations_++; | |
|
not at google - send to devlin
2014/08/07 23:21:12
should be ++x not x++
Charlie
2014/08/07 23:52:25
Either is allowed for scalar types. With the -> sy
rkc
2014/08/08 00:37:00
prefixed is still better for consistency.
| |
| 66 client->rpc_handler_.reset( | |
| 67 new RpcHandler(delegate, | |
| 68 base::Bind(&CopresenceClient::InitStepComplete, | |
| 69 client->AsWeakPtr(), | |
| 70 "Copresence device registration"))); | |
| 71 | |
| 72 client->pending_init_operations_++; | |
| 73 DCHECK(delegate->GetWhispernetClient()); | |
| 74 delegate->GetWhispernetClient()->Initialize( | |
| 75 base::Bind(&CopresenceClient::InitStepComplete, | |
| 76 client->AsWeakPtr(), | |
| 77 "Whispernet proxy initialization")); | |
| 78 | |
| 79 return client.Pass(); | |
| 80 } | |
| 81 | |
| 82 // Protected methods | |
| 83 | |
| 84 CopresenceClient::CopresenceClient() | |
| 85 : delegate_(NULL), | |
| 86 init_failed_(false), | |
| 87 pending_init_operations_(0) {} | |
| 88 | |
| 72 // Private methods | 89 // Private methods |
| 73 | 90 |
| 74 void CopresenceClient::CompleteInitialization() { | 91 void CopresenceClient::CompleteInitialization() { |
| 75 if (pending_init_operations_) | 92 if (pending_init_operations_) |
| 76 return; | 93 return; |
| 77 | 94 |
| 95 DCHECK(delegate_); | |
| 96 DCHECK(rpc_handler_.get()); | |
| 78 if (!init_failed_) | 97 if (!init_failed_) |
| 79 rpc_handler_->ConnectToWhispernet(delegate_->GetWhispernetClient()); | 98 rpc_handler_->ConnectToWhispernet(delegate_->GetWhispernetClient()); |
| 80 | 99 |
| 81 for (std::vector<PendingRequest>::iterator request = | 100 for (std::vector<PendingRequest>::iterator request = |
| 82 pending_requests_queue_.begin(); | 101 pending_requests_queue_.begin(); |
| 83 request != pending_requests_queue_.end(); | 102 request != pending_requests_queue_.end(); |
| 84 ++request) { | 103 ++request) { |
| 85 if (init_failed_) { | 104 if (init_failed_) { |
| 86 request->callback.Run(FAIL); | 105 request->callback.Run(FAIL); |
| 87 } else { | 106 } else { |
| (...skipping 11 matching lines...) Expand all Loading... | |
| 99 LOG(ERROR) << step << " failed!"; | 118 LOG(ERROR) << step << " failed!"; |
| 100 init_failed_ = true; | 119 init_failed_ = true; |
| 101 } | 120 } |
| 102 | 121 |
| 103 DVLOG(3) << "Init step: " << step << " complete."; | 122 DVLOG(3) << "Init step: " << step << " complete."; |
| 104 pending_init_operations_--; | 123 pending_init_operations_--; |
| 105 CompleteInitialization(); | 124 CompleteInitialization(); |
| 106 } | 125 } |
| 107 | 126 |
| 108 } // namespace copresence | 127 } // namespace copresence |
| OLD | NEW |