CDI SDK
SDK for transporting chunks of data reliably and with low latency using a polled mode network driver.
Loading...
Searching...
No Matches
adapter_efa_probe_rx.h File Reference

The declarations in this header file correspond to the definitions in adapter_efa_probe_rx.c. More...

#include <stdbool.h>
#include <stdint.h>
#include "adapter_api.h"

Go to the source code of this file.

Typedefs

typedef struct CdiRawProbeHeader CdiRawProbeHeader
 Forward declaration of structure to create pointers.
 

Functions

void ProbeRxEfaMessageFromEndpoint (void *param_ptr, Packet *packet_ptr, EndpointMessageType message_type)
 
void ProbeRxControlMessageFromEndpoint (void *param_ptr, Packet *packet_ptr)
 
bool ProbeRxControlProcessPacket (ProbeEndpointState *probe_ptr, const CdiDecodedProbeHeader *probe_hdr_ptr, const struct sockaddr_in *source_address_ptr, uint64_t *wait_timeout_ms_ptr)
 
uint64_t ProbeRxControlProcessProbeState (ProbeEndpointState *probe_ptr)
 

Detailed Description

The declarations in this header file correspond to the definitions in adapter_efa_probe_rx.c.

Function Documentation

◆ ProbeRxControlMessageFromEndpoint()

void ProbeRxControlMessageFromEndpoint ( void * param_ptr,
Packet * packet_ptr )

Process a control packet completion message received from an endpoint.

NOTE: This function is called from SocketReceiveThread().

Parameters
param_ptrPointer to probe endpoint state data (AdapterEndpointState*).
packet_ptrPointer to packet containing the control message.

◆ ProbeRxControlProcessPacket()

bool ProbeRxControlProcessPacket ( ProbeEndpointState * probe_ptr,
const CdiDecodedProbeHeader * probe_hdr_ptr,
const struct sockaddr_in * source_address_ptr,
uint64_t * wait_timeout_ms_ptr )

Process control message for Rx connection.

NOTE: This function is called from ProbeControlThread().

Parameters
probe_ptrPointer to probe endpoint state data.
probe_hdr_ptrPointer to control message header.
source_address_ptrPointer to source address structure (sockaddr_in).
wait_timeout_ms_ptrPointer to current wait timeout. This function may alter the contents of the value.
Returns
True if new probe state has been set, otherwise false is returned.

◆ ProbeRxControlProcessProbeState()

uint64_t ProbeRxControlProcessProbeState ( ProbeEndpointState * probe_ptr)

Called when the wait timeout period has expired. Time to process the current Rx probe state.

NOTE: This function is called from ProbeControlThread().

Parameters
probe_ptrPointer to probe endpoint state data.
Returns
Wait timeout value.

◆ ProbeRxEfaMessageFromEndpoint()

void ProbeRxEfaMessageFromEndpoint ( void * param_ptr,
Packet * packet_ptr,
EndpointMessageType message_type )

Process a probe packet completion message from the receiver EFA endpoint.

NOTE: This function is called from PollThread().

Parameters
param_ptrPointer to probe endpoint state data (ProbeEndpointState*).
packet_ptrPointer to packet.
message_typeEndpoint message type.