reactos/ntoskrnl/io/flush.c

   1 /*
   2  * COPYRIGHT:       See COPYING in the top level directory
   3  * PROJECT:         ReactOS kernel
   4  * FILE:            ntoskrnl/io/flush.c
   5  * PURPOSE:         Flushing file buffer
   6  * PROGRAMMER:      David Welch (welch@cwcom.net)
   7  * UPDATE HISTORY:
   8  *                  Created 22/05/98
   9  */
  10
  11 /* INCLUDES *****************************************************************/
  12
  13 #include <ddk/ntddk.h>
  14 #include <internal/ob.h>
  15
  16 #define NDEBUG
  17 #include <internal/debug.h>
  18
  19 /* FUNCTIONS *****************************************************************/
  20
  21
  22 NTSTATUS
  23 STDCALL
  24 NtFlushWriteBuffer(VOID)
  25 {
  26         KeFlushWriteBuffer();
  27         return STATUS_SUCCESS;
  28 }
  29
  30 NTSTATUS
  31 STDCALL
  32 NtFlushBuffersFile (
  33         IN      HANDLE                  FileHandle,
  34         OUT     PIO_STATUS_BLOCK        IoStatusBlock
  35         )
  36 /*
  37  * FUNCTION: Flushes cached file data to disk
  38  * ARGUMENTS:
  39  *       FileHandle = Points to the file
  40  *       IoStatusBlock = Caller must supply storage to receive the result of
  41  *                       the flush buffers operation. The information field is
  42  *                       set to number of bytes flushed to disk.
  43  * RETURNS: Status
  44  * REMARKS: This function maps to the win32 FlushFileBuffers
  45  */
  46 {
  47    PFILE_OBJECT FileObject = NULL;
  48    PIRP Irp;
  49    PIO_STACK_LOCATION StackPtr;
  50    KEVENT Event;
  51    NTSTATUS Status;
  52    IO_STATUS_BLOCK IoSB;
  53
  54    Status = ObReferenceObjectByHandle(FileHandle,
  55                                       FILE_WRITE_DATA,
  56                                       NULL,
  57                                       UserMode,
  58                                       (PVOID*)&FileObject,
  59                                       NULL);
  60    if (Status != STATUS_SUCCESS)
  61      {
  62         return(Status);
  63      }
  64
  65    KeInitializeEvent(&Event,NotificationEvent,FALSE);
  66    Irp = IoBuildSynchronousFsdRequest(IRP_MJ_FLUSH_BUFFERS,
  67                                       FileObject->DeviceObject,
  68                                       NULL,
  69                                       0,
  70                                       NULL,
  71                                       &Event,
  72                                       &IoSB);
  73
  74    StackPtr = IoGetNextIrpStackLocation(Irp);
  75    StackPtr->FileObject = FileObject;
  76
  77    Status = IoCallDriver(FileObject->DeviceObject,Irp);
  78    if (Status==STATUS_PENDING)
  79      {
  80         KeWaitForSingleObject(&Event,Executive,KernelMode,FALSE,NULL);
  81         Status = IoSB.Status;
  82      }
  83    if (IoStatusBlock)
  84      {
  85        *IoStatusBlock = IoSB;
  86      }
  87    return(Status);
  88 }