GetQueuedCompletionStatus - ERROR_INSUFFICIENT_BUFFER

//------------------------------------------------------------------------------
typedef struct _RECVREPLY
{
    BOOLEAN locked;
} RECVREPLY, *PRECVREPLY;
//------------------------------------------------------------------------------
typedef struct _SENDREQ
{
    char DriveName;
    BOOLEAN USBDrive;
    HANDLE ProcessID;
} SENDREQ, *PSENDREQ;
//------------------------------------------------------------------------------
PSENDREQ msg = NULL;
msg = ExAllocatePoolWithTag(NonPagedPool, sizeof(SENDREQ), 'nacS');
if (msg != NULL)
{
    ULONG replyLength = sizeof(RECVREPLY);                      
    msg->DriveName = 'C';
    msg->ProcessID = 1000;
    msg->USBDrive = TRUE;
    NTSTATUS st = FltSendMessage(pFilter, &pClientPort, msg, sizeof(SENDREQ), msg, &replyLength, NULL);     
    if (STATUS_SUCCESS == st)
    {
        KdPrint(("[MyDrv]: Recv reply - %c", ((PRECVREPLY)msg)->locked));
    } else
        {
                KdPrint(("[MyDrv]: ERROR FltSendMessage- %08x.\n", st));
        }
    ExFreePoolWithTag(msg, 'nacS');
}

pragma pack(1)
 
typedef struct _RECVREPLY
{
    BOOLEAN locked;
} RECVREPLY, *PRECVREPLY;
//---------------------------------------------------------------------------------------------------------
typedef struct _SENDREQ
{
    char DriveName;
    BOOLEAN USBDrive;
    HANDLE ProcessID;
} SENDREQ, *PSENDREQ;
//------------------------------------------------------------------------------
typedef struct _MESSAGE
{   
    FILTER_MESSAGE_HEADER MessageHeader;    
    SENDREQ DriverSendReq;
    OVERLAPPED Ovlp;
} MESSAGE, *PMESSAGE;
//------------------------------------------------------------------------------
typedef struct _REPLY_MESSAGE
{
    FILTER_REPLY_HEADER ReplyHeader;
    RECVREPLY Reply;
 
} REPLY_MESSAGE, *PREPLY_MESSAGE;
//------------------------------------------------------------------------------
typedef struct _THREAD_CONTEXT 
{
    HANDLE Port;
    HANDLE Completion;
} THREAD_CONTEXT, *PTHREAD_CONTEXT;
//------------------------------------------------------------------------------
DWORD JThread(_In_ PTHREAD_CONTEXT Context)
{
    LPOVERLAPPED pOvlp;
    DWORD outSize;
    HRESULT hr;
    BOOL result;
    ULONG_PTR key;
    PMESSAGE message = NULL;
    PSENDREQ driversendreq = NULL;
    REPLY_MESSAGE replyMessage;
 
 
#pragma warning(push)
#pragma warning(disable:4127) 
    while (1)
    {
#pragma warning(pop)
    
        if (!GetQueuedCompletionStatus(Context->Completion, &outSize, &key, &pOvlp, INFINITE))
        {   
            hr = HRESULT_FROM_WIN32(GetLastError()); [B]// При отправке драйвером сообщения всегда выпадаю сюда[/B]
            break;
        }
        message = CONTAINING_RECORD(pOvlp, MESSAGE, Ovlp);
 
        printf("Received message, size %d\n", pOvlp->InternalHigh);
 
        driversendreq = &message->DriverSendReq;
 
        printf("DriveName: %c\nProcessID: %lUSBDrive: %c", driversendreq->DriveName, driversendreq->ProcessID, driversendreq->USBDrive);
 
        replyMessage.ReplyHeader.Status = 0;
        replyMessage.ReplyHeader.MessageId = message->MessageHeader.MessageId;
        replyMessage.Reply.locked= TRUE;
 
        hr = FilterReplyMessage(Context->Port, (PFILTER_REPLY_HEADER)&replyMessage, sizeof(replyMessage));
 
        if (SUCCEEDED(hr))
            printf("Replied message\n");
        else
        {
            printf("Error replying message.\n");
            break;
        }
        memset(&message->Ovlp, 0, sizeof(OVERLAPPED));
        hr = FilterGetMessage(Context->Port, &message->MessageHeader, FIELD_OFFSET(MESSAGE, Ovlp), &message->Ovlp);
        if (hr != HRESULT_FROM_WIN32(ERROR_IO_PENDING))
        {
            printf("Error IO PENDING. Error = 0x%X\n", hr);
            break;
        }
    }
    if (!SUCCEEDED(hr))
    {
        if (hr == HRESULT_FROM_WIN32(ERROR_INVALID_HANDLE))
            printf("Driver Port is disconnected.\n");
        else
            printf("Unknown error occured. Error = 0x%X\n", hr);        
    }
    free(message);
    return 0;
}