diff --git a/src/database/engine/cf_opts.rs b/src/database/engine/cf_opts.rs index 4417be5a0..130cd902d 100644 --- a/src/database/engine/cf_opts.rs +++ b/src/database/engine/cf_opts.rs @@ -20,13 +20,13 @@ pub(crate) fn cf_options(ctx: &Context, opts: Options, desc: &Descriptor) -> Res } fn descriptor_cf_options( - mut opts: Options, + opts: Options, mut desc: Descriptor, config: &Config, cache: Option<&Cache>, ) -> Result { set_compression(&mut desc, config); - set_table_options(&mut opts, &desc, cache)?; + let mut opts = set_table_options(opts, &desc, cache)?; opts.set_min_write_buffer_number(1); opts.set_max_write_buffer_number(2); @@ -87,7 +87,11 @@ fn descriptor_cf_options( Ok(opts) } -fn set_table_options(opts: &mut Options, desc: &Descriptor, cache: Option<&Cache>) -> Result { +fn set_table_options( + mut opts: Options, + desc: &Descriptor, + cache: Option<&Cache>, +) -> Result { let mut table = table_options(desc, cache.is_some()); if let Some(cache) = cache { @@ -113,7 +117,7 @@ fn set_table_options(opts: &mut Options, desc: &Descriptor, cache: Option<&Cache opts.set_block_based_table_factory(&table); - Ok(()) + Ok(opts) } fn set_compression(desc: &mut Descriptor, config: &Config) {