extern crate collenchyma_nn as co_nn; extern crate collenchyma as co; #[cfg(feature = "cuda")] extern crate cudnn; extern crate libc; #[cfg(test)] #[cfg(feature = "cuda")] mod pooling_spec_cuda { use co::prelude::*; use co_nn::*; use co::plugin::numeric_helpers::{cast, Float}; fn get_native_backend() -> Backend { Backend::::default().unwrap() } fn get_cuda_backend() -> Backend { Backend::::default().unwrap() } fn write_to_memory(mem: &mut MemoryType, data: &[T]) { match mem { &mut MemoryType::Native(ref mut mem) => { let mut mem_buffer = mem.as_mut_slice::(); for (index, datum) in data.iter().enumerate() { mem_buffer[index] = *datum; } }, #[cfg(any(feature = "opencl", feature = "cuda"))] _ => {} } } fn get_memory(backend: &Backend, native: &Backend) -> (SharedTensor, SharedTensor){ let val = cast::(1f32).unwrap(); let val2 = cast::(2f32).unwrap(); let mut x = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x.capacity()).collect::>(); payload[0] = val2; x.add_device(native.device()).unwrap(); x.sync(native.device()).unwrap(); write_to_memory(x.get_mut(native.device()).unwrap(), payload); x.sync(backend.device()).unwrap(); let mut result = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); result.add_device(native.device()).unwrap(); result.sync(backend.device()).unwrap(); (x, result) } fn get_grad_memory(backend: &Backend, native: &Backend) -> (SharedTensor, SharedTensor, SharedTensor, SharedTensor){ let val = cast::(1f64).unwrap(); let val2 = cast::(2f64).unwrap(); let mut x = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x.capacity()).collect::>(); payload[0] = val2; x.add_device(native.device()).unwrap(); x.sync(native.device()).unwrap(); write_to_memory(x.get_mut(native.device()).unwrap(), payload); x.sync(backend.device()).unwrap(); let mut x_diff = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x_diff.capacity()).collect::>(); payload[0] = val2; x_diff.add_device(native.device()).unwrap(); x_diff.sync(native.device()).unwrap(); write_to_memory(x_diff.get_mut(native.device()).unwrap(), payload); x_diff.sync(backend.device()).unwrap(); let mut result = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(result.capacity()).collect::>(); payload[0] = val2; result.add_device(native.device()).unwrap(); result.sync(native.device()).unwrap(); write_to_memory(result.get_mut(native.device()).unwrap(), payload); result.sync(backend.device()).unwrap(); let mut result_diff = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); result_diff.add_device(native.device()).unwrap(); (x, x_diff, result, result_diff) } #[test] fn it_computes_correct_pooling_max_on_cuda_for_f32() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut result) = get_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max(&mut x, &mut result, &conf) { Ok(_) => { result.sync(native.device()).unwrap(); if let Some(mem) = result.get(native.device()).unwrap().as_native() { let mut payload: &mut [f32] = &mut ::std::iter::repeat(1f32).take(result.capacity()).collect::>(); payload[0] = 2f32; assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_on_cuda_for_f64() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut result) = get_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max(&mut x, &mut result, &conf) { Ok(_) => { result.sync(native.device()).unwrap(); if let Some(mem) = result.get(native.device()).unwrap().as_native() { let mut payload: &mut [f64] = &mut ::std::iter::repeat(1f64).take(result.capacity()).collect::>(); payload[0] = 2f64; assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_on_cuda_for_f32_plain() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut result) = get_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_plain(&mut x, &mut result, &conf) { Ok(_) => { result.sync(native.device()).unwrap(); if let Some(mem) = result.get(native.device()).unwrap().as_native() { let mut payload: &mut [f32] = &mut ::std::iter::repeat(1f32).take(result.capacity()).collect::>(); payload[0] = 2f32; assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_on_cuda_for_f64_plain() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut result) = get_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_plain(&mut x, &mut result, &conf) { Ok(_) => { result.sync(native.device()).unwrap(); if let Some(mem) = result.get(native.device()).unwrap().as_native() { let mut payload: &mut [f64] = &mut ::std::iter::repeat(1f64).take(result.capacity()).collect::>(); payload[0] = 2f64; assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_grad_on_cuda_for_f32() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_grad(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { Ok(_) => { result_diff.sync(native.device()).unwrap(); if let Some(mem) = result_diff.get(native.device()).unwrap().as_native() { let payload: &[f32] = &vec!(2f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32); assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_grad_on_cuda_for_f64() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_grad(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { Ok(_) => { result_diff.sync(native.device()).unwrap(); if let Some(mem) = result_diff.get(native.device()).unwrap().as_native() { let payload: &[f64] = &vec!(2f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64); assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_grad_on_cuda_for_f32_plain() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_grad_plain(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { Ok(_) => { result_diff.sync(native.device()).unwrap(); if let Some(mem) = result_diff.get(native.device()).unwrap().as_native() { let payload: &[f32] = &vec!(2f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32); assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } #[test] fn it_computes_correct_pooling_max_grad_on_cuda_for_f64_plain() { let backend = get_cuda_backend(); let native = get_native_backend(); let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend, &native); let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); match backend.pooling_max_grad_plain(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { Ok(_) => { result_diff.sync(native.device()).unwrap(); if let Some(mem) = result_diff.get(native.device()).unwrap().as_native() { let payload: &[f64] = &vec!(2f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64); assert_eq!(payload, mem.as_slice::()); } }, Err(err) => { println!("{:?}", err); assert!(false) } } } } #[cfg(test)] #[cfg(feature = "native")] mod pooling_spec_native { // use co::backend::{Backend, BackendConfig}; // use co::framework::IFramework; // use co::frameworks::Native; // use co_nn::*; // use co::memory::MemoryType; // use co::tensor::SharedTensor; // use co::plugin::numeric_helpers::{cast, Float}; // // fn get_native_backend() -> Backend { // let framework = Native::new(); // let hardwares = framework.hardwares(); // let backend_config = BackendConfig::new(framework, hardwares); // Backend::new(backend_config).unwrap() // } // // fn write_to_memory(mem: &mut MemoryType, data: &[T]) { // match mem { // &mut MemoryType::Native(ref mut mem) => { // let mut mem_buffer = mem.as_mut_slice::(); // for (index, datum) in data.iter().enumerate() { // mem_buffer[index] = *datum; // } // }, // #[cfg(any(feature = "opencl", feature = "cuda"))] // _ => {} // } // } // // fn get_memory(backend: &Backend) -> (SharedTensor, SharedTensor){ // let val = cast::(1f32).unwrap(); // let val2 = cast::(2f32).unwrap(); // let mut x = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); // let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x.capacity()).collect::>(); // payload[0] = val2; // write_to_memory(x.get_mut(backend.device()).unwrap(), payload); // // let result = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); // // (x, result) // } // // fn get_grad_memory(backend: &Backend) -> (SharedTensor, SharedTensor, SharedTensor, SharedTensor){ // let val = cast::(1f64).unwrap(); // let val2 = cast::(2f64).unwrap(); // let mut x = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); // let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x.capacity()).collect::>(); // payload[0] = val2; // write_to_memory(x.get_mut(backend.device()).unwrap(), payload); // // let mut x_diff = SharedTensor::::new(backend.device(), &(4, 4, 4, 4)).unwrap(); // let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(x_diff.capacity()).collect::>(); // payload[0] = val2; // write_to_memory(x_diff.get_mut(backend.device()).unwrap(), payload); // // let mut result = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); // let mut payload: &mut [T] = &mut ::std::iter::repeat(val).take(result.capacity()).collect::>(); // payload[0] = val2; // write_to_memory(result.get_mut(backend.device()).unwrap(), payload); // // let result_diff = SharedTensor::::new(backend.device(), &(4, 4, 2, 2)).unwrap(); // // (x, x_diff, result, result_diff) // } // #[test] // #[ignore] // fn it_computes_correct_pooling_max_on_native_for_f32() { // let backend = get_native_backend(); // let (mut x, mut result) = get_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max(&mut x, &mut result, &conf) { // Ok(_) => { // if let Some(mem) = result.get(backend.device()).unwrap().as_native() { // let mut payload: &mut [f32] = &mut ::std::iter::repeat(1f32).take(result.capacity()).collect::>(); // payload[0] = 2f32; // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_on_native_for_f64() { // let backend = get_native_backend(); // let (mut x, mut result) = get_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max(&mut x, &mut result, &conf) { // Ok(_) => { // if let Some(mem) = result.get(backend.device()).unwrap().as_native() { // let mut payload: &mut [f64] = &mut ::std::iter::repeat(1f64).take(result.capacity()).collect::>(); // payload[0] = 2f64; // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_on_native_for_f32_plain() { // let backend = get_native_backend(); // let (mut x, mut result) = get_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_plain(&mut x, &mut result, &conf) { // Ok(_) => { // if let Some(mem) = result.get(backend.device()).unwrap().as_native() { // let mut payload: &mut [f32] = &mut ::std::iter::repeat(1f32).take(result.capacity()).collect::>(); // payload[0] = 2f32; // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_on_native_for_f64_plain() { // let backend = get_native_backend(); // let (mut x, mut result) = get_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_plain(&mut x, &mut result, &conf) { // Ok(_) => { // if let Some(mem) = result.get(backend.device()).unwrap().as_native() { // let mut payload: &mut [f64] = &mut ::std::iter::repeat(1f64).take(result.capacity()).collect::>(); // payload[0] = 2f64; // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_grad_on_native_for_f32() { // let backend = get_native_backend(); // let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_grad(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { // Ok(_) => { // if let Some(mem) = result_diff.get(backend.device()).unwrap().as_native() { // let payload: &[f32] = &vec!(2f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32); // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_grad_on_native_for_f64() { // let backend = get_native_backend(); // let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_grad(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { // Ok(_) => { // if let Some(mem) = result_diff.get(backend.device()).unwrap().as_native() { // let payload: &[f64] = &vec!(2f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64); // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_grad_on_native_for_f32_plain() { // let backend = get_native_backend(); // let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_grad_plain(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { // Ok(_) => { // if let Some(mem) = result_diff.get(backend.device()).unwrap().as_native() { // let payload: &[f32] = &vec!(2f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32, 1f32, 1f32, 0f32, 0f32); // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } // // #[test] // #[ignore] // fn it_computes_correct_pooling_max_grad_on_native_for_f64_plain() { // let backend = get_native_backend(); // let (mut x, mut x_diff, mut result, mut result_diff) = get_grad_memory::(&backend); // // let conf = Pooling::::new_pooling_config(&backend, &vec!(2,2), &vec!(0,0), &vec!(2,1)).unwrap(); // match backend.pooling_max_grad_plain(&mut x, &mut x_diff, &mut result, &mut result_diff, &conf) { // Ok(_) => { // if let Some(mem) = result_diff.get(backend.device()).unwrap().as_native() { // let payload: &[f64] = &vec!(2f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64, 1f64, 1f64, 0f64, 0f64); // assert_eq!(payload, mem.as_slice::()); // } // }, // Err(err) => { println!("{:?}", err); assert!(false) } // } // } }