internal_rx.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_RX_H__
#define CDI_INTERNAL_RX_H__
 
#include "adapter_api.h"
#include "cdi_core_api.h"
#include "cdi_raw_api.h"
 
//*********************************************************************************************************************
//***************************************** START OF DEFINITIONS AND TYPES ********************************************
//*********************************************************************************************************************
 
typedef struct RxPayloadWorkRequestState* RxPayloadWorkRequestHandle;
 
//*********************************************************************************************************************
//******************************************* START OF PUBLIC FUNCTIONS ***********************************************
//*********************************************************************************************************************
 
CdiReturnStatus RxCreateInternal(CdiConnectionProtocolType protocol_type, CdiRxConfigData* config_data_ptr,
                                  CdiCallback rx_cb_ptr, CdiConnectionHandle* ret_handle_ptr);
 
void RxConnectionDestroyInternal(CdiConnectionHandle con_handle);
 
CdiReturnStatus RxEndpointCreateDynamicPools(CdiEndpointHandle handle);
 
void RxEndpointDestroy(CdiEndpointHandle handle);
 
void RxPacketReceive(void* param_ptr, Packet* packet_ptr, EndpointMessageType message_type);
 
void RxSendPayload(CdiEndpointState* endpoint_ptr, RxPayloadState* send_payload_state_ptr);
 
void RxFreePayloadResources(CdiEndpointState* endpoint_ptr, RxPayloadState* payload_state_ptr, bool free_memory_state);
 
void RxInvokeAppPayloadCallback(CdiConnectionState* con_state_ptr, AppPayloadCallbackData* app_cb_data_ptr);
 
CdiReturnStatus RxEnqueueFreeBuffer(const CdiSgList* sgl_ptr);
 
bool RxPollFreeBuffer(void* param_ptr, CdiSgList* ret_packet_buffer_sgl_ptr);
 
void RxEndpointFlushResources(CdiEndpointState* endpoint_ptr);
 
#endif  // CDI_INTERNAL_RX_H__