Skip to content

Commit

Permalink
rename to_arc to clone_arc
Browse files Browse the repository at this point in the history
to_arc converts a `*const C` into an `Option<Arc<T>>`. It had a lot of
verbiage to explain what it was doing with reference counts. I think the
conceptual model becomes a lot simpler if we rename the function to
reflect what it is really doing: cloning the arc.
  • Loading branch information
jsha committed Nov 16, 2023
1 parent 0b35e62 commit d9e378d
Show file tree
Hide file tree
Showing 4 changed files with 25 additions and 40 deletions.
6 changes: 3 additions & 3 deletions src/acceptor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,8 @@ use crate::rslice::{rustls_slice_bytes, rustls_str};
use crate::server::rustls_server_config;
use crate::{
ffi_panic_boundary, free_box, rustls_result, set_boxed_mut_ptr, to_box, to_boxed_mut_ptr,
try_arc_from_ptr, try_callback, try_mut_from_ptr, try_ref_from_ptr, try_take, Castable,
OwnershipBox,
try_arc_from_ptr, try_callback, try_clone_arc, try_mut_from_ptr, try_ref_from_ptr, try_take,
Castable, OwnershipBox,
};
use rustls_result::NullParameter;

Expand Down Expand Up @@ -400,7 +400,7 @@ impl rustls_accepted {
ffi_panic_boundary! {
let accepted: &mut Option<Accepted> = try_mut_from_ptr!(accepted);
let accepted = try_take!(accepted);
let config: Arc<ServerConfig> = try_arc_from_ptr!(config);
let config: Arc<ServerConfig> = try_clone_arc!(config);
match accepted.into_connection(config) {
Ok(built) => {
let wrapped = crate::connection::Connection::from_server(built);
Expand Down
8 changes: 4 additions & 4 deletions src/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@ use crate::rslice::NulByte;
use crate::rslice::{rustls_slice_bytes, rustls_slice_slice_bytes, rustls_str};
use crate::{
ffi_panic_boundary, free_arc, free_box, set_boxed_mut_ptr, to_arc_const_ptr, to_boxed_mut_ptr,
try_arc_from_ptr, try_box_from_ptr, try_mut_from_ptr, try_ref_from_ptr, try_slice,
userdata_get, Castable, OwnershipArc, OwnershipBox,
try_box_from_ptr, try_clone_arc, try_mut_from_ptr, try_ref_from_ptr, try_slice, userdata_get,
Castable, OwnershipArc, OwnershipBox,
};

/// A client config being constructed. A builder can be modified by,
Expand Down Expand Up @@ -442,7 +442,7 @@ impl rustls_client_config_builder {
let keys_ptrs: &[*const rustls_certified_key] = try_slice!(certified_keys, certified_keys_len);
let mut keys: Vec<Arc<CertifiedKey>> = Vec::new();
for &key_ptr in keys_ptrs {
let certified_key: Arc<CertifiedKey> = try_arc_from_ptr!(key_ptr);
let certified_key: Arc<CertifiedKey> = try_clone_arc!(key_ptr);
keys.push(certified_key);
}
config.cert_resolver = Some(Arc::new(ResolvesClientCertFromChoices { keys }));
Expand Down Expand Up @@ -545,7 +545,7 @@ impl rustls_client_config {
}
CStr::from_ptr(server_name)
};
let config: Arc<ClientConfig> = try_arc_from_ptr!(config);
let config: Arc<ClientConfig> = try_clone_arc!(config);
let server_name: &str = match server_name.to_str() {
Ok(s) => s,
Err(std::str::Utf8Error { .. }) => return rustls_result::InvalidDnsNameError,
Expand Down
39 changes: 12 additions & 27 deletions src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -368,19 +368,16 @@ where
Arc::into_raw(Arc::new(src)) as *const _
}

/// Convert a const pointer to a [`Castable`] to an optional `Arc` over the underlying rust type.
/// Given a const pointer to a [`Castable`] representing an `Arc`, clone the `Arc` and return
/// the corresponding Rust type.
///
/// Sometimes we create an `Arc`, then call `into_raw` and return the resulting raw pointer
/// to C, e.g. using [`to_arc_const_ptr`]. C can then call a rustls-ffi function multiple times
/// using that same raw pointer. On each call, we need to reconstruct the Arc, but once we reconstruct
/// the Arc, its reference count will be decremented on drop. We need to reference count to stay at 1,
/// because the C code is holding a copy.
/// The caller still owns its copy of the `Arc`. In other words, the reference count of the
/// `Arc` will be incremented by 1 by the end of this function.
///
/// This function turns the raw pointer back into an Arc, clones it to increment the reference count
/// (which will make it 2 in this particular case), and `mem::forget`s the clone. The `mem::forget`
/// prevents the reference count from being decremented when we exit this function, so it will stay
/// at 2 as long as we are in Rust code. Once the caller drops its `Arc`, the reference count will
/// go back down to 1, since the C code's copy remains.
/// To achieve that, we need to `mem::forget` the `Arc` we get back from `into_raw`, because
/// `into_raw` _does_ take back ownership. If we called `into_raw` without `mem::forget`, at the
/// end of the function the reference count would be decremented, potentially to 0, causing
/// memory to be freed.
///
/// Does nothing, returning `None`, when passed a `NULL` pointer. Can only be used when the
/// `Castable` has specified a cast type equal to [`OwnershipArc`].
Expand All @@ -389,7 +386,7 @@ where
///
/// If non-null, `ptr` must be a pointer that resulted from previously calling `Arc::into_raw`,
/// e.g. from using [`to_arc_const_ptr`].
pub(crate) fn to_arc<C>(ptr: *const C) -> Option<Arc<C::RustType>>
pub(crate) fn clone_arc<C>(ptr: *const C) -> Option<Arc<C::RustType>>
where
C: Castable<Ownership = OwnershipArc>,
{
Expand Down Expand Up @@ -566,32 +563,20 @@ macro_rules! try_ref_from_ptr {

pub(crate) use try_ref_from_ptr;

/// Convert a const pointer to a [`Castable`] to an optional `Arc` over the underlying
/// [`Castable::RustType`]. See [`to_arc`] for more information.
///
/// Does nothing, returning `None`, when passed `NULL`. Can only be used with `Castable`'s that
/// specify an ownership type of [`OwnershipArc`].
pub(crate) fn try_arc_from<C>(from: *const C) -> Option<Arc<C::RustType>>
where
C: Castable<Ownership = OwnershipArc>,
{
to_arc(from)
}

/// If the provided pointer to a [`Castable`] is non-null, convert it to a reference to an `Arc` over
/// the underlying rust type using [`try_arc_from`]. Otherwise, return
/// [`rustls_result::NullParameter`], or an appropriate default (`false`, `0`, `NULL`) based on the
/// context. See [`try_arc_from`] for more information.
macro_rules! try_arc_from_ptr {
macro_rules! try_clone_arc {
( $var:ident ) => {
match $crate::try_arc_from($var) {
match $crate::clone_arc($var) {
Some(c) => c,
None => return $crate::panic::NullParameterOrDefault::value(),
}
};
}

pub(crate) use try_arc_from_ptr;
pub(crate) use try_clone_arc;

/// Convert a mutable pointer to a [`Castable`] to an optional `Box` over the underlying
/// [`Castable::RustType`].
Expand Down
12 changes: 6 additions & 6 deletions src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ use crate::session::{
};
use crate::{
ffi_panic_boundary, free_arc, free_box, set_boxed_mut_ptr, to_arc_const_ptr, to_boxed_mut_ptr,
try_arc_from_ptr, try_box_from_ptr, try_mut_from_ptr, try_ref_from_ptr, try_slice,
userdata_get, Castable, OwnershipArc, OwnershipBox, OwnershipRef,
try_box_from_ptr, try_clone_arc, try_mut_from_ptr, try_ref_from_ptr, try_slice, userdata_get,
Castable, OwnershipArc, OwnershipBox, OwnershipRef,
};

/// A server config being constructed. A builder can be modified by,
Expand Down Expand Up @@ -170,7 +170,7 @@ impl rustls_server_config_builder {
) {
ffi_panic_boundary! {
let builder: &mut ServerConfigBuilder = try_mut_from_ptr!(builder);
let verifier: Arc<AllowAnyAuthenticatedClient> = try_arc_from_ptr!(verifier);
let verifier: Arc<AllowAnyAuthenticatedClient> = try_clone_arc!(verifier);
builder.verifier = verifier;
}
}
Expand All @@ -186,7 +186,7 @@ impl rustls_server_config_builder {
) {
ffi_panic_boundary! {
let builder: &mut ServerConfigBuilder = try_mut_from_ptr!(builder);
let verifier: Arc<AllowAnyAnonymousOrAuthenticatedClient> = try_arc_from_ptr!(verifier);
let verifier: Arc<AllowAnyAnonymousOrAuthenticatedClient> = try_clone_arc!(verifier);

builder.verifier = verifier;
}
Expand Down Expand Up @@ -273,7 +273,7 @@ impl rustls_server_config_builder {
let keys_ptrs: &[*const rustls_certified_key] = try_slice!(certified_keys, certified_keys_len);
let mut keys: Vec<Arc<CertifiedKey>> = Vec::new();
for &key_ptr in keys_ptrs {
let certified_key: Arc<CertifiedKey> = try_arc_from_ptr!(key_ptr);
let certified_key: Arc<CertifiedKey> = try_clone_arc!(key_ptr);
keys.push(certified_key);
}
builder.cert_resolver = Some(Arc::new(ResolvesServerCertFromChoices::new(&keys)));
Expand Down Expand Up @@ -333,7 +333,7 @@ impl rustls_server_config {
conn_out: *mut *mut rustls_connection,
) -> rustls_result {
ffi_panic_boundary! {
let config: Arc<ServerConfig> = try_arc_from_ptr!(config);
let config: Arc<ServerConfig> = try_clone_arc!(config);

let server_connection = match ServerConnection::new(config) {
Ok(sc) => sc,
Expand Down

0 comments on commit d9e378d

Please sign in to comment.