Replication.C File Reference

#include "VestaSource.H"
#include "VDirSurrogate.H"
#include "VRConcurrency.H"
#include "Mastership.H"
#include "Replication.H"
#include "UniqueId.H"
#include "logging.H"
#include "FPShortId.H"
#include "lock_timing.H"
#include <FdStream.H>

Go to the source code of this file.

Defines
#define	COPY_SIZE   (128*1024)
#define	REPLICATOR_DIR   ".replicator"
#define	BAD_READWHOLE_TTL   (60*60)
Functions
bool	ReplicationAccessCheck (VestaSource *vs, const char *which, const char *srcHost, const char *srcPort) throw ()
void	ReplicationCleanup () throw ()
VestaSource::errorCode	Replicate (const char *pathname, bool asStub, bool asGhost, const char *srcHost, const char *srcPort, char pathnameSep, AccessControl::Identity dwho, AccessControl::Identity swho) throw ()
VestaSource::errorCode	ReplicateAttribs (const char *pathname, bool includeAccess, const char *srcHost, const char *srcPort, char pathnameSep, AccessControl::Identity dwho, AccessControl::Identity swho) throw ()

---

Define Documentation

#define BAD_READWHOLE_TTL   (60*60)

Definition at line 83 of file Replication.C.

#define COPY_SIZE   (128*1024)

Definition at line 43 of file Replication.C.

#define REPLICATOR_DIR   ".replicator"

Definition at line 44 of file Replication.C. Referenced by Replicate(), and ReplicationCleanup().

---

Function Documentation

VestaSource::errorCode Replicate (  const char *  pathname, bool  asStub, bool  asGhost, const char *  srcHost, const char *  srcPort, char  pathnameSep, AccessControl::Identity  dwho, AccessControl::Identity  swho )  throw ()

Definition at line 601 of file Replication.C. References VestaSource::appendableDirectory, FP::ByteCnt, LongId::checkLock, VestaSource::dontReplace, Repos::dprintf(), VestaSource::errorCodeString(), VestaSource::fptag, VestaSource::ghost, VestaSource::immutableDirectory, VestaSource::immutableFile, VRErrorCode::inappropriateOp, VestaSource::insertMutableDirectory(), VRErrorCode::invalidArgs, VestaSource::longid, VestaSource::lookup(), LongId::lookup(), VestaSource::lookupPathname(), VestaSource::master, VestaSource::mutableRoot(), VRErrorCode::nameInUse, VRErrorCode::noPermission, VRErrorCode::notFound, NullShortId, VRErrorCode::ok, LongId::readLock, VestaSource::reallyDelete(), ReadersWritersLock::release(), VestaSource::replaceDiff, ReplicationAccessCheck(), REPLICATOR_DIR, VestaSource::repositoryRoot(), VDirSurrogate::repositoryRoot(), VRErrorCode::rpcFailure, RWLOCK_LOCKED_REASON, VestaSource::setAttrib(), VestaSource::stub, VestaSource::timestamp(), VestaSource::type, VestaSource::typeTagString(), UniqueId(), FP::Tag::Word0(), and FP::Tag::Word1().

VestaSource::errorCode ReplicateAttribs (  const char *  pathname, bool  includeAccess, const char *  srcHost, const char *  srcPort, char  pathnameSep, AccessControl::Identity  dwho, AccessControl::Identity  swho )  throw ()

Definition at line 954 of file Replication.C. References Repos::dprintf(), ReplicateAttribsClosure::dvs, ReplicateAttribsClosure::err, VestaSource::errorCodeString(), VestaAttribs::getAttribHistory(), VRErrorCode::inappropriateOp, ReplicateAttribsClosure::includeAccess, VestaSource::lookupPathname(), VRErrorCode::noPermission, VRErrorCode::ok, LongId::readLock, ReadersWritersLock::release(), ReplicationAccessCheck(), VDirSurrogate::repositoryRoot(), VestaSource::repositoryRoot(), VRErrorCode::rpcFailure, RWLOCK_LOCKED_REASON, and VestaSource::type.

bool ReplicationAccessCheck (  VestaSource *  vs, const char *  which, const char *  srcHost, const char *  srcPort )  throw ()

Definition at line 56 of file Replication.C. References MAX_ARC_LEN. Referenced by Replicate(), and ReplicateAttribs().

void ReplicationCleanup (   )  throw ()

Definition at line 583 of file Replication.C. References VestaSource::list(), VestaSource::lookup(), VestaSource::mutableRoot(), VRErrorCode::ok, ReadersWritersLock::release(), REPLICATOR_DIR, and RWLOCK_LOCKED_REASON. Referenced by main().

---