fn buffers(&self, inputs: &InputMap) -> ArgumentMap {
        let mut buffers: ArgumentMap = inputs
            .iter()
            .map(|(arg_id, (_, split_type_param))| {
                let runtime = split_type_param.ty.runtime_info();
                let output = (*arg_id, vec![0 as u8; runtime.data_size]);

                trace!(
                    "Assigning {:?} buffer of size {} (ptr={:?})",
                    arg_id,
                    runtime.data_size,
                    output.1.as_ptr()
                );

                // Values that are returned and passed around must be pointer-sized.
                if self.futures.contains(arg_id) {
                    assert_eq!(runtime.data_size, mem::size_of::<Future>());
                }
                output
            }).collect();

        for future_id in self.futures.iter() {
            buffers.entry(*future_id)
                .or_insert(vec![0 as u8; self.arguments[future_id].len()]);
        }
        buffers
    }
/// Returns thread-local buffers for storing intermediate results for each argument.
Returns thread-local buffers for storing intermediate results for each argument.
Returns thread - local buffers for storing intermediate results for each argument .
fn buffers(&self, inputs: &InputMap) -> ArgumentMap {
        let mut buffers: ArgumentMap = inputs
            .iter()
            .map(|(arg_id, (_, split_type_param))| {
                let runtime = split_type_param.ty.runtime_info();
                let output = (*arg_id, vec![0 as u8; runtime.data_size]);
                trace!(
                    "Assigning {:?} buffer of size {} (ptr={:?})",
                    arg_id,
                    runtime.data_size,
                    output.1.as_ptr()
                );
                // Values that are returned and passed around must be pointer-sized.
                if self.futures.contains(arg_id) {
                    assert_eq!(runtime.data_size, mem::size_of::<Future>());
                }
                output
            }).collect();
        for future_id in self.futures.iter() {
            buffers.entry(*future_id)
                .or_insert(vec![0 as u8; self.arguments[future_id].len()]);
        }
        buffers
    }
fn buffers ( & self , inputs : & InputMap ) -> ArgumentMap { let mut buffers : ArgumentMap = inputs . iter ( ) . map ( | ( arg_id , ( _ , split_type_param ) ) | { let runtime = split_type_param . ty . runtime_info ( ) ; let output = ( * arg_id , vec ! [ 0 as u8 runtime data_size ] ) ; trace ! ( " " arg_id runtime data_size output 1 as_ptr ( ) ) ; // Values that are returned and passed around must be pointer-sized. if self . futures . contains ( arg_id ) { assert_eq ! ( runtime data_size mem size_of Future ( ) ) ; } output } ) . collect ( ) ; for future_id in self . futures . iter ( ) { buffers . entry ( * future_id ) . or_insert ( vec ! [ 0 as u8 self arguments [ future_id ] len ( ) ] ) ; } buffers }
Returns thread-local buffers for storing intermediate results for each argument.
Returns thread - local buffers for storing intermediate results for each argument .
&self
inputs
&InputMap