@@ -126,7 +126,7 @@ func (iface *lnInterface) init(c *libnetwork.Controller, n *libnetwork.Network)

 		return

 	}

-	if err := ep.Join(sbx); err != nil {

+	if err := ep.Join(context.TODO(), sbx); err != nil {

 		iface.err = err

 		return

 	}

@@ -797,7 +797,7 @@ func (daemon *Daemon) connectToNetwork(ctx context.Context, cfg *config.Config,

 		return err

 	}

-	if err := ep.Join(sb, joinOptions...); err != nil {

+	if err := ep.Join(ctx, sb, joinOptions...); err != nil {

 		return err

 	}

@@ -8,11 +8,15 @@ import (

 	"github.com/docker/docker/libcontainerd/types"

 	"github.com/docker/docker/oci"

 	specs "github.com/opencontainers/runtime-spec/specs-go"

+	"go.opentelemetry.io/otel"

 )

 // initializeCreatedTask performs any initialization that needs to be done to

 // prepare a freshly-created task to be started.

 func (daemon *Daemon) initializeCreatedTask(ctx context.Context, tsk types.Task, container *container.Container, spec *specs.Spec) error {

+	ctx, span := otel.Tracer("").Start(ctx, "daemon.initializeCreatedTask")

+	defer span.End()

+

 	if !container.Config.NetworkDisabled {

 		nspath, ok := oci.NamespacePath(spec, specs.NetworkNamespace)

 		if ok && nspath == "" { // the runtime has been instructed to create a new network namespace for tsk.

@@ -20,7 +24,7 @@ func (daemon *Daemon) initializeCreatedTask(ctx context.Context, tsk types.Task,

 			if err != nil {

 				return errdefs.System(err)

 			}

-			return sb.FinishConfig()

+			return sb.FinishConfig(ctx)

 		}

 	}

 	return nil

@@ -55,7 +55,7 @@ func (d *manager) EndpointOperInfo(nid, eid string) (map[string]interface{}, err

 	return nil, types.NotImplementedErrorf("not implemented")

 }

-func (d *manager) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *manager) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -85,7 +85,7 @@ func (sb *Sandbox) setupDefaultGW() error {

 		}

 	}()

-	if err = newEp.sbJoin(sb); err != nil {

+	if err = newEp.sbJoin(context.TODO(), sb); err != nil {

 		return fmt.Errorf("container %s: endpoint join on GW Network failed: %v", sb.containerID, err)

 	}

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

 	EndpointOperInfo(nid, eid string) (map[string]interface{}, error)

 	// Join method is invoked when a Sandbox is attached to an endpoint.

-	Join(nid, eid string, sboxKey string, jinfo JoinInfo, options map[string]interface{}) error

+	Join(ctx context.Context, nid, eid string, sboxKey string, jinfo JoinInfo, options map[string]interface{}) error

 	// Leave method is invoked when a Sandbox detaches from an endpoint.

 	Leave(nid, eid string) error

@@ -1319,7 +1319,13 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

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

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	network, err := d.getNetwork(nid)

 	if err != nil {

 		return err

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

 		t.Fatalf("Failed to create an endpoint : %s", err.Error())

 	}

-	err = d.Join("net1", "ep1", "sbox", te, sbOptions)

+	err = d.Join(context.Background(), "net1", "ep1", "sbox", te, sbOptions)

 	if err != nil {

 		t.Fatalf("Failed to join the endpoint: %v", err)

 	}

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

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

 	sbOptions[netlabel.ExposedPorts] = exposedPorts

-	err = d.Join("net1", "ep1", "sbox", te1, sbOptions)

+	err = d.Join(context.Background(), "net1", "ep1", "sbox", te1, sbOptions)

 	if err != nil {

 		t.Fatalf("Failed to join the endpoint: %v", err)

 	}

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

 		"ChildEndpoints": []string{"ep1"},

 	}

-	err = d.Join("net1", "ep2", "", te2, sbOptions)

+	err = d.Join(context.Background(), "net1", "ep2", "", te2, sbOptions)

 	if err != nil {

 		t.Fatal("Failed to link ep1 and ep2")

 	}

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

 		"ChildEndpoints": []string{"ep1", "ep4"},

 	}

-	err = d.Join("net1", "ep2", "", te2, sbOptions)

+	err = d.Join(context.Background(), "net1", "ep2", "", te2, sbOptions)

 	if err != nil {

 		t.Fatal(err)

 	}

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

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

 	}

