Main Page | Namespace List | Class Hierarchy | Class List | Directories | File List | Namespace Members | Class Members | File Members

VestaSourceAtomic Class Reference

#include <VestaSourceAtomic.H>

List of all members.

Public Types

typedef int VSIndex

Public Member Functions

 VestaSourceAtomic (AccessControl::Identity who=NULL) throw (SRPC::failure)
 VestaSourceAtomic (const Text &host, const Text &port, AccessControl::Identity who=NULL) throw (SRPC::failure)
 ~VestaSourceAtomic () throw ()
void setTarget (const Text &stepname, VestaSource::errorCode target1=VestaSource::ok, VestaSource::errorCode target2=VestaSource::ok, VestaSource::errorCode okreplace=VestaSource::ok) throw (SRPC::failure)
VSIndex decl (const Text &stepname, VestaSource *vs) throw (SRPC::failure)
void resync (const Text &stepname, VSIndex vsi) throw (SRPC::failure)
void setTimestamp (const Text &stepname, VSIndex vsi, time_t ts) throw (SRPC::failure)
VSIndex lookup (const Text &stepname, VSIndex vsi, const Text &arc) throw (SRPC::failure)
VSIndex lookupPathname (const Text &stepname, VSIndex vsi, const Text &pathname, char pathnameSep=PathnameSep) throw (SRPC::failure)
VSIndex lookupIndex (const Text &stepname, VSIndex vsi, unsigned int index) throw (SRPC::failure)
void reallyDelete (const Text &stepname, VSIndex vsi, const Text &arc, bool existCheck=true, time_t timestamp=0) throw (SRPC::failure)
VSIndex insertFile (const Text &stepname, VSIndex vsi, const Text &arc, ShortId sid, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0, FP::Tag *fptag=NULL) throw (SRPC::failure)
VSIndex insertMutableFile (const Text &stepname, VSIndex vsi, const Text &arc, ShortId sid, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0, FP::Tag *fptag=NULL) throw (SRPC::failure)
VSIndex insertImmutableDirectory (const Text &stepname, VSIndex parenti, const Text &arc, VSIndex diri, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0, FP::Tag *fptag=NULL) throw (SRPC::failure)
VSIndex insertAppendableDirectory (const Text &stepname, VSIndex vsi, const Text &arc, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
VSIndex insertMutableDirectory (const Text &stepname, VSIndex parenti, const Text &arc, VSIndex diri, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
VSIndex insertGhost (const Text &stepname, VSIndex vsi, const Text &arc, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
VSIndex insertStub (const Text &stepname, VSIndex vsi, const Text &arc, bool master, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
void renameTo (const Text &stepname, VSIndex vsi, const Text &arc, VSIndex fromDirI, const Text &fromArc, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
void makeFilesImmutable (const Text &stepname, VSIndex vsi, unsigned int threshold) throw (SRPC::failure)
void testMaster (const Text &stepname, VSIndex vsi, bool master, VestaSource::errorCode err) throw (SRPC::failure)
void setMaster (const Text &stepname, VSIndex vsi, bool state) throw (SRPC::failure)
void inAttribs (const Text &stepname, VSIndex vsi, const Text &name, const Text &value, bool expected, VestaSource::errorCode err) throw (SRPC::failure)
void setAttrib (const Text &stepname, VSIndex vsi, const Text &name, const Text &value, time_t timestamp=0) throw (SRPC::failure)
void clearAttrib (const Text &stepname, VSIndex vsi, const Text &name, time_t timestamp=0) throw (SRPC::failure)
void addAttrib (const Text &stepname, VSIndex vsi, const Text &name, const Text &value, time_t timestamp=0) throw (SRPC::failure)
void removeAttrib (const Text &stepname, VSIndex vsi, const Text &name, const Text &value, time_t timestamp=0) throw (SRPC::failure)
void writeAttrib (const Text &stepname, VSIndex vsi, VestaSource::attribOp op, const Text &name, const Text &value, time_t timestamp=0) throw (SRPC::failure)
void mergeAttrib (const Text &stepname, VSIndex fromvsi, VSIndex tovsi, const Text &name, time_t timestamp=0) throw (SRPC::failure)
void accessCheck (const Text &stepname, VSIndex vsi, AccessControl::Class cls, bool expected, VestaSource::errorCode err) throw (SRPC::failure)
void typeCheck (const Text &stepname, VSIndex vsi, unsigned int allowed, VestaSource::errorCode err) throw (SRPC::failure)
bool run () throw (SRPC::failure)
void cancel () throw (SRPC::failure)
Text name (int step) throw ()

Static Public Member Functions

static unsigned int typebit (VestaSource::typeTag type)

Public Attributes

int nsteps
VSIndex nobjects
VestaSource::errorCode target1
VestaSource::errorCode target2
int ndone
VestaSource::errorCode lasterr
VestaSource::errorCode okreplace

Private Types

typedef Sequence< Text > NameSeq

Private Attributes

SRPC * srpc
MultiSRPC::ConnId id
NameSeq * names

Member Typedef Documentation

typedef Sequence<Text> VestaSourceAtomic::NameSeq [private]
 

Definition at line 340 of file VestaSourceAtomic.H.

typedef int VestaSourceAtomic::VSIndex
 

Definition at line 122 of file VestaSourceAtomic.H.

Constructor & Destructor Documentation

VestaSourceAtomic::VestaSourceAtomic (  AccessControl::Identity  who = NULL  )  throw (SRPC::failure)
 

Definition at line 37 of file VestaSourceAtomic.C.

References VestaSourceSRPC::Atomic, NEW, VRErrorCode::ok, VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), and VestaSourceSRPC::version.

VestaSourceAtomic::VestaSourceAtomic (  const Text &  host,
const Text &  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure)
 

Definition at line 55 of file VestaSourceAtomic.C.

References VestaSourceSRPC::Atomic, NEW, VRErrorCode::ok, VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), and VestaSourceSRPC::version.

VestaSourceAtomic::~VestaSourceAtomic (   )  throw ()
 

Definition at line 75 of file VestaSourceAtomic.C.

References cancel().

Member Function Documentation

void VestaSourceAtomic::accessCheck (  const Text &  stepname,
VSIndex  vsi,
AccessControl::Class  cls,
bool  expected,
VestaSource::errorCode  err
)  throw (SRPC::failure)
 

Definition at line 534 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicAccessCheck.

Referenced by main().

void VestaSourceAtomic::addAttrib (  const Text &  stepname,
VSIndex  vsi,
const Text &  name,
const Text &  value,
time_t  timestamp = 0
)  throw (SRPC::failure) [inline]
 

Definition at line 274 of file VestaSourceAtomic.H.

References VestaAttribs::opAdd, and writeAttrib().

Referenced by main().

void VestaSourceAtomic::cancel (   )  throw (SRPC::failure)
 

Definition at line 111 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicCancel, VestaSourceSRPC::End(), names, and srpc.

Referenced by ~VestaSourceAtomic().

void VestaSourceAtomic::clearAttrib (  const Text &  stepname,
VSIndex  vsi,
const Text &  name,
time_t  timestamp = 0
)  throw (SRPC::failure) [inline]
 

Definition at line 270 of file VestaSourceAtomic.H.

References VestaAttribs::opClear, and writeAttrib().

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::decl (  const Text &  stepname,
VestaSource *  vs
)  throw (SRPC::failure)
 

Definition at line 159 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicDeclare.

Referenced by main().

void VestaSourceAtomic::inAttribs (  const Text &  stepname,
VSIndex  vsi,
const Text &  name,
const Text &  value,
bool  expected,
VestaSource::errorCode  err
)  throw (SRPC::failure)
 

Definition at line 481 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InAttribs.

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertAppendableDirectory (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 335 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertAppendableDirectory.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertFile (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
ShortId  sid,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0,
FP::Tag *  fptag = NULL
)  throw (SRPC::failure)
 

Definition at line 259 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertFile.

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertGhost (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 379 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertGhost.

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertImmutableDirectory (  const Text &  stepname,
VSIndex  parenti,
const Text &  arc,
VSIndex  diri,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0,
FP::Tag *  fptag = NULL
)  throw (SRPC::failure)
 

Definition at line 308 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertImmutableDirectory.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertMutableDirectory (  const Text &  stepname,
VSIndex  parenti,
const Text &  arc,
VSIndex  diri,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 356 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertMutableDirectory.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertMutableFile (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
ShortId  sid,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0,
FP::Tag *  fptag = NULL
)  throw (SRPC::failure)
 

Definition at line 286 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertMutableFile.

VestaSourceAtomic::VSIndex VestaSourceAtomic::insertStub (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
bool  master,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 399 of file VestaSourceAtomic.C.

References VestaSourceSRPC::InsertStub.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::lookup (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc
)  throw (SRPC::failure)
 

Definition at line 196 of file VestaSourceAtomic.C.

References VestaSourceSRPC::Lookup.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::lookupIndex (  const Text &  stepname,
VSIndex  vsi,
unsigned int  index
)  throw (SRPC::failure)
 

Definition at line 227 of file VestaSourceAtomic.C.

References VestaSourceSRPC::LookupIndex.

Referenced by main().

VestaSourceAtomic::VSIndex VestaSourceAtomic::lookupPathname (  const Text &  stepname,
VSIndex  vsi,
const Text &  pathname,
char  pathnameSep = PathnameSep
)  throw (SRPC::failure)
 

Definition at line 210 of file VestaSourceAtomic.C.

References VestaSourceSRPC::LookupPathname.

Referenced by main().

void VestaSourceAtomic::makeFilesImmutable (  const Text &  stepname,
VSIndex  vsi,
unsigned int  threshold
)  throw (SRPC::failure)
 

Definition at line 440 of file VestaSourceAtomic.C.

References VestaSourceSRPC::MakeFilesImmutable.

void VestaSourceAtomic::mergeAttrib (  const Text &  stepname,
VSIndex  fromvsi,
VSIndex  tovsi,
const Text &  name,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 517 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicMergeAttrib.

Referenced by main().

Text VestaSourceAtomic::name (  int  step  )  throw ()
 

Definition at line 130 of file VestaSourceAtomic.C.

Referenced by main().

void VestaSourceAtomic::reallyDelete (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
bool  existCheck = true,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 242 of file VestaSourceAtomic.C.

References VestaSourceSRPC::ReallyDelete.

Referenced by main().

void VestaSourceAtomic::removeAttrib (  const Text &  stepname,
VSIndex  vsi,
const Text &  name,
const Text &  value,
time_t  timestamp = 0
)  throw (SRPC::failure) [inline]
 

Definition at line 279 of file VestaSourceAtomic.H.

References VestaAttribs::opRemove, and writeAttrib().

void VestaSourceAtomic::renameTo (  const Text &  stepname,
VSIndex  vsi,
const Text &  arc,
VSIndex  fromDirI,
const Text &  fromArc,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 419 of file VestaSourceAtomic.C.

References VestaSourceSRPC::RenameTo.

void VestaSourceAtomic::resync (  const Text &  stepname,
VSIndex  vsi
)  throw (SRPC::failure)
 

Definition at line 172 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicResync.

bool VestaSourceAtomic::run (   )  throw (SRPC::failure)
 

Definition at line 88 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicRun, VestaSourceSRPC::End(), lasterr, ndone, okreplace, SRPC::recv_end(), SRPC::recv_int(), SRPC::send_end(), SRPC::send_int(), and srpc.

Referenced by main().

void VestaSourceAtomic::setAttrib (  const Text &  stepname,
VSIndex  vsi,
const Text &  name,
const Text &  value,
time_t  timestamp = 0
)  throw (SRPC::failure) [inline]
 

Definition at line 264 of file VestaSourceAtomic.H.

References VestaAttribs::opSet, and writeAttrib().

Referenced by main().

void VestaSourceAtomic::setMaster (  const Text &  stepname,
VSIndex  vsi,
bool  state
)  throw (SRPC::failure)
 

Definition at line 468 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicSetMaster.

void VestaSourceAtomic::setTarget (  const Text &  stepname,
VestaSource::errorCode  target1 = VestaSource::ok,
VestaSource::errorCode  target2 = VestaSource::ok,
VestaSource::errorCode  okreplace = VestaSource::ok
)  throw (SRPC::failure)
 

Definition at line 137 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicTarget.

Referenced by main().

void VestaSourceAtomic::setTimestamp (  const Text &  stepname,
VSIndex  vsi,
time_t  ts
)  throw (SRPC::failure)
 

Definition at line 183 of file VestaSourceAtomic.C.

References VestaSourceSRPC::SetTimestamp.

void VestaSourceAtomic::testMaster (  const Text &  stepname,
VSIndex  vsi,
bool  master,
VestaSource::errorCode  err
)  throw (SRPC::failure)
 

Definition at line 454 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicTestMaster.

Referenced by main().

static unsigned int VestaSourceAtomic::typebit (  VestaSource::typeTag  type  )  [inline, static]
 

Definition at line 305 of file VestaSourceAtomic.H.

Referenced by TypeCheckStep::execute().

void VestaSourceAtomic::typeCheck (  const Text &  stepname,
VSIndex  vsi,
unsigned int  allowed,
VestaSource::errorCode  err
)  throw (SRPC::failure)
 

Definition at line 550 of file VestaSourceAtomic.C.

References VestaSourceSRPC::AtomicTypeCheck.

Referenced by main().

void VestaSourceAtomic::writeAttrib (  const Text &  stepname,
VSIndex  vsi,
VestaSource::attribOp  op,
const Text &  name,
const Text &  value,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 499 of file VestaSourceAtomic.C.

References VestaSourceSRPC::WriteAttrib.

Referenced by addAttrib(), clearAttrib(), removeAttrib(), and setAttrib().

Member Data Documentation

MultiSRPC::ConnId VestaSourceAtomic::id [private]
 

Definition at line 339 of file VestaSourceAtomic.H.

VestaSource::errorCode VestaSourceAtomic::lasterr
 

Definition at line 138 of file VestaSourceAtomic.H.

Referenced by main(), and run().

NameSeq* VestaSourceAtomic::names [private]
 

Definition at line 341 of file VestaSourceAtomic.H.

Referenced by cancel().

int VestaSourceAtomic::ndone
 

Definition at line 136 of file VestaSourceAtomic.H.

Referenced by main(), and run().

VSIndex VestaSourceAtomic::nobjects
 

Definition at line 131 of file VestaSourceAtomic.H.

int VestaSourceAtomic::nsteps
 

Definition at line 129 of file VestaSourceAtomic.H.

VestaSource::errorCode VestaSourceAtomic::okreplace
 

Definition at line 140 of file VestaSourceAtomic.H.

Referenced by main(), and run().

SRPC* VestaSourceAtomic::srpc [private]
 

Definition at line 338 of file VestaSourceAtomic.H.

Referenced by cancel(), and run().

VestaSource::errorCode VestaSourceAtomic::target1
 

Definition at line 133 of file VestaSourceAtomic.H.

VestaSource::errorCode VestaSourceAtomic::target2
 

Definition at line 133 of file VestaSourceAtomic.H.

The documentation for this class was generated from the following files:
Generated on Mon May 8 00:49:16 2006 for Vesta by  doxygen 1.4.2