cache -> key_cache for clarity

pull/72/head
Frank Denis 3 years ago
parent a5fef297f5
commit 8b17418372

@ -70,8 +70,12 @@ pub fn decrypt(
nonce[..DNSCRYPT_QUERY_NONCE_SIZE].copy_from_slice(client_nonce); nonce[..DNSCRYPT_QUERY_NONCE_SIZE].copy_from_slice(client_nonce);
let cached_shared_key = { let cached_shared_key = {
let mut cache = dnscrypt_encryption_params.cache.as_ref().unwrap().lock(); let mut key_cache = dnscrypt_encryption_params
cache .key_cache
.as_ref()
.unwrap()
.lock();
key_cache
.get(client_pk) .get(client_pk)
.map(|cached_shared_key| (*cached_shared_key).clone()) .map(|cached_shared_key| (*cached_shared_key).clone())
}; };
@ -84,7 +88,7 @@ pub fn decrypt(
let mut client_pk_ = [0u8; DNSCRYPT_QUERY_PK_SIZE]; let mut client_pk_ = [0u8; DNSCRYPT_QUERY_PK_SIZE];
client_pk_.copy_from_slice(client_pk); client_pk_.copy_from_slice(client_pk);
dnscrypt_encryption_params dnscrypt_encryption_params
.cache .key_cache
.as_ref() .as_ref()
.unwrap() .unwrap()
.lock() .lock()

@ -108,13 +108,13 @@ pub struct DNSCryptEncryptionParams {
resolver_kp: CryptKeyPair, resolver_kp: CryptKeyPair,
#[serde(skip)] #[serde(skip)]
#[derivative(Debug = "ignore")] #[derivative(Debug = "ignore")]
pub cache: Option<Arc<Mutex<ClockProCache<[u8; DNSCRYPT_QUERY_PK_SIZE], SharedKey>>>>, pub key_cache: Option<Arc<Mutex<ClockProCache<[u8; DNSCRYPT_QUERY_PK_SIZE], SharedKey>>>>,
} }
impl DNSCryptEncryptionParams { impl DNSCryptEncryptionParams {
pub fn new( pub fn new(
provider_kp: &SignKeyPair, provider_kp: &SignKeyPair,
cache_capacity: usize, key_cache_capacity: usize,
previous_params: Option<Arc<DNSCryptEncryptionParams>>, previous_params: Option<Arc<DNSCryptEncryptionParams>>,
) -> Vec<Self> { ) -> Vec<Self> {
let now = now(); let now = now();
@ -140,11 +140,11 @@ impl DNSCryptEncryptionParams {
} }
if now >= ts_start { if now >= ts_start {
let dnscrypt_cert = DNSCryptCert::new(provider_kp, &resolver_kp, ts_start); let dnscrypt_cert = DNSCryptCert::new(provider_kp, &resolver_kp, ts_start);
let cache = ClockProCache::new(cache_capacity).unwrap(); let cache = ClockProCache::new(key_cache_capacity).unwrap();
active_params.push(DNSCryptEncryptionParams { active_params.push(DNSCryptEncryptionParams {
dnscrypt_cert, dnscrypt_cert,
resolver_kp, resolver_kp,
cache: Some(Arc::new(Mutex::new(cache))), key_cache: Some(Arc::new(Mutex::new(cache))),
}); });
} }
ts_start += DNSCRYPT_CERTS_RENEWAL; ts_start += DNSCRYPT_CERTS_RENEWAL;
@ -154,11 +154,11 @@ impl DNSCryptEncryptionParams {
let ts_start = now - (now % DNSCRYPT_CERTS_RENEWAL); let ts_start = now - (now % DNSCRYPT_CERTS_RENEWAL);
let resolver_kp = CryptKeyPair::from_seed(seed); let resolver_kp = CryptKeyPair::from_seed(seed);
let dnscrypt_cert = DNSCryptCert::new(provider_kp, &resolver_kp, ts_start); let dnscrypt_cert = DNSCryptCert::new(provider_kp, &resolver_kp, ts_start);
let cache = ClockProCache::new(cache_capacity).unwrap(); let cache = ClockProCache::new(key_cache_capacity).unwrap();
active_params.push(DNSCryptEncryptionParams { active_params.push(DNSCryptEncryptionParams {
dnscrypt_cert, dnscrypt_cert,
resolver_kp, resolver_kp,
cache: Some(Arc::new(Mutex::new(cache))), key_cache: Some(Arc::new(Mutex::new(cache))),
}); });
} }
active_params active_params
@ -166,7 +166,7 @@ impl DNSCryptEncryptionParams {
pub fn add_key_cache(&mut self, cache_capacity: usize) { pub fn add_key_cache(&mut self, cache_capacity: usize) {
let cache = ClockProCache::new(cache_capacity).unwrap(); let cache = ClockProCache::new(cache_capacity).unwrap();
self.cache = Some(Arc::new(Mutex::new(cache))); self.key_cache = Some(Arc::new(Mutex::new(cache)));
} }
pub fn client_magic(&self) -> &[u8] { pub fn client_magic(&self) -> &[u8] {

Loading…
Cancel
Save