-	err = d.Join("dummy", "ep", "sbox", te, nil)

+	err = d.Join(context.Background(), "dummy", "ep", "sbox", te, nil)

 	if err != nil {

 		t.Fatalf("Failed to join endpoint: %v", err)

 	}

@@ -55,7 +55,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 	return nil, types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return types.NotImplementedErrorf("not implemented")

 }

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

 		t.Fatalf("Failed to create a link: %s", err.Error())

 	}

-	err = d.Join("dummy", "ep", "sbox", te, nil)

+	err = d.Join(context.Background(), "dummy", "ep", "sbox", te, nil)

 	if err != nil {

 		t.Fatalf("Failed to create a link: %s", err.Error())

 	}

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

 		t.Fatalf("Failed to create the endpoint: %s", err.Error())

 	}

-	if err = d.Join("dummy", "ep1", "sbox", te, sbOptions); err != nil {

+	if err = d.Join(context.Background(), "dummy", "ep1", "sbox", te, sbOptions); err != nil {

 		t.Fatalf("Failed to join the endpoint: %v", err)

 	}

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

 		t.Fatalf("Failed to create the endpoint: %s", err.Error())

 	}

-	if err = d.Join("dummy", "ep1", "sbox", te, sbOptions); err != nil {

+	if err = d.Join(context.Background(), "dummy", "ep1", "sbox", te, sbOptions); err != nil {

 		t.Fatalf("Failed to join the endpoint: %v", err)

 	}

@@ -68,7 +68,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return nil

 }

@@ -12,6 +12,9 @@ import (

 	"github.com/docker/docker/libnetwork/netutils"

 	"github.com/docker/docker/libnetwork/ns"

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

+	"go.opentelemetry.io/otel"

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

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

 )

 type staticRoute struct {

@@ -26,7 +29,13 @@ const (

 )

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

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

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	n, err := d.getNetwork(nid)

 	if err != nil {

 		return err

@@ -63,7 +72,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 			if err := jinfo.AddStaticRoute(defaultRoute.Destination, defaultRoute.RouteType, defaultRoute.NextHop); err != nil {

 				return fmt.Errorf("failed to set an ipvlan l3/l3s mode ipv4 default gateway: %v", err)

 			}

-			log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, Ipvlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, Ipvlan_Mode: %s, Parent: %s",

 				ep.addr.IP.String(), n.config.IpvlanMode, n.config.Parent)

 			// If the endpoint has a v6 address, set a v6 default route

 			if ep.addrv6 != nil {

@@ -74,7 +83,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 				if err = jinfo.AddStaticRoute(default6Route.Destination, default6Route.RouteType, default6Route.NextHop); err != nil {

 					return fmt.Errorf("failed to set an ipvlan l3/l3s mode ipv6 default gateway: %v", err)

 				}

-				log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s, Ipvlan_Mode: %s, Parent: %s",

+				log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s, Ipvlan_Mode: %s, Parent: %s",

 					ep.addrv6.IP.String(), n.config.IpvlanMode, n.config.Parent)

 			}

 		case modeL2:

@@ -92,7 +101,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 				if err != nil {

 					return err

 				}

-				log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, Gateway: %s, Ipvlan_Mode: %s, Parent: %s",

+				log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, Gateway: %s, Ipvlan_Mode: %s, Parent: %s",

 					ep.addr.IP.String(), v4gw.String(), n.config.IpvlanMode, n.config.Parent)

 			}

 			// parse and correlate the endpoint v6 address with the available v6 subnets

