test_control.h

Go to the documentation of this file.

// -------------------------------------------------------------------------------------------
// Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
// This file is part of the AWS CDI-SDK, licensed under the BSD 2-Clause "Simplified" License.
// License details at: https://github.com/aws/aws-cdi-sdk/blob/mainline/LICENSE
// -------------------------------------------------------------------------------------------

 
#ifndef TEST_CONTROL_H__
#define TEST_CONTROL_H__
 
#include <stdbool.h>
#include <stdint.h>
 
#include "fifo_api.h"
#include "cdi_pool_api.h"
#include "cdi_raw_api.h"
#include "test_args.h"
 
//*********************************************************************************************************************
//***************************************** START OF DEFINITIONS AND TYPES ********************************************
//*********************************************************************************************************************

#define MAX_LOG_FILENAME_LENGTH     (1024)

#define MAX_SGL_ENTRIES_PER_PAYLOAD (7)
 
extern CdiLoggerHandle test_app_logger_handle;

#define TEST_LOG_CONNECTION(log_level, ...) \
    CdiLogger(connection_info_ptr->app_file_log_handle, kLogComponentGeneric, log_level, __FUNCTION__, __LINE__, \
              __VA_ARGS__)

#define BYTES_PER_PATTERN_WORD      (sizeof(uint64_t))

#define MAX_TEST_PAYLOAD_COUNT      (0x00FFFFFF)

#define CDI_BYTES_PER_AUDIO_SAMPLE  (3)

typedef struct TestConnectionInfo TestConnectionInfo;
typedef struct TestDynamicState* TestDynamicHandle;

typedef struct {
    TestConnectionInfo* test_connection_info_ptr;

    uint64_t tx_payload_start_time;

    int stream_index;

    CdiPoolHandle tx_pool_handle;

    CdiSgList* tx_payload_sgl_ptr;
} TestTxUserData;

typedef struct {
    CdiFileID user_data_read_file_handle;

    CdiFileID user_data_write_file_handle;

    int next_payload_size;

    void* rx_expected_data_buffer_ptr;

    int payload_buffer_size;

    int tx_pool_buffer_size;

    CdiPoolHandle tx_pool_handle;

    int config_payload_skip_count;

    int payload_count;

    CdiPtpTimestamp connection_start_time;

    CdiAvmBaselineConfig last_baseline_config;

    CdiPtpTimestamp last_ptp_timestamp;
 
    uint64_t total_audio_samples; 
} TestConnectionStreamInfo;

struct TestConnectionInfo {
    CdiCsID connection_handle_lock;

    CdiConnectionHandle connection_handle;

    CdiEndpointHandle tx_stream_endpoint_handle_array[CDI_MAX_ENDPOINTS_PER_CONNECTION];

    int my_index;

    union {
        CdiRxConfigData     rx; 
        CdiTxConfigData     tx; 
    } config_data;

    void* local_data_ptr;

    TestSettings* test_settings_ptr;

    CdiSignalType payload_done_signal;

    int payload_count;

    int total_payloads;

    int current_stream_count;

    bool pass_status;

    uint64_t num_payload_errors;

    CdiSignalType done_signal;

    CdiThreadID thread_id;

    CdiSignalType connection_shutdown_signal;

    CdiSignalType connection_state_change_signal;

    volatile CdiConnectionStatus connection_status;

    CdiConnectionStatus connection_status_stream_array[CDI_MAX_ENDPOINTS_PER_CONNECTION];

    CdiFifoHandle fifo_handle;

    CdiLogHandle app_file_log_handle;

    CdiLogHandle sdk_file_callback_log_handle;

    CdiPoolHandle tx_user_data_pool_handle;

    uint64_t tx_late_payload_count;

    uint32_t transfer_time_max_overall;

    uint32_t transfer_time_min_overall;

    int number_stats;

    CdiPayloadCounterStats payload_counter_stats_array[CDI_MAX_ENDPOINTS_PER_CONNECTION];

    int total_poll_thread_load;

    TestConnectionStreamInfo stream_info[CDI_MAX_SIMULTANEOUS_TX_PAYLOADS_PER_CONNECTION];

    uint64_t pattern_count;

    TestDynamicHandle test_dynamic_handle;
};
 
//*********************************************************************************************************************
//******************************************* START OF PUBLIC FUNCTIONS ***********************************************
//*********************************************************************************************************************

bool TestWaitForConnection(TestConnectionInfo* connection_info_ptr, int timeout_seconds);

void TestConnectionCallback(const CdiCoreConnectionCbData* cb_data_ptr);

void TestStatisticsCallback(const CdiCoreStatsCbData* cb_data_ptr);

void TestIncPayloadCount(TestConnectionInfo* connection_info_ptr, int stream_index);

bool PreparePayloadData(StreamSettings* stream_settings_ptr, int payload_buffer_size, CdiFileID* read_file_handle_ptr,
                        void* buffer_ptr);

bool GetNextPayloadDataSgl(const TestConnectionInfo* connection_info_ptr, const StreamSettings* stream_settings_ptr,
    int payload_id, CdiFileID read_file_handle, CdiSgList* sgl_ptr);

bool GetNextPayloadDataLinear(const TestConnectionInfo* connection_info_ptr, const StreamSettings* stream_settings_ptr,
    TestConnectionStreamInfo* stream_info_ptr);

bool TestCreateConnectionLogFiles(TestConnectionInfo* connection_info_ptr, CdiLogMethodData* log_method_data_ptr,
                                  char* sdk_log_filename_buffer_str);

bool IsPayloadNumLessThanTotal(int current_payload_num, int total_payloads);

CdiPtpTimestamp GetVideoPtpTimestamp(const TestConnectionInfo* connection_info_ptr,
                                     const TestConnectionStreamInfo* stream_info_ptr, int ptp_rate_count);

CdiPtpTimestamp GetAudioPtpTimestamp(const StreamSettings* stream_settings_ptr,
                                     TestConnectionStreamInfo* stream_info_ptr, int audio_data_size);

void LogTimestamps(const StreamSettings* stream_settings_ptr, TestConnectionStreamInfo* stream_info_ptr,
                   CdiPtpTimestamp current_ptp_timestamp);
 
#endif // TEST_CONTROL_H__