Skip to content

GitLab

Commit 06584642 authored by Giulia Taurelli's avatar Giulia Taurelli
Browse files

removed moved the mighunter and the rechandler in the tape directory. Deleted... 

removed moved the mighunter and the rechandler in the tape directory. Deleted infoPolicy code. Made mighunter/tapegateway/rechandler to use the thread safe python library contained in castor/tape/python
parent 79590caa
Hide whitespace changes
Inline Side-by-side
castor/Imakefile
View file @ 06584642
......@@ -36,7 +36,7 @@ STAGERSUPERGROUP0 = st
STAGERSUPERUSER = -DSTAGERSUPERUSER=\"$(STAGERSUPERUSER0)\"
STAGERSUPERGROUP = -DSTAGERSUPERGROUP=\"$(STAGERSUPERGROUP0)\"
SUBDIRS = db rh vdqm gc repack monitoring stager jobmanager job infoPolicy scheduler rtcopy tape
SUBDIRS = db rh vdqm gc repack monitoring stager jobmanager job scheduler tape
DEBUG = -g -O0
STAGEFLAGS = -DSTAGEMAP=\"StageMapFile\"
CFLAGS = $(DEBUG) -I ../h -I .. $(MTCCFLAGS) $(STAGEFLAGS)
......
castor/infoPolicy/CnsInfoMigrationPolicy.cpp deleted 100644 → 0
View file @ 79590caa
/**** This file has been autogenerated by gencastor from Umbrello UML model ***/
/******************************************************************************
* castor/infoPolicy/CnsInfoMigrationPolicy.cpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
*
* Copyright (C) 2003 CERN
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* @(#)$RCSfile$ $Revision$ $Release$ $Date$ $Author$
*
*
*
* @author Castor Dev team, castor-dev@cern.ch
*****************************************************************************/
// Include Files
#include "castor/Constants.hpp"
#include "castor/IObject.hpp"
#include "castor/ObjectSet.hpp"
#include "castor/infoPolicy/CnsInfoMigrationPolicy.hpp"
#include "osdep.h"
#include <iostream>
#include <string>
//------------------------------------------------------------------------------
// Constructor
//------------------------------------------------------------------------------
castor::infoPolicy::CnsInfoMigrationPolicy::CnsInfoMigrationPolicy() throw() :
m_fileId(0),
m_fileMode(0),
m_nlink(0),
m_uid(0),
m_gid(0),
m_fileSize(0),
m_aTime(0),
m_mTime(0),
m_cTime(0),
m_fileClass(0),
m_status(0),
m_id(0) {
}
//------------------------------------------------------------------------------
// Destructor
//------------------------------------------------------------------------------
castor::infoPolicy::CnsInfoMigrationPolicy::~CnsInfoMigrationPolicy() throw() {
}
//------------------------------------------------------------------------------
// print
//------------------------------------------------------------------------------
void castor::infoPolicy::CnsInfoMigrationPolicy::print(std::ostream& stream,
std::string indent,
castor::ObjectSet& alreadyPrinted) const {
stream << indent << "[# CnsInfoMigrationPolicy #]" << std::endl;
if (alreadyPrinted.find(this) != alreadyPrinted.end()) {
// Circular dependency, this object was already printed
stream << indent << "Back pointer, see above" << std::endl;
return;
}
// Output of all members
stream << indent << "fileId : " << m_fileId << std::endl;
stream << indent << "fileMode : " << m_fileMode << std::endl;
stream << indent << "nlink : " << m_nlink << std::endl;
stream << indent << "uid : " << m_uid << std::endl;
stream << indent << "gid : " << m_gid << std::endl;
stream << indent << "fileSize : " << m_fileSize << std::endl;
stream << indent << "aTime : " << m_aTime << std::endl;
stream << indent << "mTime : " << m_mTime << std::endl;
stream << indent << "cTime : " << m_cTime << std::endl;
stream << indent << "fileClass : " << m_fileClass << std::endl;
stream << indent << "status : " << m_status << std::endl;
stream << indent << "id : " << m_id << std::endl;
alreadyPrinted.insert(this);
}
//------------------------------------------------------------------------------
// print
//------------------------------------------------------------------------------
void castor::infoPolicy::CnsInfoMigrationPolicy::print() const {
castor::ObjectSet alreadyPrinted;
print(std::cout, "", alreadyPrinted);
}
//------------------------------------------------------------------------------
// TYPE
//------------------------------------------------------------------------------
int castor::infoPolicy::CnsInfoMigrationPolicy::TYPE() {
return OBJ_CnsInfoMigrationPolicy;
}
//------------------------------------------------------------------------------
// type
//------------------------------------------------------------------------------
int castor::infoPolicy::CnsInfoMigrationPolicy::type() const {
return TYPE();
}
//------------------------------------------------------------------------------
// clone
//------------------------------------------------------------------------------
castor::IObject* castor::infoPolicy::CnsInfoMigrationPolicy::clone() {
return new CnsInfoMigrationPolicy(*this);
}
castor/infoPolicy/CnsInfoMigrationPolicy.hpp deleted 100644 → 0
View file @ 79590caa
/**** This file has been autogenerated by gencastor from Umbrello UML model ***/
/******************************************************************************
* castor/infoPolicy/CnsInfoMigrationPolicy.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
*
* Copyright (C) 2003 CERN
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* @(#)$RCSfile$ $Revision$ $Release$ $Date$ $Author$
*
*
*
* @author Castor Dev team, castor-dev@cern.ch
*****************************************************************************/
#ifndef CASTOR_INFOPOLICY_CNSINFOMIGRATIONPOLICY_HPP
#define CASTOR_INFOPOLICY_CNSINFOMIGRATIONPOLICY_HPP
// Include Files
#include "castor/infoPolicy/CnsInfoPolicy.hpp"
#include "osdep.h"
#include <iostream>
#include <string>
namespace castor {
// Forward declarations
class ObjectSet;
class IObject;
namespace infoPolicy {
/**
* class CnsInfoMigrationPolicy
*/
class CnsInfoMigrationPolicy : public virtual CnsInfoPolicy {
public:
/**
* Empty Constructor
*/
CnsInfoMigrationPolicy() throw();
/**
* Empty Destructor
*/
virtual ~CnsInfoMigrationPolicy() throw();
/**
* Outputs this object in a human readable format
* @param stream The stream where to print this object
* @param indent The indentation to use
* @param alreadyPrinted The set of objects already printed.
* This is to avoid looping when printing circular dependencies
*/
virtual void print(std::ostream& stream,
std::string indent,
castor::ObjectSet& alreadyPrinted) const;
/**
* Outputs this object in a human readable format
*/
virtual void print() const;
/**
* Gets the type of this kind of objects
*/
static int TYPE();
/********************************************/
/* Implementation of IObject abstract class */
/********************************************/
/**
* Gets the type of the object
*/
virtual int type() const;
/**
* virtual method to clone any object
*/
virtual castor::IObject* clone();
/*********************************/
/* End of IObject abstract class */
/*********************************/
/**
* Get the value of m_fileId
* @return the value of m_fileId
*/
u_signed64 fileId() const {
return m_fileId;
}
/**
* Set the value of m_fileId
* @param new_var the new value of m_fileId
*/
void setFileId(u_signed64 new_var) {
m_fileId = new_var;
}
/**
* Get the value of m_fileMode
* @return the value of m_fileMode
*/
u_signed64 fileMode() const {
return m_fileMode;
}
/**
* Set the value of m_fileMode
* @param new_var the new value of m_fileMode
*/
void setFileMode(u_signed64 new_var) {
m_fileMode = new_var;
}
/**
* Get the value of m_nlink
* @return the value of m_nlink
*/
int nlink() const {
return m_nlink;
}
/**
* Set the value of m_nlink
* @param new_var the new value of m_nlink
*/
void setNlink(int new_var) {
m_nlink = new_var;
}
/**
* Get the value of m_uid
* @return the value of m_uid
*/
u_signed64 uid() const {
return m_uid;
}
/**
* Set the value of m_uid
* @param new_var the new value of m_uid
*/
void setUid(u_signed64 new_var) {
m_uid = new_var;
}
/**
* Get the value of m_gid
* @return the value of m_gid
*/
u_signed64 gid() const {
return m_gid;
}
/**
* Set the value of m_gid
* @param new_var the new value of m_gid
*/
void setGid(u_signed64 new_var) {
m_gid = new_var;
}
/**
* Get the value of m_fileSize
* @return the value of m_fileSize
*/
u_signed64 fileSize() const {
return m_fileSize;
}
/**
* Set the value of m_fileSize
* @param new_var the new value of m_fileSize
*/
void setFileSize(u_signed64 new_var) {
m_fileSize = new_var;
}
/**
* Get the value of m_aTime
* @return the value of m_aTime
*/
u_signed64 aTime() const {
return m_aTime;
}
/**
* Set the value of m_aTime
* @param new_var the new value of m_aTime
*/
void setATime(u_signed64 new_var) {
m_aTime = new_var;
}
/**
* Get the value of m_mTime
* @return the value of m_mTime
*/
u_signed64 mTime() const {
return m_mTime;
}
/**
* Set the value of m_mTime
* @param new_var the new value of m_mTime
*/
void setMTime(u_signed64 new_var) {
m_mTime = new_var;
}
/**
* Get the value of m_cTime
* @return the value of m_cTime
*/
u_signed64 cTime() const {
return m_cTime;
}
/**
* Set the value of m_cTime
* @param new_var the new value of m_cTime
*/
void setCTime(u_signed64 new_var) {
m_cTime = new_var;
}
/**
* Get the value of m_fileClass
* @return the value of m_fileClass
*/
int fileClass() const {
return m_fileClass;
}
/**
* Set the value of m_fileClass
* @param new_var the new value of m_fileClass
*/
void setFileClass(int new_var) {
m_fileClass = new_var;
}
/**
* Get the value of m_status
* @return the value of m_status
*/
unsigned char status() const {
return m_status;
}
/**
* Set the value of m_status
* @param new_var the new value of m_status
*/
void setStatus(unsigned char new_var) {
m_status = new_var;
}
/**
* Get the value of m_id
* The id of this object
* @return the value of m_id
*/
u_signed64 id() const {
return m_id;
}
/**
* Set the value of m_id
* The id of this object
* @param new_var the new value of m_id
*/
void setId(u_signed64 new_var) {
m_id = new_var;
}
private:
u_signed64 m_fileId;
u_signed64 m_fileMode;
int m_nlink;
u_signed64 m_uid;
u_signed64 m_gid;
u_signed64 m_fileSize;
u_signed64 m_aTime;
u_signed64 m_mTime;
u_signed64 m_cTime;
int m_fileClass;
unsigned char m_status;
/// The id of this object
u_signed64 m_id;
}; /* end of class CnsInfoMigrationPolicy */
} /* end of namespace infoPolicy */
} /* end of namespace castor */
#endif // CASTOR_INFOPOLICY_CNSINFOMIGRATIONPOLICY_HPP
castor/infoPolicy/CnsInfoPolicy.hpp deleted 100644 → 0
View file @ 79590caa
/**** This file has been autogenerated by gencastor from Umbrello UML model ***/
/******************************************************************************
* castor/infoPolicy/CnsInfoPolicy.hpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
*
* Copyright (C) 2003 CERN
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* @(#)$RCSfile$ $Revision$ $Release$ $Date$ $Author$
*
*
*
* @author Castor Dev team, castor-dev@cern.ch
*****************************************************************************/
#ifndef CASTOR_INFOPOLICY_CNSINFOPOLICY_HPP
#define CASTOR_INFOPOLICY_CNSINFOPOLICY_HPP
// Include Files
#include "castor/IObject.hpp"
#include <iostream>
#include <string>
namespace castor {
// Forward declarations
class ObjectSet;
namespace infoPolicy {
// Forward declarations
class PolicyObj;
/**
* class CnsInfoPolicy
*/
class CnsInfoPolicy : public virtual castor::IObject {
public:
/**
* Empty Destructor
*/
virtual ~CnsInfoPolicy() throw() {};
/**
* Outputs this object in a human readable format
* @param stream The stream where to print this object
* @param indent The indentation to use
* @param alreadyPrinted The set of objects already printed.
* This is to avoid looping when printing circular dependencies
*/
virtual void print(std::ostream& stream,
std::string indent,
castor::ObjectSet& alreadyPrinted) const = 0;
/**
* Outputs this object in a human readable format
*/
virtual void print() const = 0;
/**
* Get the value of m_policyObject
* @return the value of m_policyObject
*/
PolicyObj* policyObject() const {
return m_policyObject;
}
/**
* Set the value of m_policyObject
* @param new_var the new value of m_policyObject
*/
void setPolicyObject(PolicyObj* new_var) {
m_policyObject = new_var;
}
private:
PolicyObj* m_policyObject;
}; /* end of class CnsInfoPolicy */
} /* end of namespace infoPolicy */
} /* end of namespace castor */
#endif // CASTOR_INFOPOLICY_CNSINFOPOLICY_HPP
castor/infoPolicy/DbInfoMigrationPolicy.cpp deleted 100644 → 0
View file @ 79590caa
<
/**** This file has been autogenerated by gencastor from Umbrello UML model ***/
/******************************************************************************
* castor/infoPolicy/DbInfoMigrationPolicy.cpp
*
* This file is part of the Castor project.
* See http://castor.web.cern.ch/castor
*
* Copyright (C) 2003 CERN
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*
* @(#)$RCSfile$ $Revision$ $Release$ $Date$ $Author$
*
*
*
* @author Castor Dev team, castor-dev@cern.ch
*****************************************************************************/
// Include Files
#include "castor/Constants.hpp"
#include "castor/IObject.hpp"
#include "castor/ObjectSet.hpp"
#include "castor/infoPolicy/DbInfoMigrationPolicy.hpp"
#include "osdep.h"
#include <iostream>
#include <string>
//------------------------------------------------------------------------------
// Constructor
//------------------------------------------------------------------------------
castor::infoPolicy::DbInfoMigrationPolicy::DbInfoMigrationPolicy() throw() :
m_tapeCopyId(0),
m_copyNb(0),
m_castorFileName(""),
m_fileId(0),
m_tapePoolName(""),
m_nsHost(""),
m_tapePoolId(0),
m_id(0) {
}
//------------------------------------------------------------------------------
// Destructor
//------------------------------------------------------------------------------
castor::infoPolicy::DbInfoMigrationPolicy::~DbInfoMigrationPolicy() throw() {
}
//------------------------------------------------------------------------------
// print
//------------------------------------------------------------------------------