@@ -109,17 +118,17 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 				if err != nil {

 					return err

 				}

-				log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s, Gateway: %s, Ipvlan_Mode: %s, Parent: %s",

+				log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s, Gateway: %s, Ipvlan_Mode: %s, Parent: %s",

 					ep.addrv6.IP.String(), v6gw.String(), n.config.IpvlanMode, n.config.Parent)

 			}

 		}

 	} else {

 		if len(n.config.Ipv4Subnets) > 0 {

-			log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, IpVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv4_Addr: %s, IpVlan_Mode: %s, Parent: %s",

 				ep.addr.IP.String(), n.config.IpvlanMode, n.config.Parent)

 		}

 		if len(n.config.Ipv6Subnets) > 0 {

-			log.G(context.TODO()).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s IpVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Ipvlan Endpoint Joined with IPv6_Addr: %s IpVlan_Mode: %s, Parent: %s",

 				ep.addrv6.IP.String(), n.config.IpvlanMode, n.config.Parent)

 		}

 		// If n.config.Internal was set locally by the driver because there's no parent

@@ -55,7 +55,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 	return nil, types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -11,10 +11,19 @@ import (

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

 	"github.com/docker/docker/libnetwork/netutils"

 	"github.com/docker/docker/libnetwork/ns"

+	"go.opentelemetry.io/otel"

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

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

 )

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

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

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	n, err := d.getNetwork(nid)

 	if err != nil {

 		return err

@@ -54,7 +63,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 			if err != nil {

 				return err

 			}

-			log.G(context.TODO()).Debugf("Macvlan Endpoint Joined with IPv4_Addr: %s, Gateway: %s, MacVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Macvlan Endpoint Joined with IPv4_Addr: %s, Gateway: %s, MacVlan_Mode: %s, Parent: %s",

 				ep.addr.IP.String(), v4gw.String(), n.config.MacvlanMode, n.config.Parent)

 		}

 		// parse and match the endpoint address with the available v6 subnets

@@ -71,16 +80,16 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 			if err != nil {

 				return err

 			}

-			log.G(context.TODO()).Debugf("Macvlan Endpoint Joined with IPv6_Addr: %s Gateway: %s MacVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Macvlan Endpoint Joined with IPv6_Addr: %s Gateway: %s MacVlan_Mode: %s, Parent: %s",

 				ep.addrv6.IP.String(), v6gw.String(), n.config.MacvlanMode, n.config.Parent)

 		}

 	} else {

 		if len(n.config.Ipv4Subnets) > 0 {

-			log.G(context.TODO()).Debugf("Macvlan Endpoint Joined with IPv4_Addr: %s, MacVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Macvlan Endpoint Joined with IPv4_Addr: %s, MacVlan_Mode: %s, Parent: %s",

 				ep.addr.IP.String(), n.config.MacvlanMode, n.config.Parent)

 		}

 		if len(n.config.Ipv6Subnets) > 0 {

-			log.G(context.TODO()).Debugf("Macvlan Endpoint Joined with IPv6_Addr: %s MacVlan_Mode: %s, Parent: %s",

+			log.G(ctx).Debugf("Macvlan Endpoint Joined with IPv6_Addr: %s MacVlan_Mode: %s, Parent: %s",

 				ep.addrv6.IP.String(), n.config.MacvlanMode, n.config.Parent)

 		}

 		// If n.config.Internal was set locally by the driver because there's no parent

@@ -55,7 +55,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 	return nil, types.NotImplementedErrorf("not implemented")

 }

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -68,7 +68,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return nil

 }

@@ -14,10 +14,19 @@ import (

 	"github.com/docker/docker/libnetwork/osl"

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

 	"github.com/gogo/protobuf/proto"

+	"go.opentelemetry.io/otel"

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

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

 )

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

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

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	if err := validateID(nid, eid); err != nil {

 		return err

 	}

