Bdb packages | Design docs | Source docs | Guidelines | Recent releases
	Search | Site Map .

                 

---

/BdbPud/testBdbPud.cc

Go to the documentation of this file.

//------------------------------------------------------------------------------
// File and Version Information:
//      $Id: testBdbPud.cc,v 1.3 2002/01/18 00:40:41 becla Exp $
//
// Description:
//      Test for BdbPud
//
// Environment:
//      Software developed for the BaBar Detector at the SLAC B-Factory
//
// Author List:
//      Jacek Becla                Original Author
//
// Copyright Information:
//      Copyright (C) 2001      Stanford Linear Accelerator Center
//
//------------------------------------------------------------------------------


#include "BdbPud/BdbPud.hh"

#include <assert.h>
#include <iostream.h>
#include <strstream.h>
#include <unistd.h> /* unlink */
#include <time.h>

const char* host    = 0;
int         port    = 0;
BdbPud      thePud;


int test_checkExist()
{
    const char* fn = "test_checkExist: ";

    const char* path = tempnam("/tmp", "tstR");
    // check if ok when file does not exist
    cout << fn << "checking if " << path << " exist (it does not)" << endl;
    if ( BdbcError != thePud.checkExist(path, host, port) ) {
        return 1;
    }

    cout << fn << "creating a temp file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 2;
    }

    // check if ok when file exists
    cout << fn << "checking if " << path << " exist (it does)" << endl;
    if ( BdbcSuccess != thePud.checkExist(path, host, port) ) {
        return 3;
    }

    cout << fn << "finished ok" << endl;
    return 0;   
}




int test_createFile()
{
    const char* fn = "test_createFile: ";

    const char* path = tempnam("/tmp", "tstR");
    cout << fn << "creating a file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 1;
    }

    // this should fail, we have just created the file
    cout << fn << "creating a file " << path << " this file should already exists, it should fail" << endl;
    if ( BdbcError != thePud.createFile(path, host, port) ) {
        return 2;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}




int test_rmFile()
{
    const char* fn = "test_rmFile: ";

    const char* path = tempnam("/tmp", "tstR");

    cout << fn << "creating a file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 1;
    }
    cout << fn << "removing a file " << path << " (file exists)" << endl;
    if ( BdbcSuccess != thePud.rmFile(path, host, port) ) {
        return 2;
    }

    // this should fail, we have just removed that file
    cout << fn << "removing a file " << path << " (it should fail, file does not exist)" << endl;
    if ( BdbcError != thePud.rmFile(path, host, port) ) {
        return 3;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}



int test_chmodRead()
{
    const char* fn = "test_chmodRead: ";

    const char* path = tempnam("/tmp", "tstR");

    cout << fn << "creating a file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 1;
    }

    cout << fn << "changing mode of " << path << " to readonly" << endl;
    if ( BdbcSuccess != thePud.chmodRead(path, host, port) ) {
        return 2;
    }
    cout << "check mode of the file " << path << ", should be -r--r--r-- ok....(y/n) " << endl;
    char c; cin >> c;
    int ret = 0;
    if ( c != 'y' ) {
        ret = 1;
    }
    thePud.rmFile(path, host, port);

    if ( ret == 0 ) {
        cout << fn << "finished ok" << endl;
    }
    
    return ret;    
}


int test_chmodWrite()
{
    const char* fn = "test_chmodWrite: ";

    const char* path = tempnam("/tmp", "tstR");

    cout << fn << "creating a file " << path << endl;    
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 1;
    }

    cout << fn << "changing mode of " << path << " to readwrite" << endl;
    if ( BdbcSuccess != thePud.chmodWrite(path, host, port) ) {
        return 2;
    }
    cout << "check mode of the file " << path << ", should be -rw-rw-r-- ok...(y/n)" << endl;
    char c; cin >> c;
    int ret = 0;
    if ( c != 'y' ) {
        ret = 1;
    }    

    thePud.rmFile(path, host, port);
    if ( ret == 0 ) {
        cout << fn << "finished ok" << endl;
    }
    return ret;
}


