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__