SrvIntNetR0.cpp revision a91aecdafa378380347ffab1e48b428b7ec37747
5b281ba489ca18f0380d7efc7a5108b606cce449vboxsync * Internal networking - The ring 0 service.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Copyright (C) 2006-2010 Oracle Corporation
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * This file is part of VirtualBox Open Source Edition (OSE), as
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * available from http://www.virtualbox.org. This file is free software;
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * you can redistribute it and/or modify it under the terms of the GNU
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * General Public License (GPL) as published by the Free Software
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Foundation, in version 2 as it comes in the "COPYING" file of the
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/*******************************************************************************
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync* Header Files *
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync*******************************************************************************/
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/*******************************************************************************
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync* Defined Constants And Macros *
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync*******************************************************************************/
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** @def INTNET_WITH_DHCP_SNOOPING
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * Enabled DHCP snooping when in shared-mac-on-the-wire mode. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** The maximum number of interface in a network. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** The number of entries to grow the destination tables with. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** The wakeup bit in the INTNETIF::cBusy and INTNETRUNKIF::cBusy counters. */
ee6e48c229ef52aee5e968d956ebd066073811abvboxsync/*******************************************************************************
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync* Structures and Typedefs *
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync*******************************************************************************/
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * MAC address lookup table entry.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The MAC address of this entry. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Is it promiscuous. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Is it active.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * We ignore the entry if this is clear and may end up sending packets addressed
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * to this interface onto the trunk. The reasoning for this is that this could
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * be the interface of a VM that just has been teleported to a different host. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Pointer to the network interface. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync/** Pointer to a MAC address lookup table entry. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * MAC address lookup table.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * @todo Having this in a separate structure didn't work out as well as it
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * should. Consider merging it into INTNETNETWORK.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsynctypedef struct INTNETMACTAB
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The current number of entries. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The number of entries we've allocated space for. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Table entries. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The host MAC address (reported). */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The host promisucous setting (reported). */
5eda82e218d35ae0691febd531e1bfc0324cc4a6vboxsync /** Whether the host is active. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync /** Whether the wire is promiscuous (config). */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** Whether the wire is active. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Pointer to the the trunk interface. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync/** Pointer to a MAC address . */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Destination table.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsynctypedef struct INTNETDSTTAB
445661c86e95894713da707c6c9787b7507dfce6vboxsync /** The trunk destinations. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync /** Pointer to the trunk interface (referenced) if fTrunkDst is non-zero. */
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync /** The number of destination interfaces. */
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync /** The interfaces (referenced). Variable sized array. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The destination interface. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** Whether to replace the destination MAC address.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * This is used when sharing MAC address with the host on the wire(less). */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to a destination table. */
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync/** Pointer to a const destination table. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync/** Network layer address type. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync /** The invalid 0 entry. */
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync /** IP version 4. */
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync /** IP version 6. */
c889bbab784ba8552102ce776b6c67b982017861vboxsync /** IPX. */
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync /** The end of the valid values. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync /** The usual 32-bit hack. */
c5d2523548cc57504b829f53f1362b848a84542cvboxsync/** Pointer to a network layer address type. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Address and type.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsynctypedef struct INTNETADDR
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The address type. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The address. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync/** Pointer to an address. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync/** Pointer to a const address. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * Address cache for a specific network layer.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Pointer to the table of addresses. */
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync /** The number of valid address entries. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The number of allocated address entries. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The address size. */
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync /** The size of an entry. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** Pointer to an address cache. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to a const address cache. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * A network interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Unless explicitly stated, all members are protect by the network semaphore.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsynctypedef struct INTNETIF
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** The MAC address.
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * This is shadowed by INTNETMACTABENTRY::MacAddr. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** Set if the INTNET::MacAddr member has been explicitly set. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** Set if the interface is in promiscuous mode.
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * This is shadowed by INTNETMACTABENTRY::fPromiscuous. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Whether the interface is active or not.
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * This is shadowed by INTNETMACTABENTRY::fActive. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** Whether someone is currently in the destructor. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync bool volatile fDestroying;
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Number of yields done to try make the interface read pending data.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * We will stop yielding when this reaches a threshold assuming that the VM is
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * paused or that it simply isn't worth all the delay. It is cleared when a
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * successful send has been done. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Pointer to the current exchange buffer (ring-0). */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Pointer to ring-3 mapping of the current exchange buffer. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Pointer to the default exchange buffer for the interface. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Pointer to ring-3 mapping of the default exchange buffer. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Event semaphore which a receiver/consumer thread will sleep on while
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync * waiting for data to arrive. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** Number of threads sleeping on the event semaphore. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** The interface handle.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * When this is INTNET_HANDLE_INVALID a sleeper which is waking up
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * should return with the appropriate error condition. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** Pointer to the network this interface is connected to.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * This is protected by the INTNET::hMtxCreateOpenDestroy. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** The session this interface is associated with. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The SUPR0 object id. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The network layer address cache. (Indexed by type, 0 entry isn't used.)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * This is protected by the address spinlock of the network. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Spinlock protecting the input (producer) side of the receive ring. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Busy count for tracking destination table references and active sends.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Usually incremented while owning the switch table spinlock. The 30th bit
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * is used to indicate wakeup. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** The preallocated destination table.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * This is NULL when it's in use as a precaution against unserialized
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * transmitting. This is grown when new interfaces are added to the network. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to an internal network interface. */
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * A trunk interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The port interface we present to the component. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The port interface we get from the component. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Pointer to the network we're connect to.
1829a716128b3e2d42bcee064a15c553dbd44798vboxsync * This may be NULL if we're orphaned? */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The current MAC address for the interface. (reported)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Updated while owning the switch table spinlock. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Whether to supply physical addresses with the outbound SGs. (reported) */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Explicit alignment. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** Busy count for tracking destination table references and active sends.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * Usually incremented while owning the switch table spinlock. The 30th bit
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * is used to indicate wakeup. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Mask of destinations that pfnXmit cope with disabled preemption for. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The GSO capabilities of the wire destination. (reported) */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The GSO capabilities of the host destination. (reported)
5979821e2c16d1fcec5b9a3ef64e13246fc9a93avboxsync * This is as bit map where each bit represents the GSO type with the same
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * number. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Header buffer for when we're carving GSO frames. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The destination table spinlock, interrupt safe.
5979821e2c16d1fcec5b9a3ef64e13246fc9a93avboxsync * Protects apTaskDstTabs and apIntDstTabs. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** The number of entries in apIntDstTabs. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** The task time destination tables.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @remarks intnetR0NetworkEnsureTabSpace and others ASSUMES this immediately
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * preceeds apIntDstTabs so that these two tables can be used as one
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * contiguous one. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The interrupt / disabled-preemption time destination tables.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * This is a variable sized array. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to a trunk interface. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync/** Converts a pointer to INTNETTRUNKIF::SwitchPort to a PINTNETTRUNKIF. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync#define INTNET_SWITCHPORT_2_TRUNKIF(pSwitchPort) ((PINTNETTRUNKIF)(pSwitchPort))
00cc5d93f7446d9394a0f6b7ad790b9fb9d6005cvboxsync * Internal representation of a network.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync /** The Next network in the chain.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * This is protected by the INTNET::hMtxCreateOpenDestroy. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** The spinlock protecting MacTab and INTNETTRUNKIF::aAddrCache.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Interrupt safe. */
00cc5d93f7446d9394a0f6b7ad790b9fb9d6005cvboxsync /** MAC address table.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * This doubles as interface collection. */
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync /** Wait for an interface to stop being busy so it can be removed or have its
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * destination table replaced. We have to wait upon this while owning the
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * network mutex. Will only ever have one waiter because of the big mutex. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Pointer to the instance data. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** The SUPR0 object id. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /** Pointer to the temporary buffer that is used when snooping fragmented packets.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * This is allocated after this structure if we're sharing the MAC address with
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * the host. The buffer is INTNETNETWORK_TMP_SIZE big and aligned on a 64-byte boundrary. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Network creation flags (INTNET_OPEN_FLAGS_*). */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** The number of active interfaces (excluding the trunk). */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** The length of the network name. */
8e3faac3e7a5ca790b1d82e9d019d6f48b8a61f2vboxsync /** The network name. */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync /** The trunk type. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** The trunk name. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to an internal network. */
234af146205f61c4aa0be736abb06601a89facb8vboxsync/** The size of the buffer INTNETNETWORK::pbTmp points at. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Internal networking instance.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsynctypedef struct INTNET
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Magic number (INTNET_MAGIC). */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync /** Mutex protecting the creation, opening and destruction of both networks and
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * interfaces. (This means all operations affecting the pNetworks list.) */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** List of networks. Protected by INTNET::Spinlock. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /** Handle table for the interfaces. */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/** Pointer to an internal network ring-0 instance. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Magic number for the internal network instance data (Hayao Miyazaki). */
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync/*******************************************************************************
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync* Global Variables *
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync*******************************************************************************/
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/** Pointer to the internal network instance data. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync/*******************************************************************************
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync* Internal Functions *
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync*******************************************************************************/
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncstatic PINTNETTRUNKIF intnetR0TrunkIfRetain(PINTNETTRUNKIF pThis);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncstatic void intnetR0TrunkIfRelease(PINTNETTRUNKIF pThis);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Worker for intnetR0SgWritePart that deals with the case where the
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * request doesn't fit into the first segment.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @returns true, unless the request or SG invalid.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pSG The SG list to write to.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param off Where to start writing (offset into the SG).
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param cb How much to write.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pvBuf The buffer to containing the bits to write.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsyncstatic bool intnetR0SgWritePartSlow(PCINTNETSG pSG, uint32_t off, uint32_t cb, void const *pvBuf)
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync return false;
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * Skip ahead to the segment where off starts.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync unsigned const cSegs = pSG->cSegsUsed; Assert(cSegs == pSG->cSegsUsed);
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync unsigned iSeg = 0;
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Copy the data, hoping that it's all from one segment...
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync memcpy((uint8_t *)pSG->aSegs[iSeg].pv + off, pvBuf, cb);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /* copy the portion in the current segment. */
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync memcpy((uint8_t *)pSG->aSegs[iSeg].pv + off, pvBuf, cbCanCopy);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /* copy the portions in the other segments. */
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync } while (cb > 0);
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync return true;
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * Writes to a part of an SG.
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * @returns true on success, false on failure (out of bounds).
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * @param pSG The SG list to write to.
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * @param off Where to start writing (offset into the SG).
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync * @param cb How much to write.
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync * @param pvBuf The buffer to containing the bits to write.
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsyncDECLINLINE(bool) intnetR0SgWritePart(PCINTNETSG pSG, uint32_t off, uint32_t cb, void const *pvBuf)
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync /* The optimized case. */
c5d2523548cc57504b829f53f1362b848a84542cvboxsync memcpy((uint8_t *)pSG->aSegs[0].pv + off, pvBuf, cb);
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync return true;
c5d2523548cc57504b829f53f1362b848a84542cvboxsync return intnetR0SgWritePartSlow(pSG, off, cb, pvBuf);
8929a16e87a515b7071399479548158b8c5fbdd2vboxsync * Reads a byte from a SG list.
ee6e48c229ef52aee5e968d956ebd066073811abvboxsync * @returns The byte on success. 0xff on failure.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pSG The SG list to read.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param off The offset (into the SG) off the byte.
ee6e48c229ef52aee5e968d956ebd066073811abvboxsyncDECLINLINE(uint8_t) intnetR0SgReadByte(PCINTNETSG pSG, uint32_t off)
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync unsigned const cSegs = pSG->cSegsUsed; Assert(cSegs == pSG->cSegsUsed);
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return ((uint8_t const *)pSG->aSegs[iSeg].pv)[off];
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return false;
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Worker for intnetR0SgReadPart that deals with the case where the
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * requested data isn't in the first segment.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @returns true, unless the SG is invalid.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pSG The SG list to read.
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync * @param off Where to start reading (offset into the SG).
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * @param cb How much to read.
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync * @param pvBuf The buffer to read into.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsyncstatic bool intnetR0SgReadPartSlow(PCINTNETSG pSG, uint32_t off, uint32_t cb, void *pvBuf)
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return false;
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Skip ahead to the segment where off starts.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync unsigned const cSegs = pSG->cSegsUsed; Assert(cSegs == pSG->cSegsUsed);
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync unsigned iSeg = 0;
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Copy the data, hoping that it's all from one segment...
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync memcpy(pvBuf, (uint8_t const *)pSG->aSegs[iSeg].pv + off, cb);
7f18b4c79440e724c5e08f007674ea7883ce6c01vboxsync /* copy the portion in the current segment. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync memcpy(pvBuf, (uint8_t const *)pSG->aSegs[iSeg].pv + off, cbCanCopy);
5eda82e218d35ae0691febd531e1bfc0324cc4a6vboxsync /* copy the portions in the other segments. */
7f18b4c79440e724c5e08f007674ea7883ce6c01vboxsync memcpy(pvBuf, (uint8_t const *)pSG->aSegs[iSeg].pv, cbCanCopy);
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync } while (cb > 0);
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync return true;
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * Reads a part of an SG into a buffer.
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync * @returns true on success, false on failure (out of bounds).
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * @param pSG The SG list to read.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * @param off Where to start reading (offset into the SG).
a2d29442b07952c0d2b4d2b703bf4c2d1eb072eavboxsync * @param cb How much to read.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * @param pvBuf The buffer to read into.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsyncDECLINLINE(bool) intnetR0SgReadPart(PCINTNETSG pSG, uint32_t off, uint32_t cb, void *pvBuf)
ad1e35f9fb71d147c2126449a25adf0f8e155aaavboxsync /* The optimized case. */
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync memcpy(pvBuf, (uint8_t const *)pSG->aSegs[0].pv + off, cb);
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync return true;
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync return intnetR0SgReadPartSlow(pSG, off, cb, pvBuf);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Wait for a busy counter to reach zero.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pNetwork The network.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pcBusy The busy counter.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncstatic void intnetR0BusyWait(PINTNETNETWORK pNetwork, uint32_t volatile *pcBusy)
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * We have to be a bit cautious here so we don't destroy the network or the
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * semaphore before intnetR0BusyDec has signalled us.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /* Reset the semaphore and flip the wakeup bit. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync RTSemEventWait(pNetwork->hEvtBusyIf, 0); /* clear it */
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync AssertMsg(!(cCurBusy & INTNET_BUSY_WAKEUP_MASK), ("%#x\n", cCurBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync AssertMsg((cCurBusy & ~INTNET_BUSY_WAKEUP_MASK) < INTNET_MAX_IFS * 3, ("%#x\n", cCurBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync } while (!ASMAtomicCmpXchgExU32(pcBusy, cCurBusy | INTNET_BUSY_WAKEUP_MASK, cCurBusy, &cCurBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync /* Wait for the count to reach zero. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync int rc2 = RTSemEventWait(pNetwork->hEvtBusyIf, 30000); NOREF(rc2);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync //AssertMsg(RT_SUCCESS(rc2), ("rc=%Rrc *pcBusy=%#x (%#x)\n", rc2, ASMAtomicReadU32(pcBusy), cCurBusy ));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync AssertMsg((cCurBusy & INTNET_BUSY_WAKEUP_MASK), ("%#x\n", cCurBusy));
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync AssertMsg((cCurBusy & ~INTNET_BUSY_WAKEUP_MASK) < INTNET_MAX_IFS * 3, ("%#x\n", cCurBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync || ASMAtomicCmpXchgU32(pcBusy, 0, INTNET_BUSY_WAKEUP_MASK));
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * Decrements the busy counter and maybe wakes up any threads waiting for it to
5eda82e218d35ae0691febd531e1bfc0324cc4a6vboxsync * reach zero.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pNetwork The network.
d60d5da33bb93fc7a8717802f21b13aa37914799vboxsync * @param pcBusy The busy counter.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsyncDECLINLINE(void) intnetR0BusyDec(PINTNETNETWORK pNetwork, uint32_t volatile *pcBusy)
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync if (RT_UNLIKELY( cNewBusy == INTNET_BUSY_WAKEUP_MASK
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync AssertMsg((cNewBusy & ~INTNET_BUSY_WAKEUP_MASK) < INTNET_MAX_IFS * 3, ("%#x\n", cNewBusy));
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * Increments the busy count of the specified interface.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * The caller must own the MAC address table spinlock.
ad1e35f9fb71d147c2126449a25adf0f8e155aaavboxsync * @param pIf The interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Increments the busy count of the specified interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * The caller must own the MAC address table spinlock or an explicity reference.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pTrunk The trunk.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncDECLINLINE(void) intnetR0BusyDecTrunk(PINTNETTRUNKIF pTrunk)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Increments the busy count of the specified interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * The caller must own the MAC address table spinlock or an explicity reference.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pIf The interface.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync AssertMsg((cNewBusy & ~INTNET_BUSY_WAKEUP_MASK) < INTNET_MAX_IFS * 3, ("%#x\n", cNewBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Increments the busy count of the specified interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * The caller must own the MAC address table spinlock or an explicity reference.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pTrunk The trunk.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncDECLINLINE(void) intnetR0BusyIncTrunk(PINTNETTRUNKIF pTrunk)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync uint32_t cNewBusy = ASMAtomicIncU32(&pTrunk->cBusy);
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync AssertMsg((cNewBusy & ~INTNET_BUSY_WAKEUP_MASK) < INTNET_MAX_IFS * 3, ("%#x\n", cNewBusy));
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * Retain an interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @returns VBox status code, can assume success in most situations.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pIf The interface instance.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pSession The current session.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncDECLINLINE(int) intnetR0IfRetain(PINTNETIF pIf, PSUPDRVSESSION pSession)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync int rc = SUPR0ObjAddRefEx(pIf->pvObj, pSession, true /* fNoBlocking */);
ad1e35f9fb71d147c2126449a25adf0f8e155aaavboxsync * Release an interface previously retained by intnetR0IfRetain or
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @returns true if destroyed, false if not.
ad1e35f9fb71d147c2126449a25adf0f8e155aaavboxsync * @param pIf The interface instance.
ad1e35f9fb71d147c2126449a25adf0f8e155aaavboxsync * @param pSession The current session.
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsyncDECLINLINE(bool) intnetR0IfRelease(PINTNETIF pIf, PSUPDRVSESSION pSession)
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * RTHandleCreateEx callback that retains an object in the
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * handle table before returning it.
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * (Avoids racing the freeing of the handle.)
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * @returns VBox status code.
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * @param hHandleTable The handle table (ignored).
c889bbab784ba8552102ce776b6c67b982017861vboxsync * @param pvObj The object (INTNETIF).
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pvCtx The context (SUPDRVSESSION).
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pvUser The user context (ignored).
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncstatic DECLCALLBACK(int) intnetR0IfRetainHandle(RTHANDLETABLE hHandleTable, void *pvObj, void *pvCtx, void *pvUser)
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync if (pIf->hIf != INTNET_HANDLE_INVALID) /* Don't try retain it if called from intnetR0IfDestruct. */
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync return intnetR0IfRetain(pIf, (PSUPDRVSESSION)pvCtx);
4d32c71a938b979c6aeee321ae325d5793a5ccdbvboxsync * Checks if the interface has a usable MAC address or not.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * @returns true if MacAddr is usable, false if not.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * @param pIf The interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncDECL_FORCE_INLINE(bool) intnetR0IfHasMacAddr(PINTNETIF pIf)
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * Locates the MAC address table entry for the given interface.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * The caller holds the MAC address table spinlock, obviously.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @returns Pointer to the entry on if found, NULL if not.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @param pNetwork The network.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pIf The interface.
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsyncDECLINLINE(PINTNETMACTABENTRY) intnetR0NetworkFindMacAddrEntry(PINTNETNETWORK pNetwork, PINTNETIF pIf)
c889bbab784ba8552102ce776b6c67b982017861vboxsync while (iIf-- > 0)
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * Checks if the IPv4 address is a broadcast address.
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync * @param Addr The address, network endian.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsyncDECLINLINE(bool) intnetR0IPv4AddrIsBroadcast(RTNETADDRIPV4 Addr)
ab02aeaf2a0312fe9267a292e3911728e4531332vboxsync /* Just check for 255.255.255.255 atm. */
31cda52093d58f5c604589fa74949c5fddcbde70vboxsync * Checks if the IPv4 address is a good interface address.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * @param Addr The address, network endian.
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsyncDECLINLINE(bool) intnetR0IPv4AddrIsGood(RTNETADDRIPV4 Addr)
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /* Usual suspects. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync if ( Addr.u == UINT32_MAX /* 255.255.255.255 - broadcast. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync || Addr.au8[0] == 0) /* Current network, can be used as source address. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return false;
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync /* Unusual suspects. */
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return false;
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync return true;
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * Gets the address size of a network layer type.
31cda52093d58f5c604589fa74949c5fddcbde70vboxsync * @returns size in bytes.
31cda52093d58f5c604589fa74949c5fddcbde70vboxsync * @param enmType The type.
5eda82e218d35ae0691febd531e1bfc0324cc4a6vboxsyncDECLINLINE(uint8_t) intnetR0AddrSize(INTNETADDRTYPE enmType)
e5bfc5c34142a7550be3564a8e01a037b1db5b31vboxsync * Compares two address to see if they are equal, assuming naturally align structures.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @returns true if equal, false if not.
6f058039e7b13efc3278b9bc84cf0fd135614b67vboxsync * @param pAddr1 The first address.
6f058039e7b13efc3278b9bc84cf0fd135614b67vboxsync * @param pAddr2 The second address.
6f058039e7b13efc3278b9bc84cf0fd135614b67vboxsync * @param cbAddr The address size.
6f058039e7b13efc3278b9bc84cf0fd135614b67vboxsyncDECLINLINE(bool) intnetR0AddrUIsEqualEx(PCRTNETADDRU pAddr1, PCRTNETADDRU pAddr2, uint8_t const cbAddr)
7f4b4ec1cadbf891d2756ce77dc4a4ec220a03bcvboxsync * Worker for intnetR0IfAddrCacheLookup that performs the lookup
ad836b4d6fb2ccaf969666246c2c389a8d10ca41vboxsync * in the remaining cache entries after the caller has check the
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * most likely ones.
9669409ada28ab1b50aa2e7d6a64d2779a47f415vboxsync * @returns -1 if not found, the index of the cache entry if found.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * @param pCache The cache.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * @param pAddr The address.
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync * @param cbAddr The address size (optimization).
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsyncstatic int intnetR0IfAddrCacheLookupSlow(PCINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr)
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync uint8_t const *pbEntry = pCache->pbEntries + pCache->cbEntry * i;
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync while (i >= 1)
d27bf03c13c7a5707386600ef9b0bbb82fb3420dvboxsync if (intnetR0AddrUIsEqualEx((PCRTNETADDRU)pbEntry, pAddr, cbAddr))
ad836b4d6fb2ccaf969666246c2c389a8d10ca41vboxsync * Lookup an address in a cache without any expectations.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @returns -1 if not found, the index of the cache entry if found.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pCache The cache.
833f83ce101b6e9168f519decc0dc7a1079d35f7vboxsync * @param pAddr The address.
c889bbab784ba8552102ce776b6c67b982017861vboxsync * @param cbAddr The address size (optimization).
DECLINLINE(int) intnetR0IfAddrCacheLookup(PCINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr)
DECLINLINE(int) intnetR0IfAddrCacheLookupLikely(PCINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr)
static int intnetR0IfAddrCacheInCacheUnlikelySlow(PCINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr)
DECLINLINE(int) intnetR0IfAddrCacheLookupUnlikely(PCINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr)
if (RT_UNLIKELY( i > 0
if (RT_UNLIKELY(intnetR0AddrUIsEqualEx((PCRTNETADDRU)(pCache->pbEntries + pCache->cbEntry * i), pAddr, cbAddr)))
static void intnetR0IfAddrCacheDeleteIt(PINTNETIF pIf, PINTNETADDRCACHE pCache, int iEntry, const char *pszMsg)
#ifdef LOG_ENABLED
switch (enmAddrType)
case kIntNetAddrType_IPv4:
pIf->hIf, &pIf->MacAddr, iEntry, pAddr->au8[0], pAddr->au8[1], pAddr->au8[2], pAddr->au8[3], pszMsg));
DECLINLINE(void) intnetR0IfAddrCacheDelete(PINTNETIF pIf, PINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr, const char *pszMsg)
if (RT_UNLIKELY(i >= 0))
DECLINLINE(void) intnetR0NetworkAddrCacheDelete(PINTNETNETWORK pNetwork, PCRTNETADDRU pAddr, INTNETADDRTYPE const enmType,
while (iIf--)
if (RT_UNLIKELY(i >= 0))
DECLINLINE(void) intnetR0NetworkAddrCacheDeleteMinusIf(PINTNETNETWORK pNetwork, PINTNETIF pIfSender, PCRTNETADDRU pAddr,
while (iIf--)
if (RT_UNLIKELY(i >= 0))
DECLINLINE(PINTNETIF) intnetR0NetworkAddrCacheLookupIf(PINTNETNETWORK pNetwork, PCRTNETADDRU pAddr, INTNETADDRTYPE const enmType, uint8_t const cbAddr)
while (iIf--)
return pIf;
return NULL;
static void intnetR0IfAddrCacheAddIt(PINTNETIF pIf, PINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, const char *pszMsg)
memmove(pCache->pbEntries, pCache->pbEntries + pCache->cbEntry, pCache->cbEntry * (pCache->cEntries - 1));
#ifdef LOG_ENABLED
switch (enmAddrType)
case kIntNetAddrType_IPv4:
pIf->hIf, &pIf->MacAddr, pCache->cEntries, pAddr->au8[0], pAddr->au8[1], pAddr->au8[2], pAddr->au8[3], pszMsg));
static void intnetR0IfAddrCacheAddSlow(PINTNETIF pIf, PINTNETADDRCACHE pCache, PCRTNETADDRU pAddr, uint8_t const cbAddr, const char *pszMsg)
if (RT_LIKELY( i > 0
&& intnetR0AddrUIsEqualEx((PCRTNETADDRU)(pCache->pbEntries + pCache->cbEntry * i), pAddr, cbAddr))) ))
static int intnetR0IfAddrCacheInit(PINTNETADDRCACHE pCache, INTNETADDRTYPE enmAddrType, bool fEnabled)
if (fEnabled)
return VERR_NO_MEMORY;
return VINF_SUCCESS;
while (iIfMac-- > 0)
if ( fExact
static INTNETSWDECISION intnetR0NetworkSwitchUnicast(PINTNETNETWORK pNetwork, uint32_t fSrc, PINTNETIF pIfSender,
while (iIfMac-- > 0)
if ( fExact
if ( fExact
static INTNETSWDECISION intnetR0NetworkSwitchBroadcast(PINTNETNETWORK pNetwork, uint32_t fSrc, PINTNETIF pIfSender,
while (iIfMac-- > 0)
return INTNETSWDECISION_BROADCAST;
static INTNETSWDECISION intnetR0NetworkSwitchTrunkAndPromisc(PINTNETNETWORK pNetwork, uint32_t fSrc, PINTNETDSTTAB pDstTab)
while (iIfMac-- > 0)
static INTNETSWDECISION intnetR0NetworkSwitchTrunk(PINTNETNETWORK pNetwork, uint32_t fSrc, PINTNETDSTTAB pDstTab)
return VERR_NO_MEMORY;
return VINF_SUCCESS;
if ( pOld
ppDstTab++)
if (pvOld)
if (pvOld)
if (paNew)
return rc;
#ifdef INTNET_WITH_DHCP_SNOOPING
static void intnetR0NetworkSnoopDhcp(PINTNETNETWORK pNetwork, PCRTNETIPV4 pIpHdr, PCRTNETUDP pUdpHdr, uint32_t cbUdpPkt)
#ifdef LOG_ENABLED
switch (MsgType)
Log6(("DHCP msg: %d (%s) client %.6Rhxs ciaddr=%d.%d.%d.%d yiaddr=%d.%d.%d.%d\n", MsgType, pszType, &pDhcp->bp_chaddr,
pDhcp->bp_yiaddr.au8[0], pDhcp->bp_yiaddr.au8[1], pDhcp->bp_yiaddr.au8[2], pDhcp->bp_yiaddr.au8[3]));
switch (MsgType)
case RTNET_DHCP_MT_REQUEST:
case RTNET_DHCP_MT_ACK:
while (iIf-- > 0)
if (!pMatchingIf)
if (pMatchingIf)
case RTNET_DHCP_MT_RELEASE:
while (iIf-- > 0)
if (!RTNetIPv4IsHdrValid(pIpHdr, cbPacket, pSG->cbTotal - sizeof(RTNETETHERHDR), true /*fChecksum*/))
intnetR0NetworkSnoopDhcp(pNetwork, pIpHdr, (PCRTNETUDP)((uintptr_t)pIpHdr + cbIpHdr), cbPacket - cbIpHdr);
#ifdef INTNET_WITH_DHCP_SNOOPING
switch (EtherType)
case RTNET_ETHERTYPE_IPV4:
uint8_t b;
Assert(pSG->cbTotal >= sizeof(RTNETETHERHDR) + RTNETIPV4_MIN_LEN + RTNETUDP_MIN_LEN + RTNETBOOTP_DHCP_MIN_LEN);
PCRTNETUDP pUdpHdr = (PCRTNETUDP)((uint8_t const *)pSG->aSegs[0].pv + sizeof(RTNETETHERHDR) + cbIpHdr);
if ( b != RTNETIPV4_PORT_BOOTPS
&& b != RTNETIPV4_PORT_BOOTPC)
if ( b != RTNETIPV4_PORT_BOOTPS
&& b != RTNETIPV4_PORT_BOOTPC)
if (b == SrcPort)
case RTNET_ETHERTYPE_IPV6:
case RTNET_ETHERTYPE_ARP:
static void intnetR0IfSnoopIPv4SourceAddr(PINTNETIF pIf, PCRTNETIPV4 pIpHdr, uint32_t cbPacket, bool fGso)
bool fValidatedIpHdr = false;
&& intnetR0IfAddrCacheLookupLikely(&pIf->aAddrCache[kIntNetAddrType_IPv4], &Addr, sizeof(Addr.IPv4)) < 0)
fValidatedIpHdr = true;
#ifdef INTNET_WITH_DHCP_SNOOPING
if ( fValidatedIpHdr
static void intnetR0IfSnoopArpAddr(PINTNETIF pIf, PCRTNETARPIPV4 pArpIPv4, uint32_t cbPacket, uint16_t *pfSgFlags)
static void intnetR0IfSnoopAddr(PINTNETIF pIf, uint8_t const *pbFrame, uint32_t cbFrame, bool fGso, uint16_t *pfSgFlags)
switch (EtherType)
case RTNET_ETHERTYPE_IPV4:
case RTNET_ETHERTYPE_IPV6:
intnetR0IfSnoopIPv6SourceAddr(pIf, (PCINTNETIPV6)((PCRTNETETHERHDR)pbFrame + 1), cbFrame, fGso, pfSgFlags);
case RTNET_ETHERTYPE_IPX_1:
case RTNET_ETHERTYPE_IPX_2:
case RTNET_ETHERTYPE_IPX_3:
case RTNET_ETHERTYPE_ARP:
int rc;
if (pNewDstMac)
return VINF_SUCCESS;
return rc;
while (--cYields > 0)
uint32_t offSegPayload = PDMNetGsoCarveSegment(&pSG->GsoCtx, (uint8_t *)pSG->aSegs[0].pv, pSG->cbTotal, iSeg, cSegs,
return rc;
return VINF_SUCCESS;
DECLINLINE(bool) intnetR0TrunkIfCanHandleGsoFrame(PINTNETTRUNKIF pThis, PINTNETSG pSG, uint32_t fDst)
int rc;
static void intnetR0NetworkEditArpFromWire(PINTNETNETWORK pNetwork, PINTNETSG pSG, PRTNETETHERHDR pEthHdr)
if (pIf)
static void intnetR0NetworkEditDhcpFromIntNet(PINTNETNETWORK pNetwork, PINTNETSG pSG, PRTNETETHERHDR pEthHdr)
if (RT_UNLIKELY(pSG->cbTotal < sizeof(RTNETETHERHDR) + RTNETIPV4_MIN_LEN + RTNETUDP_MIN_LEN + RTNETBOOTP_DHCP_MIN_LEN))
if (!RTNetIPv4IsHdrValid(pIpHdr, cbPacket, pSG->cbTotal - sizeof(RTNETETHERHDR), true /*fCheckSum*/))
switch (MsgType)
case RTNET_DHCP_MT_DISCOVER:
case RTNET_DHCP_MT_REQUEST:
Log6(("intnetR0NetworkEditDhcpFromIntNet: Setting broadcast flag in DHCP %#x, previously %x\n", MsgType, pDhcp->bp_flags));
intnetR0SgWritePart(pSG, (uintptr_t)&pDhcp->bp_flags - (uintptr_t)pIpHdr + sizeof(RTNETETHERHDR), sizeof(uFlags), &uFlags);
intnetR0SgWritePart(pSG, (uintptr_t)&pUdpHdr->uh_sum - (uintptr_t)pIpHdr + sizeof(RTNETETHERHDR), sizeof(pUdpHdr->uh_sum), &uChecksum);
DECLINLINE(bool) intnetR0NetworkIsContextOk(PINTNETNETWORK pNetwork, PINTNETIF pIfSender, PCINTNETDSTTAB pDstTab)
if (!pIfSender)
if (!fTrunkDst)
if (fSrc)
return fRc;
return INTNETSWDECISION_BAD_CONTEXT;
if ( !fSrc
if (fSrc)
#ifdef INTNET_WITH_DHCP_SNOOPING
&& pSG->cbTotal >= sizeof(RTNETETHERHDR) + RTNETIPV4_MIN_LEN + RTNETUDP_MIN_LEN + RTNETBOOTP_DHCP_MIN_LEN
static INTNETSWDECISION intnetR0NetworkSharedMacFixAndSwitchUnicast(PINTNETNETWORK pNetwork, PINTNETSG pSG,
case RTNET_ETHERTYPE_IPV4:
if (RT_UNLIKELY(!intnetR0SgReadPart(pSG, sizeof(RTNETETHERHDR) + RT_OFFSETOF(RTNETIPV4, ip_dst), sizeof(Addr.IPv4), &Addr)))
case RTNET_ETHERTYPE_IPV6
if (RT_UNLIKELY(!intnetR0SgReadPart(pSG, sizeof(RTNETETHERHDR) + RT_OFFSETOF(RTNETIPV6, ip6_dst), sizeof(Addr.IPv6), &Addr)))
case RTNET_ETHERTYPE_IPX_1:
case RTNET_ETHERTYPE_IPX_2:
case RTNET_ETHERTYPE_IPX_3:
if (RT_UNLIKELY(!intnetR0SgReadPart(pSG, sizeof(RTNETETHERHDR) + RT_OFFSETOF(RTNETIPX, ipx_dstnet), sizeof(Addr.IPX), &Addr)))
case RTNET_ETHERTYPE_ARP:
return intnetR0NetworkSharedMacFixAndSwitchBroadcast(pNetwork, INTNETTRUNKDIR_WIRE, NULL, pSG, pEthHdr, pDstTab);
#ifdef INTNET_WITH_DHCP_SNOOPING
&& pSG->cbTotal >= sizeof(RTNETETHERHDR) + RTNETIPV4_MIN_LEN + RTNETUDP_MIN_LEN + RTNETBOOTP_DHCP_MIN_LEN
return enmSwDecision;
while (iIf-- > 0)
static void intnetR0NetworkDeliver(PINTNETNETWORK pNetwork, PINTNETDSTTAB pDstTab, PINTNETSG pSG, PINTNETIF pIfSender)
if (pIfSender)
while (iIf-- > 0)
static INTNETSWDECISION intnetR0NetworkSend(PINTNETNETWORK pNetwork, PINTNETIF pIfSender, uint32_t fSrc,
return INTNETSWDECISION_INVALID;
return INTNETSWDECISION_INVALID;
if (pIfEntry)
enmSwDecision = intnetR0NetworkSharedMacFixAndSwitchBroadcast(pNetwork, fSrc, pIfSender, pSG, &EthHdr, pDstTab);
return enmSwDecision;
if (!pIf)
return VERR_INVALID_HANDLE;
intnetR0IfSnoopAddr(pIf, (uint8_t *)pvCurFrame, pHdr->cbFrame, false /*fGso*/, (uint16_t *)&Sg.fFlags);
return rc;
return VERR_INVALID_PARAMETER;
LogFlow(("IntNetR0IfGetBufferPtrs: hIf=%RX32 ppRing3Buf=%p ppRing0Buf=%p\n", hIf, ppRing3Buf, ppRing0Buf));
if (ppRing3Buf)
*ppRing3Buf = 0;
if (ppRing0Buf)
*ppRing0Buf = 0;
if (!pIf)
return VERR_INVALID_HANDLE;
if (ppRing3Buf)
if (ppRing0Buf)
return rc;
INTNETR0DECL(int) IntNetR0IfGetBufferPtrsReq(PSUPDRVSESSION pSession, PINTNETIFGETBUFFERPTRSREQ pReq)
return VERR_INVALID_PARAMETER;
if (!pIf)
return VERR_INVALID_HANDLE;
/** @todo make a SUPR0 api for obtaining the array. SUPR0/IPRT is keeping track of everything, there
return VERR_NOT_IMPLEMENTED;
INTNETR0DECL(int) IntNetR0IfSetPromiscuousMode(INTNETIFHANDLE hIf, PSUPDRVSESSION pSession, bool fPromiscuous)
if (!pIf)
return VERR_INVALID_HANDLE;
if (pNetwork)
return rc;
INTNETR0DECL(int) IntNetR0IfSetPromiscuousModeReq(PSUPDRVSESSION pSession, PINTNETIFSETPROMISCUOUSMODEREQ pReq)
return VERR_INVALID_PARAMETER;
INTNETR0DECL(int) IntNetR0IfSetMacAddress(INTNETIFHANDLE hIf, PSUPDRVSESSION pSession, PCRTMAC pMac)
if (!pIf)
return VERR_INVALID_HANDLE;
if (pNetwork)
if (pTrunk)
if (pTrunk)
if (pIfPort)
return rc;
INTNETR0DECL(int) IntNetR0IfSetMacAddressReq(PSUPDRVSESSION pSession, PINTNETIFSETMACADDRESSREQ pReq)
return VERR_INVALID_PARAMETER;
if (fActive)
if (pTrunk)
pTrunk->pIfPort->pfnSetState(pTrunk->pIfPort, fActive ? INTNETTRUNKIFSTATE_ACTIVE : INTNETTRUNKIFSTATE_INACTIVE);
return VINF_SUCCESS;
if (!pIf)
return VERR_INVALID_HANDLE;
int rc;
if (pNetwork)
return rc;
return VERR_INVALID_PARAMETER;
if (!pIf)
return VERR_INVALID_HANDLE;
return VERR_SEM_DESTROYED;
return rc;
return VERR_INVALID_PARAMETER;
if (!pIf)
return VERR_INVALID_HANDLE;
return rc;
return VERR_INVALID_PARAMETER;
if (pNetwork)
while (iIf-- > 0)
static int intnetR0NetworkCreateIf(PINTNETNETWORK pNetwork, PSUPDRVSESSION pSession, unsigned cbSend, unsigned cbRecv,
return rc;
if (!pIf)
return VERR_NO_MEMORY;
rc = SUPR0MemAlloc(pIf->pSession, cbBuf, (PRTR0PTR)&pIf->pIntBufDefault, (PRTR3PTR)&pIf->pIntBufDefaultR3);
ASMMemZero32(pIf->pIntBufDefault, cbBuf); /** @todo I thought I specified these buggers as clearing the memory... */
if (pTrunk)
if (pTrunk)
return VINF_SUCCESS;
return rc;
return rc;
static DECLCALLBACK(bool) intnetR0TrunkIfPortSetSGPhys(PINTNETTRUNKSWPORT pSwitchPort, bool fEnable)
static DECLCALLBACK(void) intnetR0TrunkIfPortReportMacAddress(PINTNETTRUNKSWPORT pSwitchPort, PCRTMAC pMacAddr)
if (pNetwork)
static DECLCALLBACK(void) intnetR0TrunkIfPortReportPromiscuousMode(PINTNETTRUNKSWPORT pSwitchPort, bool fPromiscuous)
if (pNetwork)
static DECLCALLBACK(void) intnetR0TrunkIfPortReportNoPreemptDsts(PINTNETTRUNKSWPORT pSwitchPort, uint32_t fNoPreemptDsts)
return INTNETSWDECISION_BROADCAST;
static DECLCALLBACK(bool) intnetR0TrunkIfPortRecv(PINTNETTRUNKSWPORT pSwitchPort, PINTNETSG pSG, uint32_t fSrc)
unsigned iDstTab = 0;
if (fIntCtx)
while (iDstTab-- > 0)
if (pDstTab)
if (!pDstTab)
if (pDstTab)
AssertMsg(enmSwDecision != INTNETSWDECISION_BAD_CONTEXT, ("fSrc=%#x fTrunkDst=%#x hdr=%.14Rhxs\n", fSrc, pDstTab->fTrunkDst, pSG->aSegs[0].pv));
while (iDstTab-- > 0)
return fRc;
static DECLCALLBACK(void) intnetR0TrunkIfPortSGRetain(PINTNETTRUNKSWPORT pSwitchPort, PINTNETSG pSG)
static DECLCALLBACK(void) intnetR0TrunkIfPortSGRelease(PINTNETTRUNKSWPORT pSwitchPort, PINTNETSG pSG)
return pThis;
return NULL;
if (!pThis)
if (pIfPort)
const char *pszName;
case kIntNetTrunkType_None:
return VINF_SUCCESS;
return VERR_NOT_IMPLEMENTED;
case kIntNetTrunkType_NetFlt:
case kIntNetTrunkType_NetAdp:
case kIntNetTrunkType_SrvNat:
PINTNETTRUNKIF pTrunk = (PINTNETTRUNKIF)RTMemAllocZ(RT_OFFSETOF(INTNETTRUNKIF, apIntDstTabs[cCpus]));
if (!pTrunk)
return VERR_NO_MEMORY;
pNetwork->MacTab.fWirePromiscuous = false; /** @todo !!(fFlags & INTNET_OPEN_FLAGS_PROMISC_TRUNK_WIRE); */
rc = SUPR0ComponentQueryFactory(pSession, pszName, INTNETTRUNKFACTORY_UUID_STR, (void **)&pTrunkFactory);
pszName, pNetwork->szTrunk, pNetwork->fFlags & INTNET_OPEN_FLAGS_SHARED_MAC_ON_WIRE ? " shared-mac" : "", pNetwork->szName));
return VINF_SUCCESS;
return rc;
Log(("intnetR0NetworkDestruct: pvObj=%p pNetwork=%p pIntNet=%p %s\n", pvObj, pNetwork, pIntNet, pNetwork->szName));
if (pTrunk)
while (iIf-- > 0)
if (pTrunk)
while (iIf-- > 0)
if (pTrunk)
static int intnetR0OpenNetwork(PINTNET pIntNet, PSUPDRVSESSION pSession, const char *pszNetwork, INTNETTRUNKTYPE enmTrunkType,
LogFlow(("intnetR0OpenNetwork: pIntNet=%p pSession=%p pszNetwork=%p:{%s} enmTrunkType=%d pszTrunk=%p:{%s} fFlags=%#x ppNetwork=%p\n",
while (pCur)
int rc;
return rc;
return VERR_NOT_FOUND;
static int intnetR0CreateNetwork(PINTNET pIntNet, PSUPDRVSESSION pSession, const char *pszNetwork, INTNETTRUNKTYPE enmTrunkType,
LogFlow(("intnetR0CreateNetwork: pIntNet=%p pSession=%p pszNetwork=%p:{%s} enmTrunkType=%d pszTrunk=%p:{%s} fFlags=%#x ppNetwork=%p\n",
if (!pNetwork)
return VERR_NO_MEMORY;
pNetwork->MacTab.paEntries = (PINTNETMACTABENTRY)RTMemAlloc(sizeof(INTNETMACTABENTRY) * pNetwork->MacTab.cEntriesAllocated);
pNetwork->pvObj = SUPR0ObjRegister(pSession, SUPDRVOBJTYPE_INTERNAL_NETWORK, intnetR0NetworkDestruct, pNetwork, pIntNet);
return VINF_SUCCESS;
return rc;
return rc;
LogFlow(("IntNetR0Open: pSession=%p pszNetwork=%p:{%s} enmTrunkType=%d pszTrunk=%p:{%s} fFlags=%#x cbSend=%u cbRecv=%u phIf=%p\n",
if (pszTrunk)
switch (enmTrunkType)
case kIntNetTrunkType_None:
if (*pszTrunk)
return VERR_INVALID_PARAMETER;
case kIntNetTrunkType_NetFlt:
case kIntNetTrunkType_NetAdp:
if (!*pszTrunk)
return VERR_INVALID_PARAMETER;
return VERR_NOT_IMPLEMENTED;
return rc;
rc = intnetR0CreateNetwork(pIntNet, pSession, pszNetwork, enmTrunkType, pszTrunk, fFlags, &pNetwork);
return rc;
return VERR_INVALID_PARAMETER;
if (!pIntNet)
cNetworks++;
return cNetworks;
if (!pIntNet)
if (pIntNet)
rc = RTHandleTableCreateEx(&pIntNet->hHtIfs, RTHANDLETABLE_FLAGS_LOCKED | RTHANDLETABLE_FLAGS_CONTEXT,
return VINF_SUCCESS;
return rc;