CDI SDK
SDK for transporting chunks of data reliably and with low latency using a polled mode network driver.
|
The declarations in this header file correspond to the definitions in adapter_efa_probe_rx.c. More...
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) |
The declarations in this header file correspond to the definitions in adapter_efa_probe_rx.c.
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().
param_ptr | Pointer to probe endpoint state data (AdapterEndpointState*). |
packet_ptr | Pointer to packet containing the control message. |
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().
probe_ptr | Pointer to probe endpoint state data. |
probe_hdr_ptr | Pointer to control message header. |
source_address_ptr | Pointer to source address structure (sockaddr_in). |
wait_timeout_ms_ptr | Pointer to current wait timeout. This function may alter the contents of the value. |
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().
probe_ptr | Pointer to probe endpoint state data. |
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().
param_ptr | Pointer to probe endpoint state data (ProbeEndpointState*). |
packet_ptr | Pointer to packet. |
message_type | Endpoint message type. |