/vesta/vestasys.org/vesta/repos/87/src/VestaSourceServer.C File Reference

#include <time.h>
#include <assert.h>
#include <zlib.h>
#include <SRPC.H>
#include <Thread.H>
#include <LimService.H>
#include <OS.H>
#include "VestaSourceSRPC.H"
#include "VestaSource.H"
#include "VDirVolatileRoot.H"
#include "VRConcurrency.H"
#include "VestaConfig.H"
#include "VestaSourceServer.H"
#include "FPShortId.H"
#include "logging.H"
#include "VestaSourceImpl.H"
#include "Mastership.H"
#include "Replication.H"
#include "ReposStats.H"
#include "FdCache.H"
#include "dupe.H"
#include "lock_timing.H"
#include "nfsStats.H"

Include dependency graph for VestaSourceServer.C:

Go to the source code of this file.

Classes

class  SRPC_Call_Stats
class  SRPC_Call_Stats::Helper
struct  VSLClosure
class  VestaSourceReceptionist

Defines

#define DEF_MAX_RUNNING   32
#define STACK_SIZE   256000L

Functions

void SRPC_Call_Stats_Helper_stats_init () throw ()
AccessControl::Identity srpc_recv_identity (SRPC *srpc, int intf_ver, bool access_needed)
void MakeFilesImmutable (SRPC *srpc, int intf_ver)
void SetIndexMaster (SRPC *srpc, int intf_ver)
void VSStat (SRPC *srpc, int intf_ver)
void VSRead (SRPC *srpc, int intf_ver)
void VSWrite (SRPC *srpc, int intf_ver)
void VSSetExecutable (SRPC *srpc, int intf_ver)
void VSSetSize (SRPC *srpc, int intf_ver)
void VSSetTimestamp (SRPC *srpc, int intf_ver)
void VestaSourceServerExport ()

Variables

const char * Version
time_t serverStartTime

Define Documentation

#define DEF_MAX_RUNNING   32

Definition at line 62 of file VestaSourceServer.C.

#define STACK_SIZE   256000L

Definition at line 63 of file VestaSourceServer.C.

Function Documentation

void MakeFilesImmutable ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 1606 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), VestaSource::makeFilesImmutable(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void SetIndexMaster ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 1647 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), VestaSource::setIndexMaster(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void SRPC_Call_Stats_Helper_stats_init (  )  throw ()

Definition at line 215 of file VestaSourceServer.C.

References SRPC_Call_Stats::Helper::stats_key.

AccessControl::Identity srpc_recv_identity ( SRPC *  srpc,
int  intf_ver,
bool  access_needed 
)

Definition at line 297 of file VestaSourceServer.C.

References AccessControl::admit(), SRPC::buffer_too_small, TCP_sock::get_remote_addr(), AccessControl::IdentityRep::global, AccessControl::IdentityRep::gssapi, SRPC::invalid_parameter, NEW, NEW_CONSTR, NEW_PTRFREE_ARRAY, SRPC::protocol_violation, SRPC::recv_chars(), SRPC::recv_chars_here(), SRPC::recv_int(), SRPC::recv_seq_end(), SRPC::recv_seq_start(), SRPC::send_failure(), SRPC::socket(), and AccessControl::IdentityRep::unix_flavor.

Referenced by MakeFilesImmutable(), SetIndexMaster(), VSAtomic(), VSRead(), VSSetExecutable(), VSSetSize(), VSSetTimestamp(), and VSWrite().

Here is the call graph for this function:

Here is the caller graph for this function:

void VestaSourceServerExport (  ) 

Definition at line 2937 of file VestaSourceServer.C.

References Text::cchars(), DBG_ALWAYS, DEF_MAX_RUNNING, Repos::dprintf(), LimService::Forked_Run(), VestaConfig::get(), VestaConfig::get_int(), VestaConfig::get_Text(), VestaConfig::failure::msg, and STACK_SIZE.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSRead ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 1921 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), VRErrorCode::ok, VestaSource::read(), LongId::readLock, SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseRead(), RWLOCK_LOCKED_REASON, SRPC::send_bytes(), SRPC::send_end(), SRPC::send_int(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSSetExecutable ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 2021 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), VestaSource::setExecutable(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSSetSize ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 2061 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), VestaSource::setSize(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSSetTimestamp ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 2103 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), VestaSource::setTimestamp(), srpc_recv_identity(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSStat ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 1880 of file VestaSourceServer.C.

References VestaSource::executable(), VRErrorCode::invalidArgs, LongId::lookup(), VRErrorCode::ok, LongId::readLock, SRPC::recv_bytes_here(), SRPC::recv_end(), ReadersWritersLock::releaseRead(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), VestaSource::size(), VestaSource::timestamp(), and LongId::value.

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

void VSWrite ( SRPC *  srpc,
int  intf_ver 
)

Definition at line 1972 of file VestaSourceServer.C.

References VRErrorCode::invalidArgs, LongId::lookup(), VRErrorCode::ok, SRPC::recv_bytes(), SRPC::recv_bytes_here(), SRPC::recv_end(), SRPC::recv_int(), ReadersWritersLock::releaseWrite(), RWLOCK_LOCKED_REASON, SRPC::send_end(), SRPC::send_int(), srpc_recv_identity(), LongId::value, and VestaSource::write().

Referenced by VestaSourceReceptionist::call().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

time_t serverStartTime

Definition at line 184 of file RepositoryMain.C.

Referenced by main().

const char* Version

Generated on Fri May 25 00:28:57 2007 for Vesta by  doxygen 1.5.1