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/debug1.c

C/C++ Source or Header | 2005-11-11 | 5KB | 228 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 "pvfs2-dist-simple-stripe.h"

#include "debug.h"
#include "pvfs2-internal.h"

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

PVFS_offset exp1_offset[] =
{
    0,
    4194304,
    8388608
};

PVFS_size exp1_size[] =
{
    4194304,
    4194304,
    2097152
};

PVFS_size exp2_offset[] =
{
    10485760,
    14680064,
    18874368
};

PINT_Request_result expected[] =
{{
    offset_array : &exp1_offset[0],
    size_array : &exp1_size[0],
    segmax : SEGMAX,
    segs : 1,
    bytes : 4194304
}, {
    offset_array : &exp1_offset[1],
    size_array : &exp1_size[1],
    segmax : SEGMAX,
    segs : 1,
    bytes : 4194304
}, {
    offset_array : &exp1_offset[2],
    size_array : &exp1_size[2],
    segmax : SEGMAX,
    segs : 1,
    bytes : 2097152
}, {
    offset_array : &exp2_offset[0],
    size_array : &exp1_size[0],
    segmax : SEGMAX,
    segs : 1,
    bytes : 4194304
}, {
    offset_array : &exp2_offset[1],
    size_array : &exp1_size[1],
    segmax : SEGMAX,
    segs : 1,
    bytes : 4194304
}, {
    offset_array : &exp2_offset[2],
    size_array : &exp1_size[2],
    segmax : SEGMAX,
    segs : 1,
    bytes : 2097152
}};

int request_debug(void)
{
    int i;
    PINT_Request *r1;
    PINT_Request *r2;
    PINT_Request_state *rs1;
    PINT_Request_state *rs2;
    PINT_request_file_data rf1;
    PINT_request_file_data rf2;
    PINT_Request_result seg1;
    PINT_Request_result seg2;

    /* PVFS_Process_request arguments */
    int retval;

    int32_t blocklength = 10*1024*1024; /* 10M */

    /* set up two requests */
    PVFS_size displacement = 0;  /* first at offset zero */
    PVFS_Request_indexed(1, &blocklength, &displacement, PVFS_BYTE, &r1);

    displacement = 10*1024*1024; /* next at 10M offset */
    PVFS_Request_indexed(1, &blocklength, &displacement, PVFS_BYTE, &r2);

    /* set up two request states */
    rs1 = PINT_new_request_state(r1);
    rs2 = PINT_new_request_state(r2);

    /* set up file data for first 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);

    /* file data for second request is the same, except the file
     * will have grown by 10M
     */
    rf2.server_nr = 0;
    rf2.server_ct = 1;
    rf2.fsize = 10*1024*1024;
    rf2.dist = PINT_dist_create("simple_stripe");
    rf2.extend_flag = 1;
    PINT_dist_lookup(rf2.dist);

    /* set up result structures */

    seg1.offset_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg1.size_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg1.segmax = SEGMAX;
    seg1.bytemax = BYTEMAX;
    seg1.segs = 0;
    seg1.bytes = 0;

    seg2.offset_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg2.size_array = (int64_t *)malloc(SEGMAX * sizeof(int64_t));
    seg2.segmax = SEGMAX;
    seg2.bytemax = BYTEMAX;
    seg2.segs = 0;
    seg2.bytes = 0;

   /* Turn on debugging */
    if (gossipflag)
    {
        gossip_enable_stderr();
        gossip_set_debug_mask(1,GOSSIP_REQUEST_DEBUG);
    }

    i = 0;

    printf("\n************************************\n");
    printf("Testing simple contiguous read and byte limit of 4M\n");
    printf("Two requests in SERVER mode 10M each contiguous server 0 of 1\n");
    printf("Simple stripe, default stripe size (64K)\n");
    printf("First from offset 0, file size 0, extend flag\n");
    printf("\n************************************\n");
    do
    {
        seg1.bytes = 0;
        seg1.segs = 0;
        /* process request */
        retval = PINT_process_request(rs1, NULL, &rf1, &seg1, PINT_SERVER);

        if(retval >= 0)
        {
            prtseg(&seg1,"Results obtained");
            prtseg(&expected[i],"Results expected");
            cmpseg(&seg1,&expected[i]);
        }

        i++;

    } while(!PINT_REQUEST_DONE(rs1) && retval >= 0);
    if(retval < 0)
    {
        fprintf(stderr, "Error: PINT_process_request() failure.\n");
        return(-1);
    }
    prtval(lld(rf1.fsize),"final file size obtained");
    prtval(10485760,"final file size expected");
    cmpval(lld(rf1.fsize),lld(10485760));
    if(PINT_REQUEST_DONE(rs1))
    {
        printf("**** first request done.\n");
    }
    printf("\n************************************\n");
    printf("Second from offset 10M, file size 10M, extend flag\n");
    printf("\n************************************\n");
    do
    {
        seg2.bytes = 0;
        seg2.segs = 0;
        /* process request */
        retval = PINT_process_request(rs2, NULL, &rf2, &seg2, PINT_SERVER);

        if(retval >= 0)
        {
            prtseg(&seg2,"Results obtained");
            prtseg(&expected[i],"Results expected");
            cmpseg(&seg2,&expected[i]);
        }

        i++;

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

    if(retval < 0)
    {
        fprintf(stderr, "Error: PINT_process_request() failure.\n");
        return(-1);
    }
    prtval(lld(rf2.fsize),"final file size obtained");
    prtval(20971520,"final file size expected");
    cmpval(lld(rf2.fsize),lld(20971520));
    if(PINT_REQUEST_DONE(rs2))
    {
        printf("**** second request done.\n");
    }

    return 0;
}