Struct PDUWithData 

pub struct PDUWithData<T, Body = Bytes> {
    pub header_buf: [u8; 48],
    pub header_digest: Option<U32<BigEndian>>,
    pub data_digest: Option<U32<BigEndian>>,
    pub is_x86: bool,
    /* private fields */
}

A generic container for an iSCSI Protocol Data Unit (PDU).

This struct holds the PDU’s header, payload (data), and digest information. It is generic over the body type, allowing it to be used for both requests (with a mutable body) and responses (with an immutable body).

Fields

header_buf: [u8; 48]

The raw buffer for the Basic Header Segment (BHS).

header_digest: Option<U32<BigEndian>>

The optional header digest value.

data_digest: Option<U32<BigEndian>>

The optional data digest value.

is_x86: bool

Implementations

impl<T> PDUWithData<T, Bytes>

pub fn from_header_slice(header_buf: [u8; 48], cfg: &Config) -> Self

Creates a new PDUWithData instance from a header slice and configuration.

impl<T> PDUWithData<T, BytesMut>

pub fn new_request(header_buf: [u8; 48], cfg: &Config) -> Self

Creates a new PDUWithData request instance with a mutable body.

pub fn parse_with_buff_mut(&mut self, buf: BytesMut) -> Result<()>

where T: BasicHeaderSegment + FromBytes + ZeroCopyType,

Parses the PDU payload from a mutable buffer, verifying digests.

pub fn parse_with_buff_ref(&mut self, buf: &BytesMut) -> Result<()>

where T: BasicHeaderSegment + FromBytes + ZeroCopyType,

Parses the PDU payload from a reference to a mutable buffer.

impl<T, B> PDUWithData<T, B>

where T: BasicHeaderSegment, B: Deref<Target = [u8]>,

pub fn header_view(&self) -> Result<&T>

where T: FromBytes + ZeroCopyType,

Returns an immutable view of the PDU’s header.

pub fn header_view_mut(&mut self) -> Result<&mut T>

where T: FromBytes + ZeroCopyType,

Returns a mutable view of the PDU’s header.

pub fn additional_header(&self) -> Result<&[u8]>

where T: FromBytes + ZeroCopyType,

Returns a slice of the Additional Header Segment (AHS).

pub fn data(&self) -> Result<&[u8]>

where T: FromBytes + ZeroCopyType,

Returns a slice of the PDU’s data segment.

pub fn rebind_pdu<U>(self) -> Result<PDUWithData<U, B>>

where U: BasicHeaderSegment,

Rebinds the PDU to a different header type.

impl<T> PDUWithData<T, Bytes>

where T: BasicHeaderSegment + FromBytes + ZeroCopyType,

pub fn parse_with_buff(&mut self, buf: &Bytes) -> Result<()>

Parses the PDU payload from an immutable buffer, verifying digests.

Trait Implementations

impl<T> Builder for PDUWithData<T, BytesMut>

where T: BasicHeaderSegment + SendingData + FromBytes + ZeroCopyType,

fn append_data(&mut self, more: &[u8])

On the first call, if HeaderDigest is enabled, reserve exactly one 4-byte slot for it right before DATA; then append DATA and update DataSegmentLength.

fn build( &mut self, max_recv_data_segment_length: usize, ) -> Result<(Self::Header, Self::Body)>

Finalize and return the already-laid-out body as Bytes. Ensures HeaderDigest slot exists (even for zero DATA), appends pad(DATA) and DataDigest.

type Body = Bytes

type Header = [u8; 48]

The concrete buffer type used to return the encoded header.

impl<T, Body: Clone> Clone for PDUWithData<T, Body>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, B> Debug for PDUWithData<T, B>

where T: BasicHeaderSegment + SendingData + FromBytes + Debug + ZeroCopyType, B: Deref<Target = [u8]>,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: PartialEq, Body: PartialEq> PartialEq for PDUWithData<T, Body>

fn eq(&self, other: &PDUWithData<T, Body>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<'ctx> StateMachineCtx<LoginCtx<'ctx>, PDUWithData<LoginResponse>> for LoginCtx<'ctx>

async fn execute( &mut self, _cancel: &CancellationToken, ) -> Result<PduResponse<LoginResponse>>

Executes the state machine to completion.

impl<'ctx> StateMachineCtx<LogoutCtx<'ctx>, PDUWithData<LogoutResponse>> for LogoutCtx<'ctx>

async fn execute( &mut self, _cancel: &CancellationToken, ) -> Result<PduResponse<LogoutResponse>>

Executes the state machine to completion.

impl<'s> StateMachineCtx<NopCtx<'s>, PDUWithData<NopInResponse>> for NopCtx<'s>

async fn execute( &mut self, _cancel: &CancellationToken, ) -> Result<PduResponse<NopInResponse>>

Executes the state machine to completion.

impl<'ctx> StateMachineCtx<TurCtx<'ctx>, PDUWithData<ScsiCommandResponse>> for TurCtx<'ctx>

async fn execute( &mut self, _cancel: &CancellationToken, ) -> Result<PduResponse<ScsiCommandResponse>>

Executes the state machine to completion.

impl<T: PartialEq, Body: PartialEq> StructuralPartialEq for PDUWithData<T, Body>