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


#include "RPCReply.h"

#include <debug.h>
#include <util/kernel_cpp.h>

#include "RPCDefs.h"


using namespace RPC;


Reply::Reply(void* buffer, int size)
	:
	fError(B_OK),
	fStream(buffer, size),
	fBuffer(buffer)
{
	ASSERT(buffer != NULL);

	fXID = fStream.GetUInt();
	if (fStream.GetInt() != REPLY) {
		fError = B_BAD_VALUE;
		return;
	}

	if (fStream.GetInt() == MSG_ACCEPTED) {
		fStream.GetInt();
		fStream.GetOpaque(NULL);

		switch (fStream.GetInt()) {
			case SUCCESS:
				return;
			case PROG_UNAVAIL:
			case PROG_MISMATCH:
			case PROC_UNAVAIL:
				fError = B_DEVICE_NOT_FOUND;
				return;
			case GARBAGE_ARGS:
				fError = B_MISMATCHED_VALUES;
				return;
			case SYSTEM_ERR:
				fError = B_ERROR;
				return;
			default:
				fError = B_BAD_VALUE;
				return;
		}
	} else {		// MSG_DENIED
		if (fStream.GetInt() == RPC_MISMATCH) {
			fError = B_DEVICE_NOT_FOUND;
			return;
		} else {	// AUTH_ERROR	
			fError = B_PERMISSION_DENIED;
			return;
		}
	}
}


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