@@ -12,7 +12,7 @@ import (

 // to provide network specific functionality.

 type Backend interface {

 	GetNetworks(filters.Args, backend.NetworkListConfig) ([]network.Inspect, error)

-	CreateNetwork(nc network.CreateRequest) (*network.CreateResponse, error)

+	CreateNetwork(ctx context.Context, nc network.CreateRequest) (*network.CreateResponse, error)

 	ConnectContainerToNetwork(ctx context.Context, containerName, networkName string, endpointConfig *network.EndpointSettings) error

 	DisconnectContainerFromNetwork(containerName string, networkName string, force bool) error

 	DeleteNetwork(networkID string) error

@@ -223,7 +223,7 @@ func (n *networkRouter) postNetworkCreate(ctx context.Context, w http.ResponseWr

 	// validate the configuration. The network will not be created but, if the

 	// configuration is valid, ManagerRedirectError will be returned and handled

 	// below.

-	nw, err := n.backend.CreateNetwork(create)

+	nw, err := n.backend.CreateNetwork(ctx, create)

 	if err != nil {

 		if _, ok := err.(libnetwork.ManagerRedirectError); !ok {

 			return err

@@ -868,14 +868,14 @@ func (daemon *Daemon) initNetworkController(cfg *config.Config, activeSandboxes

 func configureNetworking(controller *libnetwork.Controller, conf *config.Config) error {

 	// Create predefined network "none"

 	if n, _ := controller.NetworkByName(network.NetworkNone); n == nil {

-		if _, err := controller.NewNetwork("null", network.NetworkNone, "", libnetwork.NetworkOptionPersist(true)); err != nil {

+		if _, err := controller.NewNetwork(context.TODO(), "null", network.NetworkNone, "", libnetwork.NetworkOptionPersist(true)); err != nil {

 			return errors.Wrapf(err, `error creating default %q network`, network.NetworkNone)

 		}

 	}

 	// Create predefined network "host"

 	if n, _ := controller.NetworkByName(network.NetworkHost); n == nil {

-		if _, err := controller.NewNetwork("host", network.NetworkHost, "", libnetwork.NetworkOptionPersist(true)); err != nil {

+		if _, err := controller.NewNetwork(context.TODO(), "host", network.NetworkHost, "", libnetwork.NetworkOptionPersist(true)); err != nil {

 			return errors.Wrapf(err, `error creating default %q network`, network.NetworkHost)

 		}

 	}

@@ -1009,7 +1009,7 @@ func initBridgeDriver(controller *libnetwork.Controller, cfg config.BridgeConfig

 	}

 	// Initialize default network on "bridge" with the same name

-	_, err = controller.NewNetwork("bridge", network.NetworkBridge, "",

+	_, err = controller.NewNetwork(context.TODO(), "bridge", network.NetworkBridge, "",

 		libnetwork.NetworkOptionEnableIPv4(true),

 		libnetwork.NetworkOptionEnableIPv6(cfg.EnableIPv6),

 		libnetwork.NetworkOptionDriverOpts(netOption),

@@ -279,7 +279,7 @@ func (daemon *Daemon) initNetworkController(daemonCfg *config.Config, activeSand

 					log.G(context.TODO()).Errorf("Error occurred when removing network %v", err)

 				}

-				_, err := daemon.netController.NewNetwork("nat", name, id,

+				_, err := daemon.netController.NewNetwork(context.TODO(), "nat", name, id,

 					libnetwork.NetworkOptionGeneric(options.Generic{

 						netlabel.GenericData: netOption,

 					}),

@@ -301,7 +301,7 @@ func (daemon *Daemon) initNetworkController(daemonCfg *config.Config, activeSand

 		}

 	}

-	_, err = daemon.netController.NewNetwork("null", "none", "", libnetwork.NetworkOptionPersist(false))

+	_, err = daemon.netController.NewNetwork(context.TODO(), "null", "none", "", libnetwork.NetworkOptionPersist(false))

 	if err != nil {

 		return err

 	}

@@ -384,7 +384,7 @@ func (daemon *Daemon) initNetworkController(daemonCfg *config.Config, activeSand

 		}

 		v6Conf := []*libnetwork.IpamConf{}

-		_, err := daemon.netController.NewNetwork(strings.ToLower(v.Type), name, nid,

+		_, err := daemon.netController.NewNetwork(context.TODO(), strings.ToLower(v.Type), name, nid,

 			libnetwork.NetworkOptionGeneric(options.Generic{

 				netlabel.GenericData: netOption,

 				netlabel.EnableIPv4:  true,

@@ -430,7 +430,7 @@ func initBridgeDriver(controller *libnetwork.Controller, config config.BridgeCon

 		ipamOption = libnetwork.NetworkOptionIpam("default", "", v4Conf, v6Conf, nil)

 	}

-	_, err := controller.NewNetwork(network.DefaultNetwork, network.DefaultNetwork, "",

+	_, err := controller.NewNetwork(context.TODO(), network.DefaultNetwork, network.DefaultNetwork, "",

 		libnetwork.NetworkOptionGeneric(options.Generic{

 			netlabel.GenericData: netOption,

 			netlabel.EnableIPv4:  true,

@@ -203,7 +203,7 @@ func (daemon *Daemon) setupIngress(cfg *config.Config, create *clustertypes.Netw

 		daemon.releaseIngress(staleID)

 	}

-	if _, err := daemon.createNetwork(cfg, create.CreateRequest, create.ID, true); err != nil {

+	if _, err := daemon.createNetwork(context.TODO(), cfg, create.CreateRequest, create.ID, true); err != nil {

 		// If it is any other error other than already

 		// exists error log error and return.

 		if _, ok := err.(libnetwork.NetworkNameError); !ok {

@@ -273,16 +273,16 @@ func (daemon *Daemon) WaitForDetachment(ctx context.Context, networkName, networ

 // CreateManagedNetwork creates an agent network.

 func (daemon *Daemon) CreateManagedNetwork(create clustertypes.NetworkCreateRequest) error {

-	_, err := daemon.createNetwork(&daemon.config().Config, create.CreateRequest, create.ID, true)

+	_, err := daemon.createNetwork(context.TODO(), &daemon.config().Config, create.CreateRequest, create.ID, true)

 	return err

 }

 // CreateNetwork creates a network with the given name, driver and other optional parameters

-func (daemon *Daemon) CreateNetwork(create networktypes.CreateRequest) (*networktypes.CreateResponse, error) {

-	return daemon.createNetwork(&daemon.config().Config, create, "", false)

+func (daemon *Daemon) CreateNetwork(ctx context.Context, create networktypes.CreateRequest) (*networktypes.CreateResponse, error) {

+	return daemon.createNetwork(ctx, &daemon.config().Config, create, "", false)

 }

-func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.CreateRequest, id string, agent bool) (*networktypes.CreateResponse, error) {

+func (daemon *Daemon) createNetwork(ctx context.Context, cfg *config.Config, create networktypes.CreateRequest, id string, agent bool) (*networktypes.CreateResponse, error) {

 	if network.IsPredefined(create.Name) {

 		return nil, PredefinedNetworkError(create.Name)

 	}

@@ -304,7 +304,7 @@ func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.Crea

 	if defaultOpts, ok := cfg.DefaultNetworkOpts[driver]; create.ConfigFrom == nil && ok {

 		for k, v := range defaultOpts {

 			if _, ok := networkOptions[k]; !ok {

-				log.G(context.TODO()).WithFields(log.Fields{"driver": driver, "network": id, k: v}).Debug("Applying network default option")

+				log.G(ctx).WithFields(log.Fields{"driver": driver, "network": id, k: v}).Debug("Applying network default option")

 				networkOptions[k] = v

 			}

 		}

@@ -359,7 +359,7 @@ func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.Crea

 			// By dropping errors for agent networks, existing swarm-scoped networks also

 			// continue to behave as they did before upgrade - but new networks are still

 			// validated.

-			log.G(context.TODO()).WithFields(log.Fields{

+			log.G(ctx).WithFields(log.Fields{

 				"error":   err,

 				"network": create.Name,

 			}).Warn("Continuing with validation errors in agent IPAM")

@@ -398,7 +398,7 @@ func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.Crea

 		nwOptions = append(nwOptions, libnetwork.NetworkOptionLBEndpoint(nodeIP))

 	}

-	n, err := c.NewNetwork(driver, create.Name, id, nwOptions...)

+	n, err := c.NewNetwork(ctx, driver, create.Name, id, nwOptions...)

 	if err != nil {

 		return nil, err

 	}

new file mode 100644

@@ -0,0 +1,17 @@

+package otelutil

+

+import (

+	"go.opentelemetry.io/otel/codes"

+	"go.opentelemetry.io/otel/trace"

+)

+

+// RecordStatus records the status of a span based on the error provided.

+//

+// If err is nil, the span status is unmodified. If err is not nil, the span

+// takes status Error, and the error message is recorded.

+func RecordStatus(span trace.Span, err error) {

+	if err != nil {

+		span.RecordError(err)

+		span.SetStatus(codes.Error, err.Error())

+	}

+}

@@ -28,7 +28,7 @@ func (d *manager) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *manager) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *manager) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -179,7 +179,7 @@ func New(cfgOptions ...config.Option) (*Controller, error) {

 	c.WalkNetworks(func(nw *Network) bool {

 		if n := nw; n.hasSpecialDriver() && !n.ConfigOnly() {

-			if err := n.getController().addNetwork(n); err != nil {

+			if err := n.getController().addNetwork(context.TODO(), n); err != nil {

 				log.G(context.TODO()).Warnf("Failed to populate network %q with driver %q", nw.Name(), nw.Type())

 			}

 		}

@@ -499,7 +499,7 @@ const overlayDSROptionString = "dsr"

 // NewNetwork creates a new network of the specified network type. The options

 // are network specific and modeled in a generic way.

-func (c *Controller) NewNetwork(networkType, name string, id string, options ...NetworkOption) (_ *Network, retErr error) {

+func (c *Controller) NewNetwork(ctx context.Context, networkType, name string, id string, options ...NetworkOption) (_ *Network, retErr error) {

 	if id != "" {

 		c.networkLocker.Lock(id)

 		defer c.networkLocker.Unlock(id) //nolint:errcheck

@@ -652,7 +652,7 @@ func (c *Controller) NewNetwork(networkType, name string, id string, options ...

 	// - and updated in 87b082f3659f9ec245ab15d781e6bfffced0af83 to don't use string-matching

 	//

 	// To cut a long story short: if this broke anything, you know who to blame :)

-	if err := c.addNetwork(nw); err != nil {

+	if err := c.addNetwork(ctx, nw); err != nil {

 		if _, ok := err.(types.MaskableError); !ok { //nolint:gosimple

 			return nil, err

 		}

@@ -660,7 +660,7 @@ func (c *Controller) NewNetwork(networkType, name string, id string, options ...

 	defer func() {

 		if retErr != nil {

 			if err := nw.deleteNetwork(); err != nil {

-				log.G(context.TODO()).Warnf("couldn't roll back driver network on network %s creation failure: %v", nw.name, retErr)

+				log.G(ctx).Warnf("couldn't roll back driver network on network %s creation failure: %v", nw.name, retErr)

 			}

 		}

 	}()

@@ -681,13 +681,13 @@ func (c *Controller) NewNetwork(networkType, name string, id string, options ...

 	}

 addToStore:

-	if err := c.storeNetwork(context.TODO(), nw); err != nil {

+	if err := c.storeNetwork(ctx, nw); err != nil {

 		return nil, err

 	}

 	defer func() {

 		if retErr != nil {

 			if err := c.deleteStoredNetwork(nw); err != nil {

-				log.G(context.TODO()).Warnf("could not rollback from store, network %v on failure (%v): %v", nw, retErr, err)

+				log.G(ctx).Warnf("could not rollback from store, network %v on failure (%v): %v", nw, retErr, err)

 			}

 		}

 	}()

@@ -701,7 +701,7 @@ addToStore:

 		if retErr != nil {

 			nw.cancelDriverWatches()

 			if err := nw.leaveCluster(); err != nil {

-				log.G(context.TODO()).Warnf("Failed to leave agent cluster on network %s on failure (%v): %v", nw.name, retErr, err)

+				log.G(ctx).Warnf("Failed to leave agent cluster on network %s on failure (%v): %v", nw.name, retErr, err)

 			}

 		}

 	}()

@@ -801,14 +801,14 @@ func doReplayPoolReserve(n *Network) bool {

 	return caps.RequiresRequestReplay

 }

-func (c *Controller) addNetwork(n *Network) error {

+func (c *Controller) addNetwork(ctx context.Context, n *Network) error {

 	d, err := n.driver(true)

 	if err != nil {

 		return err

 	}

 	// Create the network

-	if err := d.CreateNetwork(n.id, n.generic, n, n.getIPData(4), n.getIPData(6)); err != nil {

+	if err := d.CreateNetwork(ctx, n.id, n.generic, n, n.getIPData(4), n.getIPData(6)); err != nil {

 		return err

 	}

@@ -1,6 +1,7 @@

 package libnetwork

 import (

+	"context"

 	"fmt"

 	"strconv"

@@ -14,7 +15,7 @@ func getPlatformOption() EndpointOption {

 }

 func (c *Controller) createGWNetwork() (*Network, error) {

-	n, err := c.NewNetwork("bridge", libnGWNetwork, "",

+	n, err := c.NewNetwork(context.TODO(), "bridge", libnGWNetwork, "",

 		NetworkOptionDriverOpts(map[string]string{

 			bridge.BridgeName:         libnGWNetwork,

 			bridge.EnableICC:          strconv.FormatBool(false),

@@ -30,7 +30,7 @@ type Driver interface {

 	// notification when a CRUD operation is performed on any

 	// entry in that table. This will be ignored for local scope

 	// drivers.

-	CreateNetwork(nid string, options map[string]interface{}, nInfo NetworkInfo, ipV4Data, ipV6Data []IPAMData) error

+	CreateNetwork(ctx context.Context, nid string, options map[string]interface{}, nInfo NetworkInfo, ipV4Data, ipV6Data []IPAMData) error

 	// DeleteNetwork invokes the driver method to delete network passing

 	// the network id.

@@ -14,6 +14,7 @@ import (

 	"github.com/docker/docker/errdefs"

 	"github.com/docker/docker/internal/modprobe"

 	"github.com/docker/docker/internal/nlwrap"

+	"github.com/docker/docker/internal/otelutil"

 	"github.com/docker/docker/libnetwork/datastore"

 	"github.com/docker/docker/libnetwork/driverapi"

 	"github.com/docker/docker/libnetwork/drivers/bridge/internal/rlkclient"

@@ -741,7 +742,7 @@ func (d *driver) GetSkipGwAlloc(opts options.Generic) (ipv4, ipv6 bool, _ error)

 }

 // CreateNetwork creates a new network using the bridge driver.

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	// Sanity checks

 	d.Lock()

 	if _, ok := d.networks[id]; ok {

@@ -787,11 +788,11 @@ func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo d

 	}

 	// there is no conflict, now create the network

-	if err = d.createNetwork(config); err != nil {

+	if err = d.createNetwork(ctx, config); err != nil {

 		return err

 	}

-	return d.storeUpdate(context.TODO(), config)

+	return d.storeUpdate(ctx, config)

 }

 func (d *driver) checkConflict(config *networkConfiguration) error {

@@ -808,7 +809,18 @@ func (d *driver) checkConflict(config *networkConfiguration) error {

 	return nil

 }

-func (d *driver) createNetwork(config *networkConfiguration) (err error) {

+func (d *driver) createNetwork(ctx context.Context, config *networkConfiguration) (err error) {

+	ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.bridge.createNetwork", trace.WithAttributes(

+		attribute.Bool("bridge.enable_ipv4", config.EnableIPv4),

+		attribute.Bool("bridge.enable_ipv6", config.EnableIPv6),

+		attribute.Bool("bridge.icc", config.EnableICC),

+		attribute.Int("bridge.mtu", config.Mtu),

+		attribute.Bool("bridge.internal", config.Internal)))

+	defer func() {

+		otelutil.RecordStatus(span, err)

+		span.End()

+	}()

+

 	// Create or retrieve the bridge L3 interface

 	bridgeIface, err := newInterface(d.nlh, config)

 	if err != nil {

@@ -280,7 +280,7 @@ func TestCreateFullOptions(t *testing.T) {

 			AuxAddresses: map[string]*net.IPNet{DefaultGatewayV4AuxKey: defgw},

 		},

 	}

-	err := d.CreateNetwork("dummy", netOption, nil, ipdList, getIPv6Data(t))

+	err := d.CreateNetwork(context.Background(), "dummy", netOption, nil, ipdList, getIPv6Data(t))

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -306,7 +306,7 @@ func TestCreateNoConfig(t *testing.T) {

 	genericOption := make(map[string]interface{})

 	genericOption[netlabel.GenericData] = netconfig

-	if err := d.CreateNetwork("dummy", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "dummy", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

 }

@@ -356,7 +356,7 @@ func TestCreateFullOptionsLabels(t *testing.T) {

 		},

 	}

-	err := d.CreateNetwork("dummy", netOption, nil, ipdList, ipd6List)

+	err := d.CreateNetwork(context.Background(), "dummy", netOption, nil, ipdList, ipd6List)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -510,11 +510,11 @@ func TestCreate(t *testing.T) {

 	genericOption := make(map[string]interface{})

 	genericOption[netlabel.GenericData] = netconfig

-	if err := d.CreateNetwork("dummy", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "dummy", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

-	err := d.CreateNetwork("dummy", genericOption, nil, getIPv4Data(t), nil)

+	err := d.CreateNetwork(context.Background(), "dummy", genericOption, nil, getIPv4Data(t), nil)

 	if err == nil {

 		t.Fatal("Expected bridge driver to refuse creation of second network with default name")

 	}

@@ -536,7 +536,7 @@ func TestCreateFail(t *testing.T) {

 	genericOption := make(map[string]interface{})

 	genericOption[netlabel.GenericData] = netconfig

-	if err := d.CreateNetwork("dummy", genericOption, nil, getIPv4Data(t), nil); err == nil {

+	if err := d.CreateNetwork(context.Background(), "dummy", genericOption, nil, getIPv4Data(t), nil); err == nil {

 		t.Fatal("Bridge creation was expected to fail")

 	}

 }

@@ -559,7 +559,7 @@ func TestCreateMultipleNetworks(t *testing.T) {

 	config1 := &networkConfiguration{BridgeName: "net_test_1", EnableIPv4: true}

 	genericOption = make(map[string]interface{})

 	genericOption[netlabel.GenericData] = config1

-	if err := d.CreateNetwork("1", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "1", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -567,7 +567,7 @@ func TestCreateMultipleNetworks(t *testing.T) {

 	config2 := &networkConfiguration{BridgeName: "net_test_2", EnableIPv4: true}

 	genericOption[netlabel.GenericData] = config2

-	if err := d.CreateNetwork("2", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "2", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -575,7 +575,7 @@ func TestCreateMultipleNetworks(t *testing.T) {

 	config3 := &networkConfiguration{BridgeName: "net_test_3", EnableIPv4: true}

 	genericOption[netlabel.GenericData] = config3

-	if err := d.CreateNetwork("3", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "3", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -583,7 +583,7 @@ func TestCreateMultipleNetworks(t *testing.T) {

 	config4 := &networkConfiguration{BridgeName: "net_test_4", EnableIPv4: true}

 	genericOption[netlabel.GenericData] = config4

-	if err := d.CreateNetwork("4", genericOption, nil, getIPv4Data(t), nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), "4", genericOption, nil, getIPv4Data(t), nil); err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -805,7 +805,7 @@ func testQueryEndpointInfo(t *testing.T, ulPxyEnabled bool) {

 	genericOption[netlabel.GenericData] = netconfig

 	ipdList := getIPv4Data(t)

-	err = d.CreateNetwork("net1", genericOption, nil, ipdList, nil)

+	err = d.CreateNetwork(context.Background(), "net1", genericOption, nil, ipdList, nil)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -908,7 +908,7 @@ func TestLinkContainers(t *testing.T) {

 	genericOption[netlabel.GenericData] = netconfig

 	ipdList := getIPv4Data(t)

-	err := d.CreateNetwork("net1", genericOption, nil, ipdList, nil)

+	err := d.CreateNetwork(context.Background(), "net1", genericOption, nil, ipdList, nil)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -1218,7 +1218,7 @@ func TestSetDefaultGw(t *testing.T) {

 		},

 	}

-	err := d.CreateNetwork("dummy", option, nil, ipam4, ipam6)

+	err := d.CreateNetwork(context.Background(), "dummy", option, nil, ipam4, ipam6)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -1341,7 +1341,7 @@ func TestCreateWithExistingBridge(t *testing.T) {

 	// Set network gateway to X.X.X.1

 	ipv4Data[0].Gateway.IP[len(ipv4Data[0].Gateway.IP)-1] = 1

-	if err := d.CreateNetwork(brName, genericOption, nil, ipv4Data, nil); err != nil {

+	if err := d.CreateNetwork(context.Background(), brName, genericOption, nil, ipv4Data, nil); err != nil {

 		t.Fatalf("Failed to create bridge network: %v", err)

 	}

@@ -1388,11 +1388,11 @@ func TestCreateParallel(t *testing.T) {

 			config := &networkConfiguration{BridgeName: name, EnableIPv4: true}

 			genericOption := make(map[string]interface{})

 			genericOption[netlabel.GenericData] = config

-			if err := d.CreateNetwork(name, genericOption, nil, ipV4Data, nil); err != nil {

+			if err := d.CreateNetwork(context.Background(), name, genericOption, nil, ipV4Data, nil); err != nil {

 				ch <- fmt.Errorf("failed to create %s", name)

 				return

 			}

-			if err := d.CreateNetwork(name, genericOption, nil, ipV4Data, nil); err == nil {

+			if err := d.CreateNetwork(context.Background(), name, genericOption, nil, ipV4Data, nil); err == nil {

 				ch <- fmt.Errorf("failed was able to create overlap %s", name)

 				return

 			}

@@ -51,7 +51,7 @@ func (d *driver) populateNetworks() error {

 	for _, kvo := range kvol {

 		ncfg := kvo.(*networkConfiguration)

-		if err = d.createNetwork(ncfg); err != nil {

+		if err = d.createNetwork(context.TODO(), ncfg); err != nil {

 			log.G(context.TODO()).Warnf("could not create bridge network for id %s bridge name %s while booting up from persistent state: %v", ncfg.ID, ncfg.BridgeName, err)

 		}

 		log.G(context.TODO()).Debugf("Network (%.7s) restored", ncfg.ID)

@@ -28,7 +28,7 @@ func (d *driver) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -31,7 +31,7 @@ func TestLinkCreate(t *testing.T) {

 	ipdList := getIPv4Data(t)

 	ipd6List := getIPv6Data(t)

-	err = d.CreateNetwork("dummy", option, nil, ipdList, ipd6List)

+	err = d.CreateNetwork(context.Background(), "dummy", option, nil, ipdList, ipd6List)

 	assert.NilError(t, err, "Failed to create bridge")

 	te := newTestEndpoint46(ipdList[0].Pool, ipd6List[0].Pool, 10)

@@ -91,7 +91,7 @@ func TestLinkCreateTwo(t *testing.T) {

 	}

 	ipdList := getIPv4Data(t)

-	err = d.CreateNetwork("dummy", option, nil, ipdList, getIPv6Data(t))

+	err = d.CreateNetwork(context.Background(), "dummy", option, nil, ipdList, getIPv6Data(t))

 	assert.NilError(t, err, "Failed to create bridge")

 	te1 := newTestEndpoint(ipdList[0].Pool, 11)

@@ -118,7 +118,7 @@ func TestLinkCreateNoEnableIPv6(t *testing.T) {

 	}

 	ipdList := getIPv4Data(t)

-	err = d.CreateNetwork("dummy", option, nil, ipdList, getIPv6Data(t))

+	err = d.CreateNetwork(context.Background(), "dummy", option, nil, ipdList, getIPv6Data(t))

 	assert.NilError(t, err, "Failed to create bridge")

 	te := newTestEndpoint(ipdList[0].Pool, 30)

@@ -144,7 +144,7 @@ func TestLinkDelete(t *testing.T) {

 	}

 	ipdList := getIPv4Data(t)

-	err = d.CreateNetwork("dummy", option, nil, ipdList, getIPv6Data(t))

+	err = d.CreateNetwork(context.Background(), "dummy", option, nil, ipdList, getIPv6Data(t))

 	assert.NilError(t, err, "Failed to create bridge")

 	te := newTestEndpoint(ipdList[0].Pool, 30)

@@ -56,7 +56,7 @@ func TestPortMappingConfig(t *testing.T) {

 	}

 	ipdList4 := getIPv4Data(t)

-	err := d.CreateNetwork("dummy", netOptions, nil, ipdList4, getIPv6Data(t))

+	err := d.CreateNetwork(context.Background(), "dummy", netOptions, nil, ipdList4, getIPv6Data(t))

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -142,7 +142,7 @@ func TestPortMappingV6Config(t *testing.T) {

 	ipdList4 := getIPv4Data(t)

 	ipdList6 := getIPv6Data(t)

-	err := d.CreateNetwork("dummy", netOptions, nil, ipdList4, ipdList6)

+	err := d.CreateNetwork(context.Background(), "dummy", netOptions, nil, ipdList4, ipdList6)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -381,7 +381,7 @@ func TestOutgoingNATRules(t *testing.T) {

 				nc.AddressIPv6 = nil

 				ipv6Data = nil

 			}

-			if err := r.d.CreateNetwork("nattest", map[string]interface{}{netlabel.GenericData: nc}, nil, ipv4Data, ipv6Data); err != nil {

+			if err := r.d.CreateNetwork(context.Background(), "nattest", map[string]interface{}{netlabel.GenericData: nc}, nil, ipv4Data, ipv6Data); err != nil {

 				t.Fatal(err)

 			}

 			defer func() {

@@ -38,7 +38,7 @@ func (d *driver) DecodeTableEntry(tablename string, key string, value []byte) (s

 	return "", nil

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	d.Lock()

 	defer d.Unlock()

@@ -1,6 +1,7 @@

 package host

 import (

+	"context"

 	"testing"

 	"github.com/docker/docker/libnetwork/types"

@@ -13,7 +14,7 @@ func TestDriver(t *testing.T) {

 		t.Fatal("Unexpected network type returned by driver")

 	}

-	err := d.CreateNetwork("first", nil, nil, nil, nil)

+	err := d.CreateNetwork(context.Background(), "first", nil, nil, nil, nil)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -22,7 +23,7 @@ func TestDriver(t *testing.T) {

 		t.Fatal("Unexpected network id stored")

 	}

-	err = d.CreateNetwork("second", nil, nil, nil, nil)

+	err = d.CreateNetwork(context.Background(), "second", nil, nil, nil, nil)

 	if err == nil {

 		t.Fatal("Second network creation should fail on this driver")

 	}

@@ -17,7 +17,7 @@ import (

 )

 // CreateNetwork the network for the specified driver type

-func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, nid string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	kv, err := kernel.GetKernelVersion()

 	if err != nil {

 		return fmt.Errorf("failed to check kernel version for ipvlan driver support: %v", err)

@@ -28,7 +28,7 @@ func (d *driver) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -16,7 +16,7 @@ import (

 )

 // CreateNetwork the network for the specified driver type

-func (d *driver) CreateNetwork(nid string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, nid string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	// reject a null v4 network if ipv4 is required

 	if v, ok := option[netlabel.EnableIPv4]; ok && v.(bool) {

 		if len(ipV4Data) == 0 || ipV4Data[0].Pool.String() == "0.0.0.0/0" {

@@ -28,7 +28,7 @@ func (d *driver) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -38,7 +38,7 @@ func (d *driver) DecodeTableEntry(tablename string, key string, value []byte) (s

 	return "", nil

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	d.Lock()

 	defer d.Unlock()

@@ -1,6 +1,7 @@

 package null

 import (

+	"context"

 	"testing"

 	"github.com/docker/docker/libnetwork/types"

@@ -13,7 +14,7 @@ func TestDriver(t *testing.T) {

 		t.Fatalf("Unexpected network type returned by driver")

 	}

-	err := d.CreateNetwork("first", nil, nil, nil, nil)

+	err := d.CreateNetwork(context.Background(), "first", nil, nil, nil, nil)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -22,7 +23,7 @@ func TestDriver(t *testing.T) {

 		t.Fatalf("Unexpected network id stored")

 	}

-	err = d.CreateNetwork("second", nil, nil, nil, nil)

+	err = d.CreateNetwork(context.Background(), "second", nil, nil, nil, nil)

 	if err == nil {

 		t.Fatalf("Second network creation should fail on this driver")

 	}

@@ -79,7 +79,7 @@ func (d *driver) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	if id == "" {

 		return fmt.Errorf("invalid network id")

 	}

@@ -162,7 +162,7 @@ func (n *network) releaseVxlanID() {

 	}

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -162,7 +162,7 @@ func (d *driver) DecodeTableEntry(tablename string, key string, value []byte) (s

 	return "", nil

 }

-func (d *driver) CreateNetwork(id string, options map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, options map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	create := &api.CreateNetworkRequest{

 		NetworkID: id,

 		Options:   options,

@@ -459,7 +459,7 @@ func TestRemoteDriver(t *testing.T) {

 	}

 	netID := "dummy-network"

-	err = d.CreateNetwork(netID, map[string]interface{}{}, nil, nil, nil)

+	err = d.CreateNetwork(context.Background(), netID, map[string]interface{}{}, nil, nil, nil)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -60,7 +60,7 @@ func (d *driver) NetworkFree(id string) error {

 	return types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	var (

 		networkName   string

 		interfaceName string

@@ -84,10 +84,10 @@ func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo d

 	existingNetwork := d.network(id)

 	if existingNetwork != nil {

-		log.G(context.TODO()).Debugf("Network preexists. Deleting %s", id)

+		log.G(ctx).Debugf("Network preexists. Deleting %s", id)

 		err := d.DeleteNetwork(id)

 		if err != nil {

-			log.G(context.TODO()).Errorf("Error deleting stale network %s", err.Error())

+			log.G(ctx).Errorf("Error deleting stale network %s", err.Error())

 		}

 	}

@@ -281,7 +281,7 @@ func (d *driver) createNetwork(config *networkConfiguration) *hnsNetwork {

 }

 // Create a new network

-func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (d *driver) CreateNetwork(ctx context.Context, id string, option map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	if _, err := d.getNetwork(id); err == nil {

 		return types.ForbiddenErrorf("network %s exists", id)

 	}

@@ -371,7 +371,7 @@ func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo d

 		}

 		configuration := string(configurationb)

-		log.G(context.TODO()).Debugf("HNSNetwork Request =%v Address Space=%v", configuration, subnets)

+		log.G(ctx).Debugf("HNSNetwork Request =%v Address Space=%v", configuration, subnets)

 		hnsresponse, err := hcsshim.HNSNetworkRequest("POST", "", configuration)

 		if err != nil {

@@ -416,15 +416,15 @@ func (d *driver) CreateNetwork(id string, option map[string]interface{}, nInfo d

 		if endpoints, err := hcsshim.HNSListEndpointRequest(); err == nil {

 			for _, ep := range endpoints {

 				if ep.VirtualNetwork == config.HnsID {

-					log.G(context.TODO()).Infof("Removing stale HNS endpoint %s", ep.Id)

+					log.G(ctx).Infof("Removing stale HNS endpoint %s", ep.Id)

 					_, err = hcsshim.HNSEndpointRequest("DELETE", ep.Id, "")

 					if err != nil {

-						log.G(context.TODO()).Warnf("Error removing HNS endpoint %s", ep.Id)

+						log.G(ctx).Warnf("Error removing HNS endpoint %s", ep.Id)

 					}

 				}

 			}

 		} else {

-			log.G(context.TODO()).Warnf("Error listing HNS endpoints for network %s", config.HnsID)

+			log.G(ctx).Warnf("Error listing HNS endpoints for network %s", config.HnsID)

 		}

 		n.created = true

@@ -33,7 +33,7 @@ func testNetwork(networkType string, t *testing.T) {

 		},

 	}

-	err = d.CreateNetwork("dummy", netOption, nil, ipdList, nil)

+	err = d.CreateNetwork(context.Background(), "dummy", netOption, nil, ipdList, nil)

 	if err != nil {

 		t.Fatalf("Failed to create bridge: %v", err)

 	}

@@ -416,7 +416,7 @@ func TestUpdateSvcRecord(t *testing.T) {

 				assert.NilError(t, err)

 				ipam6 = []*IpamConf{{PreferredPool: net6.String()}}

 			}

-			n, err := ctrlr.NewNetwork("bridge", "net1", "", nil,

+			n, err := ctrlr.NewNetwork(context.Background(), "bridge", "net1", "", nil,

 				NetworkOptionEnableIPv4(tc.addr4 != ""),

 				NetworkOptionEnableIPv6(tc.addr6 != ""),

 				NetworkOptionIpam(defaultipam.DriverName, "", ipam4, ipam6, nil),

@@ -484,7 +484,7 @@ func TestSRVServiceQuery(t *testing.T) {

 	}

 	defer c.Stop()

-	n, err := c.NewNetwork("bridge", "net1", "",

+	n, err := c.NewNetwork(context.Background(), "bridge", "net1", "",

 		NetworkOptionEnableIPv4(true),

 	)

 	if err != nil {

@@ -585,7 +585,7 @@ func TestServiceVIPReuse(t *testing.T) {

 	}

 	defer c.Stop()

-	n, err := c.NewNetwork("bridge", "net1", "", nil,

+	n, err := c.NewNetwork(context.Background(), "bridge", "net1", "", nil,

 		NetworkOptionEnableIPv4(true),

 	)

 	if err != nil {

@@ -712,10 +712,10 @@ func TestIpamReleaseOnNetDriverFailures(t *testing.T) {

 	// Test whether ipam state release is invoked  on network create failure from net driver

 	// by checking whether subsequent network creation requesting same gateway IP succeeds

 	ipamOpt := NetworkOptionIpam(defaultipam.DriverName, "", []*IpamConf{{PreferredPool: "10.34.0.0/16", Gateway: "10.34.255.254"}}, nil, nil)

-	_, err = c.NewNetwork(badDriverName, "badnet1", "", ipamOpt)

+	_, err = c.NewNetwork(context.Background(), badDriverName, "badnet1", "", ipamOpt)

 	assert.Check(t, is.ErrorContains(err, "I will not create any network"))

-	gnw, err := c.NewNetwork("bridge", "goodnet1", "",

+	gnw, err := c.NewNetwork(context.Background(), "bridge", "goodnet1", "",

 		NetworkOptionEnableIPv4(true),

 		ipamOpt,

 	)

@@ -728,7 +728,7 @@ func TestIpamReleaseOnNetDriverFailures(t *testing.T) {

 	// Now check whether ipam release works on endpoint creation failure

 	bd.failNetworkCreation = false

-	bnw, err := c.NewNetwork(badDriverName, "badnet2", "",

+	bnw, err := c.NewNetwork(context.Background(), badDriverName, "badnet2", "",

 		NetworkOptionEnableIPv4(true),

 		ipamOpt,

 	)

@@ -747,7 +747,7 @@ func TestIpamReleaseOnNetDriverFailures(t *testing.T) {

 	// Now create good bridge network with different gateway

 	ipamOpt2 := NetworkOptionIpam(defaultipam.DriverName, "", []*IpamConf{{PreferredPool: "10.35.0.0/16", Gateway: "10.35.255.253"}}, nil, nil)

-	gnw, err = c.NewNetwork("bridge", "goodnet2", "",

+	gnw, err = c.NewNetwork(context.Background(), "bridge", "goodnet2", "",

 		NetworkOptionEnableIPv4(true),

 		ipamOpt2,

 	)

@@ -784,7 +784,7 @@ func badDriverRegister(reg driverapi.Registerer) error {

 	return reg.RegisterDriver(badDriverName, &bd, driverapi.Capability{DataScope: scope.Local})

 }

-func (b *badDriver) CreateNetwork(nid string, options map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

+func (b *badDriver) CreateNetwork(ctx context.Context, nid string, options map[string]interface{}, nInfo driverapi.NetworkInfo, ipV4Data, ipV6Data []driverapi.IPAMData) error {

 	if b.failNetworkCreation {

 		return fmt.Errorf("I will not create any network")

 	}

@@ -60,7 +60,7 @@ func newController(t *testing.T) *libnetwork.Controller {

 }

 func createTestNetwork(c *libnetwork.Controller, networkType, networkName string, netOption options.Generic, ipamV4Configs, ipamV6Configs []*libnetwork.IpamConf) (*libnetwork.Network, error) {

-	return c.NewNetwork(networkType, networkName, "",

+	return c.NewNetwork(context.Background(), networkType, networkName, "",

 		libnetwork.NetworkOptionGeneric(netOption),

 		libnetwork.NetworkOptionIpam(defaultipam.DriverName, "", ipamV4Configs, ipamV6Configs, nil))

 }

@@ -130,7 +130,7 @@ func TestNilRemoteDriver(t *testing.T) {

 	defer netnsutils.SetupTestOSContext(t)()

 	controller := newController(t)

-	_, err := controller.NewNetwork("framerelay", "dummy", "",

+	_, err := controller.NewNetwork(context.Background(), "framerelay", "dummy", "",

 		libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))

 	// TODO(thaJeztah): should attempting to use a non-existing plugin/driver return an [errdefs.InvalidParameter] ?

@@ -239,7 +239,7 @@ func TestNetworkConfig(t *testing.T) {

 	controller := newController(t)

 	// Verify config network cannot inherit another config network

-	_, err := controller.NewNetwork("bridge", "config_network0", "",

+	_, err := controller.NewNetwork(context.Background(), "bridge", "config_network0", "",

 		libnetwork.NetworkOptionConfigOnly(),

 		libnetwork.NetworkOptionConfigFrom("anotherConfigNw"),

 	)

@@ -265,7 +265,7 @@ func TestNetworkConfig(t *testing.T) {

 		libnetwork.NetworkOptionIpam("default", "", ipamV4ConfList, ipamV6ConfList, nil),

 	}

-	configNetwork, err := controller.NewNetwork(bridgeNetType, "config_network0", "", netOptions...)

+	configNetwork, err := controller.NewNetwork(context.Background(), bridgeNetType, "config_network0", "", netOptions...)

 	assert.NilError(t, err)

 	// Verify a config-only network cannot be created with network operator configurations

@@ -275,7 +275,7 @@ func TestNetworkConfig(t *testing.T) {

 		libnetwork.NetworkOptionIngress(true),