pipeio.cpp File Reference

#include "ucx01000.h"
#include <debug.h>

Include dependency graph for pipeio.cpp:

Go to the source code of this file.

Macros
#define	NDEBUG

Functions
static NTSTATUS NTAPI	UcxFailStreamsUrb (_In_ PIRP Irp, _In_ PURB Urb, _In_ NTSTATUS Status)
static NTSTATUS NTAPI	UcxCreateStaticStreams (_In_ UcxEndpoint *Endpoint, _In_ ULONG Count, _Outptr_ UcxStaticStreams **StreamsOut)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 10 of file pipeio.cpp.

Function Documentation

UcxCreateStaticStreams()

static NTSTATUS NTAPI UcxCreateStaticStreams ( _In_ UcxEndpoint *  Endpoint, _In_ ULONG  Count, _Outptr_ UcxStaticStreams **  StreamsOut  )

static

Definition at line 112 of file pipeio.cpp.

{
    BOOLEAN Verifying = Endpoint->m_Controller->m_DriverVerifierEnabled;
    UcxStaticStreamsInit Init;
    UcxStaticStreams* Streams;
    ULONG Index;
    NTSTATUS Status;
 
    *StreamsOut = NULL;
 
    RtlZeroMemory(&Init, sizeof(Init));
    Init.Endpoint = Endpoint->m_Handle;
    Init.StreamCount = Count;
 
    Status = Endpoint->m_Callbacks.StaticStreamsAdd(Endpoint->m_Handle, Count, &Init);
    if (!NT_SUCCESS(Status))
    {
        DPRINT1("Endpoint %p HCD streams add failed 0x%lx\n", Endpoint->m_Handle, Status);
        if (Init.Created != NULL)
            WdfObjectDelete(Init.Created);
        return Status;
    }
 
    /* A success without a streams object is a controller driver bug */
    if (Init.Created == NULL)
    {
        DPRINT1("Endpoint %p HCD streams add created no streams object\n", Endpoint->m_Handle);
        UcxVerifierBreak(Verifying);
        return STATUS_INTERNAL_ERROR;
    }
 
    Streams = UcxStaticStreams::FromHandle(Init.Created);
    Streams->m_Init = NULL;
 
    Status = Init.Failed ? STATUS_INTERNAL_ERROR : STATUS_SUCCESS;
    for (Index = 0; NT_SUCCESS(Status) && Index < Count; Index++)
    {
        if (!Streams->Stream(Index)->Filled)
            Status = STATUS_INTERNAL_ERROR;
    }
 
    if (!NT_SUCCESS(Status))
    {
        DPRINT1("Endpoint %p HCD did not set every stream, %lu set calls for %lu streams\n",
                Endpoint->m_Handle, Init.SetInfoCalls, Count);
        UcxVerifierBreak(Verifying);
        WdfObjectDelete(Init.Created);
        return Status;
    }
 
    *StreamsOut = Streams;
    return STATUS_SUCCESS;
}

Referenced by UcxEndpoint::OpenStaticStreams().

UcxFailStreamsUrb()

static NTSTATUS NTAPI UcxFailStreamsUrb ( _In_ PIRP  Irp, _In_ PURB  Urb, _In_ NTSTATUS  Status  )

static

Fails a streams URB on the submitting thread.

Definition at line 100 of file pipeio.cpp.

{
    return UcxCompleteUrb(Irp, Urb, Status, UcxNtStatusToUsbdStatus(Status));
}

Referenced by UcxEndpoint::CloseStaticStreams(), and UcxEndpoint::OpenStaticStreams().