transport

import "github.com/TheManticoreProject/Manticore/network/dcerpc/v4/transport"

const (
    // EndpointMapperPort is the well-known UDP port of the RPC endpoint mapper
    // ([MS-RPCE] 2.1.1.1, [C706] Appendix H).
    EndpointMapperPort = 135

    // ProtocolIdentifier is the ncadg_ip_udp protocol-tower floor identifier
    // ([MS-RPCE] 2.1.1.1, [C706] Appendix I).
    ProtocolIdentifier = 0x08

    // MaxPDUSizeDefault is the maximum connectionless PDU size, in bytes, that
    // Windows (other than NT 4.0) accepts over UDP ([MS-RPCE] Appendix B note <17>).
    // The protocol machine must fragment calls into PDUs no larger than this.
    MaxPDUSizeDefault = 4096

    // MaxPDUSizeLegacy is the maximum connectionless PDU size, in bytes, accepted by
    // Windows NT 4.0 over UDP ([MS-RPCE] Appendix B note <17>).
    MaxPDUSizeLegacy = 1024
)

type Transport interface {
    // Connect opens the underlying datagram endpoint. It is idempotent: calling
    // Connect on an already-connected transport is a no-op.
    Connect() error

    // Send transmits datagram as a single message and returns the number of bytes
    // written. A datagram larger than MaxPDUSize is rejected rather than truncated or
    // fragmented; fragmentation is the protocol machine's responsibility.
    Send(datagram []byte) (int, error)

    // Recv reads and returns the bytes of a single datagram. The returned slice is
    // owned by the caller.
    Recv() ([]byte, error)

    // SetDeadline sets the absolute read/write deadline on the underlying endpoint, as
    // net.Conn.SetDeadline does. The protocol machine uses it to drive retransmission
    // and call timers. A zero time clears the deadline.
    SetDeadline(t time.Time) error

    // MaxPDUSize is the largest datagram, in bytes, that Send will transmit and that
    // the protocol machine should produce when fragmenting.
    MaxPDUSize() int

    // RemoteAddr returns the address of the peer, or nil if not connected.
    RemoteAddr() net.Addr

    // IsConnected reports whether the transport currently has an open endpoint.
    IsConnected() bool

    // Close tears down the endpoint.
    Close() error
}