aoe.c File Reference

AoE protocol. More...

#include <stddef.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <assert.h>
#include <byteswap.h>
#include <ipxe/list.h>
#include <ipxe/if_ether.h>
#include <ipxe/iobuf.h>
#include <ipxe/netdevice.h>
#include <ipxe/features.h>
#include <ipxe/interface.h>
#include <ipxe/xfer.h>
#include <ipxe/uri.h>
#include <ipxe/open.h>
#include <ipxe/ata.h>
#include <ipxe/device.h>
#include <ipxe/efi/efi_path.h>
#include <ipxe/aoe.h>

Go to the source code of this file.

Data Structures
struct	aoe_command
	An AoE command. More...
struct	aoe_command_type
	An AoE command type. More...

Functions
	FILE_LICENCE (GPL2_OR_LATER_OR_UBDL)
	FILE_SECBOOT (PERMITTED)
	FEATURE (FEATURE_PROTOCOL, "AoE", DHCP_EB_FEATURE_AOE, 1)
static	LIST_HEAD (aoe_devices)
	List of all AoE devices. More...
static	LIST_HEAD (aoe_commands)
	List of active AoE commands. More...
static struct aoe_device *	aoedev_get (struct aoe_device *aoedev)
	Get reference to AoE device. More...
static void	aoedev_put (struct aoe_device *aoedev)
	Drop reference to AoE device. More...
static struct aoe_command *	aoecmd_get (struct aoe_command *aoecmd)
	Get reference to AoE command. More...
static void	aoecmd_put (struct aoe_command *aoecmd)
	Drop reference to AoE command. More...
static const char *	aoedev_name (struct aoe_device *aoedev)
	Name AoE device. More...
static void	aoecmd_free (struct refcnt *refcnt)
	Free AoE command. More...
static void	aoecmd_close (struct aoe_command *aoecmd, int rc)
	Close AoE command. More...
static int	aoecmd_tx (struct aoe_command *aoecmd)
	Transmit AoE command request. More...
static int	aoecmd_rx (struct aoe_command *aoecmd, struct io_buffer *iobuf, const void *ll_source)
	Receive AoE command response. More...
static void	aoecmd_expired (struct retry_timer *timer, int fail)
	Handle AoE retry timer expiry. More...
static size_t	aoecmd_ata_cmd_len (struct aoe_command *aoecmd)
	Calculate length of AoE ATA command IU. More...
static void	aoecmd_ata_cmd (struct aoe_command *aoecmd, void *data, size_t len)
	Build AoE ATA command IU. More...
static int	aoecmd_ata_rsp (struct aoe_command *aoecmd, const void *data, size_t len, const void *ll_source __unused)
	Handle AoE ATA response IU. More...
static size_t	aoecmd_cfg_cmd_len (struct aoe_command *aoecmd __unused)
	Calculate length of AoE configuration command IU. More...
static void	aoecmd_cfg_cmd (struct aoe_command *aoecmd, void *data, size_t len)
	Build AoE configuration command IU. More...
static int	aoecmd_cfg_rsp (struct aoe_command *aoecmd, const void *data, size_t len, const void *ll_source)
	Handle AoE configuration response IU. More...
static struct aoe_command *	aoecmd_find_tag (uint32_t tag)
	Identify AoE command by tag. More...
static int	aoecmd_new_tag (void)
	Choose an AoE command tag. More...
static struct aoe_command *	aoecmd_create (struct aoe_device *aoedev, struct aoe_command_type *type)
	Create AoE command. More...
static int	aoedev_ata_command (struct aoe_device *aoedev, struct interface *parent, struct ata_cmd *command)
	Issue AoE ATA command. More...
static int	aoedev_cfg_command (struct aoe_device *aoedev, struct interface *parent)
	Issue AoE configuration command. More...
static void	aoedev_free (struct refcnt *refcnt)
	Free AoE device. More...
static void	aoedev_close (struct aoe_device *aoedev, int rc)
	Close AoE device. More...
static size_t	aoedev_window (struct aoe_device *aoedev)
	Check AoE device flow-control window. More...
static void	aoedev_config_done (struct aoe_device *aoedev, int rc)
	Handle AoE device configuration completion. More...
static struct device *	aoedev_identify_device (struct aoe_device *aoedev)
	Identify device underlying AoE device. More...
static struct acpi_descriptor *	aoedev_describe (struct aoe_device *aoedev)
	Get AoE ACPI descriptor. More...
static int	aoedev_open (struct interface *parent, struct net_device *netdev, unsigned int major, unsigned int minor)
	Open AoE device. More...
static int	aoe_rx (struct io_buffer *iobuf, struct net_device *netdev __unused, const void *ll_dest __unused, const void *ll_source, unsigned int flags __unused)
	Process incoming AoE packets. More...
static int	aoe_parse_uri (struct uri *uri, unsigned int *major, unsigned int *minor)
	Parse AoE URI. More...
static int	aoe_open (struct interface *parent, struct uri *uri)
	Open AoE URI. More...
static int	abft_complete (struct acpi_descriptor *desc __unused)
	Check if AoE boot firmware table descriptor is complete. More...
static int	abft_install (int(*install)(struct acpi_header *acpi))
	Install AoE boot firmware table(s) More...

Variables
struct net_protocol aoe_protocol	__net_protocol
	AoE protocol. More...
struct acpi_model abft_model	__acpi_model
	aBFT model More...
static struct aoe_command_type	aoecmd_ata
	AoE ATA command. More...
static struct aoe_command_type	aoecmd_cfg
	AoE configuration command. More...
static struct interface_operation	aoecmd_ata_op []
	AoE command ATA interface operations. More...
static struct interface_descriptor	aoecmd_ata_desc
	AoE command ATA interface descriptor. More...
static struct interface_operation	aoedev_ata_op []
	AoE device ATA interface operations. More...
static struct interface_descriptor	aoedev_ata_desc
	AoE device ATA interface descriptor. More...
static struct interface_operation	aoedev_config_op []
	AoE device configuration interface operations. More...
