eedfd9a2255041ae892ed79ba5c918e6b370b10a
[openafs.git] / src / WINNT / afsrdr / kernel / lib / AFSFlushBuffers.cpp
1 /*
2  * Copyright (c) 2008, 2009, 2010, 2011 Kernel Drivers, LLC.
3  * Copyright (c) 2009, 2010, 2011 Your File System, Inc.
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  *
10  * - Redistributions of source code must retain the above copyright notice,
11  *   this list of conditions and the following disclaimer.
12  * - Redistributions in binary form must reproduce the above copyright
13  *   notice,
14  *   this list of conditions and the following disclaimer in the
15  *   documentation
16  *   and/or other materials provided with the distribution.
17  * - Neither the names of Kernel Drivers, LLC and Your File System, Inc.
18  *   nor the names of their contributors may be used to endorse or promote
19  *   products derived from this software without specific prior written
20  *   permission from Kernel Drivers, LLC and Your File System, Inc.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
23  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
24  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
25  * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
26  * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
27  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
28  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
29  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
30  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
31  * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
32  * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
33  */
34
35 //
36 // File: AFSFlushBuffers.cpp
37 //
38
39 #include "AFSCommon.h"
40
41 NTSTATUS
42 AFSFlushBuffers( IN PDEVICE_OBJECT LibDeviceObject,
43                  IN PIRP Irp)
44 {
45
46     NTSTATUS           ntStatus = STATUS_SUCCESS;
47     IO_STACK_LOCATION *pIrpSp = IoGetCurrentIrpStackLocation( Irp);
48     PFILE_OBJECT       pFileObject = pIrpSp->FileObject;
49     AFSFcb            *pFcb = (AFSFcb *)pFileObject->FsContext;
50     AFSCcb            *pCcb = (AFSCcb *)pFileObject->FsContext2;
51     IO_STATUS_BLOCK    iosb = {0};
52
53     pIrpSp = IoGetCurrentIrpStackLocation( Irp);
54
55     __Enter
56     {
57
58         if( pFcb == NULL)
59         {
60
61             AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
62                           AFS_TRACE_LEVEL_ERROR,
63                           "AFSFlushBuffers Attempted access (%08lX) when pFcb == NULL\n",
64                           Irp);
65
66             try_return( ntStatus = STATUS_INVALID_DEVICE_REQUEST);
67         }
68
69         if( pFcb->Header.NodeTypeCode == AFS_ROOT_FCB ||
70             pFcb->Header.NodeTypeCode == AFS_ROOT_ALL )
71         {
72
73             //
74             // Once we support ADS's on directories we need to perform a flush ehre
75             //
76
77             try_return( ntStatus = STATUS_SUCCESS);
78
79         }
80         else if (pFcb->Header.NodeTypeCode != AFS_FILE_FCB)
81         {
82             //
83             // Nothing to flush Everything but files are write through
84             //
85             try_return( ntStatus = STATUS_INVALID_PARAMETER);
86         }
87         //
88         // The flush consists of two parts.  We firstly flush our
89         // cache (if we have one), then we tell the service to write
90         // to the remote server
91         //
92         __try
93         {
94
95             CcFlushCache( &pFcb->NPFcb->SectionObjectPointers, NULL, 0, &iosb);
96
97             if (!NT_SUCCESS( iosb.Status ))
98             {
99
100                 AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
101                               AFS_TRACE_LEVEL_ERROR,
102                               "AFSFlushBuffers CcFlushCache [1] failure FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
103                               pFcb->ObjectInformation->FileId.Cell,
104                               pFcb->ObjectInformation->FileId.Volume,
105                               pFcb->ObjectInformation->FileId.Vnode,
106                               pFcb->ObjectInformation->FileId.Unique,
107                               iosb.Status,
108                               iosb.Information);
109
110                 try_return( ntStatus = iosb.Status );
111             }
112         }
113         __except( EXCEPTION_EXECUTE_HANDLER)
114         {
115
116             try_return( ntStatus = GetExceptionCode());
117         }
118         //
119         // Now, flush to the server - if there is stuff to do
120         //
121
122         ntStatus = AFSFlushExtents( pFcb,
123                                     &pCcb->AuthGroup);
124
125         if( !NT_SUCCESS( ntStatus))
126         {
127
128             AFSReleaseExtentsWithFlush( pFcb,
129                                         &pCcb->AuthGroup,
130                                         TRUE);
131
132             ntStatus = STATUS_SUCCESS;
133         }
134
135 try_exit:
136
137         AFSCompleteRequest( Irp, ntStatus);
138     }
139
140     return ntStatus;
141 }