SRPC Class Reference

#include <SRPC.H>

List of all members.

Public Types
enum	{   unknown_host = -1, unknown_interface = -2, version_skew = -3, protocol_violation = -4,   buffer_too_small = -5, transport_failure = -6, internal_trouble = -7, invalid_parameter = -8,   partner_went_away = -9, not_implemented = -10, read_timeout = -11 }
enum	which_end { caller, callee }
enum	{ default_intf_version = -1 }
enum	{ default_proc_id = -1 }
enum	{ any = -1 }
Public Member Functions
	throw (failure)
	SRPC (which_end me, TCP_sock *sock) throw (failure)
	~SRPC () throw (failure)
void	start_call (int proc_id=default_proc_id, int intf_version=default_intf_version) throw (failure)
void	await_call (int &proc_id, int &intf_version) throw (failure)
bool	previous_failure (SRPC::failure *f=NULL) throw ()
bool	alive (SRPC::failure *f=NULL) throw ()
TCP_sock *	socket () throw (failure)
Text	local_socket () throw (failure)
Text	remote_socket () throw (failure)
void	enable_read_timeout (unsigned int seconds, bool use_between_calls=false) throw ()
void	disable_read_timeout () throw ()
bool	get_read_timeout (unsigned int &seconds, bool &use_between_calls) throw ()
void	send_int32 (int i) throw (failure)
int	recv_int32 (bool *got_end=NULL) throw (failure)
void	send_int (int i) throw (failure)
int	recv_int (bool *got_end=NULL) throw (failure)
void	send_int16 (Basics::int16 i) throw (failure)
Basics::int16	recv_int16 (bool *got_end=NULL) throw (failure)
void	send_short (Basics::int16 i) throw (failure)
Basics::int16	recv_short (bool *got_end=NULL) throw (failure)
void	send_int64 (Basics::int64 i) throw (failure)
Basics::int64	recv_int64 (bool *got_end=NULL) throw (failure)
void	send_float (float f) throw (failure)
float	recv_float (bool *got_end=NULL) throw (failure)
void	send_bool (bool b) throw (failure)
bool	recv_bool (bool *got_end=NULL) throw (failure)
void	send_chars (const char *s) throw (failure)
char *	recv_chars (bool *got_end=NULL) throw (failure)
char *	recv_chars (char *buff, int buff_len, bool *got_end=NULL) throw (failure)
void	recv_chars_here (char *buffer, int &len, bool *got_end=NULL) throw (failure)
void	send_Text (const Text &t) throw (failure)
void	recv_Text (Text &t, bool *got_end=NULL) throw (failure)
void	send_bytes (const char *buffer, int len) throw (failure)
char *	recv_bytes (int &len, bool *got_end=NULL) throw (failure)
void	recv_bytes_here (char *buffer, int &len, bool *got_end=NULL) throw (failure)
void	send_socket (sockaddr_in &sock) throw (failure)
sockaddr_in	recv_socket (bool *got_end=NULL) throw (failure)
void	send_int16_array (const Basics::int16 *seq, int len) throw (SRPC::failure)
Basics::int16 *	recv_int16_array (int &len) throw (SRPC::failure)
void	send_short_array (const Basics::int16 *seq, int len) throw (SRPC::failure)
Basics::int16 *	recv_short_array (int &len) throw (SRPC::failure)
void	send_int32_array (const Basics::int32 *seq, int len) throw (SRPC::failure)
Basics::int32 *	recv_int32_array (int &len) throw (SRPC::failure)
void	send_int64_array (const Basics::int64 *seq, int len) throw (SRPC::failure)
Basics::int64 *	recv_int64_array (int &len) throw (SRPC::failure)
void	send_int_seq (int_seq &is) throw (failure)
void	recv_int_seq (int_seq &is) throw (failure)
void	send_chars_seq (chars_seq &cs) throw (failure)
void	recv_chars_seq (chars_seq &cs) throw (failure)
void	send_bytes_seq (bytes_seq &bs) throw (failure)
void	recv_bytes_seq (bytes_seq &bs) throw (failure)
void	send_seq_start (int len=any, int bytes=any) throw (failure)
void	recv_seq_start (int *len=NULL, int *bytes=NULL) throw (failure)
void	send_seq_end () throw (failure)
void	recv_seq_end () throw (failure)
void	send_end () throw (failure)
void	recv_end () throw (failure)
void	send_failure (int r, const Text &msg, bool remote_only=false) throw (failure)
Static Public Member Functions
static Text	this_host () throw (failure)
static void	split_name (const Text &host_and_port, Text &host, Text &port)
static failure	convert_TCP_failure (TCP_sock::failure tf)
Private Member Functions
	SRPC (SRPC &)
