11 #include <boost/scoped_ptr.hpp> 12 #include <boost/test/unit_test.hpp> 15 #include "eckit/config/LocalConfiguration.h" 27 const util::DateTime bgn(
conf.getString(
"window_begin"));
28 const util::DateTime
end(
conf.getString(
"window_end"));
29 const eckit::LocalConfiguration otconf(
conf,
"Observation");
42 BOOST_CHECK(ov.get() !=
NULL);
43 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
44 BOOST_CHECK_EQUAL((*ov)(ii), 0.0);
50 BOOST_CHECK_EQUAL(ov->size(), obstable_->nobs());
56 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
57 BOOST_CHECK((*ov)(ii) != 0.0);
66 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
67 BOOST_CHECK_EQUAL((*ov2)(ii), (*ov1)(ii));
76 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
77 BOOST_CHECK_EQUAL((*ov2)(ii), 0.0);
83 BOOST_CHECK_EQUAL(ov->classname(),
"lorenz95::ObsVec1D");
94 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
95 BOOST_CHECK_EQUAL((*ov2)(ii), (*ov1)(ii));
108 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
109 BOOST_CHECK_EQUAL((*ov2)(ii), (*ov1)(ii) *
mult);
120 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
121 BOOST_CHECK_EQUAL((*ov1)(ii), (*ov2)(ii) + (*ov2)(ii));
132 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
133 BOOST_CHECK_EQUAL((*ov1)(ii), 0.0);
144 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
145 BOOST_CHECK_EQUAL((*ov1)(ii), (*ov2)(ii) * (*ov2)(ii));
156 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
157 BOOST_CHECK_EQUAL((*ov1)(ii), 1.0);
167 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
168 BOOST_CHECK_EQUAL((*ov)(ii), 0.0);
179 ov1->axpy(
mult, *ov2);
181 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
182 BOOST_CHECK_EQUAL((*ov1)(ii), (*ov2)(ii) +
mult * (*ov2)(ii));
193 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
194 BOOST_CHECK_EQUAL((*ov1)(ii), 1.0 / (*ov2)(ii));
203 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
204 BOOST_CHECK((*ov)(ii) != 0);
213 double result = ov1->dot_product_with(*ov2);
216 for (
unsigned int ii = 0; ii < obstable_->nobs(); ++ii) {
217 check += (*ov2)(ii) * (*ov2)(ii);
220 BOOST_CHECK_CLOSE(result,
check, 1.0
e-8);
223 BOOST_AUTO_TEST_SUITE_END()
************************************************************************GNU Lesser General Public License **This file is part of the GFDL Flexible Modeling System(FMS). ! *! *FMS is free software without even the implied warranty of MERCHANTABILITY or *FITNESS FOR A PARTICULAR PURPOSE See the GNU General Public License *for more details **You should have received a copy of the GNU Lesser General Public *License along with FMS If see< http:! ***********************************************************************!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! !! MPP_TRANSMIT !! !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! subroutine MPP_TRANSMIT_(put_data, put_len, to_pe, get_data, get_len, from_pe, block, tag, recv_request, send_request)!a message-passing routine intended to be reminiscent equally of both MPI and SHMEM!put_data and get_data are contiguous MPP_TYPE_ arrays!at each call, your put_data array is put to to_pe 's get_data! your get_data array is got from from_pe 's put_data!i.e we assume that typically(e.g updating halo regions) each PE performs a put _and_ a get!special PE designations:! NULL_PE:to disable a put or a get(e.g at boundaries)! ANY_PE:if remote PE for the put or get is to be unspecific! ALL_PES:broadcast and collect operations(collect not yet implemented)!ideally we would not pass length, but this f77-style call performs better(arrays passed by address, not descriptor)!further, this permits< length > contiguous words from an array of any rank to be passed(avoiding f90 rank conformance check)!caller is responsible for completion checks(mpp_sync_self) before and after integer, intent(in) ::put_len, to_pe, get_len, from_pe MPP_TYPE_, intent(in) ::put_data(*) MPP_TYPE_, intent(out) ::get_data(*) logical, intent(in), optional ::block integer, intent(in), optional ::tag integer, intent(out), optional ::recv_request, send_request logical ::block_comm integer ::i MPP_TYPE_, allocatable, save ::local_data(:) !local copy used by non-parallel code(no SHMEM or MPI) integer ::comm_tag integer ::rsize if(.NOT.module_is_initialized) call mpp_error(FATAL, 'MPP_TRANSMIT:You must first call mpp_init.') if(to_pe.EQ.NULL_PE .AND. from_pe.EQ.NULL_PE) return block_comm=.true. if(PRESENT(block)) block_comm=block if(debug) then call SYSTEM_CLOCK(tick) write(stdout_unit,'(a, i18, a, i6, a, 2i6, 2i8)')&'T=', tick, ' PE=', pe, ' MPP_TRANSMIT begin:to_pe, from_pe, put_len, get_len=', to_pe, from_pe, put_len, get_len end if comm_tag=DEFAULT_TAG if(present(tag)) comm_tag=tag!do put first and then get if(to_pe.GE.0 .AND. to_pe.LT.npes) then!use non-blocking sends if(debug .and.(current_clock.NE.0)) call SYSTEM_CLOCK(start_tick)!z1l:truly non-blocking send.! if(request(to_pe).NE.MPI_REQUEST_NULL) then !only one message from pe-> to_pe in queue *PE waiting for to_pe ! call error else get_len so only do gets but you cannot have a pure get with MPI call a get means do a wait to ensure put on remote PE is complete error call increase mpp_nml request_multiply call MPP_TRANSMIT end
*f90 *************************************************************************GNU Lesser General Public License **This file is part of the GFDL Flexible Modeling System(FMS). ! *! *FMS is free software without even the implied warranty of MERCHANTABILITY or *FITNESS FOR A PARTICULAR PURPOSE See the GNU General Public License *for more details **You should have received a copy of the GNU Lesser General Public *License along with FMS If see< http:! ***********************************************************************! this routine is used to retrieve scalar boundary data for symmetric domain. subroutine MPP_GET_BOUNDARY_2D_(field, domain, ebuffer, sbuffer, wbuffer, nbuffer, flags, &position, complete, tile_count) type(domain2D), intent(in) ::domain MPP_TYPE_, intent(in) ::field(:,:) MPP_TYPE_, intent(inout), optional ::ebuffer(:), sbuffer(:), wbuffer(:), nbuffer(:) integer, intent(in), optional ::flags, position, tile_count logical, intent(in), optional ::complete MPP_TYPE_ ::field3D(size(field, 1), size(field, 2), 1) MPP_TYPE_, allocatable, dimension(:,:) ::ebuffer2D, sbuffer2D, wbuffer2D, nbuffer2D integer ::xcount, ycount integer ::ntile logical ::need_ebuffer, need_sbuffer, need_wbuffer, need_nbuffer integer(LONG_KIND), dimension(MAX_DOMAIN_FIELDS, MAX_TILES), save ::f_addrs=-9999 integer(LONG_KIND), dimension(4, MAX_DOMAIN_FIELDS, MAX_TILES), save ::b_addrs=-9999 integer, save ::bsize(4)=0, isize=0, jsize=0, ksize=0, pos, list=0, l_size=0, upflags integer ::buffer_size(4) integer ::max_ntile, tile, update_position, ishift, jshift logical ::do_update, is_complete, set_mismatch character(len=3) ::text MPP_TYPE_ ::d_type type(overlapSpec), pointer ::bound=> NULL() ntile
Vector in observation space.
real(fp), parameter, public e
boost::scoped_ptr< lorenz95::ObsTable > obstable_
A Simple Observation Data Handler.
BOOST_AUTO_TEST_CASE(test_GomL95_constructor)
static const eckit::Configuration & config()
void mult(long double m[], long double v[], long double out_v[])