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

VDirSurrogate Class Reference

#include <VDirSurrogate.H>

Inheritance diagram for VDirSurrogate:

VestaSource VestaAttribs VRErrorCode List of all members.

Public Member Functions

Text host () throw ()
Text port () throw ()
 VDirSurrogate (time_t timestamp, ShortId sid, const Text host_="", const Text port_="", int executable=-1, Basics::uint64 size=(Basics::uint64)-1) throw (SRPC::failure)
void resync (AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode read (void *buffer, int *nbytes, Basics::uint64 offset, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode readWhole (std::ostream &out, AccessControl::Identity who=NULL) throw (SRPC::failure)
time_t timestamp () throw (SRPC::failure)
bool executable () throw (SRPC::failure)
Basics::uint64 size () throw (SRPC::failure)
ShortId shortId () throw (SRPC::failure)
VestaSource::errorCode lookup (Arc arc, VestaSource *&result, AccessControl::Identity who=NULL, unsigned int indexOffset=0) throw (SRPC::failure)
VestaSource::errorCode lookupIndex (unsigned int index, VestaSource *&result, char *arcbuf=NULL) throw (SRPC::failure)
VestaSource::errorCode lookupPathname (const char *pathname, VestaSource *&result, AccessControl::Identity who=NULL, char pathnameSep=PathnameSep) throw (SRPC::failure)
VestaSource::errorCode getBase (VestaSource *&result, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode list (unsigned int firstIndex, VestaSource::listCallback callback, void *closure, AccessControl::Identity who=NULL, bool deltaOnly=false, unsigned int indexOffset=0)
VestaSource::errorCode write (const void *buffer, int *nbytes, Basics::uint64 offset, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode setExecutable (bool x, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode setSize (Basics::uint64 s, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode setTimestamp (time_t ts, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode reallyDelete (Arc arc, AccessControl::Identity who=NULL, bool existCheck=true, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode insertFile (Arc arc, ShortId sid, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0, FP::Tag *fptag=NULL) throw (SRPC::failure)
VestaSource::errorCode insertMutableFile (Arc arc, ShortId sid, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode insertImmutableDirectory (Arc arc, VestaSource *dir, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0, FP::Tag *fptag=NULL) throw (SRPC::failure)
VestaSource::errorCode insertAppendableDirectory (Arc arc, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode insertMutableDirectory (Arc arc, VestaSource *dir, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode insertGhost (Arc arc, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode insertStub (Arc arc, bool master, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, VestaSource **newvs=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode renameTo (Arc arc, VestaSource *fromDir, Arc fromArc, AccessControl::Identity who=NULL, VestaSource::dupeCheck chk=VestaSource::dontReplace, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode makeMutable (VestaSource *&result, ShortId sid=NullShortId, Basics::uint64 copyMax=(Basics::uint64)-1, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode makeFilesImmutable (unsigned int threshold, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode setIndexMaster (unsigned int index, bool state, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode setMaster (bool state, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode cedeMastership (const char *requestid, const char **grantidOut, AccessControl::Identity who=NULL) throw (SRPC::failure)
bool inAttribs (const char *name, const char *value) throw (SRPC::failure)
char * getAttrib (const char *name) throw (SRPC::failure)
void getAttrib (const char *name, VestaSource::valueCallback cb, void *cl)
void listAttribs (VestaSource::valueCallback cb, void *cl)
void getAttribHistory (VestaSource::historyCallback cb, void *cl)
VestaSource::errorCode writeAttrib (VestaSource::attribOp op, const char *name, const char *value, AccessControl::Identity who=NULL, time_t timestamp=0) throw (SRPC::failure)
VestaSource::errorCode measureDirectory (VestaSource::directoryStats &result, AccessControl::Identity who=NULL) throw (SRPC::failure)
VestaSource::errorCode collapseBase (AccessControl::Identity who=NULL) throw (SRPC::failure)
virtual VestaSource * copy () throw ()

Static Public Member Functions

static Text defaultHost () throw ()
static Text defaultPort () throw ()
static VestaSource::errorCode createVolatileDirectory (const char *host, const char *port, Bit64 handle, VestaSource *&result, time_t timestamp=0, bool readOnlyExisting=true, Text reposHost="", Text reposPort="") throw (SRPC::failure)
static VestaSource::errorCode createVolatileDirectory (const char *host, Bit64 handle, VestaSource *&result, time_t timestamp=0, bool readOnlyExisting=true, Text reposHost="", Text reposPort="") throw (SRPC::failure)
static VestaSource::errorCode deleteVolatileDirectory (VestaSource *dir) throw (SRPC::failure)
static void getNFSInfo (char *&socket, LongId &root, LongId &muRoot) throw (SRPC::failure)
static ShortId fpToShortId (const FP::Tag &fptag, Text host, Text port) throw (SRPC::failure)
static VestaSource * repositoryRoot (Text host, Text port, AccessControl::Identity who=NULL) throw (SRPC::failure)
static VestaSource * mutableRoot (Text host, Text port, AccessControl::Identity who=NULL) throw (SRPC::failure)
static VestaSource * volatileRoot (Text host, Text port, AccessControl::Identity who=NULL) throw (SRPC::failure)
static VestaSource * LongIdLookup (LongId longid, Text host, Text port, AccessControl::Identity who=NULL) throw (SRPC::failure)
static bool LongIdValid (LongId longid, Text host, Text port, AccessControl::Identity who=NULL) throw (SRPC::failure)
static VestaSource::errorCode acquireMastership (const char *pathname, Text dstHost="", Text dstPort="", Text srcHost="", Text srcPort="", char pathnameSep=PathnameSep, AccessControl::Identity dwho=NULL, AccessControl::Identity swho=NULL) throw (SRPC::failure)
static VestaSource::errorCode replicate (const char *pathname, bool asStub=false, bool asGhost=false, Text dstHost="", Text dstPort="", Text srcHost="", Text srcPort="", char pathnameSep=PathnameSep, AccessControl::Identity dwho=NULL, AccessControl::Identity swho=NULL) throw (SRPC::failure)
static VestaSource::errorCode replicateAttribs (const char *pathname, bool includeAccess=true, Text dstHost="", Text dstPort="", Text srcHost="", Text srcPort="", char pathnameSep=PathnameSep, AccessControl::Identity dwho=NULL, AccessControl::Identity swho=NULL) throw (SRPC::failure)
static void getUserInfo (AccessControl::IdInfo &result, AccessControl::Identity who=NULL, AccessControl::Identity subject=NULL, Text reposHost="", Text reposPort="") throw (SRPC::failure)
static void refreshAccessTables (AccessControl::Identity who=NULL, Text reposHost="", Text reposPort="") throw (SRPC::failure)

Private Attributes

time_t timestampCache
ShortId sidCache
int executableCache
Basics::uint64 sizeCache
Text host_
Text port_

Friends

void VDirSurrogate_init ()
void VDirSurrogate_init2 ()

Constructor & Destructor Documentation

VDirSurrogate::VDirSurrogate (  time_t  timestamp,
ShortId  sid,
const Text  host_ = "",
const Text  port_ = "",
int  executable = -1,
Basics::uint64  size = (Basics::uint64)-1
)  throw (SRPC::failure)
 

Definition at line 107 of file VDirSurrogate.C.

References VestaSourceSRPC::defaultHost(), and VDirSurrogateInit().

Member Function Documentation

VestaSource::errorCode VDirSurrogate::acquireMastership (  const char *  pathname,
Text  dstHost = "",
Text  dstPort = "",
Text  srcHost = "",
Text  srcPort = "",
char  pathnameSep = PathnameSep,
AccessControl::Identity  dwho = NULL,
AccessControl::Identity  swho = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 509 of file VDirSurrogate.C.

References VestaSourceSRPC::AcquireMastership, VestaSourceSRPC::End(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by main().

VestaSource::errorCode VDirSurrogate::cedeMastership (  const char *  requestid,
const char **  grantidOut,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1723 of file VDirSurrogate.C.

References VestaSourceSRPC::CedeMastership, VestaSourceSRPC::End(), VRErrorCode::ok, SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::collapseBase (  AccessControl::Identity  who = NULL  )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1969 of file VDirSurrogate.C.

References VestaSourceSRPC::CollapseBase, VestaSourceSRPC::End(), SRPC::send_bytes(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource * VDirSurrogate::copy (   )  throw () [virtual]
 

Reimplemented from VestaSource.

Definition at line 2115 of file VDirSurrogate.C.

References NEW_CONSTR.

VestaSource::errorCode VDirSurrogate::createVolatileDirectory (  const char *  host,
Bit64  handle,
VestaSource *&  result,
time_t  timestamp = 0,
bool  readOnlyExisting = true,
Text  reposHost = "",
Text  reposPort = ""
)  throw (SRPC::failure) [static]
 

Definition at line 292 of file VDirSurrogate.C.

References Text::cchars(), createVolatileDirectory(), Text::Empty(), VestaConfig::get_Text(), and VestaConfig::failure::msg.

VestaSource::errorCode VDirSurrogate::createVolatileDirectory (  const char *  host,
const char *  port,
Bit64  handle,
VestaSource *&  result,
time_t  timestamp = 0,
bool  readOnlyExisting = true,
Text  reposHost = "",
Text  reposPort = ""
)  throw (SRPC::failure) [static]
 

Definition at line 318 of file VDirSurrogate.C.

References VestaSourceSRPC::CreateVolatileDirectory, VestaSourceSRPC::End(), NEW_CONSTR, VRErrorCode::ok, SRPC::send_bytes(), SRPC::send_chars(), SRPC::send_end(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

Referenced by CreateRootForDeriveds(), createVolatileDirectory(), RunTool(), and test_thread().

Text VDirSurrogate::defaultHost (   )  throw () [static]
 

Definition at line 96 of file VDirSurrogate.C.

References VestaSourceSRPC::defaultHost().

Referenced by VestaSource::host(), LongId::lookup(), main(), MastershipInit1(), LongId::valid(), and VDirSurrogate_init2().

Text VDirSurrogate::defaultPort (   )  throw () [static]
 

Definition at line 102 of file VDirSurrogate.C.

References VestaSourceSRPC::defaultInterface().

Referenced by LongId::lookup(), main(), MastershipInit1(), VestaSource::port(), LongId::valid(), and VDirSurrogate_init2().

VestaSource::errorCode VDirSurrogate::deleteVolatileDirectory (  VestaSource *  dir  )  throw (SRPC::failure) [static]
 

Definition at line 373 of file VDirSurrogate.C.

References VestaSourceSRPC::DeleteVolatileDirectory, VestaSourceSRPC::End(), host_, port_, SRPC::recv_end(), SRPC::recv_int(), SRPC::send_bytes(), SRPC::send_end(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

Referenced by DeleteRootForDeriveds(), DeleteRootForTool(), and test_thread().

bool VDirSurrogate::executable (   )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1802 of file VDirSurrogate.C.

References executableCache, sizeCache, and timestampCache.

ShortId VDirSurrogate::fpToShortId (  const FP::Tag &  fptag,
Text  host,
Text  port
)  throw (SRPC::failure) [static]
 

Definition at line 415 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::FPToShortId, FP::Tag::Send(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by test_thread().

void VDirSurrogate::getAttrib (  const char *  name,
VestaSource::valueCallback  cb,
void *  cl
) 
 

Definition at line 1506 of file VDirSurrogate.C.

References Sequence< Elem, elem_ptrfree >::addhi(), VestaSourceSRPC::End(), VestaSourceSRPC::GetAttrib2, host_, port_, SRPC::recv_chars(), SRPC::recv_end(), SRPC::recv_seq_end(), SRPC::recv_seq_start(), Sequence< Elem, elem_ptrfree >::remlo(), SRPC::send_bytes(), SRPC::send_chars(), SRPC::send_end(), Sequence< Elem, elem_ptrfree >::size(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

char * VDirSurrogate::getAttrib (  const char *  name  )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaAttribs.

Definition at line 1476 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::GetAttrib, SRPC::recv_chars(), SRPC::recv_end(), SRPC::recv_int(), SRPC::send_bytes(), SRPC::send_chars(), SRPC::send_end(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

void VDirSurrogate::getAttribHistory (  VestaSource::historyCallback  cb,
void *  cl
) 
 

Definition at line 1578 of file VDirSurrogate.C.

References Sequence< Elem, elem_ptrfree >::addhi(), VestaSourceSRPC::End(), VestaSourceSRPC::GetAttribHistory, host_, AttribHistoryResultItem::name, AttribHistoryResultItem::op, port_, SRPC::recv_chars(), SRPC::recv_end(), SRPC::recv_int(), SRPC::recv_seq_end(), SRPC::recv_seq_start(), Sequence< Elem, elem_ptrfree >::remlo(), SRPC::send_bytes(), SRPC::send_end(), Sequence< Elem, elem_ptrfree >::size(), VestaSourceSRPC::Start(), SRPC::start_call(), AttribHistoryResultItem::timestamp, AttribHistoryResultItem::value, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::getBase (  VestaSource *&  result,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 835 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSourceSRPC::GetBase, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::stub, VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

void VDirSurrogate::getNFSInfo (  char *&  socket,
LongId &  root,
LongId &  muRoot
)  throw (SRPC::failure) [static]
 

Definition at line 396 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::GetNFSInfo, SRPC::recv_bytes_here(), SRPC::recv_chars(), SRPC::recv_end(), SRPC::send_end(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by RunTool::send_vdir(), and test_thread().

void VDirSurrogate::getUserInfo (  AccessControl::IdInfo &  result,
AccessControl::Identity  who = NULL,
AccessControl::Identity  subject = NULL,
Text  reposHost = "",
Text  reposPort = ""
)  throw (SRPC::failure) [static]
 

Definition at line 435 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::GetUserInfo, VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by main().

Text VDirSurrogate::host (   )  throw () [inline, virtual]
 

Reimplemented from VestaSource.

Definition at line 44 of file VDirSurrogate.H.

References host_.

bool VDirSurrogate::inAttribs (  const char *  name,
const char *  value
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaAttribs.

Definition at line 1451 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::InAttribs, SRPC::recv_end(), SRPC::recv_int(), SRPC::send_bytes(), SRPC::send_chars(), SRPC::send_end(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertAppendableDirectory (  Arc  arc,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1171 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSourceSRPC::End(), VestaSource::fptag, VestaSourceSRPC::InsertAppendableDirectory, VestaSource::longid, VestaSource::master, NEW_CONSTR, NullShortId, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertFile (  Arc  arc,
ShortId  sid,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0,
FP::Tag *  fptag = NULL
)  throw (SRPC::failure)
 

Definition at line 1016 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSource::immutableFile, VestaSourceSRPC::InsertFile, VestaSource::longid, VestaSource::master, NEW_CONSTR, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), FP::Tag::Send(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), sidCache, VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertGhost (  Arc  arc,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1266 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSource::ghost, VestaSourceSRPC::InsertGhost, VestaSource::longid, VestaSource::master, NEW_CONSTR, NullShortId, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertImmutableDirectory (  Arc  arc,
VestaSource *  dir,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0,
FP::Tag *  fptag = NULL
)  throw (SRPC::failure)
 

Definition at line 1113 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSource::immutableDirectory, VestaSourceSRPC::InsertImmutableDirectory, VestaSource::longid, VestaSource::master, NEW_CONSTR, NullLongId, NullShortId, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), FP::Tag::Send(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), sidCache, VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertMutableDirectory (  Arc  arc,
VestaSource *  dir,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1215 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSourceSRPC::InsertMutableDirectory, VestaSource::longid, VestaSource::master, VestaSource::mutableDirectory, NEW_CONSTR, NullLongId, NullShortId, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertMutableFile (  Arc  arc,
ShortId  sid,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1067 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSourceSRPC::InsertMutableFile, VestaSource::longid, VestaSource::master, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), sidCache, VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::insertStub (  Arc  arc,
bool  master,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
VestaSource **  newvs = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1308 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSource::fptag, VestaSourceSRPC::InsertStub, VestaSource::longid, VestaSource::master, NEW_CONSTR, NullShortId, VRErrorCode::ok, VestaSource::pseudoInode, FP::Tag::Recv(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::stub, VestaSource::type, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::list (  unsigned int  firstIndex,
VestaSource::listCallback  callback,
void *  closure,
AccessControl::Identity  who = NULL,
bool  deltaOnly = false,
unsigned int  indexOffset = 0
)  [virtual]
 

Reimplemented from VestaSource.

Definition at line 898 of file VDirSurrogate.C.

References Sequence< Elem, elem_ptrfree >::addhi(), ListResultItem::arc, VestaSourceSRPC::End(), ListResultItem::filesid, host_, ListResultItem::index, VestaSourceSRPC::List, ListResultItem::master, VRErrorCode::ok, port_, ListResultItem::pseudoInode, Sequence< Elem, elem_ptrfree >::remlo(), SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), Sequence< Elem, elem_ptrfree >::size(), VestaSourceSRPC::Start(), SRPC::start_call(), ListResultItem::type, VestaSource::unused, LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

void VDirSurrogate::listAttribs (  VestaSource::valueCallback  cb,
void *  cl
) 
 

Definition at line 1544 of file VDirSurrogate.C.

References Sequence< Elem, elem_ptrfree >::addhi(), VestaSourceSRPC::End(), host_, VestaSourceSRPC::ListAttribs, port_, SRPC::recv_chars(), SRPC::recv_end(), SRPC::recv_seq_end(), SRPC::recv_seq_start(), Sequence< Elem, elem_ptrfree >::remlo(), SRPC::send_bytes(), SRPC::send_end(), Sequence< Elem, elem_ptrfree >::size(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource * VDirSurrogate::LongIdLookup (  LongId  longid,
Text  host,
Text  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 175 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaAttribs::attribs, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSource::fptag, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSource::longid, VestaSourceSRPC::Lookup, VestaSource::master, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, VestaSource::pseudoInode, VestaSource::rep, VestaSourceSRPC::Start(), VestaSource::stub, VestaSource::type, VDirSurrogateInit(), VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

Referenced by VestaSource::getParent(), LongId::lookup(), test_thread(), RecursiveStats::visitImports(), ReposUI::vsToFilename(), and vsToFilename().

bool VDirSurrogate::LongIdValid (  LongId  longid,
Text  host,
Text  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 234 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::Lookup, VRErrorCode::ok, VestaSourceSRPC::Start(), and VDirSurrogateInit().

Referenced by test_thread(), and LongId::valid().

VestaSource::errorCode VDirSurrogate::lookup (  Arc  arc,
VestaSource *&  result,
AccessControl::Identity  who = NULL,
unsigned int  indexOffset = 0
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 620 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSourceSRPC::Lookup, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, VestaSourceSRPC::Start(), VestaSource::stub, VDirSurrogateInit(), VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

VestaSource::errorCode VDirSurrogate::lookupIndex (  unsigned int  index,
VestaSource *&  result,
char *  arcbuf = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 683 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSourceSRPC::LookupIndex, MAX_ARC_LEN, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, FP::Tag::Recv(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), SRPC::send_bytes(), SRPC::send_end(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::stub, LongId::value, VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

VestaSource::errorCode VDirSurrogate::lookupPathname (  const char *  pathname,
VestaSource *&  result,
AccessControl::Identity  who = NULL,
char  pathnameSep = PathnameSep
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 768 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSourceSRPC::LookupPathname, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::stub, LongId::value, VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

VestaSource::errorCode VDirSurrogate::makeFilesImmutable (  unsigned int  threshold,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1647 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::MakeFilesImmutable, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::makeMutable (  VestaSource *&  result,
ShortId  sid = NullShortId,
Basics::uint64  copyMax = (Basics::uint64)-1,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1381 of file VDirSurrogate.C.

References VestaSource::appendableDirectory, VestaSource::device, VestaSourceSRPC::End(), VestaSource::evaluatorDirectory, VestaSource::evaluatorROEDirectory, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VestaSourceSRPC::MakeMutable, VestaSource::mutableDirectory, VestaSource::mutableFile, NEW_CONSTR, VRErrorCode::ok, SRPC::send_bytes(), SRPC::send_end(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VestaSource::stub, VDirSurrogateInit(), VestaSourceSRPC::version, VestaSource::volatileDirectory, and VestaSource::volatileROEDirectory.

VestaSource::errorCode VDirSurrogate::measureDirectory (  VestaSource::directoryStats &  result,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1939 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::MeasureDirectory, VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource * VDirSurrogate::mutableRoot (  Text  host,
Text  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 272 of file VDirSurrogate.C.

References VestaSource::longid, MutableRootLongId, NEW_CONSTR, NullShortId, and VestaSource::resync().

Referenced by ReposUI::filenameToVS().

Text VDirSurrogate::port (   )  throw () [inline, virtual]
 

Reimplemented from VestaSource.

Definition at line 45 of file VDirSurrogate.H.

References port_.

VestaSource::errorCode VDirSurrogate::read (  void *  buffer,
int *  nbytes,
Basics::uint64  offset,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1749 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VRErrorCode::ok, VestaSourceSRPC::Read, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::readWhole (  std::ostream &  out,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1990 of file VDirSurrogate.C.

References VestaSourceSRPC::compress_zlib_deflate, VestaSourceSRPC::End(), INFLATE_ECASE, SRPC::internal_trouble, NEW_PTRFREE_ARRAY, SRPC::not_implemented, VRErrorCode::ok, VestaSourceSRPC::ReadWholeCompressed, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::reallyDelete (  Arc  arc,
AccessControl::Identity  who = NULL,
bool  existCheck = true,
time_t  timestamp = 0
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 990 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::ReallyDelete, SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

void VDirSurrogate::refreshAccessTables (  AccessControl::Identity  who = NULL,
Text  reposHost = "",
Text  reposPort = ""
)  throw (SRPC::failure) [static]
 

Definition at line 489 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::RefreshAccessTables, VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by main().

VestaSource::errorCode VDirSurrogate::renameTo (  Arc  arc,
VestaSource *  fromDir,
Arc  fromArc,
AccessControl::Identity  who = NULL,
VestaSource::dupeCheck  chk = VestaSource::dontReplace,
time_t  timestamp = 0
)  throw (SRPC::failure)
 

Definition at line 1351 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::RenameTo, SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::replicate (  const char *  pathname,
bool  asStub = false,
bool  asGhost = false,
Text  dstHost = "",
Text  dstPort = "",
Text  srcHost = "",
Text  srcPort = "",
char  pathnameSep = PathnameSep,
AccessControl::Identity  dwho = NULL,
AccessControl::Identity  swho = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 539 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::Replicate, SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by test_thread().

VestaSource::errorCode VDirSurrogate::replicateAttribs (  const char *  pathname,
bool  includeAccess = true,
Text  dstHost = "",
Text  dstPort = "",
Text  srcHost = "",
Text  srcPort = "",
char  pathnameSep = PathnameSep,
AccessControl::Identity  dwho = NULL,
AccessControl::Identity  swho = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 571 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::ReplicateAttribs, SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), VDirSurrogateInit(), and VestaSourceSRPC::version.

Referenced by test_thread().

VestaSource * VDirSurrogate::repositoryRoot (  Text  host,
Text  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 262 of file VDirSurrogate.C.

References VestaSource::longid, NEW_CONSTR, NullShortId, VestaSource::resync(), and RootLongId.

Referenced by AcquireMastership(), ReposUI::filenameToVS(), main(), Replicate(), and ReplicateAttribs().

void VDirSurrogate::resync (  AccessControl::Identity  who = NULL  )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 603 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VestaSourceSRPC::Lookup, VRErrorCode::ok, VestaSourceSRPC::Start(), and VDirSurrogateInit().

VestaSource::errorCode VDirSurrogate::setExecutable (  bool  x,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1862 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::SetExecutable, VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::setIndexMaster (  unsigned int  index,
bool  state,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1670 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::SetIndexMaster, VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::setMaster (  bool  state,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1694 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), LongId::getParent(), VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::SetIndexMaster, VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::setSize (  Basics::uint64  s,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1887 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VRErrorCode::ok, SRPC::recv_end(), SRPC::recv_int(), SRPC::send_bytes(), SRPC::send_end(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::SetSize, VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

VestaSource::errorCode VDirSurrogate::setTimestamp (  time_t  ts,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1914 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::SetTimestamp, VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), and VestaSourceSRPC::version.

ShortId VDirSurrogate::shortId (   )  throw (SRPC::failure) [inline, virtual]
 

Reimplemented from VestaSource.

Definition at line 443 of file VDirSurrogate.H.

References sidCache.

Basics::uint64 VDirSurrogate::size (   )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1812 of file VDirSurrogate.C.

References executableCache, sizeCache, and timestampCache.

time_t VDirSurrogate::timestamp (   )  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1822 of file VDirSurrogate.C.

References executableCache, sizeCache, and timestampCache.

VestaSource * VDirSurrogate::volatileRoot (  Text  host,
Text  port,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [static]
 

Definition at line 282 of file VDirSurrogate.C.

References VestaSource::longid, NEW_CONSTR, NullShortId, VestaSource::resync(), and VolatileRootLongId.

VestaSource::errorCode VDirSurrogate::write (  const void *  buffer,
int *  nbytes,
Basics::uint64  offset,
AccessControl::Identity  who = NULL
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1832 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), VRErrorCode::ok, SRPC::send_bytes(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), VestaSourceSRPC::version, and VestaSourceSRPC::Write.

VestaSource::errorCode VDirSurrogate::writeAttrib (  VestaSource::attribOp  op,
const char *  name,
const char *  value,
AccessControl::Identity  who = NULL,
time_t  timestamp = 0
)  throw (SRPC::failure) [virtual]
 

Reimplemented from VestaSource.

Definition at line 1619 of file VDirSurrogate.C.

References VestaSourceSRPC::End(), SRPC::send_bytes(), SRPC::send_chars(), VestaSourceSRPC::send_identity(), SRPC::send_int(), VestaSourceSRPC::Start(), SRPC::start_call(), LongId::value, VDirSurrogateInit(), VestaSourceSRPC::version, and VestaSourceSRPC::WriteAttrib.

Friends And Related Function Documentation

void VDirSurrogate_init (   )  [friend]
 

Definition at line 55 of file VDirSurrogate.C.

void VDirSurrogate_init2 (   )  [friend]
 

Definition at line 39 of file VDirSurrogateOnly.C.

Member Data Documentation

int VDirSurrogate::executableCache [private]
 

Definition at line 37 of file VDirSurrogate.H.

Referenced by executable(), size(), and timestamp().

Text VDirSurrogate::host_ [private]
 

Definition at line 40 of file VDirSurrogate.H.

Referenced by deleteVolatileDirectory(), getAttrib(), getAttribHistory(), host(), list(), and listAttribs().

Text VDirSurrogate::port_ [private]
 

Definition at line 40 of file VDirSurrogate.H.

Referenced by deleteVolatileDirectory(), getAttrib(), getAttribHistory(), list(), listAttribs(), and port().

ShortId VDirSurrogate::sidCache [private]
 

Definition at line 36 of file VDirSurrogate.H.

Referenced by insertFile(), insertImmutableDirectory(), insertMutableFile(), and shortId().

Basics::uint64 VDirSurrogate::sizeCache [private]
 

Definition at line 38 of file VDirSurrogate.H.

Referenced by executable(), size(), and timestamp().

time_t VDirSurrogate::timestampCache [private]
 

Definition at line 35 of file VDirSurrogate.H.

Referenced by executable(), size(), and timestamp().

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