void	operator= (SRPC &)
Static Private Member Functions
static void	init () throw (failure)
Private Attributes
SRPC_impl *	p
Static Private Attributes
static pthread_once_t	init_block
Friends
class	SRPC_impl
Classes
struct	failure

---

Member Enumeration Documentation

anonymous enum

Enumeration values: unknown_host  unknown_interface  version_skew  protocol_violation  buffer_too_small  transport_failure  internal_trouble  invalid_parameter  partner_went_away  not_implemented  read_timeout  Definition at line 59 of file SRPC.H.

anonymous enum

Enumeration values: default_intf_version  Definition at line 133 of file SRPC.H.

anonymous enum

Enumeration values: default_proc_id  Definition at line 134 of file SRPC.H.

anonymous enum

Enumeration values: any  Definition at line 436 of file SRPC.H.

enum SRPC::which_end

Enumeration values: caller  callee  Definition at line 92 of file SRPC.H.

---

Constructor & Destructor Documentation

SRPC::SRPC (  which_end  me, TCP_sock *  sock )  throw (failure)

Definition at line 68 of file SRPC.C. References SRPC_listener::create(), and NEW_CONSTR.

SRPC::~SRPC (   )  throw (failure)

Definition at line 89 of file SRPC.C. References SRPC_impl::failed, and SRPC_impl::initial.

SRPC::SRPC (  SRPC &   )  [private]

---

Member Function Documentation

bool SRPC::alive (  SRPC::failure *  f = NULL  )  throw ()

Definition at line 126 of file SRPC.C. References convert_TCP_failure(). Referenced by VDirEvaluator::alive(), C_Conn4(), C_Fail1(), and children::killer_body().

void SRPC::await_call (  int &  proc_id, int &  intf_version )  throw (failure)

Definition at line 217 of file SRPC.C. References SRPC_impl::ic_start_call, SRPC_impl::op_await_call, and SRPC_impl::ready. Referenced by LimService::Run(), S_Conn2(), S_Conn3(), S_Conn4(), S_Conn5(), S_Conn6(), S_Conn7(), and S_Multi1().

SRPC::failure SRPC::convert_TCP_failure (  TCP_sock::failure  tf  )  [static]

Definition at line 1072 of file SRPC.C. References TCP_sock::environment_problem, internal_trouble, partner_went_away, TCP_sock::partner_went_away, read_timeout, TCP_sock::read_timeout, transport_failure, unknown_host, TCP_sock::unknown_host, unknown_interface, and TCP_sock::unknown_port. Referenced by alive(), RunTool::do_it(), SRPC_impl::report_TCP_failure(), and this_host().

void SRPC::disable_read_timeout (   )  throw ()

Definition at line 184 of file SRPC.C. References p, and SRPC_impl::use_read_timeout.

void SRPC::enable_read_timeout (  unsigned int  seconds, bool  use_between_calls = false )  throw ()

Definition at line 175 of file SRPC.C. Referenced by RunTool::get_info(), DebugC::GetCacheId(), DebugC::GetCacheInstance(), DebugC::GetCacheState(), VDirEvaluator::list(), VDirEvaluator::lookup(), DebugC::NullCall(), and ShortIdReceptionist().

bool SRPC::get_read_timeout (  unsigned int &  seconds, bool &  use_between_calls )  throw () [inline]

Definition at line 189 of file SRPC.C.

static void SRPC::init (   )  throw (failure) [static, private]

Text SRPC::local_socket (   )  throw (failure)

Definition at line 141 of file SRPC.C. References Text::cchars(), TCP_sock::get_local_addr(), inet_ntoa_r(), p, and socket(). Referenced by print_connection().