static struct interface_descriptor	aoedev_config_desc
	AoE device configuration interface descriptor. More...
struct uri_opener aoe_uri_opener	__uri_opener
	AoE URI opener. More...

Detailed Description

AoE protocol.

Definition in file aoe.c.

Function Documentation

FILE_LICENCE()

FILE_LICENCE

(

GPL2_OR_LATER_OR_UBDL

)

FILE_SECBOOT()

FILE_SECBOOT

(

PERMITTED

)

FEATURE()

FEATURE	(	FEATURE_PROTOCOL	,
		"AoE"	,
		DHCP_EB_FEATURE_AOE	,
		1
	)

LIST_HEAD() [1/2]

static LIST_HEAD ( aoe_devices  )

static

List of all AoE devices.

LIST_HEAD() [2/2]

static LIST_HEAD ( aoe_commands  )

static

List of active AoE commands.

aoedev_get()

static struct aoe_device* aoedev_get ( struct aoe_device *  aoedev )

inlinestatic

Get reference to AoE device.

Parameters

aoedev

AoE device

Return values

aoedev

AoE device

Definition at line 132 of file aoe.c.

                                         {
        ref_get ( &aoedev->refcnt );
        return aoedev;
}

References ref_get, and aoe_device::refcnt.

Referenced by aoecmd_create().

aoedev_put()

static void aoedev_put ( struct aoe_device *  aoedev )

inlinestatic

Drop reference to AoE device.

Parameters

aoedev

AoE device

Definition at line 143 of file aoe.c.

                                         {
        ref_put ( &aoedev->refcnt );
}

References ref_put, and aoe_device::refcnt.

Referenced by aoecmd_free().

aoecmd_get()

static struct aoe_command* aoecmd_get ( struct aoe_command *  aoecmd )

inlinestatic

Get reference to AoE command.

Parameters

aoecmd

AoE command

Return values

aoecmd

AoE command

Definition at line 154 of file aoe.c.

                                          {
        ref_get ( &aoecmd->refcnt );
        return aoecmd;
}

References ref_get.

Referenced by aoe_rx(), and aoedev_close().

aoecmd_put()

static void aoecmd_put ( struct aoe_command *  aoecmd )

inlinestatic

Drop reference to AoE command.

Parameters

aoecmd

AoE command

Definition at line 165 of file aoe.c.

                                          {
        ref_put ( &aoecmd->refcnt );
}

References ref_put.

Referenced by aoe_rx(), aoecmd_close(), and aoedev_close().

aoedev_name()

static const char* aoedev_name ( struct aoe_device *  aoedev )

static

Name AoE device.

Parameters

aoedev

AoE device

Return values

name	AoE device name

Definition at line 175 of file aoe.c.

                                                              {
        static char buf[16];

        snprintf ( buf, sizeof ( buf ), "%s/e%d.%d", aoedev->netdev->name,
                   aoedev->major, aoedev->minor );
        return buf;
}

References aoe_command::aoedev, aoe_device::major, aoe_device::minor, net_device::name, aoe_device::netdev, and snprintf().

Referenced by abft_install(), aoecmd_ata_cmd(), aoecmd_ata_rsp(), aoecmd_cfg_cmd(), aoecmd_cfg_rsp(), aoecmd_rx(), aoecmd_tx(), aoedev_ata_command(), and aoedev_open().

aoecmd_free()

static void aoecmd_free ( struct refcnt *  refcnt )

static

Free AoE command.

Parameters

refcnt

Reference counter

Definition at line 188 of file aoe.c.

                                                  {
        struct aoe_command *aoecmd =
                container_of ( refcnt, struct aoe_command, refcnt );

        assert ( ! timer_running ( &aoecmd->timer ) );
        assert ( list_empty ( &aoecmd->list ) );

        aoedev_put ( aoecmd->aoedev );
        free ( aoecmd );
}

References aoedev_put(), assert(), container_of, free, and list_empty.

Referenced by aoecmd_create().

aoecmd_close()

static void aoecmd_close ( struct aoe_command *  aoecmd, int  rc  )

static

Close AoE command.

Parameters

aoecmd	AoE command
rc	Reason for close

Definition at line 205 of file aoe.c.

                                                                {
        struct aoe_device *aoedev = aoecmd->aoedev;

        /* Stop timer */
        stop_timer ( &aoecmd->timer );

        /* Preserve the timeout value for subsequent commands */
        aoedev->timeout = aoecmd->timer.timeout;

        /* Remove from list of commands */
        if ( ! list_empty ( &aoecmd->list ) ) {
                list_del ( &aoecmd->list );
                INIT_LIST_HEAD ( &aoecmd->list );
                aoecmd_put ( aoecmd );
        }

        /* Shut down interfaces */
        intf_shutdown ( &aoecmd->ata, rc );
}

References aoecmd_put(), aoecmd::ata, INIT_LIST_HEAD, intf_shutdown(), list_del, list_empty, rc, stop_timer(), and aoe_device::timeout.

Referenced by aoecmd_expired(), aoecmd_rx(), and aoedev_close().

aoecmd_tx()

static int aoecmd_tx ( struct aoe_command *  aoecmd )

static

Transmit AoE command request.

Parameters

aoecmd

AoE command

Return values

rc	Return status code

