comm.cc File Reference

#include <sys/param.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/time.h>
#include <errno.h>
#include <stdio.h>
#include "coda_string.h"
#include <struct.h>
#include <unistd.h>
#include <stdlib.h>
#include <rpc2/rpc2.h>
#include <rpc2/se.h>
#include <rpc2/errors.h>
#include <vice.h>
#include <inconsist.h>
#include "comm.h"
#include "fso.h"
#include "mariner.h"
#include "user.h"
#include "venus.private.h"
#include "venusrecov.h"
#include "venusvol.h"
#include "vproc.h"

Include dependency graph for comm.cc:

Functions
int	Fcon_Init ()
void	SFTP_SetDefaults (SFTP_Initializer *initPtr)
void	SFTP_Activate (SFTP_Initializer *initPtr)
void	CommInit ()
void	PutConn (connent **cpp)
void	ConnPrint ()
void	ConnPrint (FILE *fp)
void	ConnPrint (int fd)
void	Srvr_Wait ()
void	Srvr_Signal ()
srvent *	FindServer (struct in_addr *host)
srvent *	FindServerByCBCid (RPC2_Handle connid)
srvent *	GetServer (struct in_addr *host, RealmId realmid)
void	PutServer (srvent **spp)
void	ProbeServers (int Up)
void	DoProbes (int HowMany, struct in_addr *Hosts)
void	MultiBind (int HowMany, struct in_addr *Hosts, connent **Connections)
void	MultiProbe (int HowMany, RPC2_Handle *Handles)
long	HandleProbe (int HowMany, RPC2_Handle Handles[], long offset, long rpcval,...)
void	DownServers (char *buf, unsigned int *bufsize)
void	DownServers (int nservers, struct in_addr *hostids, char *buf, unsigned int *bufsize)
void	CheckServerBW (long curr_time)
void	ServerPrint ()
void	ServerPrint (FILE *f)
int	FailDisconnect (int nservers, struct in_addr *hostids)
int	FailReconnect (int nservers, struct in_addr *hostids)

Variables
int	COPModes = 6
char	myHostName [MAXHOSTNAMELEN]
int	rpc2_retries = UNSET_RT
int	rpc2_timeout = UNSET_TO
int	sftp_windowsize = UNSET_WS
int	sftp_sendahead = UNSET_SA
int	sftp_ackpoint = UNSET_AP
int	sftp_packetsize = UNSET_PS
int	rpc2_timeflag = UNSET_ST
int	mrpc2_timeflag = UNSET_MT
long	RPC2_Perror
struct CommQueueStruct	CommQueue
int(*	Fail_SendPredicate )(unsigned char ip1, unsigned char ip2, unsigned char ip3, unsigned char ip4, unsigned char color, RPC2_PacketBuffer *pb, struct sockaddr_in *sin, int fd)
int(*	Fail_RecvPredicate )(unsigned char ip1, unsigned char ip2, unsigned char ip3, unsigned char ip4, unsigned char color, RPC2_PacketBuffer *pb, struct sockaddr_in *sin, int fd)

Function Documentation

CheckServerBW()

void CheckServerBW

(

long

curr_time

)

CommInit()

void CommInit

(

)

ConnPrint() [1/3]

void ConnPrint

(

)

ConnPrint() [2/3]

void ConnPrint

(

FILE *

fp

)

ConnPrint() [3/3]

void ConnPrint

(

int

fd

)

DoProbes()

void DoProbes	(	int	HowMany,
		struct in_addr *	Hosts
	)

DownServers() [1/2]

void DownServers	(	char *	buf,
		unsigned int *	bufsize
	)

DownServers() [2/2]

void DownServers	(	int	nservers,
		struct in_addr *	hostids,
		char *	buf,
		unsigned int *	bufsize
	)

FailDisconnect()

int FailDisconnect	(	int	nservers,
		struct in_addr *	hostids
	)

FailReconnect()

int FailReconnect	(	int	nservers,
		struct in_addr *	hostids
	)

Fcon_Init()

int Fcon_Init

(

)

FindServer()

srvent * FindServer

(

struct in_addr *

host

)

FindServerByCBCid()

srvent * FindServerByCBCid

(

RPC2_Handle

connid

)

GetServer()

srvent * GetServer	(	struct in_addr *	host,
		RealmId	realmid
	)

HandleProbe()

long HandleProbe	(	int	HowMany,
		RPC2_Handle	Handles[],
		long	offset,
		long	rpcval,
			...
	)

MultiBind()

void MultiBind	(	int	HowMany,
		struct in_addr *	Hosts,
		connent **	Connections
	)

MultiProbe()

void MultiProbe	(	int	HowMany,
		RPC2_Handle *	Handles
	)

ProbeServers()

void ProbeServers

(

int

Up

)

PutConn()

void PutConn

(

connent **

cpp

)

PutServer()

void PutServer

(

srvent **

spp

)

ServerPrint() [1/2]

void ServerPrint

(

)

ServerPrint() [2/2]

void ServerPrint

(

FILE *

f

)

SFTP_Activate()

void SFTP_Activate

(

SFTP_Initializer *

initPtr

)

SFTP_SetDefaults()

void SFTP_SetDefaults

(

SFTP_Initializer *

initPtr

)

Srvr_Signal()

void Srvr_Signal

(

)

Srvr_Wait()

void Srvr_Wait

(

)

Variable Documentation

CommQueue

struct CommQueueStruct CommQueue

COPModes

int COPModes = 6

Fail_RecvPredicate

int(* Fail_RecvPredicate) (unsigned char ip1, unsigned char ip2, unsigned char ip3, unsigned char ip4, unsigned char color, RPC2_PacketBuffer *pb, struct sockaddr_in *sin, int fd) ( unsigned char  ip1, unsigned char  ip2, unsigned char  ip3, unsigned char  ip4, unsigned char  color, RPC2_PacketBuffer *  pb, struct sockaddr_in *  sin, int  fd  )

extern

Fail_SendPredicate

int(* Fail_SendPredicate) (unsigned char ip1, unsigned char ip2, unsigned char ip3, unsigned char ip4, unsigned char color, RPC2_PacketBuffer *pb, struct sockaddr_in *sin, int fd) ( unsigned char  ip1, unsigned char  ip2, unsigned char  ip3, unsigned char  ip4, unsigned char  color, RPC2_PacketBuffer *  pb, struct sockaddr_in *  sin, int  fd  )

extern

mrpc2_timeflag

int mrpc2_timeflag = UNSET_MT

myHostName

char myHostName[MAXHOSTNAMELEN]

RPC2_Perror

long RPC2_Perror

extern

rpc2_retries

int rpc2_retries = UNSET_RT

rpc2_timeflag

int rpc2_timeflag = UNSET_ST

rpc2_timeout

int rpc2_timeout = UNSET_TO

sftp_ackpoint

int sftp_ackpoint = UNSET_AP

sftp_packetsize

int sftp_packetsize = UNSET_PS

sftp_sendahead

int sftp_sendahead = UNSET_SA

sftp_windowsize

int sftp_windowsize = UNSET_WS