/*====================================================================*
*
*   Copyright (c) 2013 Qualcomm Atheros, Inc.
*
*   All rights reserved.
*
*====================================================================*/

/*====================================================================*
 *
 *   signed ReadFMI (struct plc * plc, uint8_t MMV, uint16_t MMTYPE);
 *
 *   plc.h
 *
 *   read a fragmented message and return a pointer to a buffer that
 *   contains the concatenated message fragments; the buffer address
 *   is returned in plc->content; the calling function must free the
 *   buffer when done; buffer length is computed from the number of
 *   fragments returned in the FMI field of the first fragment;
 *
 *   Contributor(s):
 *      Charles Maier <cmaier@qca.qualcomm.com>
 *      Nathaniel Houghton <nhoughto@qca.qualcomm.com>
 *
 *--------------------------------------------------------------------*/

#ifndef READFMI_SOURCE
#define READFMI_SOURCE

#include <stdint.h>
#include <stdlib.h>
#include <memory.h>

#include "../tools/memory.h"
#include "../tools/number.h"
#include "../tools/error.h"
#include "../plc/plc.h"

signed ReadFMI (struct plc * plc, uint8_t MMV, uint16_t MMTYPE)

{
	if (ReadMME (plc, MMV, MMTYPE) > 0)
	{
		struct homeplug * homeplug = (struct homeplug *) (plc->message);
		if (homeplug->homeplug.FMSN || homeplug->homeplug.FMID)
		{
			unsigned count = ((homeplug->homeplug.FMID >> 0) & 0x0F);
			unsigned extra = ((homeplug->homeplug.FMID >> 4) & 0x0F);
			unsigned length = sizeof (* homeplug) +  extra * sizeof (homeplug->content);
			if ((plc->content = malloc (length)))
			{
				signed offset = plc->packetsize;
				memcpy (plc->content, homeplug, offset);
				while (count < extra)
				{
					if (ReadMME (plc, MMV, MMTYPE) <= 0)
					{
						free (plc->content);
						plc->content = NULL;
						return (-1);
					}
					count = ((homeplug->homeplug.FMID >> 0) & 0x0F);
					extra = ((homeplug->homeplug.FMID >> 4) & 0x0F);
					plc->packetsize -= sizeof (struct ethernet_hdr);
					plc->packetsize -= sizeof (struct homeplug_fmi);
					memcpy ((byte *) (plc->content) +  offset, homeplug->content, plc->packetsize);
					offset += plc->packetsize;
				}
				plc->packetsize = offset;
			}
		}
		else 
		{
			struct fragment_hdr * fragment = (struct fragment_hdr *) (homeplug->content);
			signed length = sizeof (struct ethernet_hdr) +  sizeof (struct qualcomm_fmi) +  LE16TOH (fragment->MME_LENGTH);
			error (0, 0, "fragment->MME_LENGTH %d", fragment->MME_LENGTH);
			if ((plc->content = malloc (length)))
			{
				signed offset = plc->packetsize;
				memcpy (plc->content, homeplug, offset);
				while (offset < length)
				{
					if (ReadMME (plc, MMV, MMTYPE) <= 0)
					{
						free (plc->content);
						plc->content = NULL;
						return (-1);
					}
					plc->packetsize -= sizeof (struct ethernet_hdr);
					plc->packetsize -= sizeof (struct qualcomm_fmi);
					memcpy ((byte *) (plc->content) +  offset, homeplug->content, plc->packetsize);
					offset += plc->packetsize;
				}
				plc->packetsize = offset;
			}
		}
	}
	error (0, 0, "plc->packetsize %d", plc->packetsize);
	return (plc->packetsize);
}

#endif