Definition at line 231 of file aoe.c.

                                                    {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct net_device *netdev = aoedev->netdev;
        struct io_buffer *iobuf;
        struct aoehdr *aoehdr;
        size_t cmd_len;
        int rc;

        /* Sanity check */
        assert ( netdev != NULL );

        /* If we are transmitting anything that requires a response,
         * start the retransmission timer.  Do this before attempting
         * to allocate the I/O buffer, in case allocation itself
         * fails.
         */
        start_timer ( &aoecmd->timer );

        /* Create outgoing I/O buffer */
        cmd_len = aoecmd->type->cmd_len ( aoecmd );
        iobuf = alloc_iob ( MAX_LL_HEADER_LEN + cmd_len );
        if ( ! iobuf )
                return -ENOMEM;
        iob_reserve ( iobuf, MAX_LL_HEADER_LEN );
        aoehdr = iob_put ( iobuf, cmd_len );

        /* Fill AoE header */
        memset ( aoehdr, 0, sizeof ( *aoehdr ) );
        aoehdr->ver_flags = AOE_VERSION;
        aoehdr->major = htons ( aoedev->major );
        aoehdr->minor = aoedev->minor;
        aoehdr->tag = htonl ( aoecmd->tag );
        aoecmd->type->cmd ( aoecmd, iobuf->data, iob_len ( iobuf ) );

        /* Send packet */
        if ( ( rc = net_tx ( iobuf, netdev, &aoe_protocol, aoedev->target,
                             netdev->ll_addr ) ) != 0 ) {
                DBGC ( aoedev, "AoE %s/%08x could not transmit: %s\n",
                       aoedev_name ( aoedev ), aoecmd->tag,
                       strerror ( rc ) );
                return rc;
        }

        return 0;
}

References alloc_iob(), AOE_VERSION, aoedev_name(), assert(), io_buffer::data, DBGC, ENOMEM, htonl, htons, iob_len(), iob_put, iob_reserve, net_device::ll_addr, aoehdr::major, aoe_device::major, MAX_LL_HEADER_LEN, memset(), aoehdr::minor, aoe_device::minor, net_tx(), netdev, aoe_device::netdev, NULL, rc, start_timer(), strerror(), aoehdr::tag, aoe_device::target, and aoehdr::ver_flags.

Referenced by aoecmd_expired(), aoedev_ata_command(), and aoedev_cfg_command().

aoecmd_rx()

static int aoecmd_rx ( struct aoe_command *  aoecmd, struct io_buffer *  iobuf, const void *  ll_source  )

static

Receive AoE command response.

Parameters

aoecmd	AoE command
iobuf	I/O buffer
ll_source	Link-layer source address

Return values

rc	Return status code

Definition at line 285 of file aoe.c.

                                               {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct aoehdr *aoehdr = iobuf->data;
        int rc;

        /* Sanity check */
        if ( iob_len ( iobuf ) < sizeof ( *aoehdr ) ) {
                DBGC ( aoedev, "AoE %s/%08x received underlength response "
                       "(%zd bytes)\n", aoedev_name ( aoedev ),
                       aoecmd->tag, iob_len ( iobuf ) );
                rc = -EINVAL;
                goto done;
        }
        if ( ( ntohs ( aoehdr->major ) != aoedev->major ) ||
             ( aoehdr->minor != aoedev->minor ) ) {
                DBGC ( aoedev, "AoE %s/%08x received response for incorrect "
                       "device e%d.%d\n", aoedev_name ( aoedev ), aoecmd->tag,
                       ntohs ( aoehdr->major ), aoehdr->minor );
                rc = -EINVAL;
                goto done;
        }

        /* Catch command failures */
        if ( aoehdr->ver_flags & AOE_FL_ERROR ) {
                DBGC ( aoedev, "AoE %s/%08x terminated in error\n",
                       aoedev_name ( aoedev ), aoecmd->tag );
                aoecmd_close ( aoecmd, -EIO );
                rc = -EIO;
                goto done;
        }

        /* Hand off to command completion handler */
        if ( ( rc = aoecmd->type->rsp ( aoecmd, iobuf->data, iob_len ( iobuf ),
                                        ll_source ) ) != 0 )
                goto done;

 done:
        /* Free I/O buffer */
        free_iob ( iobuf );

        /* Terminate command */
        aoecmd_close ( aoecmd, rc );

        return rc;
}

References AOE_FL_ERROR, aoecmd_close(), aoedev_name(), io_buffer::data, DBGC, done, EINVAL, EIO, free_iob(), iob_len(), aoehdr::major, aoe_device::major, aoehdr::minor, aoe_device::minor, ntohs, rc, and aoehdr::ver_flags.

Referenced by aoe_rx().

aoecmd_expired()

static void aoecmd_expired ( struct retry_timer *  timer, int  fail  )

static

Handle AoE retry timer expiry.

Parameters

timer	AoE retry timer
fail	Failure indicator

Definition at line 338 of file aoe.c.

                                                                   {
        struct aoe_command *aoecmd =
                container_of ( timer, struct aoe_command, timer );

        if ( fail ) {
                aoecmd_close ( aoecmd, -ETIMEDOUT );
        } else {
                aoecmd_tx ( aoecmd );
        }
}

References aoecmd_close(), aoecmd_tx(), container_of, and ETIMEDOUT.

Referenced by aoecmd_create().

aoecmd_ata_cmd_len()

static size_t aoecmd_ata_cmd_len ( struct aoe_command *  aoecmd )

static

Calculate length of AoE ATA command IU.

Parameters

aoecmd

AoE command

Return values

len	Length of command IU

Definition at line 355 of file aoe.c.

                                                                {
        struct ata_cmd *command = &aoecmd->command;

        return ( sizeof ( struct aoehdr ) + sizeof ( struct aoeata ) +
                 command->data_out_len );
}

aoecmd_ata_cmd()

static void aoecmd_ata_cmd ( struct aoe_command *  aoecmd, void *  data, size_t  len  )

static

Build AoE ATA command IU.

Parameters

aoecmd	AoE command
data	Command IU
len	Length of command IU

