/*
 * PROJECT:     ReactOS Named Pipe FileSystem
 * LICENSE:     BSD - See COPYING.ARM in the top level directory
 * FILE:        drivers/filesystems/npfs/fileinfo.c
 * PURPOSE:     Pipes Information
 * PROGRAMMERS: ReactOS Portable Systems Group
 */

/* INCLUDES *******************************************************************/

#include "npfs.h"

// File ID number for NPFS bugchecking support
#define NPFS_BUGCHECK_FILE_ID   (NPFS_BUGCHECK_FILEINFO)

/* FUNCTIONS ******************************************************************/

NTSTATUS
NTAPI
NpSetBasicInfo(IN PNP_CCB Ccb,
               IN PFILE_BASIC_INFORMATION Buffer)
{
    PAGED_CODE();
    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpSetPipeInfo(IN PNP_FCB Fcb,
              IN PNP_CCB Ccb,
              IN PFILE_PIPE_INFORMATION Buffer,
              IN ULONG NamedPipeEnd,
              IN PLIST_ENTRY List)
{
    NTSTATUS Status;
    PNP_DATA_QUEUE ReadQueue, WriteQueue;
    PAGED_CODE();

    if (Buffer->ReadMode == FILE_PIPE_MESSAGE_MODE && Fcb->NamedPipeType == FILE_PIPE_BYTE_STREAM_TYPE)
    {
        return STATUS_INVALID_PARAMETER;
    }

    if (NamedPipeEnd != FILE_PIPE_CLIENT_END)
    {
        if (NamedPipeEnd != FILE_PIPE_SERVER_END)
        {
            NpBugCheck(NamedPipeEnd, 0, 0);
        }
        ReadQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
        WriteQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];
    }
    else
    {
        ReadQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];
        WriteQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
    }

    if (Buffer->CompletionMode != FILE_PIPE_COMPLETE_OPERATION ||
        Ccb->CompletionMode[NamedPipeEnd] == FILE_PIPE_COMPLETE_OPERATION ||
        (ReadQueue->QueueState != ReadEntries &&
        WriteQueue->QueueState != WriteEntries))
    {
        Ccb->ReadMode[NamedPipeEnd] = Buffer->ReadMode & 0xFF;
        Ccb->CompletionMode[NamedPipeEnd] = Buffer->CompletionMode & 0xFF;

        NpCheckForNotify(Fcb->ParentDcb, FALSE, List);
        Status = STATUS_SUCCESS;
    }
    else
    {
        Status = STATUS_PIPE_BUSY;
    }

    return Status;
}

NTSTATUS
NTAPI
NpCommonSetInformation(IN PDEVICE_OBJECT DeviceObject,
                       IN PIRP Irp,
                       IN PLIST_ENTRY List)
{
    NODE_TYPE_CODE NodeTypeCode;
    PIO_STACK_LOCATION IoStack;
    ULONG InfoClass;
    PVOID Buffer;
    PNP_FCB Fcb;
    PNP_CCB Ccb;
    ULONG NamedPipeEnd;
    PAGED_CODE();

    IoStack = IoGetCurrentIrpStackLocation(Irp);

    NodeTypeCode = NpDecodeFileObject(IoStack->FileObject,
                                      (PVOID*)&Fcb,
                                      &Ccb,
                                      &NamedPipeEnd);
    if (!NodeTypeCode) return STATUS_PIPE_DISCONNECTED;
    if (NodeTypeCode != NPFS_NTC_CCB) return STATUS_INVALID_PARAMETER;

    InfoClass = IoStack->Parameters.QueryFile.FileInformationClass;
    Buffer = Irp->AssociatedIrp.SystemBuffer;

    if (InfoClass == FileBasicInformation) return NpSetBasicInfo(Ccb, Buffer);

    if (InfoClass != FilePipeInformation) return STATUS_INVALID_PARAMETER;

    return NpSetPipeInfo(Fcb, Ccb, Buffer, NamedPipeEnd, List);
}

NTSTATUS
NTAPI
NpFsdSetInformation(IN PDEVICE_OBJECT DeviceObject,
                    IN PIRP Irp)
{
    NTSTATUS Status;
    LIST_ENTRY DeferredList;
    PAGED_CODE();

    InitializeListHead(&DeferredList);

    FsRtlEnterFileSystem();
    NpAcquireExclusiveVcb();

    Status = NpCommonSetInformation(DeviceObject, Irp, &DeferredList);

    NpReleaseVcb();
    NpCompleteDeferredIrps(&DeferredList);
    FsRtlExitFileSystem();

    if (Status != STATUS_PENDING)
    {
        Irp->IoStatus.Status = Status;
        IoCompleteRequest(Irp, IO_NAMED_PIPE_INCREMENT);
    }

    return Status;
}

