internal_tx.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 CDI_INTERNAL_TX_H__
#define CDI_INTERNAL_TX_H__
 
#include "adapter_api.h"
#include "private.h"
#include "cdi_core_api.h"
#include "cdi_raw_api.h"
 
//*********************************************************************************************************************
//***************************************** START OF DEFINITIONS AND TYPES ********************************************
//*********************************************************************************************************************
 
typedef struct {
    uint8_t header[MAX_MSG_PREFIX_SIZE + sizeof(CdiRawPacketHeader)]; 
} TxPacketHeader;
 
typedef struct {
    uint8_t header[MAX_MSG_PREFIX_SIZE + sizeof(CdiRawExtraPacketHeader)]; 
} TxExtraPacketHeader;
 
typedef struct {
    TxPayloadState* payload_state_ptr; 
    uint16_t payload_num;              
    uint16_t packet_payload_size;      
    Packet packet;                     
 
    CdiPoolHandle header_pool_handle;
    union {
        void* union_ptr; 
        TxPacketHeader* header_ptr;
        TxExtraPacketHeader* extra_header_ptr;
    };
} TxPacketWorkRequest;
 
//*********************************************************************************************************************
//******************************************* START OF PUBLIC FUNCTIONS ***********************************************
//*********************************************************************************************************************
 
CdiReturnStatus TxCreateInternal(CdiConnectionProtocolType protocol_type, CdiTxConfigData* config_data_ptr,
                                 CdiCallback tx_cb_ptr, CdiConnectionHandle* ret_handle_ptr);
 
CdiReturnStatus TxStreamConnectionCreateInternal(CdiTxConfigData* config_data_ptr, CdiCallback tx_cb_ptr,
                                                 CdiConnectionHandle* ret_handle_ptr);
 
CdiReturnStatus TxStreamEndpointCreateInternal(CdiConnectionHandle handle, CdiTxConfigDataStream* stream_config_ptr,
                                               CdiEndpointHandle* ret_handle_ptr);
 
CdiReturnStatus TxPayloadInternal(CdiEndpointState* endpoint_ptr, const CdiCoreTxPayloadConfig* core_payload_config_ptr,
                                  const CdiSgList* sgl_ptr, int max_latency_microsecs, int extra_data_size,
                                  uint8_t* extra_data_ptr);
 
CdiReturnStatus TxConnectionThreadJoin(CdiConnectionHandle con_handle);
 
void TxConnectionDestroyInternal(CdiConnectionHandle con_handle);
 
void TxEndpointDestroy(CdiEndpointHandle handle);
 
void TxPacketWorkRequestComplete(void* param_ptr, Packet* packet_ptr, EndpointMessageType message_type);
 
void TxInvokeAppPayloadCallback(CdiConnectionState* con_state_ptr, AppPayloadCallbackData* app_cb_data_ptr);
 
void TxPayloadThreadFlushResources(CdiEndpointState* endpoint_ptr);
 
#endif  // CDI_INTERNAL_TX_H__