OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "net/quic/crypto/aes_128_gcm_12_decrypter.h" | 5 #include "net/quic/crypto/aead_base_decrypter.h" |
6 | 6 |
7 #include <openssl/err.h> | 7 #include <openssl/err.h> |
8 #include <openssl/evp.h> | 8 #include <openssl/evp.h> |
9 | 9 |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
11 | 11 |
12 using base::StringPiece; | 12 using base::StringPiece; |
13 | 13 |
14 namespace net { | 14 namespace net { |
15 | 15 |
16 namespace { | 16 namespace { |
17 | 17 |
18 const size_t kNoncePrefixSize = 4; | 18 // Clear OpenSSL error stack. |
19 const size_t kAESNonceSize = 12; | 19 void ClearOpenSslErrors() { |
| 20 #ifdef NDEBUG |
| 21 while (ERR_get_error()) {} |
| 22 #else |
| 23 while (unsigned long error = ERR_get_error()) { |
| 24 char buf[120]; |
| 25 ERR_error_string_n(error, buf, arraysize(buf)); |
| 26 DLOG(ERROR) << "OpenSSL error: " << buf; |
| 27 } |
| 28 #endif |
| 29 } |
20 | 30 |
21 } // namespace | 31 } // namespace |
22 | 32 |
23 Aes128Gcm12Decrypter::Aes128Gcm12Decrypter() {} | 33 AeadBaseDecrypter::AeadBaseDecrypter(const EVP_AEAD* aead_alg, |
| 34 size_t key_size, |
| 35 size_t auth_tag_size, |
| 36 size_t nonce_prefix_size) |
| 37 : aead_alg_(aead_alg), |
| 38 key_size_(key_size), |
| 39 auth_tag_size_(auth_tag_size), |
| 40 nonce_prefix_size_(nonce_prefix_size) { |
| 41 DCHECK_LE(key_size_, sizeof(key_)); |
| 42 DCHECK_LE(nonce_prefix_size_, sizeof(nonce_prefix_)); |
| 43 } |
24 | 44 |
25 Aes128Gcm12Decrypter::~Aes128Gcm12Decrypter() {} | 45 AeadBaseDecrypter::~AeadBaseDecrypter() {} |
26 | 46 |
27 // static | 47 bool AeadBaseDecrypter::SetKey(StringPiece key) { |
28 bool Aes128Gcm12Decrypter::IsSupported() { return true; } | 48 DCHECK_EQ(key.size(), key_size_); |
29 | 49 if (key.size() != key_size_) { |
30 bool Aes128Gcm12Decrypter::SetKey(StringPiece key) { | |
31 DCHECK_EQ(key.size(), sizeof(key_)); | |
32 if (key.size() != sizeof(key_)) { | |
33 return false; | 50 return false; |
34 } | 51 } |
35 memcpy(key_, key.data(), key.size()); | 52 memcpy(key_, key.data(), key.size()); |
36 | 53 |
37 EVP_AEAD_CTX_cleanup(ctx_.get()); | 54 EVP_AEAD_CTX_cleanup(ctx_.get()); |
38 if (!EVP_AEAD_CTX_init(ctx_.get(), EVP_aead_aes_128_gcm(), key_, | 55 if (!EVP_AEAD_CTX_init(ctx_.get(), aead_alg_, key_, key_size_, |
39 sizeof(key_), kAuthTagSize, NULL)) { | 56 auth_tag_size_, NULL)) { |
40 // Clear OpenSSL error stack. | 57 ClearOpenSslErrors(); |
41 while (ERR_get_error()) {} | |
42 return false; | 58 return false; |
43 } | 59 } |
44 | 60 |
45 return true; | 61 return true; |
46 } | 62 } |
47 | 63 |
48 bool Aes128Gcm12Decrypter::SetNoncePrefix(StringPiece nonce_prefix) { | 64 bool AeadBaseDecrypter::SetNoncePrefix(StringPiece nonce_prefix) { |
49 DCHECK_EQ(nonce_prefix.size(), kNoncePrefixSize); | 65 DCHECK_EQ(nonce_prefix.size(), nonce_prefix_size_); |
50 if (nonce_prefix.size() != kNoncePrefixSize) { | 66 if (nonce_prefix.size() != nonce_prefix_size_) { |
51 return false; | 67 return false; |
52 } | 68 } |
53 COMPILE_ASSERT(sizeof(nonce_prefix_) == kNoncePrefixSize, bad_nonce_length); | |
54 memcpy(nonce_prefix_, nonce_prefix.data(), nonce_prefix.size()); | 69 memcpy(nonce_prefix_, nonce_prefix.data(), nonce_prefix.size()); |
55 return true; | 70 return true; |
56 } | 71 } |
57 | 72 |
58 bool Aes128Gcm12Decrypter::Decrypt(StringPiece nonce, | 73 bool AeadBaseDecrypter::Decrypt(StringPiece nonce, |
59 StringPiece associated_data, | 74 StringPiece associated_data, |
60 StringPiece ciphertext, | 75 StringPiece ciphertext, |
61 uint8* output, | 76 uint8* output, |
62 size_t* output_length) { | 77 size_t* output_length) { |
63 if (ciphertext.length() < kAuthTagSize || | 78 if (ciphertext.length() < auth_tag_size_ || |
64 nonce.size() != kNoncePrefixSize + sizeof(QuicPacketSequenceNumber)) { | 79 nonce.size() != nonce_prefix_size_ + sizeof(QuicPacketSequenceNumber)) { |
65 return false; | 80 return false; |
66 } | 81 } |
67 | 82 |
68 ssize_t len = EVP_AEAD_CTX_open( | 83 ssize_t len = EVP_AEAD_CTX_open( |
69 ctx_.get(), output, ciphertext.size(), | 84 ctx_.get(), output, ciphertext.size(), |
70 reinterpret_cast<const uint8_t*>(nonce.data()), nonce.size(), | 85 reinterpret_cast<const uint8_t*>(nonce.data()), nonce.size(), |
71 reinterpret_cast<const uint8_t*>(ciphertext.data()), ciphertext.size(), | 86 reinterpret_cast<const uint8_t*>(ciphertext.data()), ciphertext.size(), |
72 reinterpret_cast<const uint8_t*>(associated_data.data()), | 87 reinterpret_cast<const uint8_t*>(associated_data.data()), |
73 associated_data.size()); | 88 associated_data.size()); |
74 | 89 |
75 if (len < 0) { | 90 if (len < 0) { |
76 // Clear OpenSSL error stack. | 91 ClearOpenSslErrors(); |
77 while (ERR_get_error()) {} | |
78 return false; | 92 return false; |
79 } | 93 } |
80 | 94 |
81 *output_length = len; | 95 *output_length = len; |
82 return true; | 96 return true; |
83 } | 97 } |
84 | 98 |
85 QuicData* Aes128Gcm12Decrypter::DecryptPacket( | 99 QuicData* AeadBaseDecrypter::DecryptPacket( |
86 QuicPacketSequenceNumber sequence_number, | 100 QuicPacketSequenceNumber sequence_number, |
87 StringPiece associated_data, | 101 StringPiece associated_data, |
88 StringPiece ciphertext) { | 102 StringPiece ciphertext) { |
89 if (ciphertext.length() < kAuthTagSize) { | 103 if (ciphertext.length() < auth_tag_size_) { |
90 return NULL; | 104 return NULL; |
91 } | 105 } |
92 size_t plaintext_size = ciphertext.length(); | 106 size_t plaintext_size = ciphertext.length(); |
93 scoped_ptr<char[]> plaintext(new char[plaintext_size]); | 107 scoped_ptr<char[]> plaintext(new char[plaintext_size]); |
94 | 108 |
95 uint8 nonce[kNoncePrefixSize + sizeof(sequence_number)]; | 109 uint8 nonce[sizeof(nonce_prefix_) + sizeof(sequence_number)]; |
96 COMPILE_ASSERT(sizeof(nonce) == kAESNonceSize, bad_sequence_number_size); | 110 const size_t nonce_size = nonce_prefix_size_ + sizeof(sequence_number); |
97 memcpy(nonce, nonce_prefix_, kNoncePrefixSize); | 111 DCHECK_LE(nonce_size, sizeof(nonce)); |
98 memcpy(nonce + kNoncePrefixSize, &sequence_number, sizeof(sequence_number)); | 112 memcpy(nonce, nonce_prefix_, nonce_prefix_size_); |
99 if (!Decrypt(StringPiece(reinterpret_cast<char*>(nonce), sizeof(nonce)), | 113 memcpy(nonce + nonce_prefix_size_, &sequence_number, sizeof(sequence_number)); |
| 114 if (!Decrypt(StringPiece(reinterpret_cast<char*>(nonce), nonce_size), |
100 associated_data, ciphertext, | 115 associated_data, ciphertext, |
101 reinterpret_cast<uint8*>(plaintext.get()), | 116 reinterpret_cast<uint8*>(plaintext.get()), |
102 &plaintext_size)) { | 117 &plaintext_size)) { |
103 return NULL; | 118 return NULL; |
104 } | 119 } |
105 return new QuicData(plaintext.release(), plaintext_size, true); | 120 return new QuicData(plaintext.release(), plaintext_size, true); |
106 } | 121 } |
107 | 122 |
108 StringPiece Aes128Gcm12Decrypter::GetKey() const { | 123 StringPiece AeadBaseDecrypter::GetKey() const { |
109 return StringPiece(reinterpret_cast<const char*>(key_), sizeof(key_)); | 124 return StringPiece(reinterpret_cast<const char*>(key_), key_size_); |
110 } | 125 } |
111 | 126 |
112 StringPiece Aes128Gcm12Decrypter::GetNoncePrefix() const { | 127 StringPiece AeadBaseDecrypter::GetNoncePrefix() const { |
| 128 if (nonce_prefix_size_ == 0) { |
| 129 return StringPiece(); |
| 130 } |
113 return StringPiece(reinterpret_cast<const char*>(nonce_prefix_), | 131 return StringPiece(reinterpret_cast<const char*>(nonce_prefix_), |
114 kNoncePrefixSize); | 132 nonce_prefix_size_); |
115 } | 133 } |
116 | 134 |
117 } // namespace net | 135 } // namespace net |
OLD | NEW |