Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(393)

Unified Diff: content/renderer/media/peer_connection_identity_store.cc

Issue 1373023002: RTCCertificate, RTCPeerConnection.generateCertificate (WebRTC JavaScript) added. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Make trybots compile (WebRTCCertificate not including wtf/Noncopyable) Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/renderer/media/peer_connection_identity_store.cc
diff --git a/content/renderer/media/peer_connection_identity_store.cc b/content/renderer/media/peer_connection_identity_store.cc
index 444006ac656acb72affc09b549d9b315174c572b..83f4333f06a683c6d92b9136fc75720a2dcfdb53 100644
--- a/content/renderer/media/peer_connection_identity_store.cc
+++ b/content/renderer/media/peer_connection_identity_store.cc
@@ -5,12 +5,15 @@
#include "content/renderer/media/peer_connection_identity_store.h"
#include "base/bind.h"
+#include "base/macros.h"
#include "base/thread_task_runner_handle.h"
#include "content/renderer/media/webrtc_identity_service.h"
#include "content/renderer/render_thread_impl.h"
namespace content {
namespace {
+const char kIdentityName[] = "WebRTC";
Ryan Sleevi 2015/10/10 04:04:48 style nit: newline before this.
hbos_chromium 2015/10/14 13:00:49 Done.
+
// Bridges identity requests between the main render thread and libjingle's
// signaling thread.
class RequestHandler : public base::RefCountedThreadSafe<RequestHandler> {
@@ -25,7 +28,7 @@ class RequestHandler : public base::RefCountedThreadSafe<RequestHandler> {
RenderThreadImpl::current()
->get_webrtc_identity_service()
->RequestIdentity(
- url, first_party_for_cookies, "WebRTC", "WebRTC",
+ url, first_party_for_cookies, kIdentityName, kIdentityName,
base::Bind(&RequestHandler::OnIdentityReady, this),
base::Bind(&RequestHandler::OnRequestFailed, this));
DCHECK_NE(request_id, 0);
@@ -67,6 +70,26 @@ class RequestHandler : public base::RefCountedThreadSafe<RequestHandler> {
const scoped_refptr<base::SingleThreadTaskRunner> signaling_thread_;
scoped_refptr<webrtc::DtlsIdentityRequestObserver> observer_;
};
+
+// PeerConnectionIdentityStore::RequestIdentity helper class.
+// Used to invokes |observer|->OnSuccess in a PostTask.
Guido Urdaneta 2015/10/08 11:13:03 s/invokes/invoke
hbos_chromium 2015/10/14 13:00:49 Done.
+class ObserverOnSuccessCaller
+ : public base::RefCountedThreadSafe<ObserverOnSuccessCaller> {
Guido Urdaneta 2015/10/08 11:13:03 Does it have to be refcounted?
hbos_chromium 2015/10/14 13:00:49 Yes, TaskRunner code uses ref counting.
+ public:
+ ObserverOnSuccessCaller() {}
+
+ void CallObserverOnSuccess(
+ rtc::scoped_refptr<webrtc::DtlsIdentityRequestObserver> observer,
Ryan Sleevi 2015/10/10 04:04:48 Why are you passing a ref-counted object by-value?
hbos_chromium 2015/10/14 13:00:49 Done.
+ rtc::SSLIdentity* identity) {
Ryan Sleevi 2015/10/10 04:04:48 if rtc::scoped_ptr<> supports .Pass() (as shown by
hbos_chromium 2015/10/14 13:00:49 This is problematic due to PostTask/base::Bind (se
+ observer->OnSuccess(rtc::scoped_ptr<rtc::SSLIdentity>(identity).Pass());
+ }
+
+ private:
+ friend class base::RefCountedThreadSafe<ObserverOnSuccessCaller>;
+ ~ObserverOnSuccessCaller() {}
+
+ DISALLOW_COPY_AND_ASSIGN(ObserverOnSuccessCaller);
+};
} // namespace
PeerConnectionIdentityStore::PeerConnectionIdentityStore(
@@ -88,14 +111,41 @@ void PeerConnectionIdentityStore::RequestIdentity(
const rtc::scoped_refptr<webrtc::DtlsIdentityRequestObserver>& observer) {
DCHECK(signaling_thread_.CalledOnValidThread());
DCHECK(observer);
- // This store only supports RSA.
- DCHECK_EQ(key_type, rtc::KT_RSA);
-
- scoped_refptr<RequestHandler> handler(new RequestHandler(observer));
- main_thread_->PostTask(
- FROM_HERE,
- base::Bind(&RequestHandler::RequestIdentityOnUIThread, handler, url_,
- first_party_for_cookies_));
+
+ // TODO(hbos): Use modulus length parameter when KeyType is parameterized.
+ if (key_type == rtc::KT_RSA) {
+ // Use Chromium identity generation code for RSA.
Ryan Sleevi 2015/10/10 04:04:48 Why split between these two?
hbos_chromium 2015/10/14 13:00:49 Ideally we would only use WebRTC code for certific
+ scoped_refptr<RequestHandler> handler(new RequestHandler(observer));
+ main_thread_->PostTask(
+ FROM_HERE,
+ base::Bind(&RequestHandler::RequestIdentityOnUIThread, handler, url_,
+ first_party_for_cookies_));
+ } else {
+ // Use WebRTC identity generation code for non-RSA.
+ rtc::SSLIdentity* identity = rtc::SSLIdentity::Generate(kIdentityName,
+ key_type);
+
+ scoped_refptr<base::SingleThreadTaskRunner> signaling_thread =
+ base::ThreadTaskRunnerHandle::Get();
+
+ // Invoke |observer| callbacks asynchronously. The callbacks of
+ // DtlsIdentityStoreInterface implementations have to be async.
+ if (identity) {
+ // Async call to observer->OnSuccess.
+ // Helper class necessary because OnSuccess takes a scoped_ptr argument
Guido Urdaneta 2015/10/08 11:13:03 You can probably use base::Passed() instead of the
hbos_chromium 2015/10/14 13:00:49 Done.
+ // and scoped_ptrs can't be passed with = operator, have to use .Pass().
+ scoped_refptr<ObserverOnSuccessCaller> observer_caller(
+ new ObserverOnSuccessCaller());
+ signaling_thread->PostTask(FROM_HERE,
+ base::Bind(&ObserverOnSuccessCaller::CallObserverOnSuccess,
+ observer_caller, observer, identity));
+ } else {
+ // Async call to observer->OnFailure.
+ signaling_thread->PostTask(FROM_HERE,
+ base::Bind(&webrtc::DtlsIdentityRequestObserver::OnFailure,
+ observer, 0));
+ }
+ }
}
} // namespace content

Powered by Google App Engine
This is Rietveld 408576698