Index: webkit/media/crypto/proxy_decryptor.h |
diff --git a/webkit/media/crypto/proxy_decryptor.h b/webkit/media/crypto/proxy_decryptor.h |
index 61360ebaceb5f33235cdef782ae9d719ba2bf6a7..ecccbf28673f99a3cdeaca8972cca16c36dfd467 100644 |
--- a/webkit/media/crypto/proxy_decryptor.h |
+++ b/webkit/media/crypto/proxy_decryptor.h |
@@ -6,11 +6,16 @@ |
#define WEBKIT_MEDIA_CRYPTO_PROXY_DECRYPTOR_H_ |
#include <string> |
+#include <vector> |
#include "base/memory/scoped_ptr.h" |
#include "base/synchronization/lock.h" |
#include "media/base/decryptor.h" |
+namespace base { |
+class MessageLoopProxy; |
+} |
+ |
namespace media { |
class DecryptorClient; |
} |
@@ -53,6 +58,21 @@ class ProxyDecryptor : public media::Decryptor { |
const std::string& key_system); |
scoped_ptr<media::Decryptor> CreateDecryptor(const std::string& key_system); |
+ // Helper function that makes sure decryptor_->Decrypt() runs on the |
+ // |message_loop|. |
+ void DecryptOnMessageLoop( |
+ const scoped_refptr<base::MessageLoopProxy>& message_loop_proxy, |
+ const scoped_refptr<media::DecoderBuffer>& encrypted, |
+ const media::Decryptor::DecryptCB& decrypt_cb); |
+ |
+ // Callback used to pass into decryptor_->Decrypt(). |
+ void OnBufferDecrypted( |
+ const scoped_refptr<base::MessageLoopProxy>& message_loop_proxy, |
+ const scoped_refptr<media::DecoderBuffer>& encrypted, |
+ const media::Decryptor::DecryptCB& decrypt_cb, |
+ media::Decryptor::DecryptStatus status, |
+ const scoped_refptr<media::DecoderBuffer>& decrypted); |
+ |
media::DecryptorClient* client_; |
// Needed to create the PpapiDecryptor. |
@@ -65,9 +85,13 @@ class ProxyDecryptor : public media::Decryptor { |
// when this rule is obeyed. This lock is solely to prevent the race condition |
// between setting the |decryptor_| in GenerateKeyRequest() and using it in |
// Decrypt(). |
- base::Lock lock_; |
+ base::Lock decryptor_lock_; |
scoped_ptr<media::Decryptor> decryptor_; // Protected by the |lock_|. |
+ // Protects the |pending_decrypt_closures_|. |
+ base::Lock pending_decrypt_closures_lock_; |
scherkus (not reviewing)
2012/07/26 02:06:38
do you need separate locks?
xhwang
2012/07/26 22:16:04
I was trying to minimize the time of lock blocking
scherkus (not reviewing)
2012/07/28 23:07:19
Yes.
There are three situations where a lock is r
|
+ std::vector<base::Closure> pending_decrypt_closures_; |
+ |
DISALLOW_COPY_AND_ASSIGN(ProxyDecryptor); |
}; |