Definition at line 369 of file aoe.c.

                                                      {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct ata_cmd *command = &aoecmd->command;
        struct aoehdr *aoehdr = data;
        struct aoeata *aoeata = &aoehdr->payload[0].ata;

        /* Sanity check */
        static_assert ( AOE_FL_DEV_HEAD == ATA_DEV_SLAVE );
        assert ( len == ( sizeof ( *aoehdr ) + sizeof ( *aoeata ) +
                          command->data_out_len ) );

        /* Build IU */
        aoehdr->command = AOE_CMD_ATA;
        memset ( aoeata, 0, sizeof ( *aoeata ) );
        aoeata->aflags = ( ( command->cb.lba48 ? AOE_FL_EXTENDED : 0 ) |
                           ( command->cb.device & ATA_DEV_SLAVE ) |
                           ( command->data_out_len ? AOE_FL_WRITE : 0 ) );
        aoeata->err_feat = command->cb.err_feat.bytes.cur;
        aoeata->count = command->cb.count.native;
        aoeata->cmd_stat = command->cb.cmd_stat;
        aoeata->lba.u64 = cpu_to_le64 ( command->cb.lba.native );
        if ( ! command->cb.lba48 )
                aoeata->lba.bytes[3] |=
                        ( command->cb.device & ATA_DEV_MASK );
        memcpy ( aoeata->data, command->data_out, command->data_out_len );

        DBGC2 ( aoedev, "AoE %s/%08x ATA cmd %02x:%02x:%02x:%02x:%08llx",
                aoedev_name ( aoedev ), aoecmd->tag, aoeata->aflags,
                aoeata->err_feat, aoeata->count, aoeata->cmd_stat,
                aoeata->lba.u64 );
        if ( command->data_out_len )
                DBGC2 ( aoedev, " out %04zx", command->data_out_len );
        if ( command->data_in_len )
                DBGC2 ( aoedev, " in %04zx", command->data_in_len );
        DBGC2 ( aoedev, "\n" );
}

References aoeata::aflags, AOE_CMD_ATA, AOE_FL_DEV_HEAD, AOE_FL_EXTENDED, AOE_FL_WRITE, aoedev_name(), assert(), aoecmd::ata, ATA_DEV_MASK, ATA_DEV_SLAVE, aoeata::bytes, aoeata::cmd_stat, aoehdr::command, aoeata::count, cpu_to_le64, data, aoeata::data, DBGC2, aoeata::err_feat, aoeata::lba, len, memcpy(), memset(), aoehdr::payload, static_assert, and aoeata::u64.

aoecmd_ata_rsp()

static int aoecmd_ata_rsp ( struct aoe_command *  aoecmd, const void *  data, size_t  len, const void *ll_source  __unused  )

static

Handle AoE ATA response IU.

Parameters

aoecmd	AoE command
data	Response IU
len	Length of response IU
ll_source	Link-layer source address

Return values

rc	Return status code

Definition at line 416 of file aoe.c.

                                                                         {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct ata_cmd *command = &aoecmd->command;
        const struct aoehdr *aoehdr = data;
        const struct aoeata *aoeata = &aoehdr->payload[0].ata;
        size_t data_len;

        /* Sanity check */
        if ( len < ( sizeof ( *aoehdr ) + sizeof ( *aoeata ) ) ) {
                DBGC ( aoedev, "AoE %s/%08x received underlength ATA response "
                       "(%zd bytes)\n", aoedev_name ( aoedev ),
                       aoecmd->tag, len );
                return -EINVAL;
        }
        data_len = ( len - ( sizeof ( *aoehdr ) + sizeof ( *aoeata ) ) );
        DBGC2 ( aoedev, "AoE %s/%08x ATA rsp %02x in %04zx\n",
                aoedev_name ( aoedev ), aoecmd->tag, aoeata->cmd_stat,
                data_len );

        /* Check for command failure */
        if ( aoeata->cmd_stat & ATA_STAT_ERR ) {
                DBGC ( aoedev, "AoE %s/%08x status %02x\n",
                       aoedev_name ( aoedev ), aoecmd->tag, aoeata->cmd_stat );
                return -EIO;
        }

        /* Check data-in length is sufficient.  (There may be trailing
         * garbage due to Ethernet minimum-frame-size padding.)
         */
        if ( data_len < command->data_in_len ) {
                DBGC ( aoedev, "AoE %s/%08x data-in underrun (received %zd, "
                       "expected %zd)\n", aoedev_name ( aoedev ), aoecmd->tag,
                       data_len, command->data_in_len );
                return -ERANGE;
        }

        /* Copy out data payload */
        memcpy ( command->data_in, aoeata->data, command->data_in_len );

        return 0;
}

References aoedev_name(), aoecmd::ata, ATA_STAT_ERR, aoeata::cmd_stat, data, aoeata::data, data_len, DBGC, DBGC2, EINVAL, EIO, ERANGE, len, memcpy(), and aoehdr::payload.

aoecmd_cfg_cmd_len()

static size_t aoecmd_cfg_cmd_len ( struct aoe_command *aoecmd  __unused )

static

Calculate length of AoE configuration command IU.

Parameters

aoecmd

AoE command

Return values

len	Length of command IU

Definition at line 472 of file aoe.c.

                                                                         {
        return ( sizeof ( struct aoehdr ) + sizeof ( struct aoecfg ) );
}

aoecmd_cfg_cmd()

static void aoecmd_cfg_cmd ( struct aoe_command *  aoecmd, void *  data, size_t  len  )

static

Build AoE configuration command IU.

Parameters

aoecmd	AoE command
data	Command IU
len	Length of command IU

Definition at line 483 of file aoe.c.

                                                      {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct aoehdr *aoehdr = data;
        struct aoecfg *aoecfg = &aoehdr->payload[0].cfg;

        /* Sanity check */
        assert ( len == ( sizeof ( *aoehdr ) + sizeof ( *aoecfg ) ) );

        /* Build IU */
        aoehdr->command = AOE_CMD_CONFIG;
        memset ( aoecfg, 0, sizeof ( *aoecfg ) );

        DBGC ( aoedev, "AoE %s/%08x CONFIG cmd\n",
               aoedev_name ( aoedev ), aoecmd->tag );
}

References AOE_CMD_CONFIG, aoedev_name(), assert(), aoecmd::cfg, aoehdr::command, data, DBGC, len, memset(), and aoehdr::payload.

aoecmd_cfg_rsp()

static int aoecmd_cfg_rsp ( struct aoe_command *  aoecmd, const void *  data, size_t  len, const void *  ll_source  )

static

Handle AoE configuration response IU.

Parameters

aoecmd	AoE command
data	Response IU
len	Length of response IU
ll_source	Link-layer source address