@@ -74,7 +83,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 		return err

 	}

-	if err = sbox.AddInterface(overlayIfName, "veth", osl.WithMaster(s.brName)); err != nil {

+	if err = sbox.AddInterface(ctx, overlayIfName, "veth", osl.WithMaster(s.brName)); err != nil {

 		return fmt.Errorf("could not add veth pair inside the network sandbox: %v", err)

 	}

@@ -96,7 +105,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 			continue

 		}

 		if err = jinfo.AddStaticRoute(sub.subnetIP, types.NEXTHOP, s.gwIP.IP); err != nil {

-			log.G(context.TODO()).Errorf("Adding subnet %s static route in network %q failed\n", s.subnetIP, n.id)

+			log.G(ctx).Errorf("Adding subnet %s static route in network %q failed\n", s.subnetIP, n.id)

 		}

 	}

@@ -110,7 +119,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 	d.peerAdd(nid, eid, ep.addr.IP, ep.addr.Mask, ep.mac, d.advertiseAddress, true)

 	if err = d.checkEncryption(nid, nil, true, true); err != nil {

-		log.G(context.TODO()).Warn(err)

+		log.G(ctx).Warn(err)

 	}

 	buf, err := proto.Marshal(&PeerRecord{

@@ -123,7 +132,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 	}

 	if err := jinfo.AddTableEntry(ovPeerTable, eid, buf); err != nil {

-		log.G(context.TODO()).Errorf("overlay: Failed adding table entry to joininfo: %v", err)

+		log.G(ctx).Errorf("overlay: Failed adding table entry to joininfo: %v", err)

 	}

 	return nil

@@ -426,7 +426,7 @@ func (n *network) setupSubnetSandbox(s *subnet, brName, vxlanName string) error

 	// create a bridge and vxlan device for this subnet and move it to the sandbox

 	sbox := n.sbox

-	if err := sbox.AddInterface(brName, "br", osl.WithIPv4Address(s.gwIP), osl.WithIsBridge(true)); err != nil {

+	if err := sbox.AddInterface(context.TODO(), brName, "br", osl.WithIPv4Address(s.gwIP), osl.WithIsBridge(true)); err != nil {

 		return fmt.Errorf("bridge creation in sandbox failed for subnet %q: %v", s.subnetIP.String(), err)

 	}

@@ -438,7 +438,7 @@ func (n *network) setupSubnetSandbox(s *subnet, brName, vxlanName string) error

 		return err

 	}

-	if err := sbox.AddInterface(vxlanName, "vxlan", osl.WithMaster(brName)); err != nil {

+	if err := sbox.AddInterface(context.TODO(), vxlanName, "vxlan", osl.WithMaster(brName)); err != nil {

 		// If adding vxlan device to the overlay namespace fails, remove the bridge interface we

 		// already added to the namespace. This allows the caller to try the setup again.

 		for _, iface := range sbox.Interfaces() {

@@ -190,7 +190,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return types.NotImplementedErrorf("not implemented")

 }

@@ -258,7 +258,7 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) (retErr error) {

+func (d *driver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) (retErr error) {

 	join := &api.JoinRequest{

 		NetworkID:  nid,

 		EndpointID: eid,

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

 	}

 	joinOpts := map[string]interface{}{"foo": "fooValue"}

-	err = d.Join(netID, endID, "sandbox-key", ep, joinOpts)

+	err = d.Join(context.Background(), netID, endID, "sandbox-key", ep, joinOpts)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -9,10 +9,19 @@ import (

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

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

 	"github.com/gogo/protobuf/proto"

+	"go.opentelemetry.io/otel"

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

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

 )

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

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

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	if err := validateID(nid, eid); err != nil {

 		return err

 	}

@@ -37,7 +46,7 @@ func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo,

 	}

 	if err := jinfo.AddTableEntry(ovPeerTable, eid, buf); err != nil {

-		log.G(context.TODO()).Errorf("overlay: Failed adding table entry to joininfo: %v", err)

+		log.G(ctx).Errorf("overlay: Failed adding table entry to joininfo: %v", err)

 	}

 	if ep.disablegateway {

@@ -835,7 +835,13 @@ func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, erro

 }

 // Join method is invoked when a Sandbox is attached to an endpoint.

-func (d *driver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+	ctx, span := otel.Tracer("").Start(ctx, fmt.Sprintf("libnetwork.drivers.windows_%s.Join", d.name), trace.WithAttributes(

+		attribute.String("nid", nid),

+		attribute.String("eid", eid),

+		attribute.String("sboxKey", sboxKey)))

+	defer span.End()

+

 	network, err := d.getNetwork(nid)

 	if err != nil {

 		return err

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

 	"github.com/docker/docker/libnetwork/options"

 	"github.com/docker/docker/libnetwork/scope"

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

+	"go.opentelemetry.io/otel"

 )

 // ByNetworkType sorts a [Endpoint] slice based on the network-type

@@ -469,7 +470,7 @@ func (ep *Endpoint) getNetworkFromStore() (*Network, error) {

 // Join joins the sandbox to the endpoint and populates into the sandbox

 // the network resources allocated for the endpoint.

-func (ep *Endpoint) Join(sb *Sandbox, options ...EndpointOption) error {

+func (ep *Endpoint) Join(ctx context.Context, sb *Sandbox, options ...EndpointOption) error {

 	if sb == nil || sb.ID() == "" || sb.Key() == "" {

 		return types.InvalidParameterErrorf("invalid Sandbox passed to endpoint join: %v", sb)

 	}

@@ -477,10 +478,13 @@ func (ep *Endpoint) Join(sb *Sandbox, options ...EndpointOption) error {

 	sb.joinLeaveStart()

 	defer sb.joinLeaveEnd()

-	return ep.sbJoin(sb, options...)

+	return ep.sbJoin(ctx, sb, options...)

 }

-func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

+func (ep *Endpoint) sbJoin(ctx context.Context, sb *Sandbox, options ...EndpointOption) (err error) {

+	ctx, span := otel.Tracer("").Start(ctx, "libnetwork.sbJoin")

+	defer span.End()

+

 	n, err := ep.getNetworkFromStore()

 	if err != nil {

 		return fmt.Errorf("failed to get network from store during join: %v", err)

@@ -518,25 +522,25 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 		return fmt.Errorf("failed to get driver during join: %v", err)

 	}

-	err = d.Join(nid, epid, sb.Key(), ep, sb.Labels())

+	err = d.Join(ctx, nid, epid, sb.Key(), ep, sb.Labels())

 	if err != nil {

 		return err

 	}

 	defer func() {

 		if err != nil {

 			if e := d.Leave(nid, epid); e != nil {

-				log.G(context.TODO()).Warnf("driver leave failed while rolling back join: %v", e)

+				log.G(ctx).Warnf("driver leave failed while rolling back join: %v", e)

 			}

 		}

 	}()

 	if !n.getController().isAgent() {

 		if !n.getController().isSwarmNode() || n.Scope() != scope.Swarm || !n.driverIsMultihost() {

-			n.updateSvcRecord(ep, true)

+			n.updateSvcRecord(context.WithoutCancel(ctx), ep, true)

 		}

 	}

-	if err := sb.updateHostsFile(ep.getEtcHostsAddrs()); err != nil {

+	if err := sb.updateHostsFile(ctx, ep.getEtcHostsAddrs()); err != nil {

 		return err

 	}

@@ -550,11 +554,11 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 		}

 	}()

-	if err = sb.populateNetworkResources(ep); err != nil {

+	if err = sb.populateNetworkResources(ctx, ep); err != nil {

 		return err

 	}

-	if err = addEpToResolver(context.TODO(), n.Name(), ep.Name(), &sb.config, ep.iface, n.Resolvers()); err != nil {

+	if err = addEpToResolver(ctx, n.Name(), ep.Name(), &sb.config, ep.iface, n.Resolvers()); err != nil {

 		return errdefs.System(err)

 	}

@@ -569,7 +573,7 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 	defer func() {

 		if err != nil {

 			if e := ep.deleteDriverInfoFromCluster(); e != nil {

-				log.G(context.TODO()).Errorf("Could not delete endpoint state for endpoint %s from cluster on join failure: %v", ep.Name(), e)

+				log.G(ctx).Errorf("Could not delete endpoint state for endpoint %s from cluster on join failure: %v", ep.Name(), e)

 			}

 		}

 	}()

@@ -593,7 +597,7 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 	moveExtConn := currentExtEp != extEp

 	if moveExtConn {

 		if extEp != nil {

-			log.G(context.TODO()).Debugf("Revoking external connectivity on endpoint %s (%s)", extEp.Name(), extEp.ID())

+			log.G(ctx).Debugf("Revoking external connectivity on endpoint %s (%s)", extEp.Name(), extEp.ID())

 			extN, err := extEp.getNetworkFromStore()

 			if err != nil {

 				return fmt.Errorf("failed to get network from store for revoking external connectivity during join: %v", err)

@@ -610,14 +614,14 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 			defer func() {

 				if err != nil {

 					if e := extD.ProgramExternalConnectivity(extEp.network.ID(), extEp.ID(), sb.Labels()); e != nil {

-						log.G(context.TODO()).Warnf("Failed to roll-back external connectivity on endpoint %s (%s): %v",

+						log.G(ctx).Warnf("Failed to roll-back external connectivity on endpoint %s (%s): %v",

 							extEp.Name(), extEp.ID(), e)

 					}

 				}

 			}()

 		}

 		if !n.internal {

-			log.G(context.TODO()).Debugf("Programming external connectivity on endpoint %s (%s)", ep.Name(), ep.ID())

+			log.G(ctx).Debugf("Programming external connectivity on endpoint %s (%s)", ep.Name(), ep.ID())

 			if err = d.ProgramExternalConnectivity(n.ID(), ep.ID(), sb.Labels()); err != nil {

 				return types.InternalErrorf(

 					"driver failed programming external connectivity on endpoint %s (%s): %v",

@@ -628,7 +632,7 @@ func (ep *Endpoint) sbJoin(sb *Sandbox, options ...EndpointOption) (err error) {

 	if !sb.needDefaultGW() {

 		if e := sb.clearDefaultGW(); e != nil {

-			log.G(context.TODO()).Warnf("Failure while disconnecting sandbox %s (%s) from gateway network: %v",

+			log.G(ctx).Warnf("Failure while disconnecting sandbox %s (%s) from gateway network: %v",

 				sb.ID(), sb.ContainerID(), e)

 		}

 	}

@@ -671,10 +675,10 @@ func (ep *Endpoint) UpdateDNSNames(dnsNames []string) error {

 			return types.InternalErrorf("could not add service state for endpoint %s to cluster on UpdateDNSNames: %v", ep.Name(), err)

 		}

 	} else {

-		nw.updateSvcRecord(ep, false)

+		nw.updateSvcRecord(context.WithoutCancel(context.TODO()), ep, false)

 		ep.dnsNames = dnsNames

-		nw.updateSvcRecord(ep, true)

+		nw.updateSvcRecord(context.WithoutCancel(context.TODO()), ep, true)

 	}

 	// Update the store with the updated name

@@ -863,7 +867,7 @@ func (ep *Endpoint) Delete(force bool) error {

 	}()

 	if !n.getController().isSwarmNode() || n.Scope() != scope.Swarm || !n.driverIsMultihost() {

-		n.updateSvcRecord(ep, false)

+		n.updateSvcRecord(context.WithoutCancel(context.TODO()), ep, false)

 	}

 	if err = ep.deleteEndpoint(force); err != nil && !force {

@@ -48,7 +48,7 @@ fe90::2	somehost.example.com somehost

 		t.Fatal(err)

 	}

-	if err := ep1.Join(sbx, JoinOptionPriority(1)); err != nil {

+	if err := ep1.Join(context.Background(), sbx, JoinOptionPriority(1)); err != nil {

 		t.Fatal(err)

 	}

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

 		}

 	}()

-	err = ep.Join(sb)

+	err = ep.Join(context.Background(), sb)

 	if err != nil {

 		t.Fatal(err)

 	}

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

 		}

 	}()

-	err = ep.Join(sb)

+	err = ep.Join(context.Background(), sb)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -673,7 +673,7 @@ func (b *badDriver) EndpointOperInfo(nid, eid string) (map[string]interface{}, e

 	return nil, nil

 }

-func (b *badDriver) Join(nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

+func (b *badDriver) Join(_ context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {

 	return fmt.Errorf("I will not allow any join")

 }

@@ -115,7 +115,7 @@ func TestNull(t *testing.T) {

 		t.Fatal(err)

 	}

-	err = ep.Join(cnt)

+	err = ep.Join(context.Background(), cnt)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -888,7 +888,7 @@ func TestEndpointDeleteWithActiveContainer(t *testing.T) {

 		}

 	}()

-	err = ep.Join(cnt)

+	err = ep.Join(context.Background(), cnt)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -961,7 +961,7 @@ func TestEndpointMultipleJoins(t *testing.T) {

 		}

 	}()

-	err = ep.Join(sbx1)

+	err = ep.Join(context.Background(), sbx1)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -972,7 +972,7 @@ func TestEndpointMultipleJoins(t *testing.T) {

 		}

 	}()

-	err = ep.Join(sbx2)

+	err = ep.Join(context.Background(), sbx2)

 	if err == nil {

 		t.Fatal("Expected to fail multiple joins for the same endpoint")

 	}

@@ -1030,12 +1030,12 @@ func TestLeaveAll(t *testing.T) {

 		t.Fatal(err)

 	}

-	err = ep1.Join(cnt)

+	err = ep1.Join(context.Background(), cnt)

 	if err != nil {

 		t.Fatalf("Failed to join ep1: %v", err)

 	}

-	err = ep2.Join(cnt)

+	err = ep2.Join(context.Background(), cnt)

 	if err != nil {

 		t.Fatalf("Failed to join ep2: %v", err)

 	}

@@ -1166,12 +1166,12 @@ func TestEndpointUpdateParent(t *testing.T) {

 		}

 	}()

-	err = ep1.Join(sbx1)

+	err = ep1.Join(context.Background(), sbx1)

 	if err != nil {

 		t.Fatal(err)

 	}

-	err = ep2.Join(sbx2)

+	err = ep2.Join(context.Background(), sbx2)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1344,7 +1344,7 @@ func TestHost(t *testing.T) {

 		t.Fatal(err)

 	}

-	if err := ep1.Join(sbx1); err != nil {

+	if err := ep1.Join(context.Background(), sbx1); err != nil {

 		t.Fatal(err)

 	}

@@ -1353,7 +1353,7 @@ func TestHost(t *testing.T) {

 		t.Fatal(err)

 	}

-	if err := ep2.Join(sbx2); err != nil {

+	if err := ep2.Join(context.Background(), sbx2); err != nil {

 		t.Fatal(err)

 	}

@@ -1393,7 +1393,7 @@ func TestHost(t *testing.T) {

 		t.Fatal(err)

 	}

-	if err := ep3.Join(sbx2); err != nil {

+	if err := ep3.Join(context.Background(), sbx2); err != nil {

 		t.Fatal(err)

 	}

@@ -1541,7 +1541,7 @@ func TestEndpointJoin(t *testing.T) {

 	}

 	// test invalid joins

-	err = ep1.Join(nil)

+	err = ep1.Join(context.Background(), nil)

 	if err == nil {

 		t.Fatalf("Expected to fail join with nil Sandbox")

 	}

@@ -1550,7 +1550,7 @@ func TestEndpointJoin(t *testing.T) {

 	}

 	fsbx := &libnetwork.Sandbox{}

-	if err = ep1.Join(fsbx); err == nil {

+	if err = ep1.Join(context.Background(), fsbx); err == nil {

 		t.Fatalf("Expected to fail join with invalid Sandbox")

 	}

 	if _, ok := err.(types.InvalidParameterError); !ok {

@@ -1571,7 +1571,7 @@ func TestEndpointJoin(t *testing.T) {

 		}

 	}()

-	err = ep1.Join(sb)

+	err = ep1.Join(context.Background(), sb)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1635,7 +1635,7 @@ func TestEndpointJoin(t *testing.T) {

 		}

 	}()

-	err = ep2.Join(sb)

+	err = ep2.Join(context.Background(), sb)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1724,7 +1724,7 @@ func externalKeyTest(t *testing.T, reexec bool) {

 	}()

 	// Join endpoint to sandbox before SetKey

-	err = ep.Join(cnt)

+	err = ep.Join(context.Background(), cnt)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1775,7 +1775,7 @@ func externalKeyTest(t *testing.T, reexec bool) {

 	}

 	// Join endpoint to sandbox after SetKey

-	err = ep2.Join(sbox)

+	err = ep2.Join(context.Background(), sbox)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1887,7 +1887,7 @@ func TestResolvConf(t *testing.T) {

 				assert.Check(t, err)

 			}()

-			err = ep.Join(sb)

+			err = ep.Join(context.Background(), sb)

 			assert.NilError(t, err)

 			defer func() {

 				err := ep.Leave(sb)

@@ -1942,7 +1942,7 @@ func (pt parallelTester) Do(t *testing.T, thrNumber int) error {

 	}

 	for i := 0; i < pt.iterCnt; i++ {

-		if err := ep.Join(sb); err != nil {

+		if err := ep.Join(context.Background(), sb); err != nil {

 			if _, ok := err.(types.ForbiddenError); !ok {

 				return errors.Wrapf(err, "thread %d", thrNumber)

 			}

@@ -2069,7 +2069,7 @@ func TestBridge(t *testing.T) {

 		}

 	}()

-	err = ep.Join(sb)

+	err = ep.Join(context.Background(), sb)

 	if err != nil {

 		t.Fatal(err)

 	}

@@ -1227,10 +1227,10 @@ func (n *Network) createEndpoint(ctx context.Context, name string, options ...En

 	}

 	if !n.getController().isSwarmNode() || n.Scope() != scope.Swarm || !n.driverIsMultihost() {

-		n.updateSvcRecord(ep, true)

+		n.updateSvcRecord(context.WithoutCancel(ctx), ep, true)

 		defer func() {

 			if err != nil {

-				n.updateSvcRecord(ep, false)

+				n.updateSvcRecord(context.WithoutCancel(ctx), ep, false)

 			}

 		}()

 	}

@@ -1302,7 +1302,12 @@ func (n *Network) EndpointByID(id string) (*Endpoint, error) {

 }

 // updateSvcRecord adds or deletes local DNS records for a given Endpoint.

-func (n *Network) updateSvcRecord(ep *Endpoint, isAdd bool) {

+func (n *Network) updateSvcRecord(ctx context.Context, ep *Endpoint, isAdd bool) {

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

+		attribute.String("ep.name", ep.name),

+		attribute.Bool("isAdd", isAdd)))

+	defer span.End()

+

 	iface := ep.Iface()

 	if iface == nil || iface.Address() == nil {

 		return

@@ -2140,7 +2145,7 @@ func (n *Network) createLoadBalancerSandbox() (retErr error) {

 		}

 	}()

-	if err := ep.Join(sb, nil); err != nil {

+	if err := ep.Join(context.TODO(), sb, nil); err != nil {