int test_copyFile()
{
    const char* fn = "test_copyFile: ";

    const char* source = tempnam("/tmp", "tstR");
    const char* dest   = tempnam("/tmp", "tstR");

    cout << fn << "creating a file " << source << endl;
    if ( BdbcSuccess != thePud.createFile(source, host, port) ) {
        return 1;
    }
    cout << fn << "copying a file from " << source << " to " << dest << endl;    
    if ( BdbcSuccess != thePud.copyFile(source, dest, host, port) ) {
        return 2;
    }

    cout << fn << "removing a file " << source << endl;    
    if ( BdbcSuccess != thePud.rmFile(source, host, port) ) {
        return 3;
    }

    cout << fn << "removing a file " << dest << endl;    
    if ( BdbcSuccess != thePud.rmFile(dest, host, port) ) {
        return 4;
    }
    
    cout << fn << "finished ok" << endl;
    return 0;
}



int test_moveFile()
{
    const char* fn = "test_moveFile: ";

    const char* source = tempnam("/tmp", "tstR");
    const char* dest   = tempnam("/tmp", "tstR");

    cout << fn << "creating a file " << source << endl;
    if ( BdbcSuccess != thePud.createFile(source, host, port) ) {
        return 1;
    }
    cout << fn << "moving a file from " << source << " to " << dest << endl;    
    if ( BdbcSuccess != thePud.moveFile(source, dest, host, port) ) {
        return 2;
    }

    cout << fn << "removing a file " << source << "(this should not exist)" << endl;    
    if ( BdbcError != thePud.rmFile(source, host, port) ) {
        return 3;
    }

    cout << fn << "removing a file " << dest << endl;    
    if ( BdbcSuccess != thePud.rmFile(dest, host, port) ) {
        return 4;
    }
    
    cout << fn << "finished ok" << endl;
    return 0;
}



int test_getFileSize()
{
    const char* fn = "test_getFileSize: ";

    const char* path = tempnam("/tmp", "tstL");
    off_t size = 0;
    cout << fn << "checking size of notexistent file" << endl;
    if ( BdbcError != thePud.getFileSize(path, size, host, port) ) {
        return 1;
    }

    path = "/tmp/testSize";
    cout << "test_getFileSize: this test expects a file: " << path << " (size=7)" << endl;
    size = 0;
    if ( BdbcSuccess != thePud.getFileSize(path, size, host, port) ) {
        return 2;
    }
    if ( size != 7 ) {
        return 3;
    }
    
    cout << fn << "finished ok" << endl;
    return 0;
}


int test_getFDFilePath()
{
    const char* fn = "test_getFDFilePath: ";

    char buf[256]; char* fdPath = buf;
    const char* path = "/tmp/BaBar.BOOT";
    cout << "test_getFDFilePath: This test expects a valid boot file: " << path << endl;
    if ( BdbcSuccess != thePud.getFDFilePath(path, fdPath, host, port) ) {
        return 1;
    }
    cout << "test_getFDFilePath: got: " << fdPath << endl;
    char c;
    cout << "Is this correct? (y/n)";
    cin >> c;
    if ( c != 'y' ) {
        return 2;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}



int test_getFDHost()
{
    const char* fn = "test_getFDHost: ";

    char buf[256]; char* fdHost = buf;
    const char* path = "/tmp/BaBar.BOOT";
    cout << "test_getFDHost: This test expects a file: " << path << endl;
    if ( BdbcSuccess != thePud.getFDHost(path, fdHost, host, port) ) {
        return 1;
    }
    cout << "test_getFDHost: got: " << fdHost << endl;
    char c;
    cout << "Is this correct? (y/n)";
    cin >> c;
    if ( c != 'y' ) {
        return 2;
    }
    cout << fn << "finished ok" << endl;
    return 0;
}


int test_getModificationDate()
{
    const char* fn = "test_getModificationDate: ";

    const char* path = tempnam("/tmp", "tstR");
    time_t stime = 0;

    cout << fn << "checking mode date of nonexisting file" << endl;
    if ( BdbcError != thePud.getModificationDate(path, stime, host, port) ) {
        return 1;
    }

    cout << fn << "creating a temp file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 2;
    }
    stime = 0;
    cout << fn << "checking mode date of just created file" << endl;
    if ( BdbcSuccess != thePud.getModificationDate(path, stime, host, port) ) {
        return 3;
    }
    thePud.rmFile(path, host, port);
    
    struct tm* ttt = localtime(&stime);
    cout << "test_getModificationDate: " << ttt->tm_hour 
         << ":" << ttt->tm_min << ":" << ttt->tm_sec << endl;

    cout << fn << "finished ok" << endl;
    return 0;
}


