/*
 * Copyright 2012 Haiku, Inc. All rights reserved.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *              Paweł Dziepak, pdziepak@quarnos.org
 */


#include "RPCCallbackRequest.h"

#include <stdlib.h>

#include <debug.h>

#include "NFS4Defs.h"
#include "RPCDefs.h"


using namespace RPC;


CallbackRequest::CallbackRequest(void* buffer, int size)
        :
        fError(B_BAD_VALUE),
        fRPCError(GARBAGE_ARGS),
        fStream(buffer, size),
        fBuffer(buffer)
{
        ASSERT(buffer != NULL);

        fXID = fStream.GetUInt();

        if (fStream.GetUInt() != CALL)
                return;

        if (fStream.GetUInt() != VERSION)
                return;

        if (fStream.GetUInt() != PROGRAM_NFS_CB) {
                fRPCError = PROG_UNAVAIL;
                return;
        }

        if (fStream.GetUInt() != NFS_CB_VERSION) {
                fRPCError = PROG_MISMATCH;
                return;
        }

        fProcedure = fStream.GetUInt();

        fStream.GetUInt();
        fStream.GetOpaque(NULL);

        fStream.GetUInt();
        fStream.GetOpaque(NULL);

        if (fProcedure == CallbackProcCompound) {
                fStream.GetOpaque(NULL); // TODO: tag may be important
                if (fStream.GetUInt() != 0)
                        return;

                fID = fStream.GetUInt();

                fRPCError = SUCCESS;
                fError = B_OK;
        } else if (fProcedure == CallbackProcNull) {
                fRPCError = SUCCESS;
                fError = B_OK;
        } else
                fRPCError = PROC_UNAVAIL;
}


CallbackRequest::~CallbackRequest()
{
        free(fBuffer);
}