Yet Another eXchange Tool  0.9.0
test_handles.c
/*
* Keywords:
* Maintainer: Jörg Behrens <behrens@dkrz.de>
* Moritz Hanke <hanke@dkrz.de>
* Thomas Jahns <jahns@dkrz.de>
* URL: https://doc.redmine.dkrz.de/yaxt/html/
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are
* met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
*
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* Neither the name of the DKRZ GmbH nor the names of its contributors
* may be used to endorse or promote products derived from this software
* without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
* IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
* TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
* PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
* OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
* PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include <mpi.h>
#include <yaxt.h>
#include "tests.h"
int main(void) {
enum {
hsize = 32,
};
int data[hsize];
int handle[hsize];
int state[hsize];
xt_mpi_call(MPI_Init(NULL, NULL), MPI_COMM_WORLD);
for (int i = 0; i<hsize; i++) {
state[i] = 0;
}
// new handles
for (int i = 0; i<hsize; i++) {
if (i % 2 == 0) {
data[i]=i;
handle[i] = xt_handle_new(hset, &data[i]);
if (!xt_handle_is_valid(hset,handle[i]))
PUT_ERR("unexpected invalid handle\n");
state[i] = 1;
}
}
// delete some handles
for (int i = 1; i<hsize; i++) {
if (state[i]) {
if (i % 3 == 0) {
if (!xt_handle_is_valid(hset,handle[i]))
PUT_ERR("unexpected invalid handle\n");
xt_handle_delete(hset,handle[i]);
if (xt_handle_is_valid(hset,handle[i]))
PUT_ERR("unexpected valid handle\n");
state[i] = 0;
}
}
}
// more new handles
for (int i = 0; i<hsize; i++) {
if (!state[i]) {
data[i]=i;
handle[i] = xt_handle_new(hset, &data[i]);
if (!xt_handle_is_valid(hset,handle[i]))
PUT_ERR("unexpected invalid handle\n");
state[i] = 1;
}
}
// delete some handles
for (int i = 0; i<hsize; i++) {
if (state[i]) {
if (i % 5 == 0) {
int h = handle[i];
if (!xt_handle_is_valid(hset,h)) PUT_ERR("unexpected invalid handle\n");
if (xt_handle_is_valid(hset,h)) PUT_ERR("unexpected valid handle\n");
state[i] = 0;
}
}
}
// check content
for (int i = 0; i<hsize; i++) {
if (state[i]) {
int h = handle[i];
if (!xt_handle_is_valid(hset,h)) PUT_ERR("unexpected invalid handle\n");
int *p = xt_handle2pointer(hset, h);
if (*p != data[i]) PUT_ERR("data lookup failed\n");
}
}
MPI_Finalize();
return TEST_EXIT_CODE;
}
/*
* Local Variables:
* c-basic-offset: 2
* coding: utf-8
* indent-tabs-mode: nil
* show-trailing-whitespace: t
* require-trailing-newline: t
* End:
*/
@ MPI_COMM_WORLD
Definition: core.h:73
void xt_initialize(MPI_Comm default_comm)
Definition: xt_init.c:70
void xt_finalize(void)
Definition: xt_init.c:89
void * xt_handle2pointer(Xt_handle_set_type hset, int handle)
Definition: xt_handles.c:77
Xt_handle_set_type xt_handle_set_new(int cap)
Definition: xt_handles.c:82
void xt_handle_set_delete(Xt_handle_set_type hset)
Definition: xt_handles.c:123
int xt_handle_is_valid(Xt_handle_set_type hset, int handle)
Definition: xt_handles.c:70
int xt_handle_new(Xt_handle_set_type hset, void *p)
Definition: xt_handles.c:130
void xt_handle_delete(Xt_handle_set_type hset, int handle)
Definition: xt_handles.c:151
#define xt_mpi_call(call, comm)
Definition: xt_mpi.h:68