afs_int32 origCBs, origZaps, finalZaps;
struct vrequest treq;
register afs_int32 code;
- register struct conn *tc;
+ register struct afs_conn *tc;
struct VenusFid newFid;
struct AFSStoreStatus InStatus;
struct AFSFetchStatus OutFidStatus, OutDirStatus;
{
struct vrequest treq;
register afs_int32 code;
- register struct conn *tc;
+ register struct afs_conn *tc;
struct VenusFid newFid;
register struct dcache *tdc;
struct dcache *new_dc;
register struct dcache *tdc;
register struct vcache *tvc = NULL;
register afs_int32 code;
- register struct conn *tc;
+ register struct afs_conn *tc;
afs_size_t offset, len;
struct AFSFetchStatus OutDirStatus;
struct AFSVolSync tsync;
HandleFlock(register struct vcache *avc, int acom, struct vrequest *areq,
pid_t clid, int onlymine)
{
- struct conn *tc;
+ struct afs_conn *tc;
struct SimpleLocks *slp, *tlp, **slpp;
afs_int32 code;
struct AFSVolSync tsync;
static int
GetFlockCount(struct vcache *avc, struct vrequest *areq)
{
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code;
struct AFSFetchStatus OutStatus;
struct AFSCallBack CallBack;
struct vrequest treq;
register struct dcache *tdc;
register afs_int32 code;
- register struct conn *tc;
+ register struct afs_conn *tc;
afs_size_t offset, len;
struct AFSFetchStatus OutFidStatus, OutDirStatus;
struct AFSVolSync tsync;
AFSCBFids fidParm; /* file ID parm for bulk stat */
AFSBulkStats statParm; /* stat info parm for bulk stat */
int fidIndex = 0; /* which file were stating */
- struct conn *tcp = 0; /* conn for call */
+ struct afs_conn *tcp = 0; /* conn for call */
AFSCBs cbParm; /* callback parm for bulk stat */
struct server *hostp = 0; /* host we got callback from */
long startTime; /* time we started the call,
struct vrequest *treqp)
{
register afs_int32 code = 0;
- register struct conn *tc;
+ register struct afs_conn *tc;
struct AFSFetchStatus OutDirStatus;
struct AFSVolSync tsync;
XSTATS_DECLS;
afsrename(struct vcache *aodp, char *aname1, struct vcache *andp,
char *aname2, struct AFS_UCRED *acred, struct vrequest *areq)
{
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code = 0;
afs_int32 returnCode;
int oneDir, doLocally;
afs_uint32 now = 0;
struct vrequest treq;
afs_int32 code;
- struct conn *tc;
+ struct afs_conn *tc;
struct VenusFid newFid;
struct dcache *tdc;
afs_size_t offset, len;
void *cellinfo; /* pointer to cell info (PAG manager only) */
};
-struct conn {
+struct afs_conn {
/* Per-connection block. */
- struct conn *next; /* Next dude same server. */
+ struct afs_conn *next; /* Next dude same server. */
struct unixuser *user; /* user validated with respect to. */
struct rx_connection *id; /* RPC connid. */
struct srvAddr *srvr; /* server associated with this conn */
struct srvAddr *next_bkt; /* next item in hash bucket */
struct srvAddr *next_sa; /* another interface on same host */
struct server *server; /* back to parent */
- struct conn *conns; /* All user connections to this server */
+ struct afs_conn *conns; /* All user connections to this server */
afs_int32 sa_ip; /* Host addr in network byte order */
u_short sa_iprank; /* indiv ip address priority */
u_short sa_portal; /* port addr in network byte order */
VLDB_Same(struct VenusFid *afid, struct vrequest *areq)
{
struct vrequest treq;
- struct conn *tconn;
+ struct afs_conn *tconn;
int i, type = 0;
union {
struct vldbentry tve;
* if this is a temporary or permanent error.
*------------------------------------------------------------------------*/
int
-afs_Analyze(register struct conn *aconn, afs_int32 acode,
+afs_Analyze(register struct afs_conn *aconn, afs_int32 acode,
struct VenusFid *afid, register struct vrequest *areq, int op,
afs_int32 locktype, struct cell *cellp)
{
struct vrequest *areq;
afs_int32 code, length_hi, bytes, locked;
- register struct conn *tc;
+ register struct afs_conn *tc;
afs_int32 i;
struct rx_call *tcall;
struct tlocal1 {
*
* @return The conn struct, or NULL.
*/
-struct conn *
+struct afs_conn *
afs_Conn(register struct VenusFid *afid, register struct vrequest *areq,
afs_int32 locktype)
{
u_short fsport = AFS_FSPORT;
struct volume *tv;
- struct conn *tconn = NULL;
+ struct afs_conn *tconn = NULL;
struct srvAddr *lowp = NULL;
struct unixuser *tu;
int notbusy;
*
* @return The new connection.
*/
-struct conn *
+struct afs_conn *
afs_ConnBySA(struct srvAddr *sap, unsigned short aport, afs_int32 acell,
struct unixuser *tu, int force_if_down, afs_int32 create,
afs_int32 locktype)
{
- struct conn *tc = 0;
+ struct afs_conn *tc = 0;
struct rx_securityClass *csec; /*Security class object */
int isec; /*Security index */
int service;
* gets set, marking the time of its ``birth''.
*/
UpgradeSToWLock(&afs_xconn, 37);
- tc = (struct conn *)afs_osi_Alloc(sizeof(struct conn));
- memset((char *)tc, 0, sizeof(struct conn));
+ tc = (struct afs_conn *)afs_osi_Alloc(sizeof(struct afs_conn));
+ memset((char *)tc, 0, sizeof(struct afs_conn));
tc->user = tu;
tc->port = aport;
*
* @return The established connection.
*/
-struct conn *
+struct afs_conn *
afs_ConnByHost(struct server *aserver, unsigned short aport, afs_int32 acell,
struct vrequest *areq, int aforce, afs_int32 locktype)
{
struct unixuser *tu;
- struct conn *tc = 0;
+ struct afs_conn *tc = 0;
struct srvAddr *sa = 0;
AFS_STATCNT(afs_ConnByHost);
*
* @return The established connection or NULL.
*/
-struct conn *
+struct afs_conn *
afs_ConnByMHosts(struct server *ahosts[], unsigned short aport,
afs_int32 acell, register struct vrequest *areq,
afs_int32 locktype)
{
register afs_int32 i;
- register struct conn *tconn;
+ register struct afs_conn *tconn;
register struct server *ts;
/* try to find any connection from the set */
* @param locktype
*/
void
-afs_PutConn(register struct conn *ac, afs_int32 locktype)
+afs_PutConn(register struct afs_conn *ac, afs_int32 locktype)
{
AFS_STATCNT(afs_PutConn);
ac->refCount--;
void
ForceNewConnections(struct srvAddr *sap)
{
- struct conn *tc = 0;
+ struct afs_conn *tc = 0;
if (!sap)
return; /* defensive check */
struct tlocal1 *tsmall = 0;
register struct dcache *tdc;
register struct osi_file *file;
- register struct conn *tc;
+ register struct afs_conn *tc;
int downDCount = 0;
struct server *newCallback = NULL;
char setNewCallback;
char *old_name, *new_name;
struct AFSFetchStatus OutOldDirStatus, OutNewDirStatus;
struct AFSVolSync tsync;
- struct conn *tc;
+ struct afs_conn *tc;
afs_uint32 code = 0;
XSTATS_DECLS;
struct AFSVolSync tsync;
struct vcache *tdp = NULL, *tvc = NULL;
struct dcache *tdc = NULL;
- struct conn *tc;
+ struct afs_conn *tc;
afs_int32 now, hash, new_hash, index;
int code = 0;
XSTATS_DECLS;
struct AFSFetchStatus OutDirStatus;
struct VenusFid pdir_fid;
struct AFSVolSync tsync;
- struct conn *tc;
+ struct afs_conn *tc;
struct vcache *tdp = NULL;
int code = 0;
XSTATS_DECLS;
*/
int afs_SendChanges(struct vcache *avc, struct vrequest *areq)
{
- struct conn *tc;
+ struct afs_conn *tc;
struct AFSStoreStatus sstat;
struct AFSFetchStatus fstat;
struct AFSVolSync tsync;
*/
int afs_ResyncDisconFiles(struct vrequest *areq, struct AFS_UCRED *acred)
{
- struct conn *tc;
+ struct afs_conn *tc;
struct vcache *tvc, *tmp;
struct AFSFetchStatus fstat;
struct AFSCallBack callback;
*/
{
struct server *ts, *nts;
- struct conn *tc, *ntc;
+ struct afs_conn *tc, *ntc;
register struct afs_cbr *tcbrp, *tbrp;
for (i = 0; i < NSERVERS; i++) {
AFS_GUNLOCK();
rx_DestroyConnection(tc->id);
AFS_GLOCK();
- afs_osi_Free(tc, sizeof(struct conn));
+ afs_osi_Free(tc, sizeof(struct afs_conn));
tc = ntc;
}
}
DECL_PIOCTL(PSetAcl)
{
register afs_int32 code;
- struct conn *tconn;
+ struct afs_conn *tconn;
struct AFSOpaque acl;
struct AFSVolSync tsync;
struct AFSFetchStatus OutStatus;
struct AFSVolSync tsync;
struct AFSFetchStatus OutStatus;
afs_int32 code;
- struct conn *tconn;
+ struct afs_conn *tconn;
struct AFSFid Fid;
XSTATS_DECLS;
char volName[32];
char *offLineMsg = afs_osi_Alloc(256);
char *motd = afs_osi_Alloc(256);
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code = 0;
struct AFSFetchVolumeStatus volstat;
register char *cp;
char volName[32];
char *offLineMsg = afs_osi_Alloc(256);
char *motd = afs_osi_Alloc(256);
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code = 0;
struct AFSFetchVolumeStatus volstat;
struct AFSStoreVolumeStatus storeStat;
{
int i;
struct srvAddr *sa;
- struct conn *tc;
+ struct afs_conn *tc;
struct unixuser *tu;
afs_int32 retValue;
*/
DECL_PIOCTL(PRemoveCallBack)
{
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code = 0;
struct AFSCallBack CallBacks_Array[1];
struct AFSCBFids theFids;
char *bufp;
struct sysname_info sysState;
afs_size_t offset, len;
- register struct conn *tc;
+ register struct afs_conn *tc;
register struct dcache *tdc;
register struct vcache *tvc;
struct AFSFetchStatus OutDirStatus;
{
register afs_int32 code, code1;
afs_int32 bytes;
- struct conn *tc;
+ struct afs_conn *tc;
struct rx_call *tcall;
struct AFSVolSync tsync;
struct AFSFetchStatus OutStatus;
DECL_PIOCTL(PResidencyCmd)
{
register afs_int32 code;
- struct conn *tc;
+ struct afs_conn *tc;
struct vcache *tvc;
struct ResidencyCmdInputs *Inputs;
struct ResidencyCmdOutputs *Outputs;
int srvAddrCount;
struct server *ts;
struct srvAddr *sa;
- struct conn *tc;
+ struct afs_conn *tc;
afs_int32 i, j;
struct unixuser *tu;
struct srvAddr **addrs;
#define _AFS_PROTOTYPES_H_
/* afs_analyze.c */
-extern int afs_Analyze(register struct conn *aconn, afs_int32 acode,
+extern int afs_Analyze(register struct afs_conn *aconn, afs_int32 acode,
struct VenusFid *afid, register struct vrequest *areq,
int op, afs_int32 locktype, struct cell *cellp);
extern afs_int32 cryptall;
extern afs_rwlock_t afs_xinterface;
extern afs_rwlock_t afs_xconn;
-extern struct conn *afs_Conn(register struct VenusFid *afid,
+extern struct afs_conn *afs_Conn(register struct VenusFid *afid,
register struct vrequest *areq,
afs_int32 locktype);
-extern struct conn *afs_ConnBySA(struct srvAddr *sap, unsigned short aport,
+extern struct afs_conn *afs_ConnBySA(struct srvAddr *sap, unsigned short aport,
afs_int32 acell, struct unixuser *tu,
int force_if_down, afs_int32 create,
afs_int32 locktype);
-extern struct conn *afs_ConnByMHosts(struct server *ahosts[],
+extern struct afs_conn *afs_ConnByMHosts(struct server *ahosts[],
unsigned short aport, afs_int32 acell,
register struct vrequest *areq,
afs_int32 locktype);
-extern struct conn *afs_ConnByHost(struct server *aserver,
+extern struct afs_conn *afs_ConnByHost(struct server *aserver,
unsigned short aport, afs_int32 acell,
struct vrequest *areq, int aforce,
afs_int32 locktype);
-extern void afs_PutConn(register struct conn *ac, afs_int32 locktype);
+extern void afs_PutConn(register struct afs_conn *ac, afs_int32 locktype);
extern void ForceNewConnections(struct srvAddr *sap);
int
afs_StoreMini(register struct vcache *avc, struct vrequest *areq)
{
- register struct conn *tc;
+ register struct afs_conn *tc;
struct AFSStoreStatus InStatus;
struct AFSFetchStatus OutStatus;
struct AFSVolSync tsync;
int nomore;
unsigned int first = 0;
int *shouldwake;
- struct conn *tc;
+ struct afs_conn *tc;
struct osi_file *tfile;
struct rx_call *tcall;
XSTATS_DECLS;
CheckVLServer(register struct srvAddr *sa, struct vrequest *areq)
{
register struct server *aserver = sa->server;
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code;
AFS_STATCNT(CheckVLServer);
struct vrequest treq;
struct server *ts;
struct srvAddr *sa;
- struct conn *tc;
+ struct afs_conn *tc;
afs_int32 i, j;
afs_int32 code;
afs_int32 start, end = 0, delta;
char tbuffer[CVBS];
int srvAddrCount;
struct srvAddr **addrs;
- struct conn **conns;
+ struct afs_conn **conns;
int nconns;
struct rx_connection **rxconns;
afs_int32 *conntimer, *deltas, *results;
if (AFS_IS_DISCONNECTED)
return;
- conns = (struct conn **)0;
+ conns = (struct afs_conn **)0;
rxconns = (struct rx_connection **) 0;
conntimer = 0;
nconns = 0;
ReleaseReadLock(&afs_xsrvAddr);
ReleaseReadLock(&afs_xserver);
- conns = (struct conn **)afs_osi_Alloc(j * sizeof(struct conn *));
+ conns = (struct afs_conn **)afs_osi_Alloc(j * sizeof(struct afs_conn *));
rxconns = (struct rx_connection **)afs_osi_Alloc(j * sizeof(struct rx_connection *));
conntimer = (afs_int32 *)afs_osi_Alloc(j * sizeof (afs_int32));
deltas = (afs_int32 *)afs_osi_Alloc(j * sizeof (afs_int32));
}
afs_osi_Free(addrs, srvAddrCount * sizeof(*addrs));
- afs_osi_Free(conns, j * sizeof(struct conn *));
+ afs_osi_Free(conns, j * sizeof(struct afs_conn *));
afs_osi_Free(rxconns, j * sizeof(struct rx_connection *));
afs_osi_Free(conntimer, j * sizeof(afs_int32));
afs_osi_Free(deltas, j * sizeof(afs_int32));
int i;
struct server *ts, *nts;
struct srvAddr *sa;
- struct conn *tc, *ntc;
+ struct afs_conn *tc, *ntc;
ObtainReadLock(&afs_xserver);
ObtainWriteLock(&afs_xconn, 1001);
AFS_GUNLOCK();
rx_DestroyConnection(tc->id);
AFS_GLOCK();
- afs_osi_Free(tc, sizeof(struct conn));
+ afs_osi_Free(tc, sizeof(struct afs_conn));
tc = ntc;
}
sa->conns = NULL;
register int i;
register struct server *ts;
register struct srvAddr *sa;
- register struct conn *tc, **lc;
+ register struct afs_conn *tc, **lc;
AFS_STATCNT(RemoveUserConns);
for (i = 0; i < NSERVERS; i++) {
AFS_GUNLOCK();
rx_DestroyConnection(tc->id);
AFS_GLOCK();
- afs_osi_Free(tc, sizeof(struct conn));
+ afs_osi_Free(tc, sizeof(struct afs_conn));
break; /* at most one instance per server */
} /*Found unreferenced connection for user */
} /*For each connection on the server */
{
int i;
struct srvAddr *sa;
- struct conn *tc;
+ struct afs_conn *tc;
AFS_STATCNT(afs_ResetUserConns);
ObtainReadLock(&afs_xsrvAddr);
{
struct srvAddr *sa;
struct server *ts;
- struct conn *tc;
+ struct afs_conn *tc;
for (i = 0; i < NSERVERS; i++) {
for (ts = afs_servers[i]; ts; ts = ts->next) {
if (ts->flags & SRVR_ISDOWN)
struct server *tsp;
int i;
struct vrequest treq;
- struct conn *tc;
+ struct afs_conn *tc;
int safety1, safety2, safety3;
XSTATS_DECLS;
if ((code = afs_InitReq(&treq, afs_osi_credp)))
{
register struct vcache *tvc;
register int i;
- register struct conn *tc;
+ register struct afs_conn *tc;
register afs_int32 code;
register struct AFS_UCRED *cred = NULL;
struct vrequest treq, ureq;
struct vrequest *areq)
{
afs_int32 code;
- struct conn *tc;
+ struct afs_conn *tc;
struct AFSFetchStatus OutStatus;
struct AFSVolSync tsync;
XSTATS_DECLS;
{
afs_int32 code;
afs_uint32 start;
- register struct conn *tc;
+ register struct afs_conn *tc;
struct AFSFetchStatus OutDirStatus;
XSTATS_DECLS;
if (!name)
{
int code;
afs_uint32 start = 0;
- register struct conn *tc;
+ register struct afs_conn *tc;
struct AFSCallBack CallBack;
struct AFSVolSync tsync;
XSTATS_DECLS;
void
afs_StuffVcache(register struct VenusFid *afid,
struct AFSFetchStatus *OutStatus,
- struct AFSCallBack *CallBack, register struct conn *tc,
+ struct AFSCallBack *CallBack, register struct afs_conn *tc,
struct vrequest *areq)
{
register afs_int32 code, i, newvcache = 0;
struct uvldbentry *utve;
struct cell *tcell;
char *tbuffer, *ve;
- struct conn *tconn;
+ struct afs_conn *tconn;
struct vrequest treq;
if (strlen(aname) > VL_MAXNAMELEN) /* Invalid volume name */
struct cell *tcell, struct vrequest *areq)
{
register struct server *ts;
- struct conn *tconn;
+ struct afs_conn *tconn;
struct cell *cellp;
register int i, j;
afs_uint32 serverid;
};
-typedef struct conn_rec conn_rec;
+typedef struct afs_conn_rec conn_rec;
typedef struct server_rec server_rec;
typedef struct request_rec request_rec;
typedef struct listen_rec listen_rec;
/* Things which are per connection
*/
-struct conn_rec {
+struct afs_conn_rec {
pool *pool;
server_rec *server;
const struct htaccess_result *next;
};
- typedef struct conn_rec conn_rec;
+ typedef struct afs_conn_rec conn_rec;
typedef struct server_rec server_rec;
typedef struct request_rec request_rec;
typedef struct listen_rec listen_rec;
/* Things which are per connection
*/
- struct conn_rec {
+ struct afs_conn_rec {
ap_pool *pool;
server_rec *server;
const struct htaccess_result *next;
};
- typedef struct conn_rec conn_rec;
+ typedef struct afs_conn_rec conn_rec;
typedef struct server_rec server_rec;
typedef struct request_rec request_rec;
typedef struct listen_rec listen_rec;
/* Things which are per connection
*/
- struct conn_rec {
+ struct afs_conn_rec {
ap_pool *pool;
server_rec *server;
T += j;
printf("%20s:\t%8d bytes\t[%d servers/%d bytes each]\n", "Server package",
j, i, sizeof(struct server));
- j = (Nconns * sizeof(struct conn));
+ j = (Nconns * sizeof(struct afs_conn));
T += j;
printf("%20s:\t%8d bytes\t[%d conns/%d bytes each]\n",
- "Connection package", j, Nconns, sizeof(struct conn));
+ "Connection package", j, Nconns, sizeof(struct afs_conn));
i = (AFS_NCBRS * sizeof(struct afs_cbr)) * (j =
afs_cmperfstats.
print_conns(kmem, srv, conns, Con, pnt)
int kmem, Con, pnt;
struct srvAddr *srv;
- struct conn *conns;
+ struct afs_conn *conns;
{
- struct conn *cep, ce, *centry = &ce;
+ struct afs_conn *cep, ce, *centry = &ce;
int i = 1;
- cep = (struct conn *)conns;
+ cep = (struct afs_conn *)conns;
if (pnt && Con != 2) {
if (cep)
printf("\tRPC connections for server %lx:\n", srv);
void
print_conn(kmem, conns, ptr, pnt)
int kmem, pnt;
- struct conn *conns, *ptr;
+ struct afs_conn *conns, *ptr;
{
if (!pnt)
return;