void SRPC::operator= (  SRPC &   )  [private]

bool SRPC::previous_failure (  SRPC::failure *  f = NULL  )  throw ()

Definition at line 119 of file SRPC.C. References SRPC_impl::failed.

bool SRPC::recv_bool (  bool *  got_end = NULL  )  throw (failure)

Definition at line 352 of file SRPC.C. References SRPC_impl::ic_bool_false, SRPC_impl::ic_bool_true, and SRPC_impl::op_recv_bool. Referenced by C_Bool(), RunTool::do_it(), and S_Bool().

char * SRPC::recv_bytes (  int &  len, bool *  got_end = NULL )  throw (failure)

Definition at line 534 of file SRPC.C. References SRPC_impl::ic_bytes, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_chars. Referenced by VSWrite().

void SRPC::recv_bytes_here (  char *  buffer, int &  len, bool *  got_end = NULL )  throw (failure)

Definition at line 558 of file SRPC.C. References SRPC_impl::ic_bytes, and SRPC_impl::op_recv_bytes_here. Referenced by DeclStep::DeclStep(), VDirSurrogate::getNFSInfo(), VDirEvaluator::lookup(), VDirSurrogate::lookupIndex(), and VSWrite().

void SRPC::recv_bytes_seq (  bytes_seq &  bs  )  throw (failure)

Definition at line 897 of file SRPC.C. References bytes_seq_impl::allocate_buffer(), bytes_seq_impl::expand(), bytes_seq_impl::full, SRPC_impl::ic_bytes_seq, byte_str::l, bytes_seq_impl::manual, SRPC_impl::op_recv_bytes_seq, and byte_str::p.

char * SRPC::recv_chars (  char *  buff, int  buff_len, bool *  got_end = NULL )  throw (failure)

Definition at line 423 of file SRPC.C. References SRPC_impl::ic_chars, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_chars.

char * SRPC::recv_chars (  bool *  got_end = NULL  )  throw (failure)

