XrdMonSndDummyXrootd.cc

Go to the documentation of this file.

/*****************************************************************************/
/*                                                                           */
/*                         XrdMonSndDummyXrootd.cc                           */
/*                                                                           */
/* (c) 2005 by the Board of Trustees of the Leland Stanford, Jr., University */
/*                            All Rights Reserved                            */
/*       Produced by Jacek Becla for Stanford University under contract      */
/*              DE-AC02-76SF00515 with the Department of Energy              */
/*****************************************************************************/

// $Id: XrdMonSndDummyXrootd.cc 24468 2008-06-22 16:47:03Z ganis $

#include "XrdMon/XrdMonSndDummyXrootd.hh"
#include "XrdMon/XrdMonSndDebug.hh"
#include "XrdSys/XrdSysHeaders.hh"

#include "sys/time.h"
#include <fstream>
#include <iomanip>
#include <sstream>
using std::cerr;
using std::cout;
using std::endl;
using std::ifstream;
using std::setfill;
using std::setw;
using std::stringstream;

// create new user/process/file every ... calls
kXR_int16 XrdMonSndDummyXrootd::NEWUSERFREQUENCY = 1;
kXR_int16 XrdMonSndDummyXrootd::NEWPROCFREQUENCY = 1;
kXR_int16 XrdMonSndDummyXrootd::NEWFILEFREQUENCY = 1;

kXR_int16 XrdMonSndDummyXrootd::MAXHOSTS         = 20;

XrdMonSndDummyXrootd::XrdMonSndDummyXrootd()
    : _noCalls2NewUser(1), 
      _noCalls2NewProc(0),
      _noCalls2NewFile(0),
      _firstAvailId(0)
{}

XrdMonSndDummyXrootd::~XrdMonSndDummyXrootd()
{
    cout << "this is the mapping:\n";
    int i, size = _noTracesPerDict.size();
    for (i=0 ; i<size ; i++) {
        cout << setw(9) << setfill('0') << i << "  --> " 
             << setw(4) << setfill('0') << _noTracesPerDict[i] << " entries" << endl;
    }
}

int
XrdMonSndDummyXrootd::initialize(const char* pathFile) 
{
    return readPaths(pathFile);
}

XrdMonSndDictEntry
XrdMonSndDummyXrootd::newXrdMonSndDictEntry()
{
    --_noCalls2NewUser;
    --_noCalls2NewProc;
    
    if ( _noCalls2NewUser == 0 ) { createUser();    }
    if ( _noCalls2NewProc == 0 ) { createProcess(); }
    createFile();

    User& user     = _users[_activeUser];
    User::HostAndPid& hp = user.myProcesses[_activeProcess];
    PathData& pd   = _paths[ hp.myFiles[_activeFile] ];


    XrdMonSndDictEntry e(generateUserName(user.uid), 
                hp.pid, 
                pd.fd, 
                hp.name, 
                pd.path, 
                _firstAvailId++);
    _noTracesPerDict.push_back(0);
    _openFiles.push_back(true);
    
    return e;
}

XrdMonSndStageEntry
XrdMonSndDummyXrootd::newXrdMonSndStageEntry()
{
    User& user     = _users[_activeUser];
    User::HostAndPid& hp = user.myProcesses[_activeProcess];
    PathData& pd   = _paths[ hp.myFiles[_activeFile] ];

    struct timeval tv;
    gettimeofday(&tv, 0);

    XrdMonSndStageEntry e(generateUserName(user.uid), 
                          hp.pid, 
                          pd.fd, 
                          hp.name, 
                          pd.path, 
                          rand() % 20000, // bytes
                          rand() % 90,    // seconds
                          tv.tv_sec,      // tod
                         _firstAvailId++);
    
    return e;
}

XrdMonSndTraceEntry
XrdMonSndDummyXrootd::newXrdMonSndTraceEntry()
{
    // make sure it is sometimes>2GB
    kXR_int64 offset = ((kXR_int64) rand())*(rand()%512);
    kXR_int32 length = 16384;
    kXR_int32 id = (kXR_unt32) rand() % _firstAvailId; // do this until finds still open file

    XrdMonSndTraceEntry d(offset, length, id);
    ++(_noTracesPerDict[id]);
    return d;
}

kXR_int32
XrdMonSndDummyXrootd::closeOneFile()
{
    while ( 1 ) {
        kXR_int32 id = (kXR_unt32) rand() % _firstAvailId;
        if ( _openFiles[id] ) {
            _openFiles[id] = false;
            return id;
        }
    }
    return 0;
}

