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 |