From: Jeffrey Altman Date: Wed, 4 Oct 2006 01:24:42 +0000 (+0000) Subject: DEVEL15-windows-multi-fix-20061003 X-Git-Tag: openafs-devel-1_5_9~45 X-Git-Url: https://git.michaelhowe.org/gitweb/?a=commitdiff_plain;h=d091134c91a64aa32237801cd5b83a867b0c2863;p=packages%2Fo%2Fopenafs.git DEVEL15-windows-multi-fix-20061003 misc cleanups hold scp->mx while recycling add FILE_NOTIFY_CHANGE_CREATION to the notification mask when adding or deleting files (cherry picked from commit de6a01e51d8ea97e943cb4fa93d6bba2ecae9644) --- diff --git a/src/WINNT/afsd/cm_callback.c b/src/WINNT/afsd/cm_callback.c index edd7534ad..3493a9009 100644 --- a/src/WINNT/afsd/cm_callback.c +++ b/src/WINNT/afsd/cm_callback.c @@ -1626,7 +1626,6 @@ long cm_GetCallback(cm_scache_t *scp, struct cm_user *userp, AFSFid tfid; cm_callbackRequest_t cbr; int mustCall; - long sflags; cm_fid_t sfid; struct rx_connection * callp = NULL; @@ -1684,16 +1683,14 @@ long cm_GetCallback(cm_scache_t *scp, struct cm_user *userp, /* turn off mustCall, since it has now forced us past the check above */ mustCall = 0; -#if 0 /* 20060929 jaltman - We are being called from within cm_SyncOp. * if we call cm_SyncOp again and another thread has attempted * to obtain current status CM_SCACHEFLAG_WAITING will be set * and we will deadlock. */ /* otherwise, we have to make an RPC to get the status */ - sflags = CM_SCACHESYNC_FETCHSTATUS | CM_SCACHESYNC_GETCALLBACK; - cm_SyncOp(scp, NULL, userp, reqp, 0, sflags); -#endif /* deadlock */ + cm_SyncOp(scp, NULL, userp, reqp, 0, + CM_SCACHESYNC_FETCHSTATUS | CM_SCACHESYNC_GETCALLBACK); cm_StartCallbackGrantingCall(scp, &cbr); sfid = scp->fid; lock_ReleaseMutex(&scp->mx); @@ -1728,10 +1725,8 @@ long cm_GetCallback(cm_scache_t *scp, struct cm_user *userp, } else { cm_EndCallbackGrantingCall(NULL, &cbr, NULL, 0); } -#if 0 /* 20060929 jaltman - don't deadlock */ - cm_SyncOpDone(scp, NULL, sflags); -#endif + cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_FETCHSTATUS | CM_SCACHESYNC_GETCALLBACK); /* now check to see if we got an error */ if (code) { diff --git a/src/WINNT/afsd/cm_dcache.c b/src/WINNT/afsd/cm_dcache.c index f2edbdff1..b668435e7 100644 --- a/src/WINNT/afsd/cm_dcache.c +++ b/src/WINNT/afsd/cm_dcache.c @@ -613,21 +613,20 @@ void cm_BkgStore(cm_scache_t *scp, afs_uint32 p1, afs_uint32 p2, afs_uint32 p3, if (scp->flags & CM_SCACHEFLAG_DELETED) { osi_Log4(afsd_logp, "Skipping BKG store - Deleted scp 0x%p, offset 0x%x:%08x, length 0x%x", scp, p2, p1, p3); - return; - } - - cm_InitReq(&req); + } else { + cm_InitReq(&req); #ifdef NO_BKG_RETRIES - req.flags |= CM_REQ_NORETRY; + req.flags |= CM_REQ_NORETRY; #endif - toffset.LowPart = p1; - toffset.HighPart = p2; - length = p3; + toffset.LowPart = p1; + toffset.HighPart = p2; + length = p3; - osi_Log4(afsd_logp, "Starting BKG store scp 0x%p, offset 0x%x:%08x, length 0x%x", scp, p2, p1, p3); + osi_Log4(afsd_logp, "Starting BKG store scp 0x%p, offset 0x%x:%08x, length 0x%x", scp, p2, p1, p3); - code = cm_BufWrite(&scp->fid, &toffset, length, /* flags */ 0, userp, &req); + code = cm_BufWrite(&scp->fid, &toffset, length, /* flags */ 0, userp, &req); + } lock_ObtainMutex(&scp->mx); cm_SyncOpDone(scp, NULL, CM_SCACHESYNC_ASYNCSTORE); diff --git a/src/WINNT/afsd/cm_scache.c b/src/WINNT/afsd/cm_scache.c index f51bdb266..c0e429cce 100644 --- a/src/WINNT/afsd/cm_scache.c +++ b/src/WINNT/afsd/cm_scache.c @@ -59,6 +59,7 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) cm_scache_t *tscp; int i; + lock_ObtainMutex(&scp->mx); if (scp->flags & CM_SCACHEFLAG_INHASH) { /* hash it out first */ i = CM_SCACHE_HASH(&scp->fid); @@ -83,6 +84,7 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) osi_QRemove((osi_queue_t **) &scp->bufWritesp, &qdp->q); osi_QDFree(qdp); if (bufp) { + lock_ReleaseMutex(&scp->mx); lock_ObtainMutex(&bufp->mx); bufp->cmFlags &= ~CM_BUF_CMSTORING; bufp->flags &= ~CM_BUF_DIRTY; @@ -96,6 +98,7 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) } lock_ReleaseMutex(&bufp->mx); buf_Release(bufp); + lock_ObtainMutex(&scp->mx); } } while(qdp = scp->bufReadsp) { @@ -103,6 +106,7 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) osi_QRemove((osi_queue_t **) &scp->bufReadsp, &qdp->q); osi_QDFree(qdp); if (bufp) { + lock_ReleaseMutex(&scp->mx); lock_ObtainMutex(&bufp->mx); bufp->cmFlags &= ~CM_BUF_CMFETCHING; bufp->flags &= ~CM_BUF_DIRTY; @@ -116,6 +120,7 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) } lock_ReleaseMutex(&bufp->mx); buf_Release(bufp); + lock_ObtainMutex(&scp->mx); } } buf_CleanDirtyBuffers(scp); @@ -181,6 +186,9 @@ long cm_RecycleSCache(cm_scache_t *scp, afs_int32 flags) */ cm_FreeAllACLEnts(scp); + osi_Wakeup((long)&scp->flags); + + lock_ReleaseMutex(&scp->mx); return 0; } diff --git a/src/WINNT/afsd/cm_vnodeops.c b/src/WINNT/afsd/cm_vnodeops.c index c5652f5e4..f44f52f5f 100644 --- a/src/WINNT/afsd/cm_vnodeops.c +++ b/src/WINNT/afsd/cm_vnodeops.c @@ -2206,6 +2206,10 @@ long cm_SetAttr(cm_scache_t *scp, cm_attr_t *attrp, cm_user_t *userp, lock_ObtainMutex(&scp->mx); /* otherwise, we have to make an RPC to get the status */ code = cm_SyncOp(scp, NULL, userp, reqp, 0, CM_SCACHESYNC_STORESTATUS); + if (code) { + lock_ReleaseMutex(&scp->mx); + return code; + } /* make the attr structure */ cm_StatusFromAttr(&afsInStatus, scp, attrp); @@ -2214,9 +2218,6 @@ long cm_SetAttr(cm_scache_t *scp, cm_attr_t *attrp, cm_user_t *userp, tfid.Vnode = scp->fid.vnode; tfid.Unique = scp->fid.unique; - lock_ReleaseMutex(&scp->mx); - if (code) - return code; /* now make the RPC */ osi_Log1(afsd_logp, "CALL StoreStatus scp 0x%p", scp); diff --git a/src/WINNT/afsd/smb.c b/src/WINNT/afsd/smb.c index 929332fca..11cb6b941 100644 --- a/src/WINNT/afsd/smb.c +++ b/src/WINNT/afsd/smb.c @@ -5129,7 +5129,7 @@ int smb_UnlinkProc(cm_scache_t *dscp, cm_dirEntry_t *dep, void *vrockp, osi_hype code = cm_Unlink(dscp, dep->name, rockp->userp, rockp->reqp); if (code == 0 && (dscp->flags & CM_SCACHEFLAG_ANYWATCH)) smb_NotifyChange(FILE_ACTION_REMOVED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, dep->name, NULL, TRUE); if (code == 0) { rockp->any = 1; @@ -5687,7 +5687,7 @@ int smb_RmdirProc(cm_scache_t *dscp, cm_dirEntry_t *dep, void *vrockp, osi_hyper code = cm_RemoveDir(dscp, dep->name, rockp->userp, rockp->reqp); if (code == 0 && (dscp->flags & CM_SCACHEFLAG_ANYWATCH)) smb_NotifyChange(FILE_ACTION_REMOVED, - FILE_NOTIFY_CHANGE_DIR_NAME, + FILE_NOTIFY_CHANGE_DIR_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, dep->name, NULL, TRUE); if (code == 0) rockp->any = 1; @@ -5987,7 +5987,7 @@ long smb_CloseFID(smb_vc_t *vcp, smb_fid_t *fidp, cm_user_t *userp, scp->flags |= CM_SCACHEFLAG_DELETED; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_REMOVED, - FILE_NOTIFY_CHANGE_DIR_NAME, + FILE_NOTIFY_CHANGE_DIR_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, fullPathp, NULL, TRUE); } } else { @@ -5996,7 +5996,7 @@ long smb_CloseFID(smb_vc_t *vcp, smb_fid_t *fidp, cm_user_t *userp, scp->flags |= CM_SCACHEFLAG_DELETED; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_REMOVED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, fullPathp, NULL, TRUE); } } @@ -7222,7 +7222,7 @@ long smb_ReceiveCoreCreate(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *outp) created = 1; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_ADDED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, lastNamep, NULL, TRUE); } else if (!excl && code == CM_ERROR_EXISTS) { /* not an exclusive create, and someone else tried diff --git a/src/WINNT/afsd/smb3.c b/src/WINNT/afsd/smb3.c index 9465b2e95..1e361d3c9 100644 --- a/src/WINNT/afsd/smb3.c +++ b/src/WINNT/afsd/smb3.c @@ -2295,7 +2295,7 @@ long smb_ReceiveTran2Open(smb_vc_t *vcp, smb_tran2Packet_t *p, smb_packet_t *op) created = 1; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_ADDED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, lastNamep, NULL, TRUE); } else if (!excl && code == CM_ERROR_EXISTS) { /* not an exclusive create, and someone else tried @@ -5079,7 +5079,7 @@ long smb_ReceiveV3OpenX(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *outp) created = 1; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_ADDED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, lastNamep, NULL, TRUE); } else if (!excl && code == CM_ERROR_EXISTS) { /* not an exclusive create, and someone else tried @@ -6079,9 +6079,9 @@ long smb_ReceiveNTCreateX(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *outp) if (createOptions & FILE_DELETE_ON_CLOSE) fidflags |= SMB_FID_DELONCLOSE; if (createOptions & FILE_SEQUENTIAL_ONLY && !(createOptions & FILE_RANDOM_ACCESS)) - fidflags | SMB_FID_SEQUENTIAL; + fidflags |= SMB_FID_SEQUENTIAL; if (createOptions & FILE_RANDOM_ACCESS && !(createOptions & FILE_SEQUENTIAL_ONLY)) - fidflags & SMB_FID_RANDOM; + fidflags |= SMB_FID_RANDOM; /* and the share mode */ if (shareAccess & FILE_SHARE_READ) @@ -6353,7 +6353,7 @@ long smb_ReceiveNTCreateX(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *outp) created = 1; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_ADDED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, lastNamep, NULL, TRUE); } else if (code == CM_ERROR_EXISTS && createDisp != FILE_CREATE) { /* Not an exclusive create, and someone else tried @@ -6827,9 +6827,9 @@ long smb_ReceiveNTTranCreate(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *out if (createOptions & FILE_DELETE_ON_CLOSE) fidflags |= SMB_FID_DELONCLOSE; if (createOptions & FILE_SEQUENTIAL_ONLY && !(createOptions & FILE_RANDOM_ACCESS)) - fidflags | SMB_FID_SEQUENTIAL; + fidflags |= SMB_FID_SEQUENTIAL; if (createOptions & FILE_RANDOM_ACCESS && !(createOptions & FILE_SEQUENTIAL_ONLY)) - fidflags & SMB_FID_RANDOM; + fidflags |= SMB_FID_RANDOM; /* And the share mode */ if (shareAccess & FILE_SHARE_READ) @@ -7034,7 +7034,7 @@ long smb_ReceiveNTTranCreate(smb_vc_t *vcp, smb_packet_t *inp, smb_packet_t *out created = 1; if (dscp->flags & CM_SCACHEFLAG_ANYWATCH) smb_NotifyChange(FILE_ACTION_ADDED, - FILE_NOTIFY_CHANGE_FILE_NAME, + FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_CREATION, dscp, lastNamep, NULL, TRUE); } else if (code == CM_ERROR_EXISTS && createDisp != FILE_CREATE) { /* Not an exclusive create, and someone else tried