void 
XrdMonSndDummyXrootd::closeFiles(vector<kXR_int32>& closedFiles)
{
    for (kXR_int32 i=0 ; i<_firstAvailId ; i++) {
        if ( _openFiles[i] ) {
            closedFiles.push_back(i);
        }
    }
}

int
XrdMonSndDummyXrootd::readPaths(const char* pathFile)
{
    ifstream f(pathFile);
    if ( ! f ) {
        cerr << "Error opening file " << pathFile << endl;
        return 1;
    }
    
    kXR_int16 fd = 100;
    while ( f ) {
        char buffer[256];
        f >> buffer;
        _paths.push_back( PathData(buffer, fd++) );
    }
    f.close();

    return 0;
}

void
XrdMonSndDummyXrootd::createUser()
{
    _noCalls2NewUser = NEWUSERFREQUENCY;
    _noCalls2NewProc = 0; // force creation of new process

    // generate new user
    kXR_int16 newid = 1 + (kXR_unt16) rand() % 5000; // user id range: 0-5000
    // check if it already exists
    int i, s = _users.size();
    for ( i=0 ; i<s ; i++ ) {
        if ( _users[i].uid == newid ) {
            if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
                cout << "Generated uid that already exists" << endl;
            }
            _activeUser = i;
            return;
        }
    }
    // no it does not, so register it and use it
    _users.push_back( User(newid) );
    _activeUser = _users.size() - 1;
    if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
        cout << "Created new user, offset " << _activeUser
             << ", uid " << newid << endl;
    }
}


void
XrdMonSndDummyXrootd::createProcess()
{
    _noCalls2NewProc = NEWPROCFREQUENCY;
    _noCalls2NewFile = 0; // force creation of new file

    User& user = _users[_activeUser];
    
    // generate new process
    kXR_int16 newid = 1 + (kXR_unt16) rand() % 10000; // pid range: 0-10000
    string newhost = generateHostName();
    // check if it already exists
    int i, s = user.myProcesses.size();
    for ( i=0 ; i<s ; i++ ) {
        if ( user.myProcesses[i].pid  == newid && 
             user.myProcesses[i].name == newhost ) {
            if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
                cout << "Generated host:pid that already exists" << endl;
            }
            _activeProcess = i;
            return;
        }
    }
    // no it does not, so register it and use it
    user.myProcesses.push_back(User::HostAndPid(newhost, newid));
    _activeProcess = user.myProcesses.size() - 1;
    if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
        cout << "Created new process, offset " << _activeProcess
             << ", " << newhost << ":" << newid << endl;
    }
}

void
XrdMonSndDummyXrootd::createFile()
{
    _noCalls2NewFile = NEWFILEFREQUENCY;

    User& user = _users[_activeUser];
    vector<User::HostAndPid>& myProcesses = user.myProcesses;
    User::HostAndPid& hp = myProcesses[_activeProcess];
    vector<kXR_int16>& myFiles = hp.myFiles;

    // open new file
    kXR_int16 newOffset = (kXR_unt16) rand() % _paths.size();
    // check if it is already open
    int i, s = myFiles.size();
    for ( i=0 ; i<s ; i++ ) {
        if ( myFiles[i] == newOffset ) {
            if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
                cout << "Generated file descr that already exists" << endl;
            }
            _activeFile = i;
            return;
        }
    }
    // no it does not, so register it and use it
    myFiles.push_back(newOffset);
    _activeFile = myFiles.size() - 1;
    _newFile = true;
    if ( XrdMonSndDebug::verbose(XrdMonSndDebug::Generator) ) {
        PathData &pd = _paths[myFiles[_activeFile]];
        cout << "Created new file " << pd.path
             << " -> " << pd.fd << endl;
    }
}

string
XrdMonSndDummyXrootd::generateHostName()
{
    vector<string> type;
    type.push_back("barb");
    type.push_back("noma");
    type.push_back("tori");
    type.push_back("bronco");

    kXR_unt16 t = (kXR_unt16) rand() % 3;
    kXR_unt16 x = (kXR_unt16) rand() % MAXHOSTS;
    stringstream ss(stringstream::out);
    ss << type[t] << setw(4) << setfill('0') << x << ".slac.stanford.edu";

    return ss.str();
}

string
XrdMonSndDummyXrootd::generateUserName(kXR_int16 uid)
{
    stringstream ss;
    ss << "a_" << uid << "_User";
    return ss.str();
}

---