NTSTATUS
NTAPI
NpQueryBasicInfo(IN PNP_CCB Ccb,
                 IN PVOID Buffer,
                 IN OUT PULONG Length)
{
    PFILE_BASIC_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));
    InfoBuffer->FileAttributes = FILE_ATTRIBUTE_NORMAL;

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryStandardInfo(IN PNP_CCB Ccb,
                    IN PVOID Buffer,
                    IN OUT PULONG Length,
                    IN ULONG NamedPipeEnd)
{
    PNP_DATA_QUEUE DataQueue;
    PFILE_STANDARD_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    if (NamedPipeEnd == FILE_PIPE_SERVER_END)
    {
        DataQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
    }
    else
    {
        DataQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];
    }

    InfoBuffer->AllocationSize.LowPart = Ccb->DataQueue[FILE_PIPE_INBOUND].Quota +
                                         Ccb->DataQueue[FILE_PIPE_OUTBOUND].Quota;
    InfoBuffer->AllocationSize.HighPart = 0;

    if (DataQueue->QueueState == WriteEntries)
    {
        InfoBuffer->EndOfFile.HighPart = 0;
        InfoBuffer->EndOfFile.LowPart = DataQueue->BytesInQueue -
                                        DataQueue->ByteOffset;
    }

    InfoBuffer->Directory = FALSE;
    InfoBuffer->NumberOfLinks = 1;
    InfoBuffer->DeletePending = TRUE;

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryEaInfo(IN PNP_CCB Ccb,
              IN PVOID Buffer,
              IN OUT PULONG Length)
{
    PFILE_EA_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryNameInfo(IN PNP_CCB Ccb,
                IN PVOID Buffer,
                IN OUT PULONG Length)
{
    PFILE_NAME_INFORMATION InfoBuffer = Buffer;
    USHORT NameLength;
    NTSTATUS Status;
    PWCHAR Name;

    *Length -= sizeof(*InfoBuffer);

    if (Ccb->NodeType == NPFS_NTC_ROOT_DCB_CCB)
    {
        NameLength = NpVcb->RootDcb->FullName.Length;
        Name = NpVcb->RootDcb->FullName.Buffer;
    }
    else
    {
        NameLength = Ccb->Fcb->FullName.Length;
        Name = Ccb->Fcb->FullName.Buffer;
    }

    if (*Length < NameLength)
    {
        Status = STATUS_BUFFER_OVERFLOW;
        NameLength = (USHORT)*Length;
    }
    else
    {
        Status = STATUS_SUCCESS;
    }

    RtlCopyMemory(InfoBuffer->FileName, Name, NameLength);
    InfoBuffer->FileNameLength = NameLength;

    *Length -= NameLength;
    return Status;
}

NTSTATUS
NTAPI
NpQueryInternalInfo(IN PNP_CCB Ccb,
                    IN PVOID Buffer,
                    IN OUT PULONG Length)
{
    PFILE_INTERNAL_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryPositionInfo(IN PNP_CCB Ccb,
                    IN PVOID Buffer,
                    IN OUT PULONG Length,
                    IN ULONG NamedPipeEnd)
{
    PNP_DATA_QUEUE DataQueue;
    PFILE_POSITION_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    if (NamedPipeEnd == FILE_PIPE_SERVER_END)
    {
        DataQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
    }
    else
    {
        DataQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];
    }

    if (DataQueue->QueueState == WriteEntries)
    {
        InfoBuffer->CurrentByteOffset.QuadPart = DataQueue->BytesInQueue -
                                                 DataQueue->ByteOffset;
    }

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryPipeLocalInfo(IN PNP_FCB Fcb,
                     IN PNP_CCB Ccb,
                     IN PVOID Buffer,
                     IN OUT PULONG Length,
                     IN ULONG NamedPipeEnd)
{
    PFILE_PIPE_LOCAL_INFORMATION InfoBuffer = Buffer;
    PNP_DATA_QUEUE InQueue, OutQueue;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    InQueue = &Ccb->DataQueue[FILE_PIPE_INBOUND];
    OutQueue = &Ccb->DataQueue[FILE_PIPE_OUTBOUND];

    InfoBuffer->NamedPipeType = Fcb->NamedPipeType;
    InfoBuffer->NamedPipeConfiguration = Fcb->NamedPipeConfiguration;
    InfoBuffer->MaximumInstances = Fcb->MaximumInstances;
    InfoBuffer->CurrentInstances = Fcb->CurrentInstances;
    InfoBuffer->InboundQuota = InQueue->Quota;
    InfoBuffer->OutboundQuota = OutQueue->Quota;
    InfoBuffer->NamedPipeState = Ccb->NamedPipeState;
    InfoBuffer->NamedPipeEnd = NamedPipeEnd;

    if (NamedPipeEnd == FILE_PIPE_SERVER_END)
    {
        if (InQueue->QueueState == WriteEntries)
        {
            InfoBuffer->ReadDataAvailable = InQueue->BytesInQueue - InQueue->ByteOffset;
        }
        InfoBuffer->WriteQuotaAvailable = OutQueue->Quota - OutQueue->QuotaUsed;
    }
    else
    {
        if (OutQueue->QueueState == WriteEntries)
        {
            InfoBuffer->ReadDataAvailable = OutQueue->BytesInQueue - OutQueue->ByteOffset;
        }
        InfoBuffer->WriteQuotaAvailable = OutQueue->Quota - InQueue->QuotaUsed;
    }

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpQueryPipeInfo(IN PNP_FCB Fcb,
                IN PNP_CCB Ccb,
                IN PVOID Buffer,
                IN OUT PULONG Length,
                IN ULONG NamedPipeEnd)
{
    PFILE_PIPE_INFORMATION InfoBuffer = Buffer;

    *Length -= sizeof(*InfoBuffer);

    RtlZeroMemory(InfoBuffer, sizeof(*InfoBuffer));

    InfoBuffer->ReadMode = Ccb->ReadMode[NamedPipeEnd];
    InfoBuffer->CompletionMode = Ccb->CompletionMode[NamedPipeEnd];

    return STATUS_SUCCESS;
}

NTSTATUS
NTAPI
NpCommonQueryInformation(IN PDEVICE_OBJECT DeviceObject,
                         IN PIRP Irp)
{
    PIO_STACK_LOCATION IoStack;
    NODE_TYPE_CODE NodeTypeCode;
    ULONG NamedPipeEnd;
    PNP_FCB Fcb;
    PNP_CCB Ccb;
    FILE_INFORMATION_CLASS InfoClass;
    ULONG Length;
    PVOID Buffer;
    PFILE_ALL_INFORMATION AllInfo;
    NTSTATUS Status;
    PAGED_CODE();

    IoStack = IoGetCurrentIrpStackLocation(Irp);
    NodeTypeCode = NpDecodeFileObject(IoStack->FileObject,
                                      (PVOID*)&Fcb,
                                      &Ccb,
                                      &NamedPipeEnd);
    if (!NodeTypeCode) return STATUS_PIPE_DISCONNECTED;

    Buffer = Irp->AssociatedIrp.SystemBuffer;
    Length = IoStack->Parameters.QueryFile.Length;
    InfoClass = IoStack->Parameters.QueryFile.FileInformationClass;

    if (NodeTypeCode != NPFS_NTC_CCB)
    {
        if (NodeTypeCode != NPFS_NTC_ROOT_DCB || InfoClass != FileNameInformation)
        {
            return STATUS_INVALID_PARAMETER;
        }
    }

    switch (InfoClass)
    {
        case FileNameInformation:
            Status = NpQueryNameInfo(Ccb, Buffer, &Length);
            break;

        case FilePositionInformation:
            Status = NpQueryPositionInfo(Ccb, Buffer, &Length, NamedPipeEnd);
            break;

        case FilePipeInformation:
            Status = NpQueryPipeInfo(Fcb, Ccb, Buffer, &Length, NamedPipeEnd);
            break;

        case FilePipeLocalInformation:
            Status = NpQueryPipeLocalInfo(Fcb, Ccb, Buffer, &Length, NamedPipeEnd);
            break;

        case FileBasicInformation:
            Status = NpQueryBasicInfo(Ccb, Buffer, &Length);
            break;

        case FileStandardInformation:
            Status = NpQueryStandardInfo(Ccb, Buffer, &Length, NamedPipeEnd);
            break;

        case FileInternalInformation:
            Status = NpQueryInternalInfo(Ccb, Buffer, &Length);
            break;

        case FileAllInformation:

            Length -= 12;
            AllInfo = (PFILE_ALL_INFORMATION)Buffer;
            NpQueryBasicInfo(Ccb, &AllInfo->BasicInformation, &Length);
            NpQueryStandardInfo(Ccb, &AllInfo->StandardInformation, &Length, NamedPipeEnd);
            NpQueryInternalInfo(Ccb, &AllInfo->InternalInformation, &Length);
            NpQueryEaInfo(Ccb, &AllInfo->EaInformation, &Length);
            NpQueryPositionInfo(Ccb, &AllInfo->PositionInformation, &Length, NamedPipeEnd);
            Status = NpQueryNameInfo(Ccb, &AllInfo->NameInformation, &Length);
            Length += 96;
            break;

        case FileEaInformation:
            Status = NpQueryEaInfo(Ccb, Buffer, &Length);
            break;

        default:
            Status = STATUS_INVALID_PARAMETER;
            break;
    }

    Irp->IoStatus.Information = IoStack->Parameters.Read.Length - Length;
    return Status;
}

NTSTATUS
NTAPI
NpFsdQueryInformation(IN PDEVICE_OBJECT DeviceObject,
                      IN PIRP Irp)
{
    NTSTATUS Status;
    PAGED_CODE();

    FsRtlEnterFileSystem();
    NpAcquireSharedVcb();

    Status = NpCommonQueryInformation(DeviceObject, Irp);

    NpReleaseVcb();
    FsRtlExitFileSystem();

    if (Status != STATUS_PENDING)
    {
        Irp->IoStatus.Status = Status;
        IoCompleteRequest(Irp, IO_NAMED_PIPE_INCREMENT);
    }

    return Status;
}

/* EOF */