Return values

rc	Return status code

Definition at line 509 of file aoe.c.

                                                                {
        struct aoe_device *aoedev = aoecmd->aoedev;
        struct ll_protocol *ll_protocol = aoedev->netdev->ll_protocol;
        const struct aoehdr *aoehdr = data;
        const struct aoecfg *aoecfg = &aoehdr->payload[0].cfg;

        /* Sanity check */
        if ( len < ( sizeof ( *aoehdr ) + sizeof ( *aoecfg ) ) ) {
                DBGC ( aoedev, "AoE %s/%08x received underlength "
                       "configuration response (%zd bytes)\n",
                       aoedev_name ( aoedev ), aoecmd->tag, len );
                return -EINVAL;
        }
        DBGC ( aoedev, "AoE %s/%08x CONFIG rsp buf %04x fw %04x scnt %02x\n",
               aoedev_name ( aoedev ), aoecmd->tag, ntohs ( aoecfg->bufcnt ),
               aoecfg->fwver, aoecfg->scnt );

        /* Record target MAC address */
        memcpy ( aoedev->target, ll_source, ll_protocol->ll_addr_len );
        DBGC ( aoedev, "AoE %s has MAC address %s\n",
               aoedev_name ( aoedev ), ll_protocol->ntoa ( aoedev->target ) );

        return 0;
}

References aoedev_name(), aoecfg::bufcnt, aoecmd::cfg, data, DBGC, EINVAL, aoecfg::fwver, len, ll_protocol::ll_addr_len, net_device::ll_protocol, memcpy(), aoe_device::netdev, ll_protocol::ntoa, ntohs, aoehdr::payload, aoecfg::scnt, and aoe_device::target.

aoecmd_find_tag()

static struct aoe_command* aoecmd_find_tag ( uint32_t  tag )

static

Identify AoE command by tag.

Parameters

tag	Command tag

Return values

aoecmd

AoE command, or NULL

Definition at line 557 of file aoe.c.

                                                             {
        struct aoe_command *aoecmd;

        list_for_each_entry ( aoecmd, &aoe_commands, list ) {
                if ( aoecmd->tag == tag )
                        return aoecmd;
        }
        return NULL;
}

References aoe_command::list, list_for_each_entry, NULL, and tag.

Referenced by aoe_rx(), and aoecmd_new_tag().

aoecmd_new_tag()

static int aoecmd_new_tag ( void  )

static

Choose an AoE command tag.

Return values

tag	New tag, or negative error

Definition at line 572 of file aoe.c.

                                   {
        static uint16_t tag_idx;
        unsigned int i;

        for ( i = 0 ; i < 65536 ; i++ ) {
                tag_idx++;
                if ( aoecmd_find_tag ( tag_idx ) == NULL )
                        return ( AOE_TAG_MAGIC | tag_idx );
        }
        return -EADDRINUSE;
}

References AOE_TAG_MAGIC, aoecmd_find_tag(), EADDRINUSE, and NULL.

Referenced by aoecmd_create().

aoecmd_create()

static struct aoe_command* aoecmd_create ( struct aoe_device *  aoedev, struct aoe_command_type *  type  )

static

Create AoE command.

Parameters

aoedev	AoE device
type	AoE command type

Return values

aoecmd

AoE command

Definition at line 591 of file aoe.c.

                                                                            {
        struct aoe_command *aoecmd;
        int tag;

        /* Allocate command tag */
        tag = aoecmd_new_tag();
        if ( tag < 0 )
                return NULL;

        /* Allocate and initialise structure */
        aoecmd = zalloc ( sizeof ( *aoecmd ) );
        if ( ! aoecmd )
                return NULL;
        ref_init ( &aoecmd->refcnt, aoecmd_free );
        list_add ( &aoecmd->list, &aoe_commands );
        intf_init ( &aoecmd->ata, &aoecmd_ata_desc, &aoecmd->refcnt );
        timer_init ( &aoecmd->timer, aoecmd_expired, &aoecmd->refcnt );
        aoecmd->aoedev = aoedev_get ( aoedev );
        aoecmd->type = type;
        aoecmd->tag = tag;

        /* Preserve timeout from last completed command */
        aoecmd->timer.timeout = aoedev->timeout;

        /* Return already mortalised.  (Reference is held by command list.) */
        return aoecmd;
}

References aoecmd_ata_desc, aoecmd_expired(), aoecmd_free(), aoecmd_new_tag(), aoe_command::aoedev, aoedev_get(), aoecmd::ata, intf_init(), list_add, NULL, ref_init, tag, aoe_device::timeout, type, and zalloc().

Referenced by aoedev_ata_command(), and aoedev_cfg_command().

aoedev_ata_command()

static int aoedev_ata_command ( struct aoe_device *  aoedev, struct interface *  parent, struct ata_cmd *  command  )

static

Issue AoE ATA command.

Parameters

aoedev	AoE device
parent	Parent interface
command	ATA command

Return values

tag	Command tag, or negative error

Definition at line 628 of file aoe.c.

                                                          {
        struct net_device *netdev = aoedev->netdev;
        struct aoe_command *aoecmd;

        /* Fail immediately if net device is closed */
        if ( ! netdev_is_open ( netdev ) ) {
                DBGC ( aoedev, "AoE %s cannot issue command while net device "
                       "is closed\n", aoedev_name ( aoedev ) );
                return -EWOULDBLOCK;
        }

        /* Create command */
        aoecmd = aoecmd_create ( aoedev, &aoecmd_ata );
        if ( ! aoecmd )
                return -ENOMEM;
        memcpy ( &aoecmd->command, command, sizeof ( aoecmd->command ) );

        /* Attempt to send command.  Allow failures to be handled by
         * the retry timer.
         */
        aoecmd_tx ( aoecmd );

        /* Attach to parent interface, leave reference with command
         * list, and return.
         */
        intf_plug_plug ( &aoecmd->ata, parent );
        return aoecmd->tag;
}