int test_copyDb()
{
    const char* fn = "test_copyDb: ";

    thePud.copyDb("/tmp/empty.bdb", "/tmp/destinFile.bdb", "/tmp/dummy.Boot", host, port);
    cout << "check pud log file. ok? (y/n)" << endl;
    char c; cin >> c;
    if ( c != 'y' ) {
        return 1;
    }
    cout << fn << "finished ok" << endl;
    return 0;
}




int test_mkDir()
{
    const char* fn = "test_mkDir: ";

    const char* path = tempnam("/tmp", "tstL");
    cout << fn << "creating directory " << path << endl;
    if ( BdbcSuccess != thePud.mkDir(path, host, port) ) {
        return 1;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}



int test_mkDirP()
{
    const char* fn = "test_mkDirP: ";

    const char* p = tempnam("/tmp", "tstL");
    char path[256];
    ostrstream b(path, 256);
    b << p << "/one/two/three/four/five" << ends;
    cout << fn << "creating directory " << path << endl;
    if ( BdbcSuccess != thePud.mkDirP(path, host, port) ) {
        return 1;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}




int test_rmDir()
{
    const char* fn = "test_rmDir: ";

    const char* path = tempnam("/tmp", "tstL");

    cout << fn << "removing nonexistent directory " << path << endl;
    if ( BdbcError != thePud.rmDir(path, host, port) ) {
        return 1;
    }

    cout << fn << "creating directory " << path << endl;
    if ( BdbcSuccess != thePud.mkDir(path, host, port) ) {
        return 2;
    }

    cout << fn << "removing directory " << path << endl;
    if ( BdbcSuccess != thePud.rmDir(path, host, port) ) {
        return 3;
    }

    cout << fn << "finished ok" << endl;
    return 0;
}


int test_purgeMigrateFile()
{
    const char* fn = "test_purgeMigrateFile: ";

    const char* path = tempnam("/tmp", "tstR");
    // the file that is being purged should exist, now it does not, so
    // it should fail
    cout << fn << "trying to purge nonexisting file" << endl;
    if ( BdbcSuccess == thePud.purgeMigrateFile(path, "mp", host, port) ) {
        return 1;
    }

    cout << fn << "creating a temp file " << path << endl;
    if ( BdbcSuccess != thePud.createFile(path, host, port) ) {
        return 2;
    }

    cout << fn << "trying to purge file" << path << endl;
    if ( BdbcSuccess != thePud.purgeMigrateFile(path, "mp", host, port) ) {
        return 3;
    }
    // this should fail, argument is not valid
    cout << fn << "trying to purge file, wrong argument" << path << endl;
    if ( BdbcSuccess == thePud.purgeMigrateFile(path, "blabla", host, port) ) {
        return 4;
    }
    thePud.rmFile(path, host, port);

    cout << fn << "finished ok" << endl;
    return 0;
}



int test_precrActiveDb()
{
    const char* fn = "test_precrActiveDb: ";

    const char* dbName     = "testDB";
    const char* dbHost     = "objyserv02";
    const char* dbDirPath  = "/tmp";
    const char* dbFileName = "testDB.bdb";
    d_ULong dbid           = 1234;
    d_ULong nrConts        = 20;
    d_ULong hashed         = 0;
    d_ULong initPg         = 10;
    d_ULong percGr         = 1;
    const char* bootF      = "/nfs/objyserv02/objy/databases/users/becla/testA/BaBar.BOOT";
    char* responseMsg      = 0;
    cout << fn << "testing precreation on objyserv02, "
         << "/nfs/objyserv02/objy/databases/users/becla/testA/BaBar.BOOT must be valid, run or skip the test? (s-skip) ";
    char c;
    cin >> c;
    if ( c == 's') {
        return 0;
    }
    
    if ( BdbcSuccess != thePud.precreateActiveDb(dbName, dbHost, 
                        dbDirPath, dbFileName, dbid, nrConts, 
                        hashed, initPg, percGr, bootF, responseMsg, host, port) ) {
        return 1;
    }
    cout << "response was: " << responseMsg << endl;
    cout << fn << "finished ok" << endl;
    return 0;
}


int test_stageInFile()
{
    const char* fn = "test_stageInFile: ";
    
    const char* path = tempnam("/tmp", "tstL");
    cout << "calling stage in " << path << ", see pud log file" << endl;
    if ( BdbcSuccess != thePud.stageInFile("token user", path,  'r',  1, host, port) ) {
        return 1;
    }
    cout << fn << "finished ok" << endl;
    return 0;
}


int test_stageInFiles()
{
    const char* fn = "test_stageInFiles: ";
    
    char** paths = new char* [3];
    *(paths+0) = tempnam("/tmp", "tstL");
    *(paths+1) = tempnam("/tmp", "tstL");
    *(paths+2) = tempnam("/tmp", "tstL");

    cout << "calling stage in paths[0] = " << *(paths+0) << "\n"
         << "                 paths[1] = " << *(paths+1) << "\n"
         << "                 paths[2] = " << *(paths+2) << "\n"
         << " see pud log file" << endl;
    if ( BdbcSuccess != thePud.stageInFiles((const char**)paths,  3, "memo", 'r',  1, host, port) ) {
        return 1;
    }
    cout << fn << "finished ok" << endl;
    return 0;
}


int test_checkAvailSpace()
{
    const char* fn = "test_checkAvailSpace: ";
    
    d_Boolean isAvail = d_False;
    cout << fn << "checking if enough space in /tmp, minSpace = 100" << endl;
    if ( BdbcSuccess != thePud.checkAvailSpace("/tmp", 100, &isAvail, host, port) ) {
        return 1;
    }
    if ( ! isAvail ) {
        return 2;
    }
    cout << fn << "checking if enough space in /tmp, minSpace = 10000000" << endl;
    if ( BdbcSuccess != thePud.checkAvailSpace("/tmp", 10000000, &isAvail, host, port) ) {
        return 3;
    }
    if ( isAvail ) {
        return 4;
    }
    cout << fn << "checking if enough space in /garbage" << endl;
    if ( BdbcError != thePud.checkAvailSpace("/garbage", 100, &isAvail, host, port) ) {
        return 5;
    }
    cout << fn << "finished ok" << endl;
    return 0;
}



void runAllTests()
{
    assert( 0 == test_checkExist()          );
    assert( 0 == test_createFile()          );
    assert( 0 == test_rmFile()              );
    assert( 0 == test_chmodRead()           );
    assert( 0 == test_chmodWrite()          );
    assert( 0 == test_copyFile()            );
    assert( 0 == test_moveFile()            );
    assert( 0 == test_getFileSize()         );
    assert( 0 == test_getFDFilePath()       );
    assert( 0 == test_getFDHost()           );
    assert( 0 == test_getModificationDate() );
    assert( 0 == test_copyDb()              );
    assert( 0 == test_mkDir()               );
    assert( 0 == test_mkDirP()              );
    assert( 0 == test_rmDir()               );
    assert( 0 == test_purgeMigrateFile()    );
    assert( 0 == test_precrActiveDb()       );
    assert( 0 == test_stageInFile()         );
    assert( 0 == test_stageInFiles()        );
    assert( 0 == test_checkAvailSpace()     );
}

int main(int, char**)
{
    host = "objyserv02.slac.stanford.edu";
    port = 3333;

    runAllTests();

    //assert( 0 == test_stageInFiles()        );
    //assert( 0 == test_stageInFiles()        );

    //cout << "\nSecond part, using predefined host/port, talking to port = 3334" << endl;
    //thePud.set(host, 3334);
    //host = 0;
    //port = 0;
    //runAllTests();
    
    return 0;  
}

 

---

BaBar Public Site | SLAC | News | Links | Who's Who | Contact Us

Page Owner: Jacek Becla
Last Update: October 04, 2002