ftp.parl.clemson.edu/2015-02-07.ftp.parl.clemson.edu.tar/ftp.parl.clemson.edu/pub/pvfs2/orangefs-2.8.3-20110323.tar.gz/orangefs-2.8.3-20110323.tar/orangefs/test/io/description/test-romio-noncontig-pattern.c

C/C++ Source or Header | 2005-11-11 | 4KB | 175 lines

/*
 * (C) 2002 Clemson University.
 *
 * See COPYING in top-level directory.
 */

#include <stdlib.h>
#include <stdio.h>
#include <pvfs2-types.h>
#include <gossip.h>
#include <pvfs2-debug.h>

#include <pint-distribution.h>
#include <pint-dist-utils.h>
#include <pvfs2-request.h>
#include <pint-request.h>
#include <assert.h>
#include "pvfs2-internal.h"

#define SEGMAX 16
#define BYTEMAX (4*1024*1024)

int main(int argc, char **argv)
{
    int i;
    PINT_Request *file_req;
    PINT_Request *mem_req;
    PINT_Request_state *mem_state;
    PINT_Request_state *file_state;
    PINT_Request_state *file_state_server;
    PINT_request_file_data rf1;
    PINT_Request_result seg1;
    int32_t* len_array = NULL;
    PVFS_offset* off_array = NULL;
    PVFS_size total_bytes_client = 0;
    PVFS_size total_bytes_server = 0;

    /* PVFS_Process_request arguments */
    int retval;

    len_array = (int32_t*)malloc(64*sizeof(int32_t));
    off_array = (PVFS_offset*)malloc(64*sizeof(PVFS_offset));
    assert(len_array != NULL && off_array != NULL);

    /* setup file datatype */
    for(i=0; i<63; i++)
    {
        len_array[i] = 4;
        off_array[i] = 4 + (8*i);
    }
    PVFS_Request_hindexed(63, len_array, off_array, PVFS_BYTE, &file_req);

    /* setup mem datatype */
    len_array[0] = 0;
    off_array[0] = 135295720;
    for(i=1; i<64; i++)
    {
        len_array[i] = 4;
        off_array[i] = off_array[0] + 4 + ((i-1)*8);
    }
    PVFS_Request_hindexed(64, len_array, off_array, PVFS_BYTE, &mem_req);

    mem_state = PINT_new_request_state(mem_req);
    file_state = PINT_new_request_state(file_req);
    file_state_server = PINT_new_request_state(file_req);

    /* set up file data for request */
    PINT_dist_initialize(NULL);
    rf1.server_nr = 0;
    rf1.server_ct = 1;
    rf1.fsize = 0;
    rf1.dist = PINT_dist_create("simple_stripe");
    rf1.extend_flag = 1;
    PINT_dist_lookup(rf1.dist);

    /* set up result struct */
    seg1.offset_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg1.size_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg1.bytemax = BYTEMAX;
    seg1.segmax = SEGMAX;
    seg1.bytes = 0;
    seg1.segs = 0;


    PINT_REQUEST_STATE_SET_TARGET(file_state, 0);
    PINT_REQUEST_STATE_SET_FINAL(file_state, PINT_REQUEST_TOTAL_BYTES(mem_req));
    PINT_REQUEST_STATE_SET_TARGET(file_state_server, 0);
    PINT_REQUEST_STATE_SET_FINAL(file_state_server, PINT_REQUEST_TOTAL_BYTES(mem_req));


   /* Turn on debugging */
    // gossip_enable_stderr();
    // gossip_set_debug_mask(1,REQUEST_DEBUG);

    printf("\nCLIENT ************************************\n");
    do
    {
        seg1.bytes = 0;
        seg1.segs = 0;

        /* process request */
        retval = PINT_process_request(file_state, mem_state, &rf1, &seg1, PINT_CLIENT);

        if(retval >= 0)
        {
            printf("results of PINT_process_request():\n");
            printf("%d segments with %lld bytes\n", seg1.segs, lld(seg1.bytes));
            total_bytes_client += seg1.bytes;
            for(i=0; i<seg1.segs; i++)
            {
                printf("  segment %d: offset: %d size: %d\n",
                    i, (int)seg1.offset_array[i], (int)seg1.size_array[i]);
            }
        }

    } while(!PINT_REQUEST_DONE(file_state) && retval >= 0);

    if(retval < 0)
    {
        fprintf(stderr, "Error: PINT_process_request() failure.\n");
        return(-1);
    }
    if(PINT_REQUEST_DONE(file_state))
    {
        printf("**** request done.\n");
    }

    printf("\nSERVER ************************************\n");
    do
    {
        seg1.bytes = 0;
        seg1.segs = 0;

        /* process request */
        retval = PINT_process_request(file_state_server, NULL, &rf1, &seg1, PINT_SERVER);

        if(retval >= 0)
        {
            printf("results of PINT_process_request():\n");
            printf("%d segments with %lld bytes\n", seg1.segs, lld(seg1.bytes));
            total_bytes_server += seg1.bytes;
            for(i=0; i<seg1.segs; i++)
            {
                printf("  segment %d: offset: %d size: %d\n",
                    i, (int)seg1.offset_array[i], (int)seg1.size_array[i]);
            }
        }

    } while(!PINT_REQUEST_DONE(file_state_server) && retval >= 0);

    if(retval < 0)
    {
        fprintf(stderr, "Error: PINT_process_request() failure.\n");
        return(-1);
    }
    if(PINT_REQUEST_DONE(file_state_server))
    {
        printf("**** request done.\n");
    }

    printf("total bytes processed on client side: %lld\n", (long long)total_bytes_client);
    printf("total bytes processed on server side: %lld\n", (long long)total_bytes_server);

    if(total_bytes_client == total_bytes_server)
    {
        printf("SUCCESS.\n");
    }
    else
    {
        printf("FAILURE!!!\n");
    }

    return 0;
}