References aoecmd_ata, aoecmd_create(), aoecmd_tx(), aoe_command::aoedev, aoedev_name(), aoecmd::ata, DBGC, ENOMEM, EWOULDBLOCK, intf_plug_plug(), memcpy(), netdev, aoe_device::netdev, and netdev_is_open().

aoedev_cfg_command()

static int aoedev_cfg_command ( struct aoe_device *  aoedev, struct interface *  parent  )

static

Issue AoE configuration command.

Parameters

aoedev	AoE device
parent	Parent interface

Return values

tag	Command tag, or negative error

Definition at line 666 of file aoe.c.

                                                           {
        struct aoe_command *aoecmd;

        /* Create command */
        aoecmd = aoecmd_create ( aoedev, &aoecmd_cfg );
        if ( ! aoecmd )
                return -ENOMEM;

        /* Attempt to send command.  Allow failures to be handled by
         * the retry timer.
         */
        aoecmd_tx ( aoecmd );

        /* Attach to parent interface, leave reference with command
         * list, and return.
         */
        intf_plug_plug ( &aoecmd->ata, parent );
        return aoecmd->tag;
}

References aoecmd_cfg, aoecmd_create(), aoecmd_tx(), aoe_command::aoedev, aoecmd::ata, ENOMEM, and intf_plug_plug().

Referenced by aoedev_open().

aoedev_free()

static void aoedev_free ( struct refcnt *  refcnt )

static

Free AoE device.

Parameters

refcnt

Reference count

Definition at line 692 of file aoe.c.

                                                  {
        struct aoe_device *aoedev =
                container_of ( refcnt, struct aoe_device, refcnt );

        netdev_put ( aoedev->netdev );
        free ( aoedev );
}

References container_of, free, aoe_device::netdev, and netdev_put().

Referenced by aoedev_open().

aoedev_close()

static void aoedev_close ( struct aoe_device *  aoedev, int  rc  )

static

Close AoE device.

Parameters

aoedev	AoE device
rc	Reason for close

Definition at line 706 of file aoe.c.

                                                               {
        struct aoe_command *aoecmd;
        struct aoe_command *tmp;

        /* Shut down interfaces */
        intf_shutdown ( &aoedev->ata, rc );
        intf_shutdown ( &aoedev->config, rc );

        /* Shut down any active commands */
        list_for_each_entry_safe ( aoecmd, tmp, &aoe_commands, list ) {
                if ( aoecmd->aoedev != aoedev )
                        continue;
                aoecmd_get ( aoecmd );
                aoecmd_close ( aoecmd, rc );
                aoecmd_put ( aoecmd );
        }
}

References aoecmd_close(), aoecmd_get(), aoecmd_put(), aoe_command::aoedev, aoe_device::ata, aoe_device::config, intf_shutdown(), aoe_command::list, list_for_each_entry_safe, rc, and tmp.

Referenced by aoedev_config_done(), and aoedev_open().

aoedev_window()

static size_t aoedev_window ( struct aoe_device *  aoedev )

static

Check AoE device flow-control window.

Parameters

aoedev

AoE device

Return values

len	Length of window

Definition at line 730 of file aoe.c.

                                                          {
        return ( aoedev->configured ? ~( ( size_t ) 0 ) : 0 );
}

References aoe_command::aoedev, and aoe_device::configured.

aoedev_config_done()

static void aoedev_config_done ( struct aoe_device *  aoedev, int  rc  )

static

Handle AoE device configuration completion.

Parameters

aoedev	AoE device
rc	Reason for completion

Definition at line 740 of file aoe.c.

                                                                     {

        /* Shut down interface */
        intf_shutdown ( &aoedev->config, rc );

        /* Close device on failure */
        if ( rc != 0 ) {
                aoedev_close ( aoedev, rc );
                return;
        }

        /* Mark device as configured */
        aoedev->configured = 1;
        xfer_window_changed ( &aoedev->ata );
}

References aoe_command::aoedev, aoedev_close(), aoe_device::ata, aoe_device::config, aoe_device::configured, intf_shutdown(), rc, and xfer_window_changed().

aoedev_identify_device()

static struct device* aoedev_identify_device ( struct aoe_device *  aoedev )

static

Identify device underlying AoE device.

Parameters

aoedev

AoE device

Return values

device

Underlying device

Definition at line 762 of file aoe.c.

                                                                            {
        return aoedev->netdev->dev;
}

References net_device::dev, and aoe_device::netdev.

aoedev_describe()

static struct acpi_descriptor* aoedev_describe ( struct aoe_device *  aoedev )

static

Get AoE ACPI descriptor.

Parameters

aoedev

AoE device

Return values

desc	ACPI descriptor

Definition at line 772 of file aoe.c.

                                                                              {
        return &aoedev->desc;
}

References aoe_device::desc.

aoedev_open()

static int aoedev_open ( struct interface *  parent, struct net_device *  netdev, unsigned int  major, unsigned int  minor  )

static

Open AoE device.

Parameters

parent	Parent interface
netdev	Network device
major	Device major number
minor	Device minor number

Return values

rc	Return status code

Definition at line 809 of file aoe.c.

                                                                  {
        struct aoe_device *aoedev;
        int rc;

        /* Allocate and initialise structure */
        aoedev = zalloc ( sizeof ( *aoedev ) );
        if ( ! aoedev ) {
                rc = -ENOMEM;
                goto err_zalloc;
        }
        ref_init ( &aoedev->refcnt, aoedev_free );
        intf_init ( &aoedev->ata, &aoedev_ata_desc, &aoedev->refcnt );
        intf_init ( &aoedev->config, &aoedev_config_desc, &aoedev->refcnt );
        aoedev->netdev = netdev_get ( netdev );
        aoedev->major = major;
        aoedev->minor = minor;
        memcpy ( aoedev->target, netdev->ll_broadcast,
                 netdev->ll_protocol->ll_addr_len );
        acpi_init ( &aoedev->desc, &abft_model, &aoedev->refcnt );

        /* Initiate configuration */
        if ( ( rc = aoedev_cfg_command ( aoedev, &aoedev->config ) ) < 0 ) {
                DBGC ( aoedev, "AoE %s could not initiate configuration: %s\n",
                       aoedev_name ( aoedev ), strerror ( rc ) );
                goto err_config;
        }

        /* Attach ATA device to parent interface */
        if ( ( rc = ata_open ( parent, &aoedev->ata, ATA_DEV_MASTER,
                               AOE_MAX_COUNT ) ) != 0 ) {
                DBGC ( aoedev, "AoE %s could not create ATA device: %s\n",
                       aoedev_name ( aoedev ), strerror ( rc ) );
                goto err_ata_open;
        }

        /* Mortalise self and return */
        ref_put ( &aoedev->refcnt );
        return 0;

 err_ata_open:
 err_config:
        aoedev_close ( aoedev, rc );
        ref_put ( &aoedev->refcnt );
 err_zalloc:
        return rc;
}

References acpi_init(), AOE_MAX_COUNT, aoedev_ata_desc, aoedev_cfg_command(), aoedev_close(), aoedev_config_desc, aoedev_free(), aoedev_name(), aoe_device::ata, ATA_DEV_MASTER, ata_open(), aoe_device::config, DBGC, aoe_device::desc, ENOMEM, intf_init(), ll_protocol::ll_addr_len, net_device::ll_broadcast, net_device::ll_protocol, major, aoe_device::major, memcpy(), minor, aoe_device::minor, netdev, aoe_device::netdev, netdev_get(), rc, ref_init, ref_put, aoe_device::refcnt, strerror(), aoe_device::target, and zalloc().

Referenced by aoe_open().

aoe_rx()

static int aoe_rx ( struct io_buffer *  iobuf, struct net_device *netdev  __unused, const void *ll_dest  __unused, const void *  ll_source, unsigned int flags  __unused  )

static

Process incoming AoE packets.

Parameters

iobuf	I/O buffer
netdev	Network device
ll_dest	Link-layer destination address
ll_source	Link-layer source address
flags	Packet flags

Return values

rc	Return status code

Definition at line 874 of file aoe.c.

                                                  {
        struct aoehdr *aoehdr = iobuf->data;
        struct aoe_command *aoecmd;
        int rc;

        /* Sanity check */
        if ( iob_len ( iobuf ) < sizeof ( *aoehdr ) ) {
                DBG ( "AoE received underlength packet (%zd bytes)\n",
                      iob_len ( iobuf ) );
                rc = -EINVAL;
                goto err_sanity;
        }
        if ( ( aoehdr->ver_flags & AOE_VERSION_MASK ) != AOE_VERSION ) {
                DBG ( "AoE received packet for unsupported protocol version "
                      "%02x\n", ( aoehdr->ver_flags & AOE_VERSION_MASK ) );
                rc = -EPROTONOSUPPORT;
                goto err_sanity;
        }
        if ( ! ( aoehdr->ver_flags & AOE_FL_RESPONSE ) ) {
                DBG ( "AoE received request packet\n" );
                rc = -EOPNOTSUPP;
                goto err_sanity;
        }

        /* Demultiplex amongst active AoE commands */
        aoecmd = aoecmd_find_tag ( ntohl ( aoehdr->tag ) );
        if ( ! aoecmd ) {
                DBG ( "AoE received packet for unused tag %08x\n",
                      ntohl ( aoehdr->tag ) );
                rc = -ENOENT;
                goto err_demux;
        }

        /* Pass received frame to command */
        aoecmd_get ( aoecmd );
        if ( ( rc = aoecmd_rx ( aoecmd, iob_disown ( iobuf ),
                                ll_source ) ) != 0 )
                goto err_rx;

 err_rx:
        aoecmd_put ( aoecmd );
 err_demux:
 err_sanity:
        free_iob ( iobuf );
        return rc;
}

References AOE_FL_RESPONSE, AOE_VERSION, AOE_VERSION_MASK, aoecmd_find_tag(), aoecmd_get(), aoecmd_put(), aoecmd_rx(), io_buffer::data, DBG, EINVAL, ENOENT, EOPNOTSUPP, EPROTONOSUPPORT, free_iob(), iob_disown, iob_len(), ntohl, rc, aoehdr::tag, and aoehdr::ver_flags.

aoe_parse_uri()

static int aoe_parse_uri ( struct uri *  uri, unsigned int *  major, unsigned int *  minor  )

static

Parse AoE URI.

Parameters

uri

URI

Return values

major	Major device number
minor	Minor device number
rc	Return status code

An AoE URI has the form "aoe:e<major>.<minor>".

Definition at line 949 of file aoe.c.

                                                 {
        const char *ptr;
        char *end;

        /* Check for URI with opaque portion */
        if ( ! uri->opaque )
                return -EINVAL;
        ptr = uri->opaque;

        /* Check for initial 'e' */
        if ( *ptr != 'e' )
                return -EINVAL;
        ptr++;

        /* Parse major device number */
        *major = strtoul ( ptr, &end, 10 );
        if ( *end != '.' )
                return -EINVAL;
        ptr = ( end + 1 );

        /* Parse minor device number */
        *minor = strtoul ( ptr, &end, 10 );
        if ( *end )
                return -EINVAL;

        return 0;
}

References EINVAL, end, major, minor, uri::opaque, and strtoul().

Referenced by aoe_open().

aoe_open()

static int aoe_open ( struct interface *  parent, struct uri *  uri  )

static

Open AoE URI.

Parameters

parent	Parent interface
uri	URI

Return values

rc	Return status code

Definition at line 985 of file aoe.c.

                                                                  {
        struct net_device *netdev;
        unsigned int major;
        unsigned int minor;
        int rc;

        /* Identify network device.  This is something of a hack, but
         * the AoE URI scheme that has been in use for some time now
         * provides no way to specify a particular device.
         */
        netdev = last_opened_netdev();
        if ( ! netdev ) {
                DBG ( "AoE cannot identify network device\n" );
                return -ENODEV;
        }

        /* Parse URI */
        if ( ( rc = aoe_parse_uri ( uri, &major, &minor ) ) != 0 ) {
                DBG ( "AoE cannot parse URI\n" );
                return rc;
        }

        /* Open AoE device */
        if ( ( rc = aoedev_open ( parent, netdev, major, minor ) ) != 0 )
                return rc;

        return 0;
}

References aoe_parse_uri(), aoedev_open(), DBG, ENODEV, last_opened_netdev(), major, minor, netdev, and rc.

abft_complete()

static int abft_complete ( struct acpi_descriptor *desc  __unused )

static

Check if AoE boot firmware table descriptor is complete.

Parameters

desc	ACPI descriptor

Return values

rc	Return status code

Definition at line 1033 of file aoe.c.

                                                                   {
        return 0;
}

abft_install()

static int abft_install ( int(*)(struct acpi_header *acpi)  install )

static

Install AoE boot firmware table(s)

Parameters

install

Installation method

Return values

rc	Return status code

Definition at line 1043 of file aoe.c.

                                                                           {
        struct aoe_device *aoedev;
        struct abft_table abft;
        int rc;

        list_for_each_entry ( aoedev, &abft_model.descs, desc.list ) {

                /* Populate table */
                memset ( &abft, 0, sizeof ( abft ) );
                abft.acpi.signature = cpu_to_le32 ( ABFT_SIG );
                abft.acpi.length = cpu_to_le32 ( sizeof ( abft ) );
                abft.acpi.revision = 1;
                abft.shelf = cpu_to_le16 ( aoedev->major );
                abft.slot = aoedev->minor;
                memcpy ( abft.mac, aoedev->netdev->ll_addr,
                         sizeof ( abft.mac ) );

                /* Install table */
                if ( ( rc = install ( &abft.acpi ) ) != 0 ) {
                        DBGC ( aoedev, "AoE %s could not install aBFT: %s\n",
                               aoedev_name ( aoedev ), strerror ( rc ) );
                        return rc;
                }
        }

        return 0;
}

References ABFT_SIG, abft_table::acpi, aoedev_name(), cpu_to_le16, cpu_to_le32, DBGC, desc, acpi_header::length, list_for_each_entry, net_device::ll_addr, abft_table::mac, aoe_device::major, memcpy(), memset(), aoe_device::minor, aoe_device::netdev, rc, acpi_header::revision, abft_table::shelf, acpi_header::signature, abft_table::slot, and strerror().

Variable Documentation

__net_protocol

struct net_protocol aoe_protocol __net_protocol

Initial value:

= {
        .name = "AoE",
        .net_proto = htons ( ETH_P_AOE ),
        .rx = aoe_rx,
}

AoE protocol.

Definition at line 56 of file aoe.c.

__acpi_model

struct acpi_model abft_model __acpi_model

Initial value:

= {
        .descs = LIST_HEAD_INIT ( abft_model.descs ),
        .complete = abft_complete,
        .install = abft_install,
}

aBFT model

Definition at line 57 of file aoe.c.

aoecmd_ata

struct aoe_command_type aoecmd_ata

static

Initial value:

= {
        .cmd_len = aoecmd_ata_cmd_len,
        .cmd = aoecmd_ata_cmd,
        .rsp = aoecmd_ata_rsp,
}

AoE ATA command.

Definition at line 460 of file aoe.c.

Referenced by aoedev_ata_command().

aoecmd_cfg

struct aoe_command_type aoecmd_cfg

static

Initial value:

= {
        .cmd_len = aoecmd_cfg_cmd_len,
        .cmd = aoecmd_cfg_cmd,
        .rsp = aoecmd_cfg_rsp,
}

AoE configuration command.

Definition at line 536 of file aoe.c.

Referenced by aoedev_cfg_command().

aoecmd_ata_op

struct interface_operation aoecmd_ata_op[]

static

Initial value:

= {
        INTF_OP ( intf_close, struct aoe_command *, aoecmd_close ),
}

AoE command ATA interface operations.

Definition at line 543 of file aoe.c.

aoecmd_ata_desc

struct interface_descriptor aoecmd_ata_desc

static

Initial value:

=
        INTF_DESC ( struct aoe_command, ata, aoecmd_ata_op )

AoE command ATA interface descriptor.

Definition at line 548 of file aoe.c.

Referenced by aoecmd_create().

aoedev_ata_op

struct interface_operation aoedev_ata_op[]

static

Initial value:

= {
        INTF_OP ( ata_command, struct aoe_device *, aoedev_ata_command ),
        INTF_OP ( xfer_window, struct aoe_device *, aoedev_window ),
        INTF_OP ( intf_close, struct aoe_device *, aoedev_close ),
        INTF_OP ( acpi_describe, struct aoe_device *, aoedev_describe ),
        INTF_OP ( identify_device, struct aoe_device *,
                  aoedev_identify_device ),
        EFI_INTF_OP ( efi_describe, struct aoe_device *, efi_aoe_path ),
}

AoE device ATA interface operations.

Definition at line 777 of file aoe.c.

aoedev_ata_desc

struct interface_descriptor aoedev_ata_desc

static

Initial value:

=
        INTF_DESC ( struct aoe_device, ata, aoedev_ata_op )

AoE device ATA interface descriptor.

Definition at line 788 of file aoe.c.

Referenced by aoedev_open().

aoedev_config_op

struct interface_operation aoedev_config_op[]

static

Initial value:

= {
        INTF_OP ( intf_close, struct aoe_device *, aoedev_config_done ),
}

AoE device configuration interface operations.

Definition at line 792 of file aoe.c.

aoedev_config_desc

struct interface_descriptor aoedev_config_desc

static

Initial value:

=
        INTF_DESC ( struct aoe_device, config, aoedev_config_op )

AoE device configuration interface descriptor.

Definition at line 797 of file aoe.c.

Referenced by aoedev_open().

__uri_opener

struct uri_opener aoe_uri_opener __uri_opener

Initial value:

= {
        .scheme = "aoe",
        .open = aoe_open,
}

AoE URI opener.

Definition at line 1015 of file aoe.c.