#include <stdlib.h>
#include "afsd.h"
+#include "smb.h"
#include <osi.h>
#include <rx_pthread.h>
#include <WINNT/syscfg.h>
#include <WINNT/afsreg.h>
-#include <../afsrdr/kif.h>
/*extern void afsi_log(char *pattern, ...);*/
afs_int32 cm_giveUpAllCBs = 0;
+afs_int32 cm_shutdown = 0;
+
#ifdef AFS_FREELANCE_CLIENT
extern osi_mutex_t cm_Freelance_Lock;
#endif
/* for directories, this sends a change notification on the dir itself */
if (scp->fileType == CM_SCACHETYPE_DIRECTORY) {
-#ifndef AFSIFS
if (scp->flags & CM_SCACHEFLAG_ANYWATCH)
smb_NotifyChange(0,
FILE_NOTIFY_GENERIC_DIRECTORY_FILTER,
scp, NULL, NULL, TRUE);
-#else
- dc_break_callback(FID_HASH_FN(&scp->fid));
-#endif
} else {
/* and for files, this sends a change notification on the file's parent dir */
cm_fid_t tfid;
cm_SetFid(&tfid, scp->fid.cell, scp->fid.volume, scp->parentVnode, scp->parentUnique);
dscp = cm_FindSCache(&tfid);
-#ifndef AFSIFS
if ( dscp &&
dscp->flags & CM_SCACHEFLAG_ANYWATCH )
smb_NotifyChange( 0,
FILE_NOTIFY_GENERIC_FILE_FILTER,
dscp, NULL, NULL, TRUE);
-#else
- if (dscp)
- dc_break_callback(FID_HASH_FN(&dscp->fid));
-#endif
if (dscp)
cm_ReleaseSCache(dscp);
}
cm_CallbackNotifyChange(scp);
lock_ObtainWrite(&cm_scacheLock);
cm_ReleaseSCacheNoLock(scp);
-
- if (scp->flags & CM_SCACHEFLAG_PURERO && scp->volp) {
- scp->volp->cbExpiresRO = 0;
+ if (scp->flags & CM_SCACHEFLAG_PURERO) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ volp->cbExpiresRO = 0;
+ cm_PutVolume(volp);
+ }
}
-
}
} /* search one hash bucket */
} /* search all hash buckets */
cm_server_t *tsp = NULL;
cm_cell_t* cellp = NULL;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
tsp = cm_FindServerByIP(host, CM_SERVER_FILE);
- if (tsp)
+ if (tsp) {
cellp = tsp->cellp;
+ cm_PutServer(tsp);
+ }
if (!cellp)
osi_Log2(afsd_logp, "SRXAFSCB_CallBack from host 0x%x port %d",
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
lock_ObtainWrite(&cm_scacheLock);
cm_ReleaseSCacheNoLock(scp);
- if (discarded && (scp->flags & CM_SCACHEFLAG_PURERO) && scp->volp && scp->volp->cbExpiresRO != 0)
- scp->volp->cbExpiresRO = 0;
+ if (discarded && (scp->flags & CM_SCACHEFLAG_PURERO)) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ if (volp->cbExpiresRO != 0)
+ volp->cbExpiresRO = 0;
+ cm_PutVolume(volp);
+ }
+ }
} /* search one hash bucket */
} /* search all hash buckets */
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
extern osi_rwlock_t cm_aclLock;
extern osi_rwlock_t buf_globalLock;
-extern osi_rwlock_t cm_callbackLock;
extern osi_rwlock_t cm_cellLock;
extern osi_rwlock_t cm_connLock;
extern osi_rwlock_t cm_daemonLock;
extern osi_rwlock_t cm_dnlcLock;
extern osi_rwlock_t cm_scacheLock;
extern osi_rwlock_t cm_serverLock;
+extern osi_rwlock_t cm_syscfgLock;
extern osi_rwlock_t cm_userLock;
extern osi_rwlock_t cm_utilsLock;
extern osi_rwlock_t cm_volumeLock;
extern osi_rwlock_t smb_rctLock;
extern osi_mutex_t cm_Freelance_Lock;
-extern osi_mutex_t cm_bufGetMutex;
extern osi_mutex_t cm_Afsdsbmt_Lock;
extern osi_mutex_t tokenEventLock;
extern osi_mutex_t smb_ListenerLock;
{"buf_globalLock", (char*)&buf_globalLock, LOCKTYPE_RW},
{"cm_serverLock", (char*)&cm_serverLock, LOCKTYPE_RW},
{"cm_callbackLock", (char*)&cm_callbackLock, LOCKTYPE_RW},
+ {"cm_syscfgLock", (char*)&cm_syscfgLock, LOCKTYPE_RW},
{"cm_aclLock", (char*)&cm_aclLock, LOCKTYPE_RW},
{"cm_cellLock", (char*)&cm_cellLock, LOCKTYPE_RW},
{"cm_connLock", (char*)&cm_connLock, LOCKTYPE_RW},
{"smb_globalLock", (char*)&smb_globalLock, LOCKTYPE_RW},
{"smb_rctLock", (char*)&smb_rctLock, LOCKTYPE_RW},
{"cm_Freelance_Lock",(char*)&cm_Freelance_Lock, LOCKTYPE_MUTEX},
- {"cm_bufGetMutex", (char*)&cm_bufGetMutex, LOCKTYPE_MUTEX},
{"cm_Afsdsbmt_Lock", (char*)&cm_Afsdsbmt_Lock, LOCKTYPE_MUTEX},
{"tokenEventLock", (char*)&tokenEventLock, LOCKTYPE_MUTEX},
{"smb_ListenerLock", (char*)&smb_ListenerLock, LOCKTYPE_MUTEX},
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
cep->Length = scp->length.LowPart;
cep->DataVersion = (afs_uint32)(scp->dataVersion & 0xFFFFFFFF);
cep->callback = afs_data_pointer_to_int32(scp->cbServerp);
- if (scp->flags & CM_SCACHEFLAG_PURERO && scp->volp)
- cep->cbExpires = scp->volp->cbExpiresRO;
- else
- cep->cbExpires = scp->cbExpires;
+ if (scp->flags & CM_SCACHEFLAG_PURERO) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ cep->cbExpires = volp->cbExpiresRO;
+ cm_PutVolume(volp);
+ }
+ } else {
+ /* TODO: deal with time_t below */
+ cep->cbExpires = (afs_int32) scp->cbExpires;
+ }
cep->refCount = scp->refCount;
cep->opens = scp->openReads;
cep->writers = scp->openWrites;
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
#endif
cep->DataVersion = (afs_uint32)(scp->dataVersion & 0xFFFFFFFF);
cep->callback = afs_data_pointer_to_int32(scp->cbServerp);
- if (scp->flags & CM_SCACHEFLAG_PURERO && scp->volp)
- cep->cbExpires = scp->volp->cbExpiresRO;
- else
- cep->cbExpires = scp->cbExpires;
+ if (scp->flags & CM_SCACHEFLAG_PURERO) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ cep->cbExpires = volp->cbExpiresRO;
+ cm_PutVolume(volp);
+ }
+ } else {
+ /* TODO: handle time_t */
+ cep->cbExpires = (afs_int32) scp->cbExpires;
+ }
cep->refCount = scp->refCount;
cep->opens = scp->openReads;
cep->writers = scp->openWrites;
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
int
SRXAFSCB_InitCallBackState2(struct rx_call *callp, struct interfaceAddr* addr)
{
+ if (cm_shutdown)
+ return 1;
+
osi_Log0(afsd_logp, "SRXAFSCB_InitCallBackState2 ->");
return SRXAFSCB_InitCallBackState(callp);
SRXAFSCB_WhoAreYou(struct rx_call *callp, struct interfaceAddr* addr)
{
int i;
- int cm_noIPAddr; /* number of client network interfaces */
- int cm_IPAddr[CM_MAXINTERFACE_ADDR]; /* client's IP address in host order */
- int cm_SubnetMask[CM_MAXINTERFACE_ADDR];/* client's subnet mask in host order*/
- int cm_NetMtu[CM_MAXINTERFACE_ADDR]; /* client's MTU sizes */
- int cm_NetFlags[CM_MAXINTERFACE_ADDR]; /* network flags */
long code;
struct rx_connection *connp;
struct rx_peer *peerp;
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
}
- /* get network related info */
- cm_noIPAddr = CM_MAXINTERFACE_ADDR;
- code = syscfg_GetIFInfo(&cm_noIPAddr,
- cm_IPAddr, cm_SubnetMask,
- cm_NetMtu, cm_NetFlags);
-
- /* return all network interface addresses */
osi_Log2(afsd_logp, "SRXAFSCB_WhoAreYou from host 0x%x port %d",
ntohl(host),
ntohs(port));
+ lock_ObtainRead(&cm_syscfgLock);
+ if (cm_LanAdapterChangeDetected) {
+ lock_ConvertRToW(&cm_syscfgLock);
+ if (cm_LanAdapterChangeDetected) {
+ /* get network related info */
+ cm_noIPAddr = CM_MAXINTERFACE_ADDR;
+ code = syscfg_GetIFInfo(&cm_noIPAddr,
+ cm_IPAddr, cm_SubnetMask,
+ cm_NetMtu, cm_NetFlags);
+ cm_LanAdapterChangeDetected = 0;
+ }
+ lock_ConvertWToR(&cm_syscfgLock);
+ }
+
+ /* return all network interface addresses */
addr->numberOfInterfaces = cm_noIPAddr;
addr->uuid = cm_data.Uuid;
for ( i=0; i < cm_noIPAddr; i++ ) {
cm_NetMtu[i] : rx_mtu;
}
+ lock_ReleaseRead(&cm_syscfgLock);
+
return 0;
}
{
char *p = NULL;
+ if (cm_shutdown)
+ return 1;
+
if (UuidToString((UUID *)serverUuid, &p) == RPC_S_OK) {
osi_Log1(afsd_logp, "SRXAFSCB_InitCallBackState3 %s ->",osi_LogSaveString(afsd_logp,p));
RpcStringFree(&p);
char *p,*q;
int code = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
unsigned short port = 0;
int rc;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
int i;
afs_int32 *dataBuffP;
afs_int32 dataBytes;
- int cm_noIPAddr; /* number of client network interfaces */
- int cm_IPAddr[CM_MAXINTERFACE_ADDR]; /* client's IP address in host order */
- int cm_SubnetMask[CM_MAXINTERFACE_ADDR];/* client's subnet mask in host order*/
- int cm_NetMtu[CM_MAXINTERFACE_ADDR]; /* client's MTU sizes */
- int cm_NetFlags[CM_MAXINTERFACE_ADDR]; /* network flags */
long code;
struct rx_connection *connp;
struct rx_peer *peerp;
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
}
- /* get network related info */
- cm_noIPAddr = CM_MAXINTERFACE_ADDR;
- code = syscfg_GetIFInfo(&cm_noIPAddr,
- cm_IPAddr, cm_SubnetMask,
- cm_NetMtu, cm_NetFlags);
-
osi_Log2(afsd_logp, "SRXAFSCB_TellMeAboutYourself from host 0x%x port %d",
ntohl(host),
ntohs(port));
+ lock_ObtainRead(&cm_syscfgLock);
+ if (cm_LanAdapterChangeDetected) {
+ lock_ConvertRToW(&cm_syscfgLock);
+ if (cm_LanAdapterChangeDetected) {
+ /* get network related info */
+ cm_noIPAddr = CM_MAXINTERFACE_ADDR;
+ code = syscfg_GetIFInfo(&cm_noIPAddr,
+ cm_IPAddr, cm_SubnetMask,
+ cm_NetMtu, cm_NetFlags);
+ cm_LanAdapterChangeDetected = 0;
+ }
+ lock_ConvertWToR(&cm_syscfgLock);
+ }
+
/* return all network interface addresses */
addr->numberOfInterfaces = cm_noIPAddr;
addr->uuid = cm_data.Uuid;
addr->mtu[i] = (rx_mtu == -1 || (rx_mtu != -1 && cm_NetMtu[i] < rx_mtu)) ?
cm_NetMtu[i] : rx_mtu;
}
+ lock_ReleaseRead(&cm_syscfgLock);
dataBytes = 1 * sizeof(afs_int32);
dataBuffP = (afs_int32 *) osi_Alloc(dataBytes);
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
unsigned short port = 0;
int rc;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
ntohl(host), ntohs(port));
if (cm_data.rootCellp) {
- t_name = (char *)malloc(strlen(cm_data.rootCellp->name)+1);
- strcpy(t_name, cm_data.rootCellp->name);
+ t_name = strdup(cm_data.rootCellp->name);
} else {
t_name = (char *)malloc(1);
t_name[0] = '\0';
unsigned long host = 0;
unsigned short port = 0;
+ if (cm_shutdown)
+ return 1;
+
if ((connp = rx_ConnectionOf(callp)) && (peerp = rx_PeerOf(connp))) {
host = rx_HostOf(peerp);
port = rx_PortOf(peerp);
/* called by afsd without any locks to initialize this module */
void cm_InitCallback(void)
{
- lock_InitializeRWLock(&cm_callbackLock, "cm_callbackLock");
+ lock_InitializeRWLock(&cm_callbackLock, "cm_callbackLock", LOCK_HIERARCHY_CALLBACK_GLOBAL);
cm_activeCallbackGrantingCalls = 0;
}
if (cm_freelanceEnabled &&
scp->fid.cell==AFS_FAKE_ROOT_CELL_ID && scp->fid.volume==AFS_FAKE_ROOT_VOL_ID) {
- /* if it's something on /afs */
- if (!(scp->fid.vnode==0x1 && scp->fid.unique==0x1)) {
- /* if it's not root.afs */
- return 1;
- }
-
lock_ObtainMutex(&cm_Freelance_Lock);
fdc = cm_fakeDirCallback;
fgc = cm_fakeGettingCallback;
if (scp->cbServerp != NULL) {
return 1;
} else if (cm_OfflineROIsValid) {
- switch (cm_GetVolumeStatus(scp->volp, scp->fid.volume)) {
- case vl_offline:
- case vl_alldown:
- case vl_unknown:
- return 1;
- default:
- return 0;
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ switch (cm_GetVolumeStatus(volp, scp->fid.volume)) {
+ case vl_offline:
+ case vl_alldown:
+ case vl_unknown:
+ cm_PutVolume(volp);
+ return 1;
+ default:
+ cm_PutVolume(volp);
+ return 0;
+ }
}
- } else {
- return 0;
+ return 1;
}
+ return 0;
}
/* need to detect a broken callback that races with our obtaining a callback.
serverp = cbrp->serverp;
}
scp->cbExpires = cbrp->startTime + cbp->ExpirationTime;
- if (scp->flags & CM_SCACHEFLAG_PURERO && scp->volp)
- scp->volp->cbExpiresRO = scp->cbExpires;
+ if (scp->flags & CM_SCACHEFLAG_PURERO) {
+ cm_volume_t * volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ volp->cbExpiresRO = scp->cbExpires;
+ cm_PutVolume(volp);
+ }
+ }
} else {
if (freeFlag)
serverp = cbrp->serverp;
cbrp->callbackCount, revp->callbackCount,
cm_callbackCount);
discardScp = 1;
-
- if ((scp->flags & CM_SCACHEFLAG_PURERO) && scp->volp &&
- (revp->flags & (CM_RACINGFLAG_CANCELVOL | CM_RACINGFLAG_CANCELALL)))
- scp->volp->cbExpiresRO = 0;
+ if ((scp->flags & CM_SCACHEFLAG_PURERO) &&
+ (revp->flags & (CM_RACINGFLAG_CANCELVOL | CM_RACINGFLAG_CANCELALL))) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ volp->cbExpiresRO = 0;
+ cm_PutVolume(volp);
+ }
+ }
}
if (freeFlag)
free(revp);
cm_callbackRequest_t cbr;
int mustCall;
cm_fid_t sfid;
- struct rx_connection * callp = NULL;
+ struct rx_connection * rxconnp = NULL;
int syncop_done = 0;
osi_Log4(afsd_logp, "GetCallback scp 0x%p cell %d vol %d flags %lX",
if (code)
continue;
- callp = cm_GetRxConn(connp);
- code = RXAFS_FetchStatus(callp, &tfid,
+ rxconnp = cm_GetRxConn(connp);
+ code = RXAFS_FetchStatus(rxconnp, &tfid,
&afsStatus, &callback, &volSync);
- rx_PutConnection(callp);
+ rx_PutConnection(rxconnp);
} while (cm_Analyze(connp, userp, reqp, &sfid, &volSync, NULL,
&cbr, code));
long cm_CBServersUp(cm_scache_t *scp, time_t * downTime)
{
cm_vol_state_t *statep;
- cm_volume_t * volp = scp->volp;
+ cm_volume_t * volp;
afs_uint32 volID = scp->fid.volume;
cm_serverRef_t *tsrp;
int found;
if (scp->cbServerp == NULL)
return 1;
- if (volp->rw.ID == volID) {
- statep = &volp->rw;
- } else if (volp->ro.ID == volID) {
- statep = &volp->ro;
- } else if (volp->bk.ID == volID) {
- statep = &volp->bk;
- }
+ volp = cm_GetVolumeByFID(&scp->fid);
+ if (!volp)
+ return 1;
+ statep = cm_VolumeStateByID(volp, volID);
+ cm_PutVolume(volp);
if (statep->state == vl_online)
return 1;
for (found = 0,tsrp = statep->serversp; tsrp; tsrp=tsrp->next) {
+ if (tsrp->status == srv_deleted)
+ continue;
if (tsrp->server == scp->cbServerp)
found = 1;
if (tsrp->server->downTime > *downTime)
for (i=0; i<cm_data.scacheHashTableSize; i++) {
for (scp = cm_data.scacheHashTablep[i]; scp; scp=scp->nextp) {
downTime = 0;
- if (scp->flags & CM_SCACHEFLAG_PURERO && scp->volp) {
- if (scp->volp->cbExpiresRO > scp->cbExpires && scp->cbExpires > 0)
- scp->cbExpires = scp->volp->cbExpiresRO;
+ if (scp->flags & CM_SCACHEFLAG_PURERO) {
+ cm_volume_t *volp = cm_GetVolumeByFID(&scp->fid);
+ if (volp) {
+ if (volp->cbExpiresRO > scp->cbExpires && scp->cbExpires > 0)
+ scp->cbExpires = volp->cbExpiresRO;
+ cm_PutVolume(volp);
+ }
}
-
if (scp->cbServerp && scp->cbExpires > 0 && now > scp->cbExpires &&
(cm_CBServersUp(scp, &downTime) || downTime == 0 || downTime >= scp->cbExpires))
{
cm_volume_t * volp;
int i;
+ cm_ForceNewConnections(tsp);
+
lock_ObtainMutex(&tsp->mx);
if (!(tsp->flags & CM_SERVERFLAG_DOWN)) {
tsp->flags |= CM_SERVERFLAG_DOWN;
tsp->downTime = time(NULL);
}
- cm_ForceNewConnections(tsp);
-
/* Now update the volume status */
for (tsrvp = tsp->vols; tsrvp; tsrvp = tsrvp->nextp) {
for (i=0; i<NUM_SERVER_VOLS; i++) {
cm_req_t req;
cm_InitReq(&req);
-
- code = cm_GetVolumeByID(tsp->cellp, tsrvp->ids[i], cm_rootUserp,
+ lock_ReleaseMutex(&tsp->mx);
+ code = cm_FindVolumeByID(tsp->cellp, tsrvp->ids[i], cm_rootUserp,
&req, CM_GETVOL_FLAG_NO_LRU_UPDATE | CM_GETVOL_FLAG_NO_RESET, &volp);
+ lock_ObtainMutex(&tsp->mx);
if (code == 0) {
cm_UpdateVolumeStatus(volp, tsrvp->ids[i]);
cm_PutVolume(volp);
- }
+ }
}
}
}
git://git.openafs.org / openafs.git / blobdiff