mirror of
https://github.com/moby/moby.git
synced 2026-08-10 17:15:06 +00:00
51d7f95c4b
endpointCnt is a refcounter used to track how many endpoints use a network, and how many networks references a config-only network. It's stored separately from the network. This is only used to determine if a network can be removed. This commit removes the `endpointCnt` struct and all its references. The refcounter is replaced by two lookups in the newly introduced `networks` and `endpoints` caches added to the `Controller`. Signed-off-by: Albin Kerouanton <albinker@gmail.com>
67 lines
1.8 KiB
Go
67 lines
1.8 KiB
Go
// FIXME(thaJeztah): remove once we are a module; the go:build directive prevents go from downgrading language version to go1.16:
|
|
//go:build go1.22
|
|
|
|
package libnetwork
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/docker/docker/internal/maputil"
|
|
)
|
|
|
|
// storeNetwork inserts or updates the network in the store and the in-memory
|
|
// cache maintained by the Controller.
|
|
//
|
|
// This method is thread-safe.
|
|
func (c *Controller) storeNetwork(ctx context.Context, n *Network) error {
|
|
if err := c.updateToStore(ctx, n); err != nil {
|
|
return err
|
|
}
|
|
c.cacheNetwork(n)
|
|
return nil
|
|
}
|
|
|
|
// deleteStoredNetwork deletes the network from the store and the in-memory
|
|
// cache maintained by the Controller.
|
|
//
|
|
// This method is thread-safe.
|
|
func (c *Controller) deleteStoredNetwork(n *Network) error {
|
|
if err := c.deleteFromStore(n); err != nil {
|
|
return err
|
|
}
|
|
|
|
c.networksMu.Lock()
|
|
defer c.networksMu.Unlock()
|
|
delete(c.networks, n.id)
|
|
|
|
return nil
|
|
}
|
|
|
|
// cacheNetwork caches the network in the in-memory cache of networks
|
|
// maintained by the Controller.
|
|
//
|
|
// This method is thread-safe.
|
|
func (c *Controller) cacheNetwork(n *Network) {
|
|
c.networksMu.Lock()
|
|
defer c.networksMu.Unlock()
|
|
c.networks[n.ID()] = n
|
|
}
|
|
|
|
// findNetworks looks for all networks matching the filter from the in-memory
|
|
// cache of networks maintained by the Controller.
|
|
//
|
|
// This method is thread-safe, but do not use it unless you're sure your code
|
|
// uses the returned networks in thread-safe way (see the comment on
|
|
// Controller.networks).
|
|
func (c *Controller) findNetworks(filter func(nw *Network) bool) []*Network {
|
|
c.networksMu.Lock()
|
|
defer c.networksMu.Unlock()
|
|
return maputil.FilterValues(c.networks, filter)
|
|
}
|
|
|
|
func filterNetworkByConfigFrom(expected string) func(nw *Network) bool {
|
|
return func(nw *Network) bool {
|
|
return nw.configFrom == expected
|
|
}
|
|
}
|