//Sender
void TCPRenderer::SendFrame()
{
    unsigned short TotalSize  = 0;
    unsigned short TmpSize    = 0;
    int            Offset     = 0;
    int            UShortSize = sizeof(unsigned short);
    char*           Buffer    = NULL;


    TotalSize = (UShortSize * 3) + (USHORT)sizeof(NetData) + (USHORT)m_mt.cbFormat + m_BufferSize;

    Buffer    = new char[ TotalSize + UShortSize ];

    ZeroMemory(Buffer, TotalSize + UShortSize);
    ZeroMemory(&Sample, sizeof(Sample));

    Sample.MediaType  = m_mt;
    Sample.SampleProp = m_SampleProps;
    
    //Add Total Size
    memcpy(Buffer, &TotalSize, UShortSize);
    Offset = UShortSize;

    //Add Remainig Data Sizes
    TmpSize = sizeof(NetData);
    memcpy(Buffer + Offset, &TmpSize, UShortSize);
    Offset += UShortSize;

    TmpSize = (unsigned short)m_mt.cbFormat;
    memcpy(Buffer + Offset, &TmpSize, UShortSize);
    Offset += UShortSize;

    TmpSize = m_BufferSize;
    memcpy(Buffer + Offset, &TmpSize, UShortSize);
    Offset += UShortSize;


    //Add Actual Data
    memcpy(Buffer + Offset, &Sample, sizeof(Sample));
    Offset += sizeof(Sample);

    memcpy(Buffer + Offset, m_mt.pbFormat, m_mt.cbFormat);
    Offset += m_mt.cbFormat;

    memcpy(Buffer + Offset, m_Buffer, m_BufferSize);
    Offset += m_BufferSize;


    //Send & clean up
    Send(Buffer, TotalSize + UShortSize );
    DELETE_ARRAY(Buffer);
}

//Send
void TCPRenderer::Send(const char *Buffer, int Size)
{
    int sended = 0;
    while(sended < Size)
    {
        int ret = m_Sender.Send((char*)Buffer + sended, Size -                                       sended);

        if(ret == SOCKET_ERROR)
        {
            PrintWinsockError();
            return;
        }

        sended += ret;
    }
}

//Receiver
int TCPSourceStream::ReadNetworkData()
{
    bool      FirstPacket  = true;
    char*     Buffer       = 0;
    USHORT    Size         = 0;
    USHORT    TotalReceive = 0;
    int       Received     = 0;



    while(true)
    {

        if(FirstPacket)
        {

            char cSize[sizeof(USHORT)];
            Received = m_Receiver.Receive(cSize,                                        sizeof(USHORT));

            ON_WS_ERROR(Received);
           
            memcpy(&Size, cSize, sizeof(USHORT));

            //Error occurred
            if(Size > g_MaxPacketSize)
            {
                printf("Packet Size (%u) Exceeded the maximum packet size (%d)", Size, g_MaxPacketSize);
                return -1;
            }

            Buffer = new char[ Size ];
            ZeroMemory(Buffer, Size);

            FirstPacket = false;
            continue;
        }

        Received = m_Receiver.Receive(Buffer + TotalReceive,                              Size - TotalReceive);

        ON_WS_ERROR(Received);

        TotalReceive += Received;

        if(TotalReceive > Size)
        {
            printf("TotalReceive (%u) Exceeds Packet Size(%u) \n", TotalReceive, Size);
            DELETE_ARRAY(Buffer);
            return -1;
        }
       
        if(TotalReceive == Size)
        {
            //Delete any previous aloocated buffers
            DELETE_ARRAY(m_Buffer);
            m_Buffer = Buffer;
            break;
        }
    }

    return Size;
}