Definition at line 396 of file SRPC.C. References SRPC_impl::ic_chars, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_chars. Referenced by C_Catna(), C_CatnT(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirSurrogate::getNFSInfo(), InAttribsStep::InAttribsStep(), VDirSurrogate::listAttribs(), MergeAttribStep::MergeAttribStep(), S_Cat2(), and WriteAttribStep::WriteAttribStep().

void SRPC::recv_chars_here (  char *  buffer, int &  len, bool *  got_end = NULL )  throw (failure)

Definition at line 455 of file SRPC.C. References SRPC_impl::ic_chars, and SRPC_impl::op_recv_chars_here. Referenced by C_Cat2(), VDirEvaluator::list(), and LookupStep::LookupStep().

void SRPC::recv_chars_seq (  chars_seq &  cs  )  throw (failure)

Definition at line 825 of file SRPC.C. References chars_seq_impl::allocate_buffer(), chars_seq_impl::expand(), chars_seq_impl::full, SRPC_impl::ic_chars_seq, chars_seq_impl::manual, and SRPC_impl::op_recv_chars_seq. Referenced by S_Catna(), S_Catnf(), S_CatnT(), and S_Seq2().

void SRPC::recv_end (   )  throw (failure)

Definition at line 1029 of file SRPC.C. References SRPC_impl::ic_end_ack, SRPC_impl::ic_end_call, SRPC_impl::initial, SRPC_impl::op_recv_end, and SRPC_impl::ready. Referenced by C_Add2(), C_Add2_64(), C_Add2f(), C_Add_Int16Array(), C_Add_Int32Array(), C_Add_Int64Array(), C_Addna(), C_Addnf(), C_Addnfp(), C_Bool(), C_Cat2(), C_Cat2T(), C_Catna(), C_Catnf(), C_CatnT(), C_Conn2(), C_Conn3(), C_Conn4(), C_Conn5(), C_Conn6(), C_Multi1(), C_Seq1(), C_Seq2(), VDirSurrogate::deleteVolatileDirectory(), RunTool::do_it(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirSurrogate::getNFSInfo(), VDirSurrogate::inAttribs(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), VDirEvaluator::lookup(), VDirSurrogate::lookupIndex(), MainClientProc(), DebugC::NullCall(), VestaSourceAtomic::run(), S_Add2(), S_Add2_64(), S_Add2f(), S_Add_Int16Array(), S_Add_Int32Array(), S_Add_Int64Array(), S_Addna(), S_Addnf(), S_Addnfp(), S_Bool(), S_Cat2(), S_Cat2T(), S_Catna(), S_Catnf(), S_CatnT(), S_Multi1(), S_Seq1(), S_Seq2(), VDirSurrogate::setSize(), and ShortIdReceptionist().

float SRPC::recv_float (  bool *  got_end = NULL  )  throw (failure) [inline]

Definition at line 239 of file SRPC.H. References recv_int32(). Referenced by C_Add2f(), C_Addnfp(), RunTool::get_info(), S_Add2f(), and S_Addnfp().

int SRPC::recv_int (  bool *  got_end = NULL  )  throw (failure) [inline]

Definition at line 210 of file SRPC.H. References recv_int32(). Referenced by AccessCheckStep::AccessCheckStep(), C_Add2(), C_Addna(), C_Addnf(), C_Conn7(), C_Multi1(), C_Seq1(), C_Seq2(), VDirSurrogate::deleteVolatileDirectory(), RunTool::do_it(), RunTool::get_info(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirSurrogate::inAttribs(), InAttribsStep::InAttribsStep(), VDirEvaluator::list(), VDirEvaluator::lookup(), VDirSurrogate::lookupIndex(), LookupIndexStep::LookupIndexStep(), LookupStep::LookupStep(), MainClientProc(), MergeAttribStep::MergeAttribStep(), VestaSourceAtomic::run(), S_Add2(), S_Addnfp(), S_Fail1(), S_Multi1(), S_Seq1(), S_Seq2(), VDirSurrogate::setSize(), SetTargetStep::SetTargetStep(), ShortIdReceptionist(), TestMasterStep::TestMasterStep(), VSWrite(), and WriteAttribStep::WriteAttribStep().

Basics::int16 SRPC::recv_int16 (  bool *  got_end = NULL  )  throw (failure)

Definition at line 299 of file SRPC.C. References SRPC_impl::ic_int16, and SRPC_impl::op_recv_int16. Referenced by C_Add_Int16Array(), and recv_short().

Basics::int16 * SRPC::recv_int16_array (  int &  len  )  throw (SRPC::failure)

Definition at line 704 of file SRPC.C. References SRPC_impl::ic_int16_array, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_int16_array. Referenced by recv_short_array(), and S_Add_Int16Array().

int SRPC::recv_int32 (  bool *  got_end = NULL  )  throw (failure)

Definition at line 272 of file SRPC.C. References SRPC_impl::ic_int32, and SRPC_impl::op_recv_int32. Referenced by C_Add_Int32Array(), recv_float(), and recv_int().

Basics::int32 * SRPC::recv_int32_array (  int &  len  )  throw (SRPC::failure)

Definition at line 739 of file SRPC.C. References SRPC_impl::ic_int32_array, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_int32_array. Referenced by S_Add_Int32Array().

Basics::int64 SRPC::recv_int64 (  bool *  got_end = NULL  )  throw (failure)

Definition at line 326 of file SRPC.C. References SRPC_impl::ic_int64, and SRPC_impl::op_recv_int64. Referenced by C_Add2_64(), C_Add_Int64Array(), and S_Add2_64().

Basics::int64 * SRPC::recv_int64_array (  int &  len  )  throw (SRPC::failure)

Definition at line 774 of file SRPC.C. References SRPC_impl::ic_int64_array, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_int64_array. Referenced by S_Add_Int64Array().

void SRPC::recv_int_seq (  int_seq &  is  )  throw (failure)

Definition at line 663 of file SRPC.C. References int_seq_impl::allocate_buffer(), SRPC_impl::ic_int32_seq, and SRPC_impl::op_recv_int32_seq. Referenced by S_Addna(), S_Addnf(), and S_Seq2().

void SRPC::recv_seq_end (   )  throw (failure)

Definition at line 984 of file SRPC.C. References SRPC_impl::data_in, SRPC_impl::ic_seq_end, and SRPC_impl::op_recv_seq_end. Referenced by VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), S_Seq1(), and S_Seq2().

void SRPC::recv_seq_start (  int *  len = NULL, int *  bytes = NULL )  throw (failure)

Definition at line 958 of file SRPC.C. References SRPC_impl::ic_seq_start, SRPC_impl::op_recv_seq_start, and SRPC_impl::seq_in. Referenced by VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), S_Seq1(), and S_Seq2().

Basics::int16 SRPC::recv_short (  bool *  got_end = NULL  )  throw (failure) [inline]

Definition at line 222 of file SRPC.H. References recv_int16().

Basics::int16* SRPC::recv_short_array (  int &  len  )  throw (SRPC::failure) [inline]

Definition at line 324 of file SRPC.H. References recv_int16_array().

sockaddr_in SRPC::recv_socket (  bool *  got_end = NULL  )  throw (failure)

Definition at line 612 of file SRPC.C. References SRPC_impl::ic_socket, and SRPC_impl::op_recv_socket.

void SRPC::recv_Text (  Text &  t, bool *  got_end = NULL )  throw (failure)

Definition at line 496 of file SRPC.C. References SRPC_impl::ic_text, NEW_PTRFREE_ARRAY, and SRPC_impl::op_recv_text. Referenced by C_Cat2T(), C_Catnf(), RunTool::get_info(), and S_Cat2T().

Text SRPC::remote_socket (   )  throw (failure)

Definition at line 156 of file SRPC.C. References Text::cchars(), TCP_sock::get_remote_addr(), inet_ntoa_r(), p, and socket(). Referenced by print_connection(), ShortIdFailure(), ShortIdReceptionist(), and VestaSourceFailure().

void SRPC::send_bool (  bool  b  )  throw (failure)

Definition at line 341 of file SRPC.C. References SRPC_impl::ic_bool_false, SRPC_impl::ic_bool_true, and SRPC_impl::op_send_bool. Referenced by C_Bool(), and S_Bool().

void SRPC::send_bytes (  const char *  buffer, int  len )  throw (failure)

Definition at line 522 of file SRPC.C. References SRPC_impl::ic_bytes, and SRPC_impl::op_send_bytes. Referenced by VDirSurrogate::cedeMastership(), VDirSurrogate::collapseBase(), VDirSurrogate::createVolatileDirectory(), VDirSurrogate::deleteVolatileDirectory(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirSurrogate::getBase(), VDirSurrogate::inAttribs(), VDirSurrogate::insertAppendableDirectory(), VDirSurrogate::insertFile(), VDirSurrogate::insertGhost(), VDirSurrogate::insertImmutableDirectory(), VDirSurrogate::insertMutableDirectory(), VDirSurrogate::insertMutableFile(), VDirSurrogate::insertStub(), VDirSurrogate::list(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), VDirEvaluator::lookup(), VDirSurrogate::lookupIndex(), VDirSurrogate::lookupPathname(), VDirSurrogate::makeFilesImmutable(), VDirSurrogate::makeMutable(), VDirSurrogate::measureDirectory(), VDirSurrogate::read(), VDirSurrogate::readWhole(), VDirSurrogate::reallyDelete(), VDirSurrogate::renameTo(), send_dir(), RunTool::send_vdir(), VDirSurrogate::setExecutable(), VDirSurrogate::setIndexMaster(), VDirSurrogate::setMaster(), VDirSurrogate::setSize(), VDirSurrogate::setTimestamp(), ShortIdReceptionist(), VDirSurrogate::write(), and VDirSurrogate::writeAttrib().

void SRPC::send_bytes_seq (  bytes_seq &  bs  )  throw (failure)

Definition at line 867 of file SRPC.C. References bytes_seq_impl::allocate_buffer(), SRPC_impl::ic_bytes_seq, SRPC_impl::op_send_bytes_seq, and byte_str::p.

void SRPC::send_chars (  const char *  s  )  throw (failure)

Definition at line 384 of file SRPC.C. References SRPC_impl::ic_chars, and SRPC_impl::op_send_chars. Referenced by VDirSurrogate::acquireMastership(), C_Cat2(), VDirSurrogate::cedeMastership(), VDirSurrogate::createVolatileDirectory(), VDirSurrogate::getAttrib(), VDirSurrogate::inAttribs(), VDirSurrogate::insertAppendableDirectory(), VDirSurrogate::insertFile(), VDirSurrogate::insertGhost(), VDirSurrogate::insertImmutableDirectory(), VDirSurrogate::insertMutableDirectory(), VDirSurrogate::insertMutableFile(), VDirSurrogate::insertStub(), VDirEvaluator::lookup(), VDirSurrogate::lookupPathname(), VDirSurrogate::reallyDelete(), VDirSurrogate::renameTo(), VDirSurrogate::replicate(), VDirSurrogate::replicateAttribs(), S_Cat2(), S_Catna(), S_CatnT(), and VDirSurrogate::writeAttrib().

void SRPC::send_chars_seq (  chars_seq &  cs  )  throw (failure)

Definition at line 795 of file SRPC.C. References chars_seq_impl::allocate_buffer(), SRPC_impl::ic_chars_seq, and SRPC_impl::op_send_chars_seq. Referenced by C_Catna(), C_Catnf(), C_CatnT(), C_Seq2(), and RunTool::do_it().

void SRPC::send_end (   )  throw (failure)

Definition at line 1000 of file SRPC.C. References SRPC_impl::ic_end_ack, SRPC_impl::ic_end_call, SRPC_impl::initial, SRPC_impl::op_send_end, and SRPC_impl::ready. Referenced by C_Add2(), C_Add2_64(), C_Add2f(), C_Add_Int16Array(), C_Add_Int32Array(), C_Add_Int64Array(), C_Addna(), C_Addnf(), C_Addnfp(), C_Bool(), C_Cat2(), C_Cat2T(), C_Catna(), C_Catnf(), C_CatnT(), C_Conn2(), C_Conn3(), C_Conn4(), C_Conn5(), C_Conn6(), C_Conn7(), C_Multi1(), C_Seq1(), C_Seq2(), VDirSurrogate::createVolatileDirectory(), VDirSurrogate::deleteVolatileDirectory(), RunTool::do_it(), RunTool::get_info(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), DebugC::GetCacheId(), DebugC::GetCacheInstance(), DebugC::GetCacheState(), VDirSurrogate::getNFSInfo(), VDirSurrogate::inAttribs(), WeederC::init_server_instance(), CacheC::init_server_instance(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), VDirEvaluator::lookup(), VDirSurrogate::lookupIndex(), MainClientProc(), VDirSurrogate::makeMutable(), DebugC::NullCall(), VestaSourceAtomic::run(), S_Add2(), S_Add2_64(), S_Add2f(), S_Add_Int16Array(), S_Add_Int32Array(), S_Add_Int64Array(), S_Addna(), S_Addnf(), S_Addnfp(), S_Bool(), S_Cat2(), S_Cat2T(), S_Catna(), S_Catnf(), S_CatnT(), S_Multi1(), S_Seq1(), S_Seq2(), VDirSurrogate::setSize(), and ShortIdReceptionist().

void SRPC::send_failure (  int  r, const Text &  msg, bool  remote_only = false )  throw (failure)

Definition at line 1054 of file SRPC.C. References SRPC_impl::failed, SRPC_impl::ic_failure, and SRPC_impl::op_send_failure. Referenced by C_Fail1(), and ShortIdReceptionist().

void SRPC::send_float (  float  f  )  throw (failure) [inline]

Definition at line 234 of file SRPC.H. References send_int32(). Referenced by C_Add2f(), C_Addnfp(), S_Add2f(), and S_Addnfp().

void SRPC::send_int (  int  i  )  throw (failure) [inline]

Definition at line 206 of file SRPC.H. References send_int32(). Referenced by VDirSurrogate::acquireMastership(), C_Add2(), C_Addnfp(), C_Multi1(), C_Seq1(), C_Seq2(), VDirSurrogate::createVolatileDirectory(), VDirSurrogate::insertAppendableDirectory(), VDirSurrogate::insertFile(), VDirSurrogate::insertGhost(), VDirSurrogate::insertImmutableDirectory(), VDirSurrogate::insertMutableDirectory(), VDirSurrogate::insertMutableFile(), VDirSurrogate::insertStub(), VDirSurrogate::list(), VDirEvaluator::list(), VDirSurrogate::lookupIndex(), MainClientProc(), VDirSurrogate::makeFilesImmutable(), VDirSurrogate::makeMutable(), VDirSurrogate::read(), VDirSurrogate::replicate(), VDirSurrogate::replicateAttribs(), VestaSourceAtomic::run(), S_Add2(), S_Addna(), S_Addnf(), S_Multi1(), S_Seq1(), S_Seq2(), VDirSurrogate::setExecutable(), VDirSurrogate::setIndexMaster(), VDirSurrogate::setMaster(), VDirSurrogate::setSize(), VDirSurrogate::setTimestamp(), ShortIdReceptionist(), VDirSurrogate::write(), and VDirSurrogate::writeAttrib().

void SRPC::send_int16 (  Basics::int16  i  )  throw (failure)

Definition at line 287 of file SRPC.C. References SRPC_impl::ic_int16, and SRPC_impl::op_send_int16. Referenced by S_Add_Int16Array(), and send_short().

void SRPC::send_int16_array (  const Basics::int16 *  seq, int  len )  throw (SRPC::failure)

Definition at line 690 of file SRPC.C. References SRPC_impl::ic_int16_array, and SRPC_impl::op_send_int16_array. Referenced by C_Add_Int16Array(), and send_short_array().

void SRPC::send_int32 (  int  i  )  throw (failure)

Definition at line 260 of file SRPC.C. References SRPC_impl::ic_int32, and SRPC_impl::op_send_int32. Referenced by S_Add_Int32Array(), send_float(), and send_int().

void SRPC::send_int32_array (  const Basics::int32 *  seq, int  len )  throw (SRPC::failure)

Definition at line 725 of file SRPC.C. References SRPC_impl::ic_int32_array, and SRPC_impl::op_send_int32_array. Referenced by C_Add_Int32Array().

void SRPC::send_int64 (  Basics::int64  i  )  throw (failure)

Definition at line 314 of file SRPC.C. References SRPC_impl::ic_int64, and SRPC_impl::op_send_int64. Referenced by C_Add2_64(), S_Add2_64(), and S_Add_Int64Array().

void SRPC::send_int64_array (  const Basics::int64 *  seq, int  len )  throw (SRPC::failure)

Definition at line 760 of file SRPC.C. References SRPC_impl::ic_int64_array, and SRPC_impl::op_send_int64_array. Referenced by C_Add_Int64Array().

void SRPC::send_int_seq (  int_seq &  is  )  throw (failure)

Definition at line 646 of file SRPC.C. References int_seq_impl::allocate_buffer(), SRPC_impl::ic_int32_seq, and SRPC_impl::op_send_int32_seq. Referenced by C_Addna(), C_Addnf(), and C_Seq2().

void SRPC::send_seq_end (   )  throw (failure)

Definition at line 973 of file SRPC.C. References SRPC_impl::data_out, SRPC_impl::ic_seq_end, and SRPC_impl::op_send_seq_end. Referenced by C_Seq1(), and C_Seq2().

void SRPC::send_seq_start (  int  len = any, int  bytes = any )  throw (failure)

Definition at line 945 of file SRPC.C. References SRPC_impl::ic_seq_start, SRPC_impl::op_send_seq_start, and SRPC_impl::seq_out. Referenced by C_Seq1(), and C_Seq2().

void SRPC::send_short (  Basics::int16  i  )  throw (failure) [inline]

Definition at line 218 of file SRPC.H. References send_int16().

void SRPC::send_short_array (  const Basics::int16 *  seq, int  len )  throw (SRPC::failure) [inline]

Definition at line 319 of file SRPC.H. References send_int16_array().

void SRPC::send_socket (  sockaddr_in &  sock  )  throw (failure)

Definition at line 596 of file SRPC.C. References SRPC_impl::ic_socket, and SRPC_impl::op_send_socket. Referenced by RunTool::send_relay_socket(), and RunTool::send_vdir().

void SRPC::send_Text (  const Text &  t  )  throw (failure)

Definition at line 483 of file SRPC.C. References SRPC_impl::ic_text, and SRPC_impl::op_send_text. Referenced by C_Cat2T(), RunTool::do_it(), S_Cat2T(), and S_Catnf().

TCP_sock * SRPC::socket (   )  throw (failure)

Definition at line 137 of file SRPC.C. References p, and SRPC_impl::s. Referenced by local_socket(), and remote_socket().

void SRPC::split_name (  const Text &  host_and_port, Text &  host, Text &  port )  [static]

Definition at line 107 of file SRPC.C. References Text::FindCharR(), and Text::Sub().

void SRPC::start_call (  int  proc_id = default_proc_id, int  intf_version = default_intf_version )  throw (failure)

Definition at line 204 of file SRPC.C. References SRPC_impl::ic_start_call, SRPC_impl::op_start_call, and SRPC_impl::ready. Referenced by VDirSurrogate::acquireMastership(), CacheC::AddEntry(), C_Conn3(), C_Conn4(), C_Conn5(), C_Conn6(), C_Conn7(), C_Multi1(), VDirSurrogate::cedeMastership(), CacheC::Checkpoint(), VDirSurrogate::collapseBase(), WeederC::CommitChkpt(), VDirSurrogate::createVolatileDirectory(), VDirSurrogate::deleteVolatileDirectory(), RunTool::do_it(), WeederC::EndMark(), VDirSurrogate::fpToShortId(), CacheC::FreeVariables(), RunTool::get_info(), VDirSurrogate::getAttrib(), VDirSurrogate::getAttribHistory(), VDirSurrogate::getBase(), DebugC::GetCacheId(), DebugC::GetCacheInstance(), DebugC::GetCacheState(), WeederC::GetLeases(), VDirSurrogate::getNFSInfo(), VDirSurrogate::getUserInfo(), VDirSurrogate::inAttribs(), WeederC::init_server_instance(), CacheC::init_server_instance(), VDirSurrogate::insertAppendableDirectory(), VDirSurrogate::insertFile(), VDirSurrogate::insertGhost(), VDirSurrogate::insertImmutableDirectory(), VDirSurrogate::insertMutableDirectory(), VDirSurrogate::insertMutableFile(), VDirSurrogate::insertStub(), VDirSurrogate::list(), VDirEvaluator::list(), VDirSurrogate::listAttribs(), VDirEvaluator::lookup(), CacheC::Lookup(), VDirSurrogate::lookupIndex(), VDirSurrogate::lookupPathname(), MainClientProc(), VDirSurrogate::makeFilesImmutable(), VDirSurrogate::makeMutable(), VDirSurrogate::measureDirectory(), WeederC::NullCall(), DebugC::NullCall(), VDirSurrogate::read(), VDirSurrogate::readWhole(), VDirSurrogate::reallyDelete(), VDirSurrogate::refreshAccessTables(), VDirSurrogate::renameTo(), CacheC::RenewLeases(), VDirSurrogate::replicate(), VDirSurrogate::replicateAttribs(), VDirSurrogate::setExecutable(), WeederC::SetHitFilter(), VDirSurrogate::setIndexMaster(), VDirSurrogate::setMaster(), VDirSurrogate::setSize(), VDirSurrogate::setTimestamp(), WeederC::StartMark(), WeederC::WeederRecovering(), VDirSurrogate::write(), and VDirSurrogate::writeAttrib().

Text SRPC::this_host (   )  throw (failure) [static]

Definition at line 99 of file SRPC.C. References convert_TCP_failure(), and TCP_sock::this_host(). Referenced by CreateRootForDeriveds(), and RunTool().

SRPC::throw (  failure   )

---

Friends And Related Function Documentation

friend class SRPC_impl [friend]

Definition at line 52 of file SRPC.H.

---

Member Data Documentation

pthread_once_t SRPC::init_block [static, private]

Definition at line 500 of file SRPC.H.

SRPC_impl* SRPC::p [private]

Definition at line 499 of file SRPC.H. Referenced by disable_read_timeout(), local_socket(), remote_socket(), and socket().

---

The documentation for this class was generated from the following files:

• /vesta/vestasys.org/vesta/srpc/33/src/SRPC.H
• /vesta/vestasys.org/vesta/srpc/33/src/SRPC.C

---