/*
 * Trace Recorder for Tracealyzer v4.6.0
 * Copyright 2021 Percepio AB
 * www.percepio.com
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Supporting functions for trace streaming, used by the "stream ports"
 * for reading and writing data to the interface.
 * This "stream port" sets up the recorder to stream to a Ring Buffer.
 */

#include <trcRecorder.h>

#if ( TRC_USE_TRACEALYZER_RECORDER == 1 )

    #if ( TRC_CFG_RECORDER_MODE == TRC_RECORDER_MODE_STREAMING )

/* Backwards compatibility with plugins */
        typedef TraceRingBuffer_t RecorderData;
        RecorderData * RecorderDataPtr = 0;

        TraceStreamPortData_t * pxStreamPortData;

        traceResult xTraceStreamPortInitialize( TraceStreamPortBuffer_t * pxBuffer )
        {
            TraceRingBuffer_t * pxRingBuffer;

            TRC_ASSERT_EQUAL_SIZE( TraceStreamPortBuffer_t, TraceStreamPortData_t );

            if( pxBuffer == 0 )
            {
                return TRC_FAIL;
            }

            pxStreamPortData = ( TraceStreamPortData_t * ) pxBuffer;
            RecorderDataPtr = pxRingBuffer = &pxStreamPortData->xRingBuffer;

            pxRingBuffer->xEventBuffer.uiSize = sizeof( pxRingBuffer->xEventBuffer.uiBuffer );

            #if ( TRC_CFG_STREAM_PORT_RINGBUFFER_MODE == TRC_STREAM_PORT_RINGBUFFER_MODE_OVERWRITE_WHEN_FULL )
                if( xTraceMultiCoreEventBufferInitialize( &pxStreamPortData->xMultiCoreEventBuffer, TRC_EVENT_BUFFER_OPTION_OVERWRITE, pxRingBuffer->xEventBuffer.uiBuffer, sizeof( pxRingBuffer->xEventBuffer.uiBuffer ) ) == TRC_FAIL )
                {
                    return TRC_FAIL;
                }
            #else
                if( xTraceMultiCoreEventBufferInitialize( &pxStreamPortData->xMultiCoreEventBuffer, TRC_EVENT_BUFFER_OPTION_SKIP, pxRingBuffer->xEventBuffer.uiBuffer, sizeof( pxRingBuffer->xEventBuffer.uiBuffer ) ) == TRC_FAIL )
                {
                    return TRC_FAIL;
                }
            #endif

            if( xTraceHeaderInitialize( &pxRingBuffer->xHeaderBuffer ) == TRC_FAIL )
            {
                return TRC_FAIL;
            }

            if( xTraceEntryTableInitialize( &pxRingBuffer->xEntryTableBuffer ) == TRC_FAIL )
            {
                return TRC_FAIL;
            }

            if( xTraceTimestampInitialize( &pxRingBuffer->xTimestampInfo ) == TRC_FAIL )
            {
                return TRC_FAIL;
            }

            pxRingBuffer->END_MARKERS[ 0 ] = 0x0A;
            pxRingBuffer->END_MARKERS[ 1 ] = 0x0B;
            pxRingBuffer->END_MARKERS[ 2 ] = 0x0C;
            pxRingBuffer->END_MARKERS[ 3 ] = 0x0D;

            pxRingBuffer->END_MARKERS[ 4 ] = 0x71;
            pxRingBuffer->END_MARKERS[ 5 ] = 0x72;
            pxRingBuffer->END_MARKERS[ 6 ] = 0x73;
            pxRingBuffer->END_MARKERS[ 7 ] = 0x74;

            pxRingBuffer->END_MARKERS[ 8 ] = 0xF1;
            pxRingBuffer->END_MARKERS[ 9 ] = 0xF2;
            pxRingBuffer->END_MARKERS[ 10 ] = 0xF3;
            pxRingBuffer->END_MARKERS[ 11 ] = 0xF4;

            pxRingBuffer->START_MARKERS[ 0 ] = 0x05;
            pxRingBuffer->START_MARKERS[ 1 ] = 0x06;
            pxRingBuffer->START_MARKERS[ 2 ] = 0x07;
            pxRingBuffer->START_MARKERS[ 3 ] = 0x08;

            pxRingBuffer->START_MARKERS[ 4 ] = 0x75;
            pxRingBuffer->START_MARKERS[ 5 ] = 0x76;
            pxRingBuffer->START_MARKERS[ 6 ] = 0x77;
            pxRingBuffer->START_MARKERS[ 7 ] = 0x78;

            pxRingBuffer->START_MARKERS[ 8 ] = 0xF5;
            pxRingBuffer->START_MARKERS[ 9 ] = 0xF6;
            pxRingBuffer->START_MARKERS[ 10 ] = 0xF7;
            pxRingBuffer->START_MARKERS[ 11 ] = 0xF8;

            return TRC_SUCCESS;
        }

        traceResult xTraceStreamPortCommit( void * pvData,
                                            uint32_t uiSize,
                                            int32_t * piBytesCommitted )
        {
            if( pvData == 0 )
            {
                return TRC_FAIL;
            }

            xTraceMultiCoreEventBufferPush( &pxStreamPortData->xMultiCoreEventBuffer, pvData, uiSize, piBytesCommitted );

            #if ( TRC_CFG_STREAM_PORT_RINGBUFFER_MODE == TRC_STREAM_PORT_RINGBUFFER_MODE_STOP_WHEN_FULL )

                /* If no bytes was written it means that the buffer is full and we should stop
                 * tracing.
                 */
                if( ( uiSize > 0 ) && ( *piBytesCommitted == 0 ) )
                {
                    xTraceDisable();
                    return TRC_FAIL;
                }
            #endif

            return TRC_SUCCESS;
        }

        traceResult xTraceStreamPortOnTraceBegin()
        {
            return xTraceMultiCoreEventBufferClear( &pxStreamPortData->xMultiCoreEventBuffer );
        }

    #endif /*(TRC_CFG_RECORDER_MODE == TRC_RECORDER_MODE_STREAMING)*/

#endif /*(TRC_USE_TRACEALYZER